是用来构建并传输数据到服务端的逻辑概念，负责把数据放入消息队列。 订阅器 用于订阅安全云脑管道消息，一个管道可由多个订阅器进行订阅，安全云脑通过订阅器进行消息分发。 消费者 是用来接收并处理数据的运行实体，负责通过订阅器把安全云脑管道中的消息进行消费并处理。 消息队列 是数据存储和传输的实际容器。 威胁检测模型

查看更多 →

单击"添加"进入"添加转发目标"页面，设置转发目标为"MQTT推送消息队列"，单击“预置服务接入凭证”预置接入凭证密钥（access_code）和接入凭证键值（access_key）。 图4 新建转发目标-转发至MQTT推送消息队列预置凭证 如果您之前预置过接入凭证，重新预置之后，之前的接入凭证密钥将不能再使用。

查看更多 →

R001C00 HL7 2.1、2.2、2.3、2.3.1、2.4、2.5、2.6、2.7、2.8、2.8.1 HANA 1.0 IBM MQ 9.1 Kafka 1.1.0、2.3.0 LDAP 无版本号 MongoDB 3.4 MQS 无版本号 MRS Hbase MRS 3

查看更多 →

maxItems) 消费消息 输入参数 topic：消息队列 timeout：读取超时时间，最大值为30000毫秒，建议timeout设置值小于前端API的“后端超时”时间值 maxItems：读取消息的最大数量 返回信息 Kafka已消费的消息数组，消息数组即将多条消息的内容组成一个数组

查看更多 →

Sec-WebSocket-Key: wJ34Os631BNGJ1R72gQ/mQ== Sec-WebSocket-Extensions: permessage-deflate; client_max_window_bits 错误码 当您使用华为云会议服务端API时，如果遇到“MMC”或者

查看更多 →

是一个开源的高性能消息队列（Message Queue）系统，它是基于 Apache ActiveMQ 和 Apache Artemis 的技术构建而成的。ArtemisMQ 提供了可靠的异步消息传递机制，允许不同的应用程序之间通过消息进行通信。它采用了基于消息的中间件模式，允许

查看更多 →

收发顺序消息 顺序消息是分布式消息服务RocketMQ版提供的一种严格按照顺序来发布和消费的消息类型。 顺序消息分为全局顺序消息和分区顺序消息： 全局顺序消息：对于指定的一个Topic，将队列数量设置为1，这个队列内所有消息按照严格的先入先出FIFO（First In First

查看更多 →

用 域名 对接多个只读数据库实例，一旦出现问题，可以增加只读实例应急。 不用作消息队列 发布订阅场景下，不建议作为消息队列使用。 如没有非常特殊的需求，不建议将 Redis 当作消息队列使用。 Redis 当作消息队列使用，会有容量、网络、效率、功能方面的多种问题。 如需要消息队列，可使用高吞吐的Kafka或者高可靠的RocketMQ。

查看更多 →

您可以使用HTTP或HTTPS协议进行推送。详细参数填写请参考HTTP/HTTPS服务端订阅。 AMQP推送消息队列 消息队列：选择需要推送消息的队列。若没有队列，请创建队列。消息队列名限制请参考配置AMQP服务端。 分布式消息服务（RocketMQ） 说明： 目前仅企业版实例和标准版实例支持转发到RocketMQ，基础版实例不支持。

查看更多 →

订阅动态脱敏策略 通过动态脱敏订阅，数据安全可以实现同步第三方平台的动态脱敏策略。 第三方平台的动态脱敏策略发布到Kafka消息队列后，数据安全进行订阅和消费。消息格式满足要求时，待消息消费成功后，数据安全会生成动态脱敏策略（策略名为Kafka消息中的策略名）并同步到MRS Ranger组件中生效。

查看更多 →

请输入Tag。 说明： 表示订阅指定Topic下的Tags。 * 表示订阅所有消息。 TagA || TagB || TagC 表示订阅TagA或TagB或TagC的消息。 开启保存消息轨迹 请选择是否开启保存消息轨迹。 启用鉴权认证 请选择是否启用鉴权认证。 Access Key（启用鉴权认证）

查看更多 →

游戏开合服过程中，会遇到如何将不同 服务器 数据同步的问题。通过D CS 服务Redis的消息队列pub/sub机制，可以将数据变更消息发布到Redis的频道中，其他游戏服务器订阅该频道，接收数据变更消息，从而实现数据同步。该实践介绍如何使用Redis实现不同服务器数据同步。 Redis客户端通过CCE连接DCS

查看更多 →

分布式 分布式RabbitMQ 作为消息队列中间件，可以缓解流量压力，避免尖峰流量对应用的影响。 高可用 分布式缓存服务 DCS（ Redis）、云数据库服务主备分区部署，具备跨可用区故障容灾的能力。 一键部署 一键轻松部署，即可完成分布式消息服务 DMS（RabbitMQ）、分布式

查看更多 →

json、plain 消息队列 Kafka json、plain 云脑管道 Pipe json、plain ElasticSearch CSS json、plain 日志从安全云脑转出 传输控制协议 TCP json 用户数据协议 UDP json 消息队列 Kafka json

查看更多 →

Storm与其他组件的关系 Storm，提供实时的分布式计算框架，它可以从数据源（如Kafka、TCP连接等）中获得实时消息数据，在实时平台上完成高吞吐、低延迟的实时计算，并将结果输出到消息队列或者进行持久化。Storm与其他组件的关系如图1所示： 图1 组件关系图 Storm和Streaming的关系

查看更多 →

连接ActiveMQ时是否使用SSL认证。 描述 填写连接器的描述信息，用于识别不同的连接器。 支持的动作 监听队列 配置参数 参数 说明 队列名称 要监听的消息队列名称。 父主题： 触发器

查看更多 →

Connect实例，源端实例配置后目标端自动关联，无需配置。 目标端集成应用 选择IBM MQ数据源所属的集成应用，在接入数据源时已配置。 目标端数据类型 选择“IBM MQ”。 数据源名称 选择接入数据源中已配置的IBM MQ数据源。 目标端类型 选择IBM MQ数据源的消息传递模型，可选择“Topic”和“Queue”。

查看更多 →

方案概述 应用场景 该解决方案可以帮助您在华为云 弹性云服务器 ECS上轻松搭建高可用的RabbitMQ集群。RabbitMQ是采用Erlang语言开发，实现了高级消息队列协议AMQP(advanced Message Queuing Protocol)的开源中间件，支持多种编程语言。

查看更多 →

华为云使用Kafka作为消息引擎，以下概念基于Kafka进行描述。 Topic 消息主题。消息的生产与消费，围绕消息主题进行生产、消费以及其他消息管理操作。 Topic也是消息队列的一种发布与订阅消息模型。生产者向消息主题发布消息，多个消费者订阅该消息主题的消息，生产者与消费者彼此并无直接关系。

查看更多 →

填写为“RuleTest”。 数据来源 选择“设备消息”。 触发事件 选择“设备消息上报”。 资源空间 选择对应资源空间。 添加AMQP推送消息队列的转发目标，配置参数如下： 表6 转发目标参数说明 参数值 配置说明 转发目标 选择“AMQP推送消息队列”。 消息队列 选择“DefaultQueue”。

查看更多 →

数据源管理与数据标准管理 数据源管理 支持对 OLAP 数据源、关系型数据源、NoSQL 数据库、文件数据源、消息队列数据源等异构数据源类型进行接入，屏蔽不同数据库之间的差异，实现数据源的统一管理。 图1 数据源管理1 图2 数据源管理2 数据标准管理 数据元标准 通过“数据标准

查看更多 →