

首页  思维导图  详情



消息组件

2022-06-17 15:51:03   16  举报





AI智能生成

如何封装消息组件大纲

架构图

RocketMQ

系统架构图

模版推荐

作者其他创作

大纲/内容

解决消息重发的问题

为什么消息重发

Producer在发送消息时比如遇到网络问题时，发送后因超时得不到服务器的ack,从而进行重发

RocketMQ对于消费时一直无法消费的消息，超过一定重试次数后，会将消息写入私信队列，避免分区被卡住。

如何解决

利用redis给消息分配一个全局id，

建立一个消息表，consumer消费之前，拿到消息做insert操作，用消息id做唯一主键，重复消费会导致主键冲突，携程的QMQ实现方式

消费端处理消息的业务逻辑保持幂等性

MQTT协议给出服务质量标准

Kafka At least once<br>RocketMQ At least once<br>RabbitMQ At least once<br>

Exactly once：恰好一次。消息在传递时，只会被送达一次，不允许丢失也不允许重复，这个是最高的等级。

At least once: 至少一次。消息在传递时，至少会被送达一次。也就是说，不允许丢消息，但是允许有少量重复消息出现。

At most once: 至多一次。消息在传递时，最多会被送达一次。换一个说法就是，没什么消息可靠性保证，允许丢消息。一般都是一些对消息可靠性要求不太高的监控场景使用，比如每分钟上报一次机房温度数据，可以接受数据少量丢失。

组件能做什么

消息队列本身不能处理和避免重复消费的情况

强制增加约束会导致整体组件特别臃肿

消息顺序

参考：RocketMQ通过轮询所有队列的方式来确定消息被发送到哪一个队列（负载均衡策略），在获取到路由信息以后，会根据MessageQueueSelector实现的算法来选择一个队列，同一个OrderId获取到的肯定是同一个队列。

组件能做什么

1、约定一个新的路由规则和约定一个参数，作为一个ID，消费，生产消息时方法均以代理对象的方式注册到容器，然后增强方法，走自己自定义的路由去选择队列来，来保证顺序（总结一句话，统一放入一个queue中，队列本身就是有顺序的）

2、增加消息版本号的概念，根据版本号和消息ID，可以确定顺序，但消费非首条消息时需要消费方重试

消息组件解决最终一致性的问题

建议用seata ，因为万一消息消息一直失败，需要自己从死信队列中人工重试

消息监听

埋点

监控

消息重试<br>

rocketMq若配置了重试规则，则引用，若非rocketMq,则默认建立一个重试队列，模仿rocketMq重试

消息区分

消息发送

Producer轮询某topic下的所有队列的方式来实现发送方的负载均衡，基本都以roundbin的方式

消息消费

怎么去兼容，怎么去区分

 Collect

Get Started

消息服务统一平台

 Collect

Get Started

配置消息

 Collect

Get Started

组件化|模块化CICD

 Collect

Get Started

后端组件





0 条评论

下一页