当前位置: 首页 > 网络应用技术

[MQ] MQ-09-COMEMERS绘制从头开始的消息

时间:2023-03-05 21:07:10 网络应用技术

  [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