[MQ] MQ-01生产者和消费者从头开始
[MQ]如何实现生产者从头开始称呼消费者?
[MQ] MQ-03在经纪人中间引入了从头开始
[MQ] MQ-04启动检测和实现优化
[MQ] MQ-05-ACHIEVE典雅停止从头开始
[MQ] MQ-06-Consumer Heartbeat检测心跳从头开始
[MQ] MQ-07-负载平衡负载余额从头开始
[MQ] MQ-08-CONFIGURATION优化从头开始的优化
[MQ] MQ-09-COMEMERS绘制从头开始的消息
大家好,我是一匹老马。
让我们看一下将MQ消息的推送和拉动的两种模式。
该消息是由经纪人直接推向消费者的,这是实时更好的。
缺点是,如果消费者无法处理,它将引起很多问题。
该消息是由消费者定期从经纪人中汲取的。优势在于,它很容易实现,并且可以根据消费者自己的处理能力消费。
缺点是真正的时间性质相对较差。
在实际业务中,您需要结合特定方案以选择正确的策略。
让我们首先看一下推动策略的简化核心实现:
我们保留一种方法来促进亚行载荷。
拉动策略可以在本地放置订阅/取消订阅,以避免与服务器的交互。
我们已经重载了推动策略方法。
当应用程序启动时,定期拉动指定的时间并处理消费者处理。
其中,抽奖如下:
MQBrokersist是一个界面,该接口演示了基于数据库基于数据库的数据库的本地实现。
该原理是相似的,仅作为示范。
我们穿越了匹配的消息,并将其状态更新为中间状态。
但是这里仍然有一个关键步骤,这是消息的消息。
我们将在下一部分中实施。
消息的推动和拉动具有自己的优势和缺点,这要求我们合并自己的业务以选择。
一般来说,IM更适合新闻推动;为了削减山峰以填补山谷,一般业务更适合拉车型。
我希望本文对您有所帮助。如果您喜欢,请喜欢收藏并重新发布。
我是一匹老马,期待与您团聚。
Java中的消息队列。
rpc- rpchttps://github.com/houbb/rpc
原始:https://juejin.cn/post/70964418828505102