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 监听器 的相关文章

  • RocketMQ吐血总结

    RocketMQ吐血总结 架构 概念模型 最基本的概念模型与扩展后段概念模型 存储模型 RocketMQ吐血总结 User Guide RocketMQ是一款分布式消息中间件 最初是由阿里巴巴消息中间件团队研发并大规模应用于生产系统 满足线
  • RabbitMQ宕机后,消息100%不会丢失吗

    V xin ruyuanhadeng获得600 页原创精品文章汇总PDF 这篇文章 给不太熟悉MQ技术的同学 介绍一个生产环境中可能会遇到的问题 目前为止 你的RabbitMQ部署在线上服务器了 对吧 然后订单服务和仓储服务都可以基于Rab
  • 《消息队列高手课》如何利用事务消息实现分布式事务?

    一说起事务 你可能自然会联想到数据库 的确 我们日常使用事务的场景 绝大部分都是在操作数据库的时候 像 MySQL Oracle 这些主流的关系型数据库 也都提供了完整的事务实现 那消息队列为什么也需要事务呢 其实很多场景下 我们 发消息
  • Rocket学习原理以及命令【详细】

    运行原理图 NameServer 相当于一个注册中心 把所有信息注册到其中 Broker 存储消息的 Producer 消息生产者 Consumer 消费者 总结 首先启动NameServer 然后启动Borker把ip地址等信息注册到Na
  • kafka-__consumer_offsets

    consumer offsets zookeeper不适合大批量的频繁写入操作 Kafka 1 0 2将consumer的位移信息保存在Kafka内部的topic中 即 consumer offsets主题 并 且默认提供了kafka co
  • rocketmq消息重试和死信队列

    1 消息重试 若Consumer消费某条消息失败 则RocketMQ会在重试间隔时间后 将消息重新投递给Consumer消费 若达到最大重试次数后消息还没有成功被消费 则消息将被投递至死信队列 消息重试只针对集群消费模式生效 广播消费模式不
  • 《消息队列高手课》内存管理:如何避免内存溢出和频繁的垃圾回收?

    不知道你有没有发现 在高并发 高吞吐量的极限情况下 简单的事情就会变得没有那么简单了 一个业务逻辑非常简单的微服务 日常情况下都能稳定运行 为什么一到大促就卡死甚至进程挂掉 再比如 一个做数据汇总的应用 按照小时 天这样的粒度进行数据汇总都
  • MQ可以用在哪些地方,解决什么问题?

    MQ kafka是以吞吐量高而闻名 不过其数据稳定性一般 而且无法保证消息有序性 阿里巴巴的RocketMQ基于Kafka的原理 利用Java代码打造 弥补了Kafka的缺点 继承了其高吞吐的优势 其客户端目前以Java为主 RabbitM
  • RabbitMQ优秀博文整理

    1 关于主流MQ的介绍 各MQ的优缺点 MQ的使用选举等 MQ消息队列详解 四大MQ的优缺点分析 从百草园杀到三味书屋 的博客 CSDN博客 几种消息队列的优缺点 2 RabbitMQ常见问题的整理 以及解决思路 图文并茂 比较详细 Rab
  • 【不是拷贝】rabbitmq安装延迟队列插件rabbitmq_delayed_message_exchange

    1 查看当前rabbitmq已安装的插件 查看当前的rabbitmq 安装了哪些插件 rabbitmq plugins list root yq test1 rabbitmq plugins list Configured E explic
  • MQ线上平滑迁移方案

    一 迁移的问题点 1 多生产者 多消费者切换排期跨度较大 场景一 多个生产者 一个消费者 如何保证多个生产者不同排期切换平滑稳定过渡 不漏消费 不重复消费 场景二 一个生产者 多个消费者 如何保证多个消费者不同排期切换平滑稳定过渡 不漏消费
  • rabbitmq简介

    开发十年 就只剩下这套Java开发体系了 gt gt gt 1 AMQP AMQP协议是一个高级抽象层消息通信协议 RabbitMQ是AMQP协议的实现 它主要包括以下组件 1 1 Server broker 接受客户端连接 实现AMQP消
  • RocketMQ-名词和架构

    RocketMQ rocketMQ是做什么的我就不用解释了吧 以及他的背景 本文主要是为了让大家明白RocketMQ的工作原理 架构图 上图 双箭头代表是双向通信 ProducerGroup和ConsumerGroup以及Broker集群
  • rocketmq客户端配置

    1 客户端配置 相对于RocketMQ的Broker集群 生产者和消费者都是客户端 2 客户端寻址方式 RocketMQ可以令客户端找到Name Server 然后通过Name Server再找到Broker 如下所示有多种配置方式 优先级
  • RocketMQ的消息优先级

    有些场景 需要应用程序处理几种类型的消息 不同消息的优先级不同 RocketMQ是个先入先出的队列 不支持消息级别或者Topic级别的优先级 业务中简单的优先级需求 可以通过间接的方式解决 下面列举三种优先级相关需求的具体处理方法 第一种
  • 关于IBM MQ6.0与MQ8.0的通信问题

    国庆之后 负责的一个项目突然出现了问题 描述问题 在网络 业务 业务量都没有增长的情况下 MQ8的批量发送通道突然就挂掉了 变成retrying状态了 消息全都堵在传输队列里了 死信队列无消息 实时通道正常 排除网络原因导致的通道问题 采取
  • 队列管理器和消息代理之间的区别

    Websphere Message Broker 和队列管理器之间有什么区别 我猜队列管理器将消息放入队列 从队列中取出消息 将消息移动到回退队列等 那么代理的工作是什么 它位于发布者和队列管理器之间还是消费者和队列管理器之间 Websph
  • Kafka速度之谜:高性能的幕后秘密大揭秘

    提示 文章写完后 目录可以自动生成 如何生成可参考右边的帮助文档 文章目录 前言 一 kafka高性能的原因 Page Cache ZeroCopy 零拷贝 前言 Kafka的介绍 kafka是linkedIn开源的分布式消息系统 归给Ap
  • Java:在后台更新有大量行的 JTable

    我正在编写一个简单的 Java Swing 实用程序 它将从 MQ JMS 服务器读取消息并将它们显示在 JTable 中 private void getMessages try if null Queue Queue close Clo
  • 以编程方式设置 mosquitto 中的访问控制限制

    我正在开发一个将使用 mqtt 的应用程序 我将使用 python 库 我一直倾向于使用 mosquitto 但找不到以编程方式为其设置访问控制限制的方法 我正在编写的应用程序需要能够区分用户 并且只允许他们订阅某些主题 当前的解决方案看起

随机推荐

  • 【编程之路(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 如果我们使用这个端口 那么我们在发出启动监听器 命令时就不必指定端口号 本节介绍我们如何管