开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

IBM-MQ PCF用于获取特定主题的订阅者计数

IBM-MQ PCF是IBM提供的一种用于管理和监控IBM MQ消息队列的工具。PCF是指Programmable Command Format，它提供了一种编程接口，允许开发人员通过发送命令来查询和操作MQ队列管理器。

PCF可以用于获取特定主题的订阅者计数，即订阅了某个特定主题的客户端数量。这对于监控和管理消息队列的使用非常有用，可以帮助管理员了解当前订阅者的数量，以及随着时间的推移订阅者的变化情况。

IBM-MQ PCF的优势包括：

灵活性：PCF提供了丰富的命令和选项，可以满足不同的管理和监控需求。
实时性：PCF命令可以立即返回订阅者计数，管理员可以实时了解订阅者的情况。
可编程性：PCF提供了编程接口，可以通过编写代码来自动化执行PCF命令，提高效率和准确性。

IBM-MQ PCF的应用场景包括：

监控和管理：通过获取订阅者计数，管理员可以实时监控消息队列的使用情况，并根据需要进行调整和优化。
故障排查：当消息队列出现问题时，可以使用PCF命令获取订阅者计数，帮助定位问题所在，并进行相应的修复。
容量规划：通过了解订阅者的数量和变化情况，可以进行容量规划，确保消息队列的性能和可靠性。

腾讯云提供了一系列与消息队列相关的产品，其中包括腾讯云消息队列 CMQ。CMQ是一种高可靠、高可用的消息队列服务，可以满足各种场景下的消息通信需求。您可以通过以下链接了解更多关于腾讯云消息队列 CMQ的信息：https://cloud.tencent.com/product/cmq

页面内容是否对你有帮助？

有帮助

没帮助

相关·内容

IBM WebSphere MQ 系列（四）使用MQ命令

结合上节使用到的MQ命令，本节系统阐述MQ的命令。一、MQ命令集合 MQ命令集合有三种命令：控制命令、MQSC（MQ脚本命令）和PCF（Programmable Command Formats，可编程的命令格式）。二、控制命令控制命令：用于管理 WebSphere MQ的系统配置,包括队列管理器、侦听器、通道、日志的管理。例如：创建队列管理器（crtmqm）,启动队列管理器（strmqm）,启动用于运行队列管理器MQSC命令的控制台（runmqsc）、运行通道（runmqch

06

基于单片机设计的防煤气泄漏装置

煤气泄漏是一个严重的安全隐患，可能导致火灾、爆炸以及对人体健康的威胁。为了提高家庭和工业环境中煤气泄漏的检测和预防能力，设计了一种基于单片机的防煤气泄漏装置。

02

消息队列面试解析系列（一）- 消息队列的意义

见名知义，消息队列主要就是用来发送和接收处理消息，但它的作用可不仅解决应用间通信问题。

00

消息队列面试解析系列(一)-消息队列(MQ)的意义

见名知义，消息队列主要就是用来发送和接收处理消息，但它的作用可不仅解决应用间通信问题。

02

图解：消息传输的架构模式

本文介绍在 Redis、Apache Kafka、RabbitMQ、ZeroMQ 和 IBM MQ 等技术中使用的消息交换架构和路由方法的基本模式。另外介绍如何使用这些模式简化架构师和开发人员之间的互动。

02

物流网首选协议，关于 MQTT 你需要了解这些

MQTT 是一种基于发布/订阅模式的轻量级消息传输协议，专门针对低带宽和不稳定网络环境的物联网应用而设计，可以用极少的代码为联网设备提供实时可靠的消息服务。MQTT 协议广泛应用于物联网、移动互联网、智能硬件、车联网、智慧城市、远程医疗、电力、石油与能源等领域。

03

物联网的基础协议之MQTT

本文主要介绍MQTT相关的概念，并且通过搭建MQTT服务器和客户端，测试MQTT的通信。本文主要从实际使用的角度去理解MQTT，并不会讲述过于深奥的理论知识。可以通过下面的文章了解MQTT的相关介绍。

04

面试官：消息队列是怎么演进的？

