Websphere MQ 监听器

2023-11-04

MQ监听器管理

在本地队列管理器可以将消息发送到远程队列管理器之前,我们需要为远程队列管理器启动一个监听器。默认的 MQ 监听器端口 号是 1414 ,如果我们使用这个端口,那么我们在发出启动监听器 命令时就不必指定端口号 。本节介绍我们如何管理 MQ 侦听器。我们将研究定义、启动和停止 Listener 的不同方式。

定义/启动 MQ 侦听器:

有两种定义和启动 MQ 监听器的方法:
第一种方法使用运行 Listener  RUNMQLSR 命令。该命令的参数是连接类型 ( -t )、队列管理器名称 ( -m ) 和要启动的端口号 ( -p )。因此,如果我们想在端口 1450 上为队列管理器 QMA启动 TCP 侦听器,我们将发出:

$ runmqlsr -t tcp -m QMA -p 1450

可以将此命令放入批处理文件 ( SYSA_QMA_START_RUNMQLSR.BAT ) 中,并且在 UNIX 中可以使用 nohup 和 & 选项运行:

$ nohup runmqlsr -t tcp -m QMA -p 1450 &

为队列管理器 QMB 在端口 1451 上启动 TCP 侦听器的命令是:

$ nohup runmqlsr -t tcp -m QMB -p 1451 &

可以将此命令放入 SYSB_QMB_START_RUNMQLSR.BAT 批处理文件中。

第二种方法  使用以下 RUNMQSC命令文件从MQSC环境创建监听器:

DEFINE LISTENER (QMA1450) +
TRPTYPE (TCP) +
PORT (1450) +
CONTROL(QMGR)

在此文本文件中,我们为监听器指定了一个名称 ( QMA1450 ),并为该监听器分配了一个端口号。显示的最后一个参数是 CONTROL,它决定了监听器的启动方式,可能的选项是 MANUAL、  QMGR和 STARTONLY,这意味着:

·          MANUAL:(默认)Listener 不会自动启动或自动停止。它是通过使用 START LISTENER 和 STOP LISTENER 命令来控制的。
·          QMGR:被定义的监听器将在队列管理器启动和停止的同时启动和停止。
·          STARTONLY:侦听器将在队列管理器启动的同时启动,但不会在队列管理器停止时请求停止。

如果要手动控制监听器,则可以使用从 MQSC 环境发出的以下命令启动它:

:start listener(QMA1450)

所以回顾一下,如果我们使用 MQ 命令 ( RUNMQLSR ) 启动一个监听器,那么我们不能给它一个名字,我们必须在每次启动队列管理器时手动启动它。如果我们使用来自MQSC 环境的文本文件,那么我们可以命名监听器并让它在队列管理器启动时启动。

要启动监听器,请分别在QMA 和 QMB上发出以下命令  :

start runmqlsr -t tcp -m QMA -p 1450
start runmqlsr -t tcp -m QMB -p 1451

这两个命令都可以分别包含在批处理文件 SYSA_QMA_START_RUNMQLSR.BAT 和SYSB_QMB_START_RUNMQLSR.BAT 中。
根据您站点的标准,您可以根据第二种方法创建监听器。

显示 MQ 侦听器:

我们所说的“显示”MQ Listener 的意思是首先检查 Listener 是否实际运行,其次显示 Listener 的属性。让我们首先看看检查 Listener 是否正在运行。

如果监听器是使用 RUNMQLSR  MQ 命令启动的:

$ runmqlsr -t tcp -m QMA -p 1450 &

然后这将创建一个监听器,其名称的格式为 SYSTEM.LISTENER.TCP.<n>。我们可以通过发出 DISPLAY LSSTATUS MQSC 命令检查此侦听器是否正在运行:

: display lsstatus(*)

你会看到:

AMQ8631: Display listener status details.
LISTENER(SYSTEM.LISTENER.TCP.3)                    STATUS(RUNNING)
PID(12912)

我们可以看到状态是 RUNNING。PID 对应于 UNIX  ps –ef命令的 输出:

$ ps -ef | grep -i "runmqlsr"
mqm 12912 1 0 14:14 pts/1 00:00:00 runmqlsr -t tcp -m QMA -p 1450
db2instp 15937 10695 0 14:43 pts/1 00:00:00 grep -i runmqlsr

如果监听器是使用文件中的 MQSC 命令创建的(如前所示),那么我们可以为监听器命名 ( QMA1450 )。现在我们可以使用DISPLAY LSSTATUS MQSC 命令检查监听器是否正在运行:

: display lsstatus(*)

你会看到:

AMQ8631: Display listener status details.
LISTENER(QMA1450)         STATUS(RUNNING)
PID(2360)

