消息传递系统-导论

向消费者通知新事件的常用方式 消息传递系统（messaging system）：Pro发送包含事件的消息，然后将消息推给Con。

像Pro和Con之间的 Unix 管道或 TCP 连接这样的直接信道，是实现消息传递系统的简单方法。但大多消息传递系统都在这一基本模型扩展。Unix管道和TCP将恰好一个发送者与恰好一个接收者连接，而一个消息传递系统允许多个Pro节点将消息发到同一主题，并允许多个Con节点接收主题的消息。在这发布 / 订阅模式中，不同系统采取各种方法，并没有针对所有目的的通用答案，区分前提：

1. 若生产者发送消息的速度＞消费者能够处理的速度，一般有三种选择：系统丢掉消息，将消息放入缓冲队列，或使用背压（backpressure，也称流量控制flow control：阻塞生产者，以免其发送更多的消息）。Unix 管道和 TCP 使用背压：它们有一个固定大小的小缓冲区，如填满，发送者会被阻塞，直到接收者从缓冲区中取出数据。

   如消息被缓存在队列，当队列装不进内存时系统会崩溃吗？还是将消息写盘？如这样，磁盘访问又会如何影响消息传递系统的性能？

2. 如节点崩溃或暂时脱机，是否会有消息丢失？与数据库一样，持久性可能需写入磁盘和 / 或复制的某种组合，这有代价。如果你能接受有时消息会丢失，则可能在同一硬件上获得更高吞吐量、更低延迟。