IBM MQ通道常用知识列举(一)_mq通道配置查看-程序员宅基地

技术标签: MQ  IBM MQ  通道  

MQ的几个基本组件:

1. 什么是通道

通道是分布式队列管理器在IBM MQ MQI 客户端和IBM MQ服务器之间或两个IBM MQ服务器之间使用的逻辑通信链路。通道用于将消息从一个队列管理器移动到另一个队列管理器。

2, 启动通道

对发送方、服务器和请求方通道使用 MQSC 命令 START CHANNEL。对于能够交换消息的应用程序,您必须启动入站连接的侦听器程序。
在已使用队列管理器触发设置通道的情况下,不需要启动通道。
启动时,发送 MCA 读取通道定义并打开传输队列。发出通道启动序列(start-up sequence)事件,远程启动接收器或服务器通道的相应 MCA。当它们启动时,发送方和服务器进程等待消息到达传输队列并在消息到达时传输它们。
当您使用触发通道或将通道作为线程运行时,请确保通道启动器可用于监视启动队列。通道发起程序默认作为队列管理器的一部分启动。
但是,TCP 和 LU 6.2 确实提供了其他功能:
对于UNIX 和Linux系统上的 TCP,inetd 可以配置为启动一个通道。inetd 作为一个单独的进程启动。
对于UNIX 和Linux系统中的 LU 6.2,配置您的 SNA 产品以启动 LU 6.2 响应程序进程。
使用 Start 选项总是会导致通道在必要时重新同步。

为了启动成功:
-本地和远程通道定义必须存在。如果接收器或服务器连接通道没有合适的通道定义,如果通道是自动定义的,则会自动创建一个默认通道。
-传输队列必须存在,并且没有其他通道使用它。
-必须存在本地和远程 MCA。
-通信链接必须可用。
-队列管理器必须在本地和远程运行。
-消息通道不得是已在运行状态。


一条消息返回到屏幕,确认启动频道的请求已被接受。要确认启动命令已成功,请检查错误日志或使用 DISPLAY CHSTATUS。错误日志是:
UNIX 和Linux系统
/var/mqm/qmgrs/qmname/errors/AMQERR01.LOG(对于每个调用的队列管理器qmname)
/var/mqm/qmgrs/@SYSTEM/errors/AMQERR01.LOG(对于一般错误)

在 Windows、UNIX 和Linux系统上,使用 runmqlsr 命令启动 WebSphere MQ 侦听器进程。默认情况下,任何对通道带有附件的入站请求都会导致侦听器进程将 MCA 作为 amqrmppa 进程的线程启动。

runmqlsr -t tcp -m QM2

对于出站连接,您必须通过以下三种方式之一启动通道:
1)使用 MQSC 命令 START CHANNEL 指定通道名称,根据 MCATYPE 参数将通道作为进程或线程启动。(如果通道作为线程启动,则它们是通道启动器的线程。)

START CHANNEL(QM1.TO.QM2)

2)使用控制命令 runmqchl 将通道作为进程启动。

runmqchl -c QM1.TO.QM2 -m QM1

3)使用通道启动器触发通道。

3,查看通道数量

echo "DISPLAY CHSTATUS(CHLNAME)" | runmqsc QMGR | grep 'AMQ8417' | wc -l

例如:echo "DISPLAY CHSTATUS(FIRST.CHANNEL)" | runmqsc saturn.queue.manager | grep 'AMQ8417' | wc -l

4. 通道进程

MCATYPE:

通道是否以进程方式运行,在通道属性里的MCATYPE参数来控制。例如,

发送者通道:

display channel (TO.TEST.R)
     4 : display channel (TO.TEST.R)
AMQ8414: Display Channel details.
   CHANNEL(TO.TEST.R)                      CHLTYPE(SDR)
   ALTDATE(2022-10-27)                     ALTTIME(14.04.06)
   BATCHHB(0)                              BATCHINT(0)
   BATCHSZ(50)                             COMPHDR(NONE)
   COMPMSG(NONE)                           CONNAME(192.168.88.9(1418))
   CONVERT(NO)                             DESCR( )
   DISCINT(6000)                           HBINT(300)
   KAINT(AUTO)                             LOCLADDR( )
   LONGRTY(999999999)                      LONGTMR(1200)
   MAXMSGL(4194304)                        MCANAME( )
   MCATYPE(PROCESS)                        MCAUSER( )
   MODENAME( )                             MONCHL(QMGR)
   MSGDATA( )                              MSGEXIT( )
   NPMSPEED(FAST)                          PASSWORD( )
   PROPCTL(COMPAT)                         RCVDATA( )
   RCVEXIT( )                              SCYDATA( )
   SCYEXIT( )                              SENDDATA( )
   SENDEXIT( )                             SEQWRAP(999999999)
   SHORTRTY(10)                            SHORTTMR(60)
   SSLCIPH( )                              SSLPEER( )
   STATCHL(QMGR)                           TPNAME( )
   TRPTYPE(TCP)                            USERID( )
   XMITQ(TEST.R)       

