事务消息发送 事务消息介绍 事务消息步骤 示例代码 事务消息发送 事务消息介绍 在一些对数据一致性有强需求的场景，可以用 Apache RocketMQ 事务消息来解决，从而保证上下游数据的一致性。 以电商交易场景为例，用户支付订单这一核心操作的同时会涉及到下游物流发货、积分变更、购物车状态清空等多个子系统的变更。当前业务的处理分支包括：...

批量消息发送 批量消息发送 在对吞吐率有一定要求的情况下，Apache RocketMQ可以将一些消息聚成一批以后进行发送，可以增加吞吐率，并减少API和网络调用次数。 public class SimpleBatchProducer { public static void main ( String [...

顺序消息发送 顺序消息介绍 顺序消息示例代码 顺序消息的一致性 顺序消息发送 顺序消息介绍 顺序消息是一种对消息发送和消费顺序有严格要求的消息。 对于一个指定的Topic，消息严格按照先进先出（FIFO）的原则进行消息发布和消费，即先发布的消息先消费，后发布的消息后消费。在 Apache RocketMQ 中支持分区顺序消息，如下图所示。我们...

合并消息模板 文件名 变量 变基（Rebase） 合并消息模板 文件名 PR 默认合并消息模板可能的文件名： .gitea/default_merge_message/MERGE_TEMPLATE.md .gitea/default_merge_message/REBASE_TEMPLATE.md .gitea/default_merg...

合并消息模板 文件名 变量 变基（Rebase） 合并消息模板 文件名 PR 默认合并消息模板可能的文件名： .gitea/default_merge_message/MERGE_TEMPLATE.md .gitea/default_merge_message/REBASE_TEMPLATE.md .gitea/default_merg...

配置分析消息 IST0001: InternalError IST0002: Deprecated IST0101: ReferencedResourceNotFound IST0102: NamespaceNotInjected IST0103: PodMissingProxy IST0106: SchemaValidationError IS...

消息派发扩展 扩展说明 扩展接口 扩展配置 已知扩展 扩展示例 消息派发扩展 扩展说明 通道信息派发器，用于指定线程池模型。 扩展接口 org.apache.dubbo.remoting.Dispatcher 扩展配置 <dubbo:protocol dispatcher = "xxx" /> <!-- 缺省值设置，当...

配置分析消息 IST0001: InternalError IST0002: Deprecated IST0101: ReferencedResourceNotFound IST0102: NamespaceNotInjected IST0103: PodMissingProxy IST0104: GatewayPortNotOnWorkload ...

DynamoDB 消息存储 配置 DyanmoDB 消息存储 DynamoDB 数据库创建表 DynamoDB 用户状态表(Client Table) DynamoDB 用户订阅主题(Subscription Table) DynamoDB 发布消息(Message Table) DynamoDB 保留消息(Retain Message Table...

MQTT 保留消息 简介 创建模块 保留消息配置简介 MQTT 保留消息 简介 服务端收到 Retain 标志为 1 的 PUBLISH 报文时，会将该报文视为保留消息，除了被正常转发以外，保留消息会被存储在服务端，每个主题下只能存在一份保留消息，因此如果已经存在相同主题的保留消息，则该保留消息被替换。 当客户端建立订阅时，如果服务端存在主题...