关键策略 组件之间通过消息队列、消息缓存、负载均衡器等交互（即松耦合关系），可一定程度上屏蔽组件的状态变化，防止对其他组件造成影响 相关云服务和工具 弹性负载均衡服务 ELB 分布式缓存服务 D CS 分布式消息服务Kafka版 分布式消息服务RabbitMQ版 分布式消息服务RocketMQ版

查看更多 →

创建FlinkServer作业写入数据至Hive表 创建FlinkServer作业写入数据至Hudi表 创建FlinkServer作业写入数据至Kafka消息队列 父主题： 使用Flink

查看更多 →

因为短信计费结算周期是1小时，账户变更为欠费冻结状态前，短信平台已受理的短信发送请求不会失败，具体以状态报告为准；如果账户已欠费冻结，则无法使用短信业务，且还在消息队列中的短信发送请求都会失败。 父主题： 短信发送问题

查看更多 →

数据类型 说明 数据管理 Kafka 按照分布式事务日志架构的大规模发布/订阅消息队列，用于日志数据及spark和flink清洗后的数据存储的消息队列。 HDFS 分布式文件系统，用于离线日志接入原始数据存储。 Hive 可实现大规模分析的分布式容错 数据仓库 系统，用于离线日志接入处理后的数据存储。

查看更多 →

的在线云数据库服务。 7 分布式缓存服务 提供即开即用、安全可靠、弹性扩容、便捷管理的在线分布式缓存能力，兼容redis、Memcached 8 RocketMQ 分布式消息服务RocketMQ版是一个低延迟、弹性高可靠、高吞吐、动态扩展、便捷多样的消息中间件服务。 9 TLS

查看更多 →

AMQP队列告警配置 用户在订阅AMQP队列进行消费时，由于网络通信问题、未及时对已经收到的消息进行确认等可能导致消费端离线、消息消费速度变慢，造成消息积压，影响消息实时性。 华为云物联网平台支持AMQP队列告警配置，用户可以通过设置告警规则来监控AMQP队列消息的积压以及队列消费速

查看更多 →

Message Service（JMS）标准的开源消息中间件，提供可靠、高效、可扩展的消息传递机制，支持多种消息协议和传输协议，如TCP、UDP、SSL、NIO等。ActiveMQ支持多种队列和主题模式，可以用于异步消息传递、发布/订阅、消息路由等场景。它还提供了可视化的管理界面，便于

查看更多 →

Kafka是一个分布式的消息发布-订阅系统。它采用独特的设计提供了类似JMS的特性，主要用于处理活跃的流式数据。 Kafka有很多适用的场景：消息队列、行为跟踪、运维数据监控、日志收集、流处理、事件溯源、持久化日志等。 Kafka有如下几个特点： 高吞吐量 消息持久化到磁盘 分布式系统易扩展

查看更多 →

产品优势 分布式消息服务RocketMQ版具有如下产品优势，旨在打造一个即开即用、全托管、低延迟、弹性高可靠、动态扩展、便捷管理和多样功能的消息队列。 即开即用：简单几步即可在云上构建自己专属的消息服务，RocketMQ实例创建完成后，使用实例提供的访问地址即可快速接入。兼容开源

查看更多 →

源端为Kafka/MQ的数据迁移 在泛IOT、新闻、舆情、社交等数据量较大的行业，通常会引入消息中间件（kafka、MQ等）对流量进行削峰填谷，然后借助Flink/Logstash等工具消费数据并进行数据预处理，最终将数据导入到搜索引擎。本实践为您详细介绍源端为Kafka/MQ的集群迁移流程和操作流程。

查看更多 →

# 与领域服务层的I{biz}GatewayService.java一一对应 |-- mq # mq的具体实现，如kafka、rocketmq |-- common

查看更多 →

Message Service（JMS）标准的开源消息中间件，提供可靠、高效、可扩展的消息传递机制，支持多种消息协议和传输协议，如TCP、UDP、SSL、NIO等。ActiveMQ支持多种队列和主题模式，可以用于异步消息传递、发布/订阅、消息路由等场景。它还提供了可视化的管理界面，便于

查看更多 →

数据类型 说明 数据管理 Kafka 按照分布式事务日志架构的大规模发布/订阅消息队列，用于日志数据及spark和flink清洗后的数据存储的消息队列。 HDFS 分布式文件系统，用于离线日志接入原始数据存储。 Hive 可实现大规模分析的分布式容错数据仓库系统，用于离线日志接入处理后的数据存储。

查看更多 →

ending队列移除，当pending队列占满时Spout暂停消息发送。增加pending值可提高Spout的每秒消息吞吐量，提高性能，但延时同步增加。 topology.transfer.buffer.size 32 每个worker进程Distuptor消息队列大小，建议在4

查看更多 →

Kafka是一个分布式的消息发布-订阅系统。它采用独特的设计提供了类似JMS的特性，主要用于处理活跃的流式数据。 Kafka有很多适用的场景：消息队列、行为跟踪、运维数据监控、日志收集、流处理、事件溯源、持久化日志等。 Kafka有如下几个特点： 高吞吐量 消息持久化到磁盘 分布式系统易扩展

查看更多 →

选择合适规格的虚拟机和容器节点 使用弹性伸缩 选择合适类型的网络云服务 选择合适类型的存储云服务 选择合适的消息队列 选择合适规格的Kafka 选择合适规格的RocketMQ 选择合适规格的RabbitMQ 选择合适的关系型数据库 选择合适的非关系型数据库 PERF04 如何进行性能分析？ 定义性能验收标准

查看更多 →

收发普通消息 本章节介绍普通消息的收发方法和示例代码。普通消息发送方式分为同步发送和异步发送。 同步发送：消息发送方发出一条消息到服务端，服务端接收并处理消息，然后返回响应给发送方，发送方收到响应后才会发送下一条消息。 异步发送：消息发送方发出一条消息后，不等服务端返回响应，接着发送下一条消息。

查看更多 →

单击“事件目标”，右侧弹出“事件目标”弹窗。 目标服务选择“分布式消息服务 Kafka版”。 设置事件目标参数。 图2 分布式消息服务 Kafka版 表2 分布式消息服务 Kafka版参数说明 参数名称 说明 目标连接 选择目标连接。如果还未创建目标连接，请先创建分布式消息服务Kafka版目标连接。 Topic

查看更多 →

量”、“当前消息存储大小”等相关指标信息。 管道：显示当前管道指定时间（近2/6/12/24小时、近7天或自定义）内的“管道存储的消息大小(MB)”、“生产到管道的消息大小(MB)”、“生产到管道的消息数量(条)”、“从管道消费的消息大小(MB)”、“从管道消费的消息数量(条)”

查看更多 →

RabbitMqCommon监控 介绍APM采集的RabbitMqCommon监控指标的类别、名称、含义等信息。 表1 RabbitMqCommon监控指标说明 指标类别 指标 指标名称 指标说明 单位 数据类型 默认聚合方式 异常 (exception，RabbitMqCommon调用的异常信息统计。)

查看更多 →

Kafka是一个分布式的消息发布-订阅系统。它采用独特的设计提供了类似JMS的特性，主要用于处理活跃的流式数据。 Kafka有很多适用的场景：消息队列、行为跟踪、运维数据监控、日志收集、流处理、事件溯源、持久化日志等。 Kafka有如下几个特点： 高吞吐量 消息持久化到磁盘 分布式系统易扩展

查看更多 →