RocketMQ基础知识
目录 RocketMQ架构 概述 Name Server Broker Producer Consumer RocketMQ客户端如何找到Name Server Roc...
emanlee
RocketMQ服务端安装
目录 说明 环境准备 安装架构图 Name Server安装 Broker安装 查看集群节点情况 问题 说明 为了尽量模拟实际应用场景，我们以集群的方式安装Rocke...
RocketMQ发送同步、异步、单向消息
目录 说明 基础工具类 测试代码 效果展示 说明 后续打算根据RocketMQ官网的例子，也对各种类型的消息进行简单的使用。在熟悉基本使用，了解各类消息的特点之后，再抽时间进行内...
RocketMQ使用顺序消息
目录 说明 生产端 消费端 总结 说明 RocketMQ与其它消息队列一样，一个Topic利用多个队列来存储数据，单个队列内的数据是顺序存储的，但队列间的数据无法保证顺序性。Ro...
RocketMQ使用广播消息
目录 说明 生产端 消费端 总结 说明 RocketMQ消息模式主要有两种： （1）、MessageModel.CLUSTERING：集群模式。同一消费者组内的每个消费者，只消费...
RocketMQ使用延迟消息
目录 说明 生产端 消费端 运行结果示例 延迟级别与延迟时间对应关系 说明 1、延时消息不是延迟发送，消息是实时发送的，只是消费者延迟消费 2、延迟消息主要通过对Messag...
RocketMQ使用批量消息
目录 说明 生产端 消费端 遗留问题 说明 批量发送消息条件： 1、发送到同一个topic 2、等待同一个发送结果 3、不允许使用定时消息 4、不支持半事务特性 5、同一批消息大...
RocketMQ消息过滤
目录 说明 生产端 消费端 说明 消息过滤的两种方式：Tag和SQL表达式。 生产者：对Message设置Tag、用户属性 消费者：subscribe时指定Tag、SQL表达式 生...
RocketMQ使用事务消息
目录 说明 原理 事务消息处理流程 生产端 消费端 说明 事务消息： 1、不支持延时消息和批量消息 2、如果消息没有及时提交，默认check 15次，可以通过Broker的t...
RocketMQ Producer启动过程
目录 说明 启动过程 总结 说明 RocketMQ Producer启动过程，其实比较简单，主要是对涉及的组件初始化、启动定时任务、初始化Netty客户端等。先来看一下Produce...
