ile rpg 紅皮書_在ILE RPG中使用IBM WebSphere MQ消息属性API

2024-03-27 10:40

本文主要是介绍ile rpg 紅皮書_在ILE RPG中使用IBM WebSphere MQ消息属性API,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

旧的路和前进的路

传统上,要与JMS应用程序(例如,在IBM WebSphere Application Server中运行的Web服务)进行通信,则需要使用RFH2标头。 这很麻烦,尤其是在RPG中。 RFH2头包括一组固定的头字段,后跟任意数量的数据结构,每个数据结构包含一个长度字段和一个缓冲区,该缓冲区包含定义属性的XML数据。 生成RFH2标头并不难。 只需将复制文件cmqrfh2g包含到您的数据结构中,并根据需要设置的文件夹数量定义所需的长度和数据对即可(不同文件夹中的属性必须成对发送)。 为了获得更大的自由并消除从固定长度字段中发送额外的空格,您还可以动态构建缓冲区。 真正的麻烦在于尝试读取属性,这需要解析另一个应用程序发送的RFH2标头。 尽管RPG完全能够解析具有任意数量的可变长度字段的可变长度报头,但它更适合固定长度,类似记录的数据。

在RPG(实际上是任何ILE语言)中使用RFH2标头的另一个问题是XML数据必须为Unicode。 RPG在此具有原生支持UTF-16的优势。 但是,除非您仅与其他RPG应用程序打交道,否则您从其他应用程序获得的任何RFH2标头很可能都将使用UTF-8,因为这是Linux,Windows和Java的默认设置。 这意味着您几乎可以肯定必须处理iconv,这总是很痛苦的。

随着WebSphere MQ 7.0的发布,MQ获得了新的API调用,从而大大减少了与消息属性进行交互所需的工作量,并消除了生成或解析RFH2标头的需要。 这些是:

  • MQSETMP –设置消息属性
  • MQDLTMP –删除消息属性
  • MQINQMP –查询消息属性

除了这些API之外,还添加了其他API来帮助使用消息属性API:

  • MQCRTMH –创建消息句柄
  • MQDLTMH –删除消息句柄
  • MQBUFMH –将消息缓冲区转换为消息句柄
  • MQMHBUF –将消息句柄转换为消息缓冲区

新消息属性API的关键是消息句柄。 消息句柄( MQHMSG )是64位标识符,用于允许应用程序引用消息的属性,类似于使用MQHCONN来引用与队列管理器的连接或使用MQHOBJ来进行连接。请参阅主题或队列。 使用这些新的消息属性API的第一步是创建消息句柄。

dcl-s Hmsg int(20);
dcl-ds MQCMHO Qualified;/copy CMQCMHOG
end-ds;MQCRTMH(HConn : MQCMHO : HMsg : CompletionCode : Reason);

您声明两个变量, HMsg为64位整数和MQCMHO (创建消息句柄选项)结构。 然后,您调用MQCRTMH生成我们的消息句柄。 假设CompletionCode0 ,您现在有了一个消息句柄,可以使用它使用新的消息属性API。

使用MQSETMP

要查看如何使用MQSETMP设置消息属性,让我们首先看一下MQSETMP的参数:

示例1:来自CMQG的MQSETMP过程定义
DMQSETMP          PR                  EXTPROC('MQSETMP')
D* Connection handle
D HCONN                         10I 0 VALUE
D* Message handle
D HMSG                          20I 0 VALUE
D* Options that control the action of MQSETMP (MQSMPO)
D SETOPT                        20A   
D* Property name (MQCHARV)
D PRNAME                        32A   
D* Property descriptor (MQPD)
D PRPDSC                        24A   
D* Property data type
D TYPE                          10I 0 VALUE
D* Length of the Value area
D VALLEN                        10I 0 VALUE
D* Property value
D VALUE                           *   VALUE
D* Completion code
D CMPCOD                        10I 0
D* Reason code qualifying CompCode
D REASON                        10I 0

在本练习中,可以使用MQSMPOMQPD的默认值。 有关这些参数的更多信息,请参考WebSphere MQ信息中心 。

让我们定义一些变量以使用MQSETMP

dcl-ds PropName Qualified;/copy QMCHRVG
end-ds;dcl-s PropertyName varchar(40);
dcl-s PropertyValue varchar(40);dcl-ds MQPD Qualified;/copy CMQPDG
end-ds;dcl-ds MQSMPO Qualified;/copy CMQSMPOG
end-ds;

在此示例中,我们将定义usr.format属性,以通知接收应用程序该消息是XML数据。 首先,设置属性名称。

PropertyName = 'format';
PropertyValue = 'xml';
PropName.VCHRP = %ADDR(PropertyName : *DATA);
PropName.VCHRL = %LEN(PropertyName);