我们当然可以指定我们的监听器名称来代替星号:

: display lsstatus(QMA1450)
AMQ8631: Display listener status details.
  LISTENER(QMA1450)       STATUS(RUNNING)
  PID(2360)                            STARTDA(2009-02-19)
  STARTTI(16.41.41)                                 DESCR( )
  TRPTYPE(TCP)                                       CONTROL(QMGR)
  IPADDR(*)                          PORT(1450)
  BACKLOG(100)

如果侦听器是使用 MQSC 命令文件创建的,则可以使用 DISPLAY LISTENER MQSC 命令并指定名称来显示其属性:

: display listener(QMA1450)
AMQ8630: Display listener information details.
  LISTENER(QMA1450)       CONTROL(QMGR)
  TRPTYPE(TCP)                                       PORT(1450)
  IPADDR( )                           BACKLOG(100)
  DESCR( )                             ALTDATE(2009-02-19)
  ALTTIME(16.41.41)

如果监听器是使用 RUNMQLSR 命令启动的,那么要显示它的属性,我们需要将参数 ALL 附加到 DISPLAY LSSTATUS 命令:

: display lsstatus(*) all
AMQ8631: Display listener status details.
  LISTENER(SYSTEM.LISTENER.TCP.3)                  STATUS(RUNNING)
  PID(8256)                                                 STARTDA(2010-01-07)
  STARTTI(16.54.54)                                                     DESCR( )
  TRPTYPE(TCP)                                                           CONTROL(MANUAL)
  IPADDR(*)                                              PORT(1450)
  BACKLOG(100)

停止 MQ 侦听器

有两种方法可以停止 Listener。第一种方法使用 ENDMQLSR  MQ 命令,第二种方法使用 STOP LISTENER MQSC 命令。

在以下示例中,我们希望  使用 ENDMQLSR  MQ 命令停止 Queue Manager QMA的侦听器:
$ endmqlsr –w -m QMA
在以下示例中,我们使用 STOP LISTENER MQSC 命令来停止监听器:
: stop listener(QMA1450)

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