说明是以进程的方式启动的通道。

接收者通道:

display CHANNEL(TO.TEST.R)
    11 : display CHANNEL(TO.TEST.R)
AMQ8414: Display Channel details.
   CHANNEL(TO.TEST.R)                      CHLTYPE(RCVR)
   ALTDATE(2022-10-27)                     ALTTIME(14.05.21)
   BATCHSZ(50)                             COMPHDR(NONE)
   COMPMSG(NONE)                           DESCR( )
   HBINT(300)                              KAINT(AUTO)
   MAXMSGL(4194304)                        MCAUSER( )
   MONCHL(QMGR)                            MRDATA( )
   MREXIT( )                               MRRTY(10)
   MRTMR(1000)                             MSGDATA( )
   MSGEXIT( )                              NPMSPEED(FAST)
   PUTAUT(DEF)                             RCVDATA( )
   RCVEXIT( )                              SCYDATA( )
   SCYEXIT( )                              SENDDATA( )
   SENDEXIT( )                             SEQWRAP(999999999)
   SSLCAUTH(REQUIRED)                      SSLCIPH( )
   SSLPEER( )                              STATCHL(QMGR)
   TRPTYPE(TCP)                         

说明通道是以线程的方式运行在amqrmppa进程上。只要amqrmppa进程存在,mq通道就可以正常工作,不管通道监听器是否运行。因为通道在创建时启用了另外一个随机的端口,而不是默认的1414端口。

作为进程或线程运行通道
WebSphere MQ for Windows 提供了将发送通道作为 Windows 进程或 Windows 线程运行的灵活性。这是在发送方通道定义的 MCATYPE 参数中指定的。大多数安装将它们的发送通道作为线程运行,因为支持许多并发通道连接所需的虚拟和实际内存减少了。

消息通道代理类型 (MCATYPE)

作为进程运行的优点包括:
-为每个通道的隔离提供更高的完整性
-为每个通道设定特定的作业权限
-控制作业调度
线程的优点包括:
-大大减少了存储的使用
-通过在命令行上输入更容易配置
-执行速度更快——启动线程比指示操作系统启动进程更快

对于发送者、服务器和请求者的通道类型,默认为process。对于 cluster-sender 和 cluster-receiver 的通道类型,默认是thread。这些默认值可能会在您的安装过程中发生变化。
如果您在通道定义上指定进程,那么将启动 RUNMQCHL 进程。如果指定thread,则 MCA 在 AMQRMPPA 进程的线程上运行,或者如果指定了 MQNOREMPOOL,则在 RUNMQCHI 进程的线程上运行。在接收入站分配的机器上,如果您使用 RUNMSLSR,则 MCA 作为线程运行。如果您使用inetd ,它会作为一个进程运行。

在 WebSphere MQ for z/OS 上,只有通道类型为 cluster-receiver 的通道才支持此属性。在其他平台上,它对以下通道类型有效:
发件人
服务器
请求者
集群发送器
集群接收器

5,通道池进程amqldmpa

您的 MQ 队列管理器通过服务器连接通道拥有数百或数千个远程 MQ 客户端连接;这些连接由多个 MQ amqrmppa 进程处理。
一旦确定了进程的进程 ID,就可以开始跟踪(用正确的进程 ID 替换 PID)。
   strmqtrc -t all -t details -p PID

以下教程逐步说明如何通过 MQ 实用程序 amqldmpa 查找连接(服务器连接通道的实例)与处理连接的特定 MQ amqrmppa 之间的关系。

https://www.ibm.com/support/pages/node/6207043
如何在 MQ 连接启动时查找日期时间戳(runmqsc DISPLAY CONN、DISPLAY CHSTATUS 以及 amqldmpa)

https://stackoverflow.com/questions/42818464/mq-process-amqrmppa-keep-increasing
该amqrmppa进程是 MQ 的通道池进程,默认情况下将使用线程和新进程实例进行扩展。如果它疯狂的增加时,有两种可能性。

1)内存泄漏。当 Fix Pack 已知时,可以通过 APARS 查看它是否是已知问题。

