MQ通道常用知识列举(一)

news2025/1/19 17:22:02

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]
如果您不指定队列管理器名称,则假定为默认队列管理器。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/26658.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

CentOS 7.6安装JDK8过程(通过官网下载压缩包方式)

Oracle官网JDK下载地址 JDK8下载地址 选择tar.gz压缩包进行下载 复制下载链接,登录服务器,执行wget xxxxx(刚刚复制的下载地址) 下载完毕后,执行解压命令tar -zxvf xxxxx.tar.gz 配置/etc/profile 执行命令vim /etc…

把Mybatis Generator生成的代码加上想要的注释

作者:王建乐 1 前言 在日常开发工作中,我们经常用Mybatis Generator根据表结构生成对应的实体类和Mapper文件。但是Mybatis Generator默认生成的代码中,注释并不是我们想要的,所以一般在Generator配置文件中,会设置不…

Java题目集

Java冒泡排序和查找冒泡排序,从小到达排列查找,某一个字符串输出如下数据输出杨辉三角形冒泡排序,从小到达排列 分析:数组 [15,21,20,35,10] 第 1 轮排序: 目标把最大数放在最后 第 1 次比较 [15,21,20,35,10] 第 2 次比较 [15,21,20,35,10…

目标检测 YOLOv5 - ncnn模型的加密 C++实现封装库和Android调用库示例

目标检测 YOLOv5 - ncnn模型的加密 C实现封装库和Android调用库示例 flyfish 文章目录目标检测 YOLOv5 - ncnn模型的加密 C实现封装库和Android调用库示例前言模型版本库的版本示例程序的编译环境模型的转换库的制作主要接口部分模型初始化部分推理的输入输出CMakeList的配置示…

LeetCode-878-第N个神奇数字

1、二分查找 如果我们用函数f(x)f(x)f(x)表示数字小于x的神奇数字的个数,显然我们可以得到如下的公式:f(x)⌊xa⌋⌊xb⌋−⌊xc⌋f(x)\left \lfloor \frac{x}{a} \right \rfloor\left \lfloor \frac{x}{b} \right \rfloor-\left \lfloor \frac{x}{c} \ri…

门店管理|火锅店数字化系统转型

火锅几乎是每个人的最爱,吃着火锅喝着酒,生活日子乐逍遥。在很多火锅店里,我们经常可以看见客人爆满。虽然这几天疫情的冲击导致不少餐饮商家生存很难,但随着对疫情的有效控制,餐饮行业正在回暖。 无论以前还是现在&am…

艾美捷 DetergentOUT GB-S10去垢剂的特点和多种应用

去垢剂,亦有称为清洁剂,主要成分是表面活性剂(部分场合即特指表面活性剂,可分阴离子、阳离子和中性去垢剂等多种类型,中性去垢剂在蛋白提取中应用的较多),根据实际需求有时也会包括研磨剂,pH调节剂&#xf…

Spring Cloud Alibaba(一)

整合nacos 一、项目结构small-shop为父工程&#xff0c;order(订单服务)、stock(库存服务) 二、父工程pom.xml文件&#xff0c;添加基础依赖&#xff0c;控制版本 <modules><module>order</module><module>stock</module></modules><pr…

数字时代,医疗健康企业如何通过数字营销创造用户价值

前言&#xff1a;数字化时代&#xff0c;数字营销为企业深入洞察用户需求、把握用户画像、与用户建立有效互动提供了可能性&#xff0c;从而帮助企业实现降本增效的精细化营销&#xff0c;大大提升企业的经营效率。对医疗健康企业来说&#xff0c;因其行业和需求的特殊性&#…

数据结构--单链表

1.定义 由于顺序表的插入删除操作需要移动大量的元素&#xff0c;影响了运行效率&#xff0c;因此引入了线性表的链式存储——单链表。单链表通过一组任意的存储单元来存储线性表中的数据元素&#xff0c;不需要使用地址连续的存储单元&#xff0c;因此它不要求在逻辑上相邻的…

携手!Kyligence 支持 Amazon EMR Serverless,赋能云上企业降本增效

近日&#xff0c;Kyligence 与亚马逊云科技宣布 Kyligence Cloud 4.6 正式支持 Amazon EMR Serverless&#xff0c;共同助力企业构建高效、低成本云上数据分析。今天&#xff0c;我们将为大家介绍 Kyligence Cloud 4.6 如何通过集成 Amazon EMR Serverless 提供端到端的云上数…

字节给我狠狠上了一课:危机来的时候你连准备时间都没有~

各大互联网公司的接连裁员&#xff0c;政策限制的行业接连消失&#xff0c;让今年的求职雪上加霜&#xff0c;想躺平却没有资本&#xff0c;还有人说软件测试岗位饱和了&#xff0c;对此很多求职者深信不疑&#xff0c;因为投出去的简历回复的越来越少了。甚至还有不少大厂直接…

shell的test命令和两种参数获取方式,详解getopts以及eval、exec、export、read、shift内置命令

一、linux里while [-n “$1”]这里的-n是什么意思? -n str&#xff0c;字符串不为null&#xff0c;长度大于零while [ -n “$1” ] 第一个参数不为空&#xff0c;返回TRUE执行while循环do … done 二、Shell test 命令 Shell中的 test 命令用于检查某个条件是否成立&#x…

【web渗透思路】敏感信息泄露(网站+用户+服务器)

目录 一、信息泄露示例 1、示例&#xff1a; 二、泄露方式 1、原理&#xff1a; 三、泄露危害 1、危害&#xff1a; 四、泄露挖掘 1、爬虫文件 2、目录信息 3、越权访问 4、开发注释、js文件 5、错误提示 6、调试信息 7、备份等目录文件 8、配置不安全 9、版本控…

数字集成电路设计(五、仿真验证与 Testbench 编写)(五)

文章目录9. 编译预处理语句9.1 仿真时间标度10. Verilog HDL测试方法简介9. 编译预处理语句 这些在C语言中都有涉及&#xff0c;但是在硬件描述语言中相对用的不是特别多&#xff0c;比如说include&#xff0c;在语言用的特别多&#xff0c;但是在硬件描述语言很少include&…

【每天学习一点新知识】OWSAP TOP10

OWASP OWASP开放式Web应用程序安全项目&#xff08;open web application security project&#xff09;每年会通过确定企业面临的最严重的10类威胁&#xff0c;以此提高人们对Web应用程序安全的关注度。 2021年 A01 失效的访问控制 未对通过身份验证的用户实施恰当的访问控…

裸辞4个月,面试了30家公司,终于找到理想工作了

上半年裁员&#xff0c;下半年裸辞&#xff0c;有不少人高呼裸辞后躺平真的好快乐&#xff01;但也有很多人&#xff0c;裸辞后的生活五味杂陈。 面试30次终于找到心仪工作 因为工作压力大、领导PUA等各种原因&#xff0c;今年2月下旬我从一家互联网小厂裸辞&#xff0c;没想…

APS高级排产在冶金行业的应用

冶金工业是指对金属矿物的勘探、开采、精选、冶炼、以及轧制成材的工业部门。包括黑色冶金工业(即钢铁工业)和有色冶金工业两大类。随着业务量的不断扩大&#xff0c;仅具有传统的ERP系统和人工生产调度已逐渐不能满足精益生产改进的要求。建立高效的精益生产计划模型及其对应的…

Nginx模块开发之http handler实现流量统计(入门篇)

Nginx模块开发之http handler实现流量统计一、Nginx模块之http handler简介二、Nginx handler模块开发2.1、示例代码2.2、编写config文件2.3、编译模块到Nginx源码中2.4、修改conf文件2.5、执行效果三、Nginx的热更新总结后言一、Nginx模块之http handler简介 当nginx解析conf…

计算机毕业设计之java+ssm手机综合类门户网站

项目介绍 手机综合类门户网站采用ssm框架和eclipse编辑器、MySQL数据库设计并实现的,主要包括系统手机评测管理模块、文章管理模块、手机新闻管理、所有评论管理、登录模块、和退出模块等多个模块。 管理员的登录模块&#xff1a;管理员登录系统对本系统其他管理模块进行管理。…