Websphere MQ 监听器 的相关文章

  • RabbitMQ宕机后,消息100%不会丢失吗

    V xin ruyuanhadeng获得600 页原创精品文章汇总PDF 这篇文章 给不太熟悉MQ技术的同学 介绍一个生产环境中可能会遇到的问题 目前为止 你的RabbitMQ部署在线上服务器了 对吧 然后订单服务和仓储服务都可以基于Rab
  • 如何防止mq的消息丢失

    分为两种情况 1 主要在消费方 当消息从mq传到消费者时 消费者可能消费消息失败 这时mq中的消息已经自动删除了 导致消息的丢失 需要使用ack机制来保证消息不会丢失 当消费者从mq中拿到消息时 这个消息在mq中不删除 而是消费者对消息进行
  • Kafka指南

    Kafka入门 API Spring集成 入门 下载代码 https kafka apache org downloads kafka 2 13 2 6 0 tgz 启动服务器 创建一个单节点ZooKeeper实例 bin zookeepe
  • 大牛总结超详细的RabbitMQ入门,看这篇文章就够了!

    V xin ruyuanhadeng获得600 页原创精品文章汇总PDF 目录 一 前情提示 二 ack机制回顾 三 ack机制实现原理 delivery tag 四 RabbitMQ如何感知仓储服务实例宕机 五 仓储服务处理失败时的消息重
  • Rocket学习原理以及命令【详细】

    运行原理图 NameServer 相当于一个注册中心 把所有信息注册到其中 Broker 存储消息的 Producer 消息生产者 Consumer 消费者 总结 首先启动NameServer 然后启动Borker把ip地址等信息注册到Na
  • RocketMQ rocketmq_client.log日志文件配置

    1 默认路径 项目添加RocketMQ以后启动项目时会在user home下创建一个rocketmq client log日志文件 文件全路径是 user home logs rocketmqlogs rocketmq client log
  • redis 管道(pipeline),深入解读

    文章目录 前言 一 动手试试 1 对比 2 请求 二 原理 1 模式 2 服务端 3 客户端 3 1 redisson 3 2 jedis 3 3 lettuce 总结 前言 本文源码参考版本 redis 6 2 redisson 3 17
  • 【注意】Kafka生产者异步发送消息仍有可能阻塞

    文章目录 问题描述 原因分析 解决办法 总结 问题描述 Kafka是常用的消息中间件 在Spring Boot项目中 使用KafkaTemplate作为生产者发送消息 有时 为了不影响主业务流程 会采用异步发送的方式 如下所示 Slf4j
  • rocketmq安装、启动

    1 下载 gt wget http mirror bit edu cn apache rocketmq 4 4 0 rocketmq all 4 4 0 source release zip gt unzip rocketmq all 4
  • 【不是拷贝】rabbitmq安装延迟队列插件rabbitmq_delayed_message_exchange

    1 查看当前rabbitmq已安装的插件 查看当前的rabbitmq 安装了哪些插件 rabbitmq plugins list root yq test1 rabbitmq plugins list Configured E explic
  • Docker实战:docker compose 搭建Rocketmq

    1 配置文件准备 1 1 新建目录 home docker data rocketmq conf mkdir home docker data rocketmq conf 1 2 在上面目录下新建文件broker conf文件 内容如下 b
  • 消息队列的两种模式

    Java消息服务 Java Message Service JMS 应用程序接口是一个Java平台中关于面向消息中间件 MOM 的API 用于在两个应用程序之间 或分布式系统中发送消息 进行异步通信 点对点与发布订阅最初是由JMS定义的 这
  • IBM MQ 故障诊断(一)

    说明 本文主要是针对运维人员的手册 前面部分主要是应用三板斧的方式 后面的步骤可能会发散和具体深入一些 不过也不是严格的划分 读者就当看一遍杂文的方式来看待此文吧 一 队列管理器的启停 QMGR的启停是故障诊断中遇到最多的需求之一 启动队列
  • 事务提交后发送MQ消息

    前言 本文主要介绍关于MQ使用过程中 通过场景分析为什么要使用事务控制 以及事务如何实现 场景分析 为什么我们在使用MQ的时候需要考虑结合事务 试想一下 我们平时使用Mq发送消息的通用场景是不是 生产者和MQ集群建立连接 并发送消息 消费者
  • rocketMq介绍和安装

    rocketMq介绍和安装 Mq介绍 MQ MessageQueue 消息队列 队列 是一种FIFO 先进先出的数据结构 消息由生产者发送到MQ进行排队 然后按原来的顺序交由消息的消费者进行处理 QQ和微信就是典型的MQ MQ的作用 主要有
  • RocketMQ的消息优先级

    有些场景 需要应用程序处理几种类型的消息 不同消息的优先级不同 RocketMQ是个先入先出的队列 不支持消息级别或者Topic级别的优先级 业务中简单的优先级需求 可以通过间接的方式解决 下面列举三种优先级相关需求的具体处理方法 第一种
  • MQ的基本原理是怎样的?MQ的优点有哪些?MQ的核心概念包括哪些?MQ的消息传递模式有哪些?

    1 MQ的基本原理是怎样的 MQ 消息队列 是一种面向消息的中间件 用于实现不同系统之间的异步通信 其基本原理如下 生产者 Producer 将消息发送到消息队列中 而不是直接发送给消费者 Consumer 消息队列将接收到的消息存储在内部
  • 队列管理器和消息代理之间的区别

    Websphere Message Broker 和队列管理器之间有什么区别 我猜队列管理器将消息放入队列 从队列中取出消息 将消息移动到回退队列等 那么代理的工作是什么 它位于发布者和队列管理器之间还是消费者和队列管理器之间 Websph
  • 以编程方式设置 mosquitto 中的访问控制限制

    我正在开发一个将使用 mqtt 的应用程序 我将使用 python 库 我一直倾向于使用 mosquitto 但找不到以编程方式为其设置访问控制限制的方法 我正在编写的应用程序需要能够区分用户 并且只允许他们订阅某些主题 当前的解决方案看起
  • com.ibm.msg.client.jms.DetailedJMSException:JMSWMQ0018:无法使用连接模式“yyy”和主机名“zzz”连接到队列管理器“xxx”

    JMS 应用程序需要七个参数才能与此处给出的 MQ 系列成功建立 SSL 连接 https github com ibm messaging mq tls ssl wizard blob master com ibm mq ssl wiza

