标签：lin 不同 组件 asc scala 很多 filter 模块 ref
你在系统中是否写过这样的接口：客户端访问服务器，服务器进行了大量逻辑/耗时操作之后，才能将结果返回给客户端，而这时，客户端的连接或许已经因为超时而关闭了。
为了能够及时的给客户端返回数据， 在项目中，将一些无需即时返回且耗时的操作提取出来，进行了异步处理，而这种异步处理的方式大大的节省了服务器的请求响应时间，从而提高了系统的吞吐量。
RabbitMQ 是一个在 AMQP 基础上完成的，可复用的企业消息系统。RabbitMQ 用 Erlang 语言编写，支持多种消息协议，消息队列，传送确认，可以将消息灵活的路由到队列，并支持多种交换类型。同时也可部署为负载均衡的集群，实现高可用性和吞吐量，联跨多个可用性区域和地区。RabbitMQ 支持 Java, .NET, PHP, Python, JavaScript, Ruby, Go 等多种语言，方便开发者使用。
言归正传。RabbitMQ，或者说AMQP解决了什么问题，或者说它的应用场景是什么？
对于一个大型的软件系统来说，它会有很多的组件或者说模块或者说子系统或者（subsystem or Component or submodule）。那么这些模块的如何通信？这和传统的IPC有很大的区别。传统的IPC很多都是在单一系统上的，模块耦合性很大，不适合扩展（Scalability）；如果使用socket那么不同的模块的确可以部署到不同的机器上，但是还是有很多问题需要解决。比如：
1）信息的发送者和接收者如何维持这个连接，如果一方的连接中断，这期间的数据如何方式丢失？
2）如何降低发送者和接收者的耦合度？
3）如何让Priority高的接收者先接到数据？
4）如何做到load balance？有效均衡接收者的负载？
5）如何有效的将数据发送到相关的接收者？也就是说将接收者subscribe 不同的数据，如何做有效的filter。
6）如何做到可扩展，甚至将这个通信模块发到cluster上？
7）如何保证接收者接收到了完整，正确的数据？
AMDQ协议解决了以上的问题，而RabbitMQ实现了AMQP。
标签：lin 不同 组件 asc scala 很多 filter 模块 ref
原文地址：https://www.cnblogs.com/Regina-wisdom/p/9414226.html
