Java高并发--消息队列

举个例子：在购物商城下单后，希望购买者能收到短信或者邮件通知。有一种做法时在下单逻辑执行后调用短信发送的API，如果此时服务器响应较慢、短信客户端出现问题等诸多原因购买者不能正常收到短信，那么此时是不断重试呢还是直接放弃发送呢？不管选择哪一种，在实现上都会变得复杂。

消息队列是如何解决的呢？可以讲发送短信这个过程封装成一条消息，发送到消息队列，消息队列按照一定顺序依次处理队列中的消息，在某一个时刻就会处理刚才收到的发送短信的消息。消息队列会通知一个服务去发送这个短信，顺利的话这个消息刚被放进队列就会被处理，这种情况一次性就发送成功了。如果出现了什么问题，可以再次将该消息放进消息队列中等待处理。

image

上面的例子中如果使用消息队列，其好处是将发送短信这个流程与其他功能解耦，发送短信时只需要保证将这条消息发送到消息队列就行了，然后就可以处理发送短信后的其他事情了；其次，系统设计变得简单，不用在下单的场景下过多的考虑发送短信的问题，而是交给了消息队列来处理这个事。而且可以保证消息一定会被发送出去，消息只要没有发送成功会不断被重新加入到消息队列。如果短信服务出现问题，那么等到服务恢复了，消息队列再发送出去即可，只是发送的不那么及时而已。

消息队列的特性

和业务无关：只负责消息分发

FIFO：先投递先到达

容灾：得益于节点的动态增删和消息的持久化

性能：吞吐量提升，系统内部通信效率提高

什么时候需要消息队列呢？当生产和消费的速度和稳定性等因素不一致时，消息队列可以弥补双方的差异。

消息队列的好处：

业务解耦

最终一致性(两个系统的状态保持一致，要么都成功要么都失败)

广播

错峰与流控