注意:如果您没有限定属性名称,则默认为“ usr”文件夹。

然后,您只需要调用MQSETMP ,指定所有参数:

MQSETMP(HConn : HMsg : MQSMPO : PropName : MQPD : TYPSTR :%LEN(PropertyValue) : %ADDR(PropertyValue : *DATA) :CompletionCode : Reason);

至此,您已经创建了一个消息句柄并将usr.format属性设置为xml ,但是什么消息接收到了该属性? 答案是您尚未在实际消息上实际设置此属性。 您已经完成的所有工作都分配了一个消息句柄,该消息句柄指向WebSphere MQ中包含消息属性的存储区域。 放置消息时,可以告诉WebSphere MQ将那些属性添加到您要放置的消息中。 为此,您唯一要做的就是将消息句柄字段设置为从MQCRTMH获得的消息句柄,并告诉WebSphere MQ您正在使用版本3 MQPMO (以便WebSphere MQ知道已定义消息句柄字段。 )。

MQPMO.PMVER = PMVER3;
MQPMO.PMOMH = Hmsg;

现在,像往常一样执行MQPUT ,消息属性将添加到消息中。 在幕后,WebSphere MQ将从消息句柄读取属性并为您生成RFH2标头。 您可以使用IBM WebSphere MQ Explorer或WRKMQMQ系统命令轻松地验证一切是否正常。 MQ Explorer是基于Eclipse的图形工具,使您能够从Microsoft®Windows®或Linux®PC浏览和配置所有WebSphere MQ对象和资源。 它包含在MQ服务器安装中,也可以在MS0T SupportPac中单独获得。 要在MQ Explorer中查看,请展开队列管理器,然后单击Queues 。 然后,您可以右键单击队列,然后单击浏览消息 。 在列表中找到要检查的消息,然后右键单击它,然后单击“ 属性” 。 在左窗格中选择“ 命名属性”时 ,可以看到如图1所示的属性。

图1:MQ Explorer
图1:MQ Explorer

使用MQINQMP

MQSETMP一样,它使设置消息属性更加容易,还有MQINQMP可以检索特定消息属性的值,甚至可以使用通配符来获取多个属性的值。 示例2中显示了一个原型。

示例2:来自CMQG的MQINQMP过程定义
DMQINQMP          PR                  EXTPROC('MQINQMP')
D* Connection handle
D HCONN                         10I 0 VALUE
D* Message handle
D HMSG                          20I 0 VALUE
D* Options that control the action of MQINQMP (MQIMPO)
D INQOPT                        72A   
D* Property name (MQCHARV)
D PRNAME                        32A   
D* Property descriptor (MQPD)
D PRPDSC                        24A   
D* Property data type
D TYPE                          10I 0
D* Length in bytes of the Value area
D VALLEN                        10I 0 VALUE
D* Property value
D VALUE                           *   VALUE
D* Length of the property value
D DATLEN                        10I 0
D* Completion code
D CMPCOD                        10I 0
D* Reason code qualifying CompCode
D REASON                        10I 0

MQSETMP的唯一真正区别是,您使用MQIMPO而不是MQSMPO

要使用MQINQMP ,首先要像上面那样创建一个消息句柄,并将其传递到MQGMO 。 您唯一需要的其他技巧是告诉WebSphere MQ您希望在消息句柄中而不是在RFH2标头中返回消息属性。

MQGMO.GMVER = GMVER4;
MQGMO.GMMH = Hmsg;MQGMO.GMOPT += GMPRIH; // return message properties in handleMQIMPO.IPOPT = IPINQN + // iterate over propertiesIPCTYP + // convert type if necessaryIPCVAL;  // convert value into native CCSIDPropQuery = 'usr.%';
PropName.VCHRP = %ADDR(PropQuery : *DATA);
PropName.VCHRL = %LEN(PropQuery);MQIMPO.IPRETNAMCHRP = %ADDR(PropertyName : *DATA);
MQIMPO.IPRETNAMVSBS = PropNameMax;MQINQMP(HConn : HMsg : MQIMPO : PropName : MQPD : PropertyType :PropValueMax : %ADDR(PropertyValue : *DATA) :ActPropLength : CompletionCode : Reason);%LEN(PropertyValue) = ActPropLength;
%LEN(PropertyName) = MQIMPO.IPRETNAMCHRL;

在这里,您使用usr.%的查询来检索usr文件夹中的所有属性。 在调用MQINQMPPropertyName包含找到的第一个用户属性的名称,而PropertyValue包含其值。 处理MQINQMP此属性后,可以再次调用MQINQMP来检索与查询匹配的下一个属性。 最终,将没有更多的属性,并且WebSphere MQ将设置完成码1和原因码2471(MQRC_PROPERTY_NOT_AVAILABLE)。

