| 核心思想 | 子分类 | 服务端的框架 | 移动端的框架 |
|---|---|---|---|
| 消息传输模型 | 生产者消费者模型（Producer-Consumer） | Handler消息机制 | |
| 消息传输模型 | 发布订阅模型（Pub/Sub 或Publisher-Subscriber） | Kafka（或Jafka） | |
| 消息传输模型 | 发布订阅模型（Pub/Sub 或Publisher-Subscriber） | Redis | |
| 消息传输模型 | 发布订阅模型（Pub/Sub 或Publisher-Subscriber） | RabbitMQ | |
| 消息传输模型 | 发布订阅模型（Pub/Sub 或Publisher-Subscriber） | ZeroMQ | |
| 消息传输模型 | 发布订阅模型（Pub/Sub 或Publisher-Subscriber） | ActiveMQ |
发布订阅模型
Kafka架构图
【Kafka生产者发送消息】
- 消息路由：
a. 发送消息时如果指定了 Partition，则直接使用。
b. 如果指定了 Key，则对 Key 进行哈希，选出一个 Partition。
c. 如果都未指定，通过 Round-Robin 来选 Partition。 - 消息并不会立即发送，而是先进行序列化后，发送给 Partitioner，由 Partitioner 确定目标分区后，发送到一块内存缓冲区中（发送队列）。
- Producer 的Sender 线程则负责实时地从该缓冲区中提取出准备好的消息封装到一个批次内，统一发送到对应的 Broker 中。
RabbitMQ架构图
Radis发布订阅使用：参考这个：https://www.cnblogs.com/longjee/p/8668974.html
ZeroMQ架构图：
ZeroMQ架构图
参考：https://blog.csdn.net/flourishLi/article/details/54962713
ActiveMQ架构图：
EventBus
EventBus很像NATS（一对一，多对一）
RxJava
Dagger2
Android事件分发机制用的责任链设计模式。对比服务端Spring框架中的Filter的加载流程和执行流程就是用的责任链设计模式。参考：实际项目中运用责任链模式
生产者消费者模式解析
生产者消费者模式是通过一个容器来解决生产者和消费者的强耦合问题。生产者和消费者彼此之间不直接通讯，而通过阻塞队列来进行通讯，所以生产者生产完数据之后不用等待消费者处理，直接扔给阻塞队列，消费者不找生产者要数据，而是直接从阻塞队列里取，阻塞队列就相当于一个缓冲区，平衡了生产者和消费者的处理能力。
这个阻塞队列就是用来给生产者和消费者解耦的。纵观大多数设计模式，都会找一个第三者出来进行解耦，如工厂模式的第三者是工厂类，模板模式的第三者是模板类。
参考：https://www.jianshu.com/p/dc77009c45d2
图解：
生产消费者模型图解
生产者消费者模型简单实现（Java多线程就是一个典型的示例）
参考：https://www.jianshu.com/p/678be034abe2
总结一下：发布订阅模式大量适用于服务端架构，这种思想也逐渐在移动端的SDK以及第三方框架里面开始扩展开来，这种编程思想是很重要的，掌握了发布订阅模式的思想，其实不管是什么开发，都可以快速实现一个类似的框架，归根到底换汤不换药，只是具体的体现形式不一样而已，需要花点时间去掌握一下。
网友评论