随机推荐

  • 【编程之路(003)】循环语句(for,while,do while语句)(C语言实现)

    目录 总体介绍 引言 for语句 基本语法 具体使用 for循环中的break和continue while语句 基本语法 具体使用 while语句中的break和continue do while 循环 具体使用 while语句中的bre
  • vc入门

    一 VC是什么 学VC是学什么 首先VC是一个软件 IDE集成开发环境 编译 编辑 调试 C和C 但C 中的有些特性是不用的 例如I O流 多态继承 WindowsSDK 软件开发工具 VC的灵魂 MFC 微软基础类库 ATL Active
  • php mail方法_php邮件发送的两种方式

    这篇文章研究的主要内容就是使用PHP来发送电子邮件 总结为以下两种方法 一 使用PHP内置的mail 函数 to test 163 com 收件人 subject Test 主题 message This is a test mail 正文
  • geopy 库 ConfigurationError 错误

    错误详情 geopy exc ConfigurationError Using Nominatim with default or sample user agent geopy 2 2 0 is strongly discouraged
  • LeetCode每日一练 —— 160. 相交链表

    前言 Wassup guys 我是Edison 今天是 LeetCode 上的 leetcode 160 相交链表 Let s get it 文章目录 1 题目分析 2 思路分析 判断相交 求出交点 实现步骤 3 代码实现 1 题目分析 给
  • Optional 详细用法

    1 Optional 是一个对象容器 具有以下两个特点 提示用户要注意该对象有可能为null 简化if else代码 Optional empty 创建一个空的 Optional 实例 Optional of T t 创建一个 Option
  • 正大国际:期货日内波段交易

    期货市场是变幻莫测的市场 期货价格受到各个方面的影响 很多投资者认为无法掌握期市规律 觉得期市没有规律 我认为 期货市场还是有很多规律可循的 我们只要掌握这些规律 就可以掌握大的概率 第一 价格总是能反映市场预期 第二 价格运行总是从一个平
  • PGF 概率生成函数 Probability generating function

    文章目录 随机结构举例 two classical combinatorial distributions PGF Probability generating functions定义 矩 Moments 例题 二项分布的r order 阶
  • Urban Radiance Fields

    Urban Radiance Fields 城市辐射场 摘要 这项工作的目标是根据扫描平台捕获的数据执行 3D 重建和新视图合成 这些扫描平台通常部署用于城市室外环境中的世界地图绘制 例如 街景 给定 RGB 图像序列和通过室外场景移动的相
  • 动态加载js文件-不适用缓存

    浏览器每次加载资源时 都会查看缓存内容 如果浏览器判断缓存中存在 则不重新加载资源 可以在请求资源后面增加随机数或者时间戳 让浏览器判断此请求为新请求 js文件加随机数方式如下
  • 字符串数组的输入

    题目 编写一个程序 输入n n lt 6 个字符串 输出其中最短字符串的有效长度 要求定义函数int minlen char str int n 用于计算有n个元素的指针数组str中最短的字符串长度 code include
  • SQL查询包含指定列的所有表

    select from information schema columns where column name 指定列名 其中information schema是一个系统库 包含了columns tables routines等表
  • 7-2 二分查找

    这个题其实就是一个二分查找的练习 如果不想写二分查找代码的就直接写lower bound int 查找的数 二分查找相比普通查找他的复杂度是log2n include
  • java中final修饰成员变量注意事项

    java核心技术中说到 实例成员变量被final修饰后 构建对象时必须初始化这个变量 并且之后不允许再改变这个值 也就是说 一个构造器执行后 确保这个值被初始化了 所以可以得知 1 如果一个被final修饰的实例域只声明没有初始化 那么必须
  • MySQL数据库-Day1笔记

    1 创建学生表 create table student id int primary key auto increment name varchar 20 not null sex char 5 age int score double
  • [libuv]uv_loop_close和uv_stop的区别

    作者 玄冬Wong uv loop close 是释放掉uv loop t 指针相关的资源 uv stop 是退出当初由uv run 运行的正在阻塞中的逻辑 当程序完全退出需要清理全部uv相关的资源时 具体清理方式如下 1 这里假设你在函数
  • 非极大值抑制(NMS)及其变种实现

    文章目录 非极大值抑制 NMS 及其变种实现 NMS各大变种 标准NMS 局部感知NMS LNMS 倾斜NMS INMS 多边形NMS PNMS 掩膜NMS MNMS 总结 Soft NMS Motivation Method 非极大值抑制
  • 在 Webpack 中使用 art-template

    一 搭建Webpack环境 1 项目目录 2 初始化项目 npm init 3 安装 Webpack 相关依赖包 npm install save dev webpack 4 44 1 webpack cli 3 3 12 html web
  • Linux在yum时报错Could not resolve host: mirrorlist.centos.org

    1 进入修改配置文件 vi etc resolv conf 2 在配置文件里加上一句 nameserver 114 114 114 114 这是国内的dns服务器系统 还是比较好用的 谷歌的可以使用8 8 8 8 3 重启网络 servic
  • Websphere MQ 监听器

    MQ监听器管理 在本地队列管理器可以将消息发送到远程队列管理器之前 我们需要为远程队列管理器启动一个监听器 默认的 MQ 监听器端口 号是 1414 如果我们使用这个端口 那么我们在发出启动监听器 命令时就不必指定端口号 本节介绍我们如何管