2)应用程序错误。当应用程序不正确地终止客户端连接时,它会留下一个孤立的通道实例。这些最终会超时,但是池化过程释放线程的速度很慢,因为重用一个线程比从头开始重建整个过程要快。因此,进程数量通常反映了最近启动通道的高水位线。
通常糟糕的编程或外部因素(如防火墙超时)比 MQ 代码错误更可能是根本原因,但是每个 Fix Pack 中的 APARS 数量证明这些确实会发生。您可能希望调整MAXCHAN设置,以便没有一个应用程序可以启动超过合理数量的并发通道实例。

更多注意事项:

通常,由于将通道分派给线程,进程数少于并发通道数。不过,这是可调的,本地 队列管理器可能会将通道设置为PROCESS而不是THREAD。此外,如果通道由inetd结果启动,则每个进程一个通道。(不要在现代 QMGR 中这样做!)

6,试验环境里与通道相关进程

通道进程

mqm       5673     1  0 08:58 ?        00:00:00 /opt/mqm/bin/runmqchl -c TO.TEST              -m TEST_RQM

通道启动器进程

mqm       5570  5560  0 08:52 ?        00:00:00 /opt/mqm/bin/runmqchi -m TEST_RQM -q SYSTEM.CHANNEL.INITQ -r

运行通道启动器进程以自动启动通道。
使用runmqchi命令运行通道启动器进程。您必须使用与您正在使用的队列管理器关联的安装中的runmqchi命令。您可以使用dspmq -o 安装命令找出队列管理器与哪个安装相关联。

MQ监听器(IBM MQ listener):

runmqlsr 是一个网络端口侦听器。它将传入的通道连接请求移交给另一个已在运行的 MQ 进程 amqrmppa。amqrmppa 管理消息通道代理进程和线程池。

mqm       5572  5560  0 08:52 ?        00:00:00 /opt/mqm/bin/runmqlsr -r -m TEST_RQM -t TCP -p 1418
要运行随IBM MQ提供的监听器(它将新通道作为线程启动),请使用以下runmqlsr命令。
例如:
runmqlsr -t tcp [-m QMNAME] [-p 1822]
方括号表示可选参数;QMNAME默认队列管理器不需要端口号,如果您使用默认端口号 (1414),则不需要端口号。端口号不得超过 65535。
为获得最佳性能,请将IBM MQ监听器作为可信应用程序运行,如将通道和侦听器作为可信应用程序运行中所述。 有关受信任应用程序的信息,请参阅受信任应用程序的限制。
您可以使用以下命令停止在非活动队列管理器上运行的所有IBM MQ侦听器:
endmqlsr [-m QMNAME]
如果您不指定队列管理器名称,则假定为默认队列管理器。

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/yangkei/article/details/127979253

智能推荐

解决win10/win8/8.1 64位操作系统MT65xx preloader线刷驱动无法安装_mt65驱动-程序员宅基地

文章浏览阅读1.3w次。转载自 http://www.miui.com/thread-2003672-1-1.html 当手机在刷错包或者误修改删除系统文件后会出现无法开机或者是移动定制(联通合约机)版想刷标准版,这时就会用到线刷,首先就是安装线刷驱动。 在XP和win7上线刷是比较方便的,用那个驱动自动安装版,直接就可以安装好,完成线刷。不过现在也有好多机友换成了win8/8.1系统,再使用这个_mt65驱动

SonarQube简介及客户端集成_sonar的客户端区别-程序员宅基地

文章浏览阅读1k次。SonarQube是一个代码质量管理平台,可以扫描监测代码并给出质量评价及修改建议,通过插件机制支持25+中开发语言,可以很容易与gradle\maven\jenkins等工具进行集成,是非常流行的代码质量管控平台。通CheckStyle、findbugs等工具定位不同,SonarQube定位于平台,有完善的管理机制及强大的管理页面,并通过插件支持checkstyle及findbugs等既有的流..._sonar的客户端区别

元学习系列(六):神经图灵机详细分析_神经图灵机方法改进-程序员宅基地

文章浏览阅读3.4k次,点赞2次,收藏27次。神经图灵机是LSTM、GRU的改进版本,本质上依然包含一个外部记忆结构、可对记忆进行读写操作,主要针对读写操作进行了改进,或者说提出了一种新的读写操作思路。神经图灵机之所以叫这个名字是因为它通过深度学习模型模拟了图灵机,但是我觉得如果先去介绍图灵机的概念,就会搞得很混乱,所以这里主要从神经图灵机改进了LSTM的哪些方面入手进行讲解,同时,由于模型的结构比较复杂,为了让思路更清晰,这次也会分开几..._神经图灵机方法改进