结论

随着WebSphere MQ 7.0中新消息属性功能的出现,现在在ILE应用程序中处理消息属性变得更加容易。 应用程序不再需要解析RFH2标头,处理XML或使用iconv处理字符转换来获取或设置消息属性。 本文介绍了如何在您的应用程序中使用这些新的API。 完整示例可在WebSphere MQ 7.1随附的AMQ3IQM4和AMQ3STM4示例中找到。 这些样本也包含在WebSphere MQ 7.0.1.6和更高版本的修订包中。

翻译自: https://www.ibm.com/developerworks/ibmi/library/i-websphere-mq-messaging/index.html

这篇关于ile rpg 紅皮書_在ILE RPG中使用IBM WebSphere MQ消息属性API的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/851831

相关文章

Python使用Tenacity一行代码实现自动重试详解

《Python使用Tenacity一行代码实现自动重试详解》tenacity是一个专为Python设计的通用重试库,它的核心理念就是用简单、清晰的方式,为任何可能失败的操作添加重试能力,下面我们就来看... 目录一切始于一个简单的 API 调用Tenacity 入门:一行代码实现优雅重试精细控制:让重试按我

MySQL中EXISTS与IN用法使用与对比分析

《MySQL中EXISTS与IN用法使用与对比分析》在MySQL中,EXISTS和IN都用于子查询中根据另一个查询的结果来过滤主查询的记录,本文将基于工作原理、效率和应用场景进行全面对比... 目录一、基本用法详解1. IN 运算符2. EXISTS 运算符二、EXISTS 与 IN 的选择策略三、性能对比

使用Python构建智能BAT文件生成器的完美解决方案

《使用Python构建智能BAT文件生成器的完美解决方案》这篇文章主要为大家详细介绍了如何使用wxPython构建一个智能的BAT文件生成器,它不仅能够为Python脚本生成启动脚本,还提供了完整的文... 目录引言运行效果图项目背景与需求分析核心需求技术选型核心功能实现1. 数据库设计2. 界面布局设计3

使用IDEA部署Docker应用指南分享

《使用IDEA部署Docker应用指南分享》本文介绍了使用IDEA部署Docker应用的四步流程:创建Dockerfile、配置IDEADocker连接、设置运行调试环境、构建运行镜像,并强调需准备本... 目录一、创建 dockerfile 配置文件二、配置 IDEA 的 Docker 连接三、配置 Do

Android Paging 分页加载库使用实践

《AndroidPaging分页加载库使用实践》AndroidPaging库是Jetpack组件的一部分,它提供了一套完整的解决方案来处理大型数据集的分页加载,本文将深入探讨Paging库... 目录前言一、Paging 库概述二、Paging 3 核心组件1. PagingSource2. Pager3.

python使用try函数详解

《python使用try函数详解》Pythontry语句用于异常处理,支持捕获特定/多种异常、else/final子句确保资源释放,结合with语句自动清理,可自定义异常及嵌套结构,灵活应对错误场景... 目录try 函数的基本语法捕获特定异常捕获多个异常使用 else 子句使用 finally 子句捕获所

SpringBoot监控API请求耗时的6中解决解决方案

《SpringBoot监控API请求耗时的6中解决解决方案》本文介绍SpringBoot中记录API请求耗时的6种方案,包括手动埋点、AOP切面、拦截器、Filter、事件监听、Micrometer+... 目录1. 简介2.实战案例2.1 手动记录2.2 自定义AOP记录2.3 拦截器技术2.4 使用Fi

C++11右值引用与Lambda表达式的使用

《C++11右值引用与Lambda表达式的使用》C++11引入右值引用,实现移动语义提升性能,支持资源转移与完美转发;同时引入Lambda表达式,简化匿名函数定义,通过捕获列表和参数列表灵活处理变量... 目录C++11新特性右值引用和移动语义左值 / 右值常见的左值和右值移动语义移动构造函数移动复制运算符

Python对接支付宝支付之使用AliPay实现的详细操作指南

《Python对接支付宝支付之使用AliPay实现的详细操作指南》支付宝没有提供PythonSDK,但是强大的github就有提供python-alipay-sdk,封装里很多复杂操作,使用这个我们就... 目录一、引言二、准备工作2.1 支付宝开放平台入驻与应用创建2.2 密钥生成与配置2.3 安装ali

C#中lock关键字的使用小结

《C#中lock关键字的使用小结》在C#中,lock关键字用于确保当一个线程位于给定实例的代码块中时,其他线程无法访问同一实例的该代码块,下面就来介绍一下lock关键字的使用... 目录使用方式工作原理注意事项示例代码为什么不能lock值类型在C#中,lock关键字用于确保当一个线程位于给定实例的代码块中时