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

article/2025/9/27 3:38:22

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://chatgpt.dhexx.cn/article/AMtJMlLt.shtml

相关文章

微服务 消息中间件MQ

微服务 消息中间件MQ 1. MQ的定义2. MQ的作用3. MQ的特点4. MQ消费方式5. 常用MQ对比分析 1. MQ的定义 MQ就是消息中间件。面向消息的中间件(message-oriented middleware)MOM能够很好的解决以上问题。是指利用高效可靠的消息传递机制与平台无关的数据交…

MQ消息队列

MQ MQ全称Message Queue(消息队列), 实在消息传输过程中保存消息的容器。多用于分布式系统之间进行通信两种 通信方式: MQ优势 消息到达MQ后直接给出响应,然后服务去消费相应的消息,用户体验极好 应用解耦:提高系…

IBMMQ linux版命令创建队列管理器、队列、通道、window连接(六)

1. 队列、通道介绍 1.1 本地队列 本地队列又分为普通本地队列和传输队列,普通本地队列是应用程序通过API对其进行读写操作的队列;传输队列可以理解为存储-转发队列,比如:我们将某个消 息交给MQ系统发送到远程主机,而此…

IBM MQ 通道

一,定义 通道是分布式队列管理器在IBM MQ MQI 客户端和IBM MQ服务器之间或两个IBM MQ服务器之间使用的逻辑通信链接。 通道是提供从一个队列管理器到另一个队列管理器的通信路径的对象。通道在分布式队列中用于将消息从一个队列管理器移动到另一个队列管理器&#x…

MQ135

这里写自定义目录标题 以MQ135为例 原文链接 首先声明,公式不是官方给定的,而且有很多的局限性。 这篇文章是个人对MQ系列传感器电压与浓度转换的公式进行一个探索。 以MQ135为例 在氨气曲线上采点,得 x(ppm)[10,2…

MQ简介以及架构图

一、什么是MQ Message Query(MQ),消息队列中间件,很多初学者认为,MQ通过消息的发送和接受来实现程序的异步和解耦,mq主要用于异步操作,这个不是mq的真正目的,只不过是mq的应用&…

IBMMQ java远程访问(四)

当应用程序和MQ不在同一台主机上的时候,我们将要通过通道去访问; 1.创建队列管理器时勾选创建服务器链接通道; 2.创建一个本地队列 命名为Q1 3.创建通道 右击通道->新建->服务器链接通道 命名为SERVERQM2 4.代码示例调用 package com.i…

MQ理论介绍与主流MQ对比

1、什么是MQ? MQ(Message Queue)消息队列,是基础数据结构中“先进先出”的一种数据结构。指把要传输的数据(消息)放在队列中,用队列机制来实现消息传递——生产者产生消息并把消息放入队列,然…

什么是MQ

MQ概述 MQ全称 Message Queue(消息队列),是在消息的传输过程中保存消息的容器。多用于分布式系统之间进 行通信。 分布式系统之间进行通信: 远程调用:各系统间直接通过远程调用的方式; 借助第三方完成系统…

MQ的概念和RabbitMQ知识点(无代码)

目录 1. MQ的基本概念 1.1 MQ概述 1.2 MQ的优势 1. 应用解耦 2. 异步提速 3. 削峰填谷 1.3 MQ的劣势以及可能引发的问题 1.4 常见的MQ产品 2. RabbitMQ的知识点 2.1 RabbitMQ的工作模式 1. 简单模式 2. 工作队列模式 Work Queue 3. 发布订阅模式 Publish/subscri…

MQ简介

一、何为MQ? MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息(针对应用程序的数据)来通信,而无需专用连接来链接它们。消息传递指的是程序之间通…

【MQ基本概念 MQ的工作原理】

一、 MQ 基本概念 1 、 MQ 概述 MQ 全称 Message Queue (消息队列),是在消息的传输过程中保存 消息的容器。多用于分布式系统之间进 行通信。 小结 MQ ,消息 队列,存储消息的中间件 分布式系统通信两种方式&…

mq的基本介绍和基本用法

一 、什么是MQ,有什么用 MQ 是message queue ,消息队列,也叫消息中间件,遵守JMS(java message service)规范的一种软件。(同时还有另一个叫AMQP的应用层协议,语言无关性不受产品 语言等限制,r…

MQ(Message Queue)简介

一、何为MQ? MQ全称为Message Queue, 消息队列(MQ)是一种应用程序对应用程序的通信方法。应用程序通过读写出入队列的消息(针对应用程序的数据)来通信,而无需专用连接来链接它们。消息传递指的是程序之间通…

MQ消息队列详解、四大MQ的优缺点分析

MQ消息队列详解、四大MQ的优缺点分析 前言面试题切入面试官心理分析面试题剖析①为什么要使用MQ系统解耦异步调用流量削峰消息队列的优缺点四大主流MQ(kafka、ActiveMQ、RabbitMQ、RocketMQ)各自的优缺点 前言 近期有了想跳槽的打算,所以自己…

file和filestream

在C#编程环境中,当我们对电脑文件进行读写、移动、复制、删除等这些操作时,这些都可以在system.IO名称空间下,所以当我们想要通过C#编程语言对其进行操作时,需要添加该名称空间,它内部包含对数据流和文件进行同步或异步…

java filestream_java FileStream文件流操作

直接上代码,函数使用说明详见Java API文档 import java.io.*; public class StreamDemo { public static void main(String[] args) { File fnew File("F:\\workspace\\JavaPrj\\test.txt"); FileOutputStream outnull; try { outnew FileOutputStream(f)…

c#FileStream文件读写

//C#文件流写文件,默认追加FileMode.Append string msg "okffffffffffffffff"; byte[] myByte System.Text.Encoding.UTF8.GetBytes(msg); using (FileStream fsWrite new FileStream("D:\1.txt", FileMode.Append)) {fsWrite.Write(myByte, 0, myByte.…

FileStream类

FileStream类的官方介绍请见&#xff1a; https://msdn.microsoft.com/zh-cn/library/system.io.filestream.aspx 一、使用FileStream来读取文本文件 <pre name"code" class"csharp"> string path "E:\TEMP\TestFileStream\the ol…

猿创征文|【.Net实用方法总结】 整理并总结System.IO中FileStream类及其方法介绍

&#x1f40b;作者简介&#xff1a;博主是一位.Net开发者&#xff0c;同时也是RPA和低代码平台的践行者。 &#x1f42c;个人主页&#xff1a;会敲键盘的肘子 &#x1f430;系列专栏&#xff1a;.Net实用方法总结 &#x1f980;专栏简介&#xff1a;博主针对.Net开发和C站问答过…