[MQ] MQ-01生产者和消费者从头开始
[MQ]如何实现生产者从头开始称呼消费者?
[MQ] MQ-03在经纪人中间引入了从头开始
[MQ] MQ-04启动检测和实现优化
[MQ] MQ-05-ACHIEVE典雅停止从头开始
[MQ] MQ-06-Consumer Heartbeat检测心跳从头开始
[MQ] MQ-07-负载平衡负载余额从头开始
大家好,我是一匹老马。
本节使我们能够查看如何实现MQ的负载平衡。
为什么我需要负载平衡?
负载平衡的核心作用:
(1)可以避免单点故障
(2)您可以将平均请求分散到每个节点
实施负载平衡的方法有很多。最简单的是选择一个随机。
扩展阅读:
从零手载荷平衡http://houpb.github.io/2020/06/19/load-balance-03 hand-write
当制作人发送消息时,可以将其发送给Ren Yi经纪人。
收到消息后,收到消息后,您也可以在推向消费者时选择一条消息。
消费消费者消耗后,将向国家提供经纪人,您可以选择其中任何一个。
一些新闻很特别。例如,如果您需要确保消费顺序,则可以通过Shardingkey的方法将其修复到指定区域。
统一调整获得通道的方法。
该工具类被实现为核心实现:
如果指定了Shardingkey,则根据Shadringkey对哈希进行判断。
如果没有,则执行默认负载平衡策略。
消费者订阅列表采集:
核心逻辑:获取,其他遗体保持不变。
消费者也很相似。
负载平衡是分布式服务的基本特征之一。实施原则并不复杂。
我希望本文对您有所帮助。如果您喜欢,请喜欢收藏并重新发布。
我是一匹老马,期待与您团聚。
Java中的消息队列。
rpc- rpchttps://github.com/houbb/rpc
原始:https://juejin.cn/post/7095225769172926495