1、对于同步消息重发2次，异步消息或者oneWay消息发送一次，对于没有发送的消息，可以暂时入库，定时去发
2、其次选择queue，对于任何一个线程而言，首次都有一个threadlocal存储一个随机数，下次在发送消息会加1，依次往所有队列里发消息
然后进行了大概的步骤
1、获得broker地址
2、设置唯一消息id
3、压缩消息
4、判断是否事务消息
5、消息hook检查
6、设置请求头、请求体
7、发送消息
8、响应结果解析
broker接收消息：
1、消息检查
2、判断queueId
3、判断是否进入死信队列
4、存储消息
5、返回结果
1、对于同步消息重发2次，异步消息或者oneWay消息发送一次，对于没有发送的消息，可以暂时入库，定时去发 2、其...
一、基础概念 Producer:消息生产者 Producer Group:消息生产者组，发送同类消息的一个消息生产...
问题：1、如何保证消息发送的高可用2、副本直接如何同步
专业术语 Producer:消息生产者，负责生产消息，一般由业务系统负债生产消息。 Consumer:消息消费者，...
专业术语 Producer消息生产者、负责生产消息、一般由业务系统负责生产消息 Consumer消息消费者、负责消...
核心概念 Topic：消息主题，一级消息类型，生产者向其发送消息。 生产者：也称为消息发布者，负责生产并发送消息至...
消息队列是生产者向消息队列发送消息，消费者从消息队列拉取（pull）消息。 生产者生产者是消息队列的数据源，可以向...
Confirm确认消息 消息确认，是指生产者消息投递后，如果Broker收到消息，则会给生产者一个应答 生产者进行...
1. 消息生产者、消息者、队列 消息生产者Producer：发送消息到消息队列。 消息消费者Consumer：从消...
消息订阅 消息生产 测试
本文标题：生产消息
本文链接：https://www.haomeiwen.com/subject/izylbqtx.html
网友评论