..

分布式消息

问题

如何保证消息不丢失?

• 发送方是否需要等待确认？
• 消息是否落盘持久化？
• 消息是否多副本？
• 消息消费的业务异常如何处理？

如何处理重复消息？

• 消息消费的业务异常如何处理？

如何保证消息的有序性？

• 有序性与扩展性可能存在冲突？

如何处理消息堆积？

• 允许堆积多少？

场景

• 异步处理

• 服务解耦

• 流量控制

两种模型

• 队列模型

• 发布/订阅模型

如何打造可以无限扩展的分布式消息队列