上一篇我们用一个秒杀案例探讨了我们为什么需要消息队列。今天我们来回顾一下消息队列的发展历史。

02

树莓派基础实验21：烟雾报警传感器实验

气体传感器MQ-2是检测空气中可燃气体浓度的易燃气体和烟雾传感器。他们经常用于家用、工业或汽车中的烟气和易燃气体，如液化石油气，异丁烷，丙烷，甲烷和酒精的气体检测设备。

03

MQ消息中间件（工作+面试）

AMQP协议介绍 AMQP，即Advanced Message Queuing Protocol，高级消息队列协议，是应用层协议的一个开放标准，为面向消息的中间件设计。 AMQP的主要特征是面向消息、

07

MQ详解及四大MQ比较

一、消息中间件相关知识 1、概述消息队列已经逐渐成为企业IT系统内部通信的核心手段。它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能，成为异步RPC的主要手段之一。当今市面上有很多主流的消息中间件，如老牌的ActiveMQ、RabbitMQ，炙手可热的Kafka，阿里巴巴自主开发RocketMQ等。 2、消息中间件的组成 2.1 Broker 消息服务器，作为server提供消息核心服务 2.2 Producer 消息生产者，业务的发起方，负责生产消息传输给broker， 2.3 Consumer 消息消费者，业务的处理方，负责从broker获取消息并进行业务逻辑处理 2.4 Topic 主题，发布订阅模式下的消息统一汇集地，不同生产者向topic发送消息，由MQ服务器分发到不同的订阅者，实现消息的广播 2.5 Queue 队列，PTP模式下，特定生产者向特定queue发送消息，消费者订阅特定的queue完成指定消息的接收 2.6 Message 消息体，根据不同通信协议定义的固定格式进行编码的数据包，来封装业务数据，实现消息的传输 3 消息中间件模式分类 3.1 点对点 PTP点对点:使用queue作为通信载体

02

关于MQ，你了解多少？（干货分享之一）

导语本文梳理笔者 MQ 知识，从消息中间件的基础知识讲起，在有了基础知识后，对市面上各主流的消息中间件进行详细的解析，包括 RabbitMQ、RocketMQ、Kafka、Pulsar，最后再横向对比这几款主流的消息中间件。消息中间件历史介绍 MQ 的文章网上千千万，最好的学习途径还是官方文档，文中介绍的这几款 MQ 都在努力推广自己，所以文档在权威性、全面性、专业性、时效性都是无人能及其左右，现在的官网文档甚至自己做竞品比对，比如 RocketMQ 就自己放了比对表格在首页。所以要学好哪一款MQ，

05

消息中间件基础知识-从RabbitMQ、RocketMQ、Kafka到Pulsar

本文梳理笔者的MQ知识，从消息中间件的基础知识讲起，在有了基础知识后，对市面上各主流的消息中间件进行详细的解析，包括 RabbitMQ、RocketMQ、Kafka、Pulsar，最后再横向对比这几款主流的消息中间件。

03

MQTT安全性设计详解

MQTT(MQ Telemetry Transport, MQ 遥测传输)。它是一种发布/订阅、极其简单和轻量级的消息传递协议，旨在用于受限设备和低带宽，高延迟或不可靠的网络。设计原则是使网络带宽和设备资源要求最小化，同时还要尝试确保可靠性和一定程度的交付保证。这些原则也使该协议成为新兴的“M2M”或“物联网”连接设备世界的理想选择，并且适用于带宽和电池电量极为宝贵的移动应用。

01

看完这篇，还怕面试官问消息中间件么？

如果现有A、B两个应用程序，B应用希望从A应用获取到自己感兴趣的信息，A和B部署在不同的机房，可能还有C、D、E等更多的这样的应用程序需要A的这些消息，这就是我们常说的消息中间件的点对点、发布订阅模式。

02

Kafka实战(1)-为何大厂都选择Kafka作为消息队列

MQ是一组规范。利用这组规范可以在不同系统间传递语义准确的消息，实现松耦合的异步式数据传递。

04

pmq再学习一

首先基础数据的来源和怎么产生联系的？创建主题，有了主题，创建消费组，然后基于消费组这个大前提，执行订阅操作，订阅需要进行消费的主题信息，然后在订阅的基础上，进行队列的分配，而分配过程中，首先会去找到可分配的数据节点，然后根据条件进行匹配，然后进行返回。在这个过程中会执行元数据的变更和重平衡操作。特别的，这里需要重点关注队列是怎样产生和分配的。

03

MQ Kafka

Options: Kafka，ActiveMQ，RabbitMQ, WebSphere MQ*(IBM)，RocketMQ(阿里系) ...

01

快速掌握消息队列MQ最内核，图文并茂详解！

消息队列MQ是大型分布式系统不可缺少的中间件，也是高并发系统的基石中间件，其重要性不言而喻。

01

ACP互联网架构认证笔记-MQ消息队列服务

MQ是消息服务中间件，基于高可用分布式集群技术，是消费模式基于发布订阅模式的消息系统。支持Java，C++以及.NET，PHP，Python，为分布式应用系统提供异步解耦、削峰填谷的能力，具备海量消息堆积、高吞吐、可靠重试等特性。具有消息查询，消息回溯(不是消息撤回，也不支持消息撤回)，消息轨迹查询，堆积监控报警功能。 MQ协议支持接入方式 : TCP、HTTP(RESTful 风格)、MQTT。MQ支持公网访问，但可用性较低。 MQ应用场景 : 分布式事务，物联网应用，实时计算(将产生的数据实时流入到实时计算引擎来实现)，同步大规模缓存。实时计算引擎一般有 : Spark / Storm / EMR / ARMS / BeamRunner。 MQ拥有管理工具 : Web控制台，Open API，mqadmin命令集。拥有微消息队列(LMQ)，RocketMQ消息队列，Kafka消息队列，跨域中继服务(CRS)等组件。 Web控制台提供消息查询、消息轨迹查询、重置消费位点、资源统计、监控报警等操作。消息查询有三种方式 :** 根据Message ID(精确查询)，Message Key(模糊查询)以及Topic查询(范围查询)，HTTP消息目前只支持Message ID和Topic两种查询方式。** 消息轨迹查询只支持TCP和HTTP协议，可追踪消息从生产者发出到消费者消费的整个链路中各个相关节点的时间地点。重置消费位点可跳过堆积的消息，即不想消费这部分消息，或者只想消费某个时间点后的消息（这些消息不论之前是否消费过）。资源报表可对消息发送和消息消费的数据进行统计，暂不支持HTTP消费数据的统计查询。监控报警一般用在消息堆积数或者延迟时间超过阈值之后，对报警接收人发送短信，如果发现消息堆积很多，可检查阈值是否设置过小导致消息堆积，可调整业务代码或者对消费者进行扩容，可使用jstack查看是否消费线程阻塞。微消息队列(LMQ)基于MQTT(Message Queuing Telemetry Transport 消息队列遥测传输)协议，标准协议端口为1883，支持加密SSL，WebSocket，Flash接入方式。协议重要部分主要分为 : MQ Core Service(负责底层的消息存储和分发)，MQ私有协议服务器以及MQTT协议网关服务器(负责对客户端提供服务和协议转换)。主要使用场景有 : 直播互动、车联网、金融支付、即时聊天等。协议相关 : QoS(Quality of Service)指代消息传输的服务质量。它包括QoS0(最多分发一次)、QoS1(至少达到一次)和QoS2(仅分发一次)三种级别。cleanSession标识客户端建立TCP连接后是否关心之前状态(true or false)。 MQTT可进行实例管理(查看消息收发TPS、同时在线连接数、订阅关系数等信息，可设置实例报警)，可申请MQTT Topic，可为Topic申请MQTT Group ID(一组逻辑功能完全一致的节点共用的组名，代表一类相同功能的设备，必须拥有Topic的读写权限)。可进行签名计算和签名生成。 MQTT可获取离线消息，可主动拉取离线消息，客户端每次拉取消息数量最多为30条，拉取请求的最大频率限制为5次/秒。离线消息优先级低，对其进行有限和最终能处理即可，要求比较实时。 MQTT可获取客户端上下线事件(上下线事件触发时，会向后端MQ推送一条上下线消息，通过订阅这条消息获取)，上下线事件类型一般放在MQ的Tag中，有三种状态 : connect(客户端上线)，disconnect(客户端主动断开连接)，tcpclean(实际的TCP连接断开)。tcpclean代表客户端网络层连接的真实断开，判断客户端下线请使用tcpclean事件。 MQTT通过Token鉴权服务向客户端提供访问权限。客户端需要采用MQTT控制报文以同步发送模式并且QoS必须为1，来上传Token。客户端应该对Token做好持久化，监听Proxy下推的Token失效的通知消息，Token失效必须重新申请。 LMQ的Topic，ClientId长度最大为64个字符，消息大小最大为64K，消息保存时间最长为3天，单个客户端订阅Topic数量最大为30个(超过该限制数量的Topic会被丢弃)，消息顺序性为上行顺序。跨域中继服务(CRS，跨域哦，实现服务发布与订阅，实现不同网络的服务互通)提供三种MQ消息发送方式 :可靠同步发送(发出消息响应后才能发下一个消息，应用场景广，如重要通知邮件、报名短信通知、营销短信系统)，可靠异步发送(不需要等待响应即可发下一个消息，应用场景一般是耗时长，对RT响应敏感的业务，如视频上传后通知转码服务，转码后通知推送转码结果)，One Way(单向发送，不需要响应的方式，耗时超短，对可靠性要求不高的场

03

基于ZigBee的工业废气监测系统

本文主要对工业现场中排放的工业废气浓度进行检测。并根据国内外气体监测技术的发展现状，提出了基于ZigBee的工业废气监测系统的设计方案。

01

常见消息中间件大 PK

说到消息中间件，估计大伙多多少少都能讲出来一些，ActiveMQ、RabbitMQ、RocketMQ、Kafka 等等各种以及 JMS、AMQP 等各种协议，然而这些消息中间件各自都有什么特点，我们在开发中又该选择哪种呢？今天松哥就来和小伙伴们梳理一下。

01

消息队列基础总结

本文主要讲解 MQ 的通用知识，让大家先弄明白：如果让你来设计一个 MQ，该如何下手？需要考虑哪些问题？又有哪些技术挑战？

03

【精选】由浅入深带你吃透MQ原理与应用场景

本文主要讲解 MQ 的通用知识，让大家先弄明白：如果让你来设计一个 MQ，该如何下手？需要考虑哪些问题？又有哪些技术挑战？

03

RocketMQ为什么要保证订阅关系的一致性？

前段时间有个朋友向我提了一个问题，他说在搭建 RocketMQ 集群过程中遇到了关于消费订阅的问题，具体问题如下：

04

分布式架构核心组件之消息队列

消息队列已经逐渐成为分布式应用场景、内部通信、以及秒杀等高并发业务场景的核心手段，它具有低耦合、可靠投递、广播、流量控制、最终一致性等一系列功能。

02

API协议设计的10种技术

在这个数字时代，我们的日常生活中充斥着各种应用程序和系统之间的交互。无论是社交媒体、在线购物还是智能家居设备，它们都需要通过API（应用程序接口）来实现数据的传输和通信。然而，这些看似简单的操作背后隐藏着复杂的协议。

01

RocketMQ深入浅出-02-详细介绍与安装

RocketMQ是一个统一消息引擎、轻量级数据处理平台。 RocketMQ是⼀款阿⾥巴巴开源的消息中间件。2016年11⽉28⽇，阿⾥巴巴向 Apache 软件基⾦会捐赠RocketMQ，成为 Apache 孵化项⽬。2017 年 9 ⽉ 25 ⽇，Apache 宣布 RocketMQ孵化成为 Apache 顶级项⽬（TLP ），成为国内⾸个互联⽹中间件在 Apache 上的顶级项⽬。它使用Java语言开发，在阿里内部，RocketMQ承接了例如“双11”等高并发场景的消息流转，能够处理万亿级别的消息。

02

开发者的福利--Cloud Foundry

要确保公司云资产的安全性，首先要应用基于虚拟网络独特性修改的可靠的数据安全实践。

08

应用消息中间件设计可以解决哪些实际问题？

消息队列中间件是分布式系统中重要的组件，主要解决应用解耦，异步消息，流量削锋等问题，实现高性能，高可用，可伸缩和最终一致性架构。目前使用较多的消息队列有ActiveMQ，RabbitMQ，ZeroMQ，Kafka，MetaMQ，RocketMQ。消息中间件到底该如何使用，何时使用这是一个问题，胡乱地使用消息中间件增加了系统的复杂度，如果用不好消息中间件还不如不用。

02

云原生中间件RocketMQ(一)基本概念&功能特性&架构设计&环境搭建

消息队列（Message Queue，简称 MQ）是构建分布式互联网应用的基础设施，通过 MQ 实现的松耦合架构设计可以提高系统可用性以及可扩展性，是适用于现代应用的最佳设计方案。

01

认识MQTT协议

MQTT（Message Queuing Telemetry Transport）是一种轻量级的消息协议，设计用于在低带宽、不稳定或高延迟的网络环境中传输消息。MQTT最初由IBM开发，后来成为OASIS标准，广泛用于物联网（IoT）应用和其他需要高效消息传递的场景。

01

【企业架构】什么是第一?架构还是流程？

过去，APQC就APQC的产品（流程管理、内容/知识管理和基准测试）详细讨论了流程分类框架®（PCF）。受同事Holly最近研究的启发，我开始思考APQC如何在企业架构（EA）领域定位自己。专注于企业架构的组织如何利用APQC的PCF实现更好的EA结果？我们的流程管理工具MosaiQ®如何加速EA工作？我们的流程管理方法如何减少返工？

02

Message Queue消息队列基本原理

如果需要和新的系统建立通信或删除已建立的通信，都需要修改代码，这种方案显然耦合度很高。

03

kafka 工作原理介绍

消息队列技术是分布式应用间交换信息的一种技术。消息队列可驻留在内存或磁盘上, 队列存储消息直到它们被应用程序读走。通过消息队列，应用程序可独立地执行--它们不需要知道彼此的位置、或在继续执行前不需要等待接收程序接收此消息。在分布式计算环境中，为了集成分布式应用，开发者需要对异构网络环境下的分布式应用提供有效的通信手段。为了管理需要共享的信息，对应用提供公共的信息交换机制是重要的。常用的消息队列技术是 Message Queue。

01

MCS-51单片机温度控制系统的设计

注塑机是一种常用的制造设备，用于生产塑料制品。在注塑机的工作过程中，溶胶必须达到一定的温度才能被注入模具中进行成型。因此，在注塑机的生产过程中，温度控制是非常重要的一环。

03

详解接口测试（1）-常见的网络通信协议

在网上查询编程相关资料，我们或多或少听过API (Application Programming Interface,应用程序编程接口)这个词，简称接口

02

消息队列介绍

消息(Message)是指在应用间传送的数据（比如字符串，json等），消息队列（Message Queue，简称MQ）是一个古老的计算机术语，UNIX进程间通信就用到了消息队列技术：一个进程把数据写入某个特定队列中，其它队列读取特定队列中的数据实现异步通信。而现在我们所说的MQ通常指的是独立的消息队列中间件，利用高效可靠的消息传递机制进行与平台无关的数据交流，并基于数据通信来进行分布式系统的集成。

01

4.8 51单片机-PCF8591(ADC/DAC)转换芯片

通过原理图得到的重要信息: PCF8591芯片地址线全部接GND。也就是当前模块的地址固定为: 1001000

02

发送和接收IBM WebSphere MQ消息

InterSystems IRIS为IBM WebSphere MQ提供了一个接口，可以使用该接口在InterSystems IRIS和IBM WebSphere MQ的消息队列之间交换消息。要使用此接口，必须能够访问IBM WebSphere MQ服务器，并且IBM WebSphere MQ客户端必须与InterSystems IRIS在同一台计算机上运行。

03

Kafka快速入门系列(1) | Kafka的简单介绍(一文令你快速了解Kafka)

自Flume快速入门系列结束后，博主决定后面几篇博客为大家带来关于Kafka的知识分享作为快速入门Kafka系列的第一篇博客，本篇为大家带来的是Kafka的简单介绍。

02

Go 事件驱动编程：实现一个简单的事件总线

在当今微服务和分布式系统盛行的背景下，事件驱动架构（Event-Driven Architecture，EDA）扮演着一个至关重要的角色，此架构的设计使得服务间可以通过事件进行同步或异步通信，替代了传统的直接接口调用。基于事件的交互方式，促进了服务之间的松耦合，提高系统的可扩展性。

07

SpringCloud-RabbitMQ消息模型

本文深入介绍了RabbitMQ消息模型，涵盖了基本消息队列、工作消息队列、广播、路由和主题等五种常见消息模型。每种模型都具有独特的特点和适用场景，为开发者提供了灵活而强大的消息传递工具。通过这些模型，RabbitMQ实现了解耦、异步通信以及高效的消息路由，为分布式系统的开发和部署提供了可靠的基础。阅读本文，读者将深入了解RabbitMQ不同消息模型的应用场景和使用方法，为构建可靠的消息传递系统提供了有益的指导。

01

用了那么久MQTT，这些知识点你了解吗

哈喽，小伙伴们，今天来聊一聊什么是MQTT协议，以及常用的几个术语是什么意思，有图有真相哦，欢迎阅读

05

消息传输模型的思考

在P2P模型中，有几个关键术语：消息队列(Queue)、发送者(Sender)、接收者(Receiver)。每个消息都被发送到一个特定的队列，接收者从队列中获取消息。队列保留着消息，直到它们被消费或超时。

03

RocketMQ之消费者启动与消费流程

RocketMQ是由阿里巴巴开源的分布式消息中间件，支持顺序消息、定时消息、自定义过滤器、负载均衡、pull/push消息等功能。RocketMQ主要由 Producer、Broker、Consumer 、NameServer四部分组成，其中Producer 负责生产消息，Consumer 负责消费消息，Broker 负责存储消息。NameServer充当名字路由服务，整体架构图如下所示：

02

Redis 中如何实现的消息队列？实现的方式有几种？

细心的你可能发现了，本系列课程中竟然出现了三个课时都是在说消息队列，第 10 课时讲了程序级别的消息队列以及延迟消息队列的实现，而第 15 课时讲了常见的消息队列中间件 RabbitMQ、Kafka 等，由此可见消息队列在整个 Java 技术体系中的重要程度。本课时我们将重点来看一下 Redis 是如何实现消息队列的。

06

消息队列的过去、现在和未来

作者 | 厉启鹏本文以互联网的发展为主线，用叙事的方式向读者再现了消息系统从诞生至今的发展历史。从 1983 年开始，消息系统经历了不同历史时期的历练与打磨，它们的使用方式、功能特性、产品形态、应用场景都发生了非常大的变化。作者选取了五款不同时代的代表性作品，描述了这些产品诞生的历史背景，立足解决的核心问题，并尝试分析它们取得成功的关键因素。最后作者给出了在 Serverless 时代的三个断言，指出了当前消息系统在解决 Serverless 场景存在的核心痛点，展望了未来消息产品应该具备的关键能力，

02

基于STM32设计智能家居控制系统(OneNet)_2022

随着科学技术的发展，人们的生活方式发生着巨大改变，基于物联网技术实现的智能家居使我们的生活变得更加方便快捷。本次设计结合现代生活的具体需求，设计出一套基于物联网技术的智能家居电子系统设计，可以远程实时查看家里光照强度、温湿度等信息，支持在云端控制家里的电器设备，实现远程控制。

03

消息队列中间件（二）使用 ActiveMQ

Active MQ 是由 Apache 出品的一款流行的功能强大的开源消息中间件，它速度快，支持跨语言的客户端，具有易于使用的企业集成模式和许多的高级功能，同时完全支持 JSM1.1 和 J2EE1.4 。

02

扫码

添加站长进交流群

领取专属 10元无门槛券

手把手带您无忧上云

扫码加入开发者社群

相关资讯

热门标签

活动推荐

运营活动

活动名称

广告关闭