【机器学习】机器学习模型迭代方法(Python)-程序员宅基地

文章浏览阅读2.8k次。一、模型迭代方法机器学习模型在实际应用的场景,通常要根据新增的数据下进行模型的迭代,常见的模型迭代方法有以下几种:1、全量数据重新训练一个模型,直接合并历史训练数据与新增的数据,模型直接离线学习全量数据,学习得到一个全新的模型。优缺点:这也是实际最为常见的模型迭代方式,通常模型效果也是最好的,但这样模型迭代比较耗时,资源耗费比较多,实时性较差,特别是在大数据场景更为困难;2、模型融合的方法,将旧模..._模型迭代

base64图片打成Zip包上传,以及服务端解压的简单实现_base64可以装换zip吗-程序员宅基地

文章浏览阅读2.3k次。1、前言上传图片一般采用异步上传的方式,但是异步上传带来不好的地方,就如果图片有改变或者删除,图片服务器端就会造成浪费。所以有时候就会和参数同步提交。笔者喜欢base64图片一起上传,但是图片过多时就会出现数据丢失等异常。因为tomcat的post请求默认是2M的长度限制。2、解决办法有两种:① 修改tomcat的servel.xml的配置文件,设置 maxPostSize=..._base64可以装换zip吗

Opencv自然场景文本识别系统(源码&教程)_opencv自然场景实时识别文字-程序员宅基地

文章浏览阅读1k次,点赞17次,收藏22次。Opencv自然场景文本识别系统(源码&教程)_opencv自然场景实时识别文字

随便推点

ESXi 快速复制虚拟机脚本_exsi6.7快速克隆centos-程序员宅基地

文章浏览阅读1.3k次。拷贝虚拟机文件时间比较长,因为虚拟机 flat 文件很大,所以要等。脚本完成后,以复制虚拟机文件夹。将以下脚本内容写入文件。_exsi6.7快速克隆centos

好友推荐—基于关系的java和spark代码实现_本关任务:使用 spark core 知识完成 " 好友推荐 " 的程序。-程序员宅基地

文章浏览阅读2k次。本文主要实现基于二度好友的推荐。数学公式参考于:http://blog.csdn.net/qq_14950717/article/details/52197565测试数据为自己随手画的关系图把图片整理成文本信息如下:a b c d e f yb c a f gc a b dd c a e h q re f h d af e a b gg h f bh e g i di j m n ..._本关任务:使用 spark core 知识完成 " 好友推荐 " 的程序。

南京大学-高级程序设计复习总结_南京大学高级程序设计-程序员宅基地

文章浏览阅读367次。南京大学高级程序设计期末复习总结,c++面向对象编程_南京大学高级程序设计

4.朴素贝叶斯分类器实现-matlab_朴素贝叶斯 matlab训练和测试输出-程序员宅基地

文章浏览阅读3.1k次,点赞2次,收藏12次。实现朴素贝叶斯分类器,并且根据李航《统计机器学习》第四章提供的数据训练与测试,结果与书中一致分别实现了朴素贝叶斯以及带有laplace平滑的朴素贝叶斯%书中例题实现朴素贝叶斯%特征1的取值集合A1=[1;2;3];%特征2的取值集合A2=[4;5;6];%S M LAValues={A1;A2};%Y的取值集合YValue=[-1;1];%数据集和T=[ 1,4,-1;..._朴素贝叶斯 matlab训练和测试输出

Markdown 文本换行_markdowntext 换行-程序员宅基地

文章浏览阅读1.6k次。Markdown 文本换行_markdowntext 换行

错误:0xC0000022 在运行 Microsoft Windows 非核心版本的计算机上,运行”slui.exe 0x2a 0xC0000022″以显示错误文本_错误: 0xc0000022 在运行 microsoft windows 非核心版本的计算机上,运行-程序员宅基地

文章浏览阅读6.7w次,点赞2次,收藏37次。win10 2016长期服务版激活错误解决方法:打开“注册表编辑器”;(Windows + R然后输入Regedit)修改SkipRearm的值为1:(在HKEY_LOCAL_MACHINE–》SOFTWARE–》Microsoft–》Windows NT–》CurrentVersion–》SoftwareProtectionPlatform里面,将SkipRearm的值修改为1)重..._错误: 0xc0000022 在运行 microsoft windows 非核心版本的计算机上,运行“slui.ex