RabbitMQ RabbitMQ是一个开源的消息队列系统，它实现了高效的消息传递机制，可以在分布式系统中进行消息的异步传递和处理。RabbitMQ基于AMQP（Advanced Message Queuing Protocol）协议，支持多种编程语言，包括Java、Python、Ruby、

查看更多 →

IBM MQ IBM MQ是IBM提供的一个消息队列软件，它可以在分布式系统中进行异步通信，确保数据的可靠传输。MQ是一种基于消息的中间件，它提供了一种可靠、安全的方式来传输消息，可以在不同的应用程序、平台和系统之间进行通信。MQ可以确保消息在传输过程中不会丢失、重复或失序，并且

查看更多 →

List<String> consume(String topic, long timeout, long maxItems) 消费消息 输入参数 topic：消息队列 timeout：读取超时时间，最大值为30000毫秒，建议timeout设置值小于前端API的“后端超时”时间值 maxItems：读取消息的最大数量

查看更多 →

在左侧导航栏中选择“服务”，选择“服务”页签，并选择服务所在命名空间。如需新建命名空间，请参见创建命名空间。 单击右上角“创建服务”，设置集群内访问参数。 Service名称：自定义服务名称，可与工作负载名称保持一致。 访问类型：选择“节点访问 NodePort”。 服务亲和： 集群级

查看更多 →

移除 为了方便地在华为云上移除您的服务，可以使用remove命令。 运行serverless remove触发移除进程。 Serverless开始移除时，会在控制台中通知您进程。移除整个服务后，打印成功消息。 移除过程将仅移除提供商基础设施上的服务。服务目录仍将保留在本地计算机上，因

查看更多 →

RecordMetadata produce(String topic, String message) 生产消息 输入参数 topic：消息队列 message：消息内容 返回信息 消息记录 父主题： 自定义后端开发（函数后端）

查看更多 →

创建完成后，可以在服务列表中查看服务对应的内部访问 域名 。 图2 查看服务内部访问域名和访问端口 更新服务 服务支持更新端口配置，包括访问端口、容器端口和协议。 登录IEF管理控制台，在“总览”页面切换实例为铂金版。 选择左侧导航栏的“应用网格 > 服务列表”，单击服务所在行的“更新”，如下图所示。

查看更多 →

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

查看更多 →

消息/邮件。 代理（Broker） 即Kafka集群架构设计中的单个Kafka进程，一个Kafka进程对应一台服务器，因此手册中描述的代理，还包括对应的存储、带宽等服务器资源。 分区（Partition） 为了实现水平扩展与高可用，Kafka将Topic划分为多个分区，消息被分布式存储在分区中。

查看更多 →

Udp、对象存储 Obs、消息队列 Kafka、云脑管道 Pipe 新增数据源连接目的。 选择“目的”页签中，选择数据源类型的目的，并根据选择的类型进行参数配置。 数据源类型目的支持以下类型：文件 File、传输控制协议 Tcp、用户数据协议 Udp、消息队列 Kafka、对象存储 Obs、云脑管道

查看更多 →

自动上报事件至 CTS 服务，在3中通过配置的“协议”您会同步收到消息，例如协议配置“邮件”，你的邮箱将会收到消息通知的邮件。 您还可以在CTS服务上查看全部事件。 登录管理控制台。 在“服务列表”中，选择“管理与监管 > 云审计 服务 CTS”，进入“云审计服务”页面。 在“事件列表

查看更多 →

SUM RabbitMq版本（version ，RabbitMq版本。） version 版本 版本 - STRING LAST 父主题： 消息队列

查看更多 →

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

查看更多 →

连接ActiveMQ的用户密码。 是否开启SSL认证 连接ActiveMQ时是否使用SSL认证。 支持的动作 监听队列 配置参数 参数 说明 队列名称 要监听的消息队列名称。 父主题： 触发器

查看更多 →

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

查看更多 →

节点内的同步WAL堆积大小,单位MB； rsync_push_cost Long 同步消息从放入消息队列，直到收到对端响应的平均耗时，单位us； rsync_send_cost Long 同步消息从消息队列取出，直到收到对端响应的平均耗时，单位us； rsync_max_push_cost Long

查看更多 →

CCE集群部署了业务的前后端以及注册中心，配置中心等。 E CS ，部署了ELK集群，RocketMQ消息队列集群，Promethues集群，提供程序日志查询服务，服务之前消息传递服务。 IoTDA-设备接入，接入业务设备，通过Kakfa方式，程序去消费物联网设备消息。 DCS存储用

查看更多 →

在AppStage业务控制台右上角选择“产品与服务 > 服务管理”。 在“服务管理”页面右上角，单击“创建服务”。 在“创建服务”页面的“所属产品”下拉列表中选择服务所属产品，设置服务中文名、服务英文名，其中服务所属产品和服务英文名设置后不可修改。 服务中文名支持汉字、数字、字母，3~64个字符。 服务英文名必须以

查看更多 →

在AppStage业务控制台右上角选择“产品与服务 > 服务管理”。 在“服务管理”页面右上角，单击“创建服务”。 在“创建服务”页面的“所属产品”下拉列表中选择服务所属产品，设置服务中文名、服务英文名，其中服务所属产品和服务英文名设置后不可修改。 服务中文名支持汉字、数字、字母，3~64个字符。 服务英文名必须以

查看更多 →

”以及“技术栈”。 单击“组件”列，某一个组件名称，进入该组件指标项详情页，默认展示“接口调用”详细信息。 单击“远程过程调用”，切换至消息队列页签。默认展示“全部实例”的“GRPCServer监控”信息。 图1 查看远程过程调用 在下拉列表中选择您想要查看的“实例名称”和“监控

查看更多 →

），物联网平台会滚动清除超期和超出容量限制的数据。 如何进行数据订阅 在物联网平台创建规则、添加转发目标为MQTT消息队列后实现数据订阅，详情请参考配置MQTT服务端订阅。 通过调用API接口进行数据订阅。通过API接口进行数据订阅请参考如何调用API、创建规则触发条件、创建规则动作和修改规则触发条件。

查看更多 →