type
status
date
slug
summary
tags
category
icon
password

发送方式分类
- 同步发送:等待结果返回
- 异步发送:异步回调发送结果
- 一次发送:没有结果返回
发送消息数量
- 单条消息发送
- 批量消息发送
是否指定队列
- 随机选择发送
- 指定特定消息队列
- 自定义消息队列选择器
发送重试机制
Broker故障转移
场景分析
1.对应一个主题的消息状态变更场景,期望顺序消费,同一队列顺序消费,MessageSelector按订单hash
2.消息指定多个key
3.tag场景,对应同一个topic,按不同业务场景区分不同消费者组,指定tag
问题处理
- 同一个机器多进程
- 客户端日志处理
- 找不到topic
没有开启自动创建主题
- 消息发送超时
- pageCache性能瓶颈
transientStorePoolEnable = true 堆外内存, 消息补偿
扩容
- TIMEOUT_CLEAN_QUEUE
waitTimeMillsInSendQueue=1000