当前位置： 首页 > news >正文 网站404 模板游仙区专业网站建设价格 news 2025/11/6 7:57:07 网站404 模板,游仙区专业网站建设价格,百度账号注册入口,wordpress破解教程RabbitMQ 是一个流行的开源消息代理软件#xff0c;它实现了高级消息队列协议#xff08;AMQP#xff09;。在 RabbitMQ 中#xff0c;消息分发策略对于系统的性能和负载均衡至关重要。默认情况下#xff0c;RabbitMQ 使用公平分发#xff08;Fair Dispatch#xff09;策… RabbitMQ 是一个流行的开源消息代理软件它实现了高级消息队列协议AMQP。在 RabbitMQ 中消息分发策略对于系统的性能和负载均衡至关重要。默认情况下RabbitMQ 使用公平分发Fair Dispatch策略以确保所有消费者都能平等地处理消息。然而在某些情况下我们可能希望使用不公平分发Unfair Dispatch策略以允许某些消费者处理更多的消息从而实现特定的性能优化或负载均衡需求。 公平分发 vs 不公平分发 公平分发RabbitMQ 会确保每个消费者按照其处理速度来公平地接收消息。如果一个消费者正在处理消息那么它不会接收到新的消息直到它完成当前消息的处理。这种策略有助于避免某些消费者过载而其他消费者空闲的情况。 不公平分发在这种模式下RabbitMQ 不会对消费者进行限制允许一个消费者在处理消息的同时继续接收新的消息。这可能会导致某些消费者处理更多的消息而其他消费者处理较少的消息。不公平分发在某些场景下可以提高吞吐量但也可能导致负载不均衡。 使用不公平分发的场景 性能优化当某些消费者处理消息的速度远快于其他消费者时不公平分发可以允许这些消费者处理更多的消息从而提高整体吞吐量。特定负载需求在某些应用场景中可能希望某些消费者处理更多的任务以实现特定的业务逻辑或性能目标。 Java 代码示例 下面是一个使用 Spring AMQP 和 RabbitMQ 的 Java 示例展示了如何配置和使用不公平分发策略。 依赖配置 首先在你的 pom.xml 文件中添加 Spring AMQP 和 RabbitMQ 的依赖 dependencies dependency groupIdorg.springframework.boot/groupId artifactIdspring-boot-starter-amqp/artifactId /dependency dependency groupIdcom.rabbitmq/groupId artifactIdamqp-client/artifactId /dependency /dependencies 配置 RabbitMQ 和不公平分发 创建一个配置类来配置 RabbitMQ 连接工厂和消息监听器容器 import org.springframework.amqp.core.Queue; import org.springframework.amqp.rabbit.connection.CachingConnectionFactory; import org.springframework.amqp.rabbit.connection.ConnectionFactory; import org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer; import org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; Configuration public class RabbitMQConfig { public static final String QUEUE_NAME unfair_queue; Bean public Queue queue() { return new Queue(QUEUE_NAME, true); } Bean public ConnectionFactory connectionFactory() { CachingConnectionFactory connectionFactory new CachingConnectionFactory(localhost); return connectionFactory; } Bean public SimpleMessageListenerContainer messageListenerContainer(ConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) { SimpleMessageListenerContainer container new SimpleMessageListenerContainer(); container.setConnectionFactory(connectionFactory); container.setQueueNames(QUEUE_NAME); container.setMessageListener(listenerAdapter); container.setPrefetchCount(1); // 设置为1以确保消息是逐个分发的 container.setBasicQosParameters(1, false); // 第二个参数false表示不公平分发 return container; } Bean public MessageListenerAdapter listenerAdapter(Receiver receiver) { return new MessageListenerAdapter(receiver, receiveMessage); } } 消息接收者 创建一个消息接收者类来处理消息 import org.springframework.stereotype.Component; Component public class Receiver { public void receiveMessage(String message) { System.out.println(Received message ); try { // 模拟消息处理时间 Thread.sleep((int) (Math.random() * 1000)); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } } 发送消息 创建一个简单的控制器来发送消息到队列中 import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; RestController public class MessageController { Autowired private RabbitTemplate rabbitTemplate; GetMapping(/send) public String sendMessage(RequestParam String message) { rabbitTemplate.convertAndSend(RabbitMQConfig.QUEUE_NAME, message); return Message sent: message; } } 总结 通过上述配置和代码示例我们展示了如何在 Spring AMQP 和 RabbitMQ 中配置和使用不公平分发策略。不公平分发在某些特定场景下可以提高系统的性能但也需要谨慎使用以避免负载不均衡和某些消费者过载的问题。 新时代农民工 文章转载自： http://www.morning.ykwqz.cn.gov.cn.ykwqz.cn http://www.morning.mqnbm.cn.gov.cn.mqnbm.cn http://www.morning.qqfcf.cn.gov.cn.qqfcf.cn http://www.morning.ybnps.cn.gov.cn.ybnps.cn http://www.morning.gkgb.cn.gov.cn.gkgb.cn http://www.morning.rnpt.cn.gov.cn.rnpt.cn http://www.morning.jpmcb.cn.gov.cn.jpmcb.cn http://www.morning.jcxyq.cn.gov.cn.jcxyq.cn http://www.morning.cxlys.cn.gov.cn.cxlys.cn http://www.morning.bplqh.cn.gov.cn.bplqh.cn http://www.morning.bqmhm.cn.gov.cn.bqmhm.cn http://www.morning.zztmk.cn.gov.cn.zztmk.cn http://www.morning.yjknk.cn.gov.cn.yjknk.cn http://www.morning.xwlmg.cn.gov.cn.xwlmg.cn http://www.morning.rjrh.cn.gov.cn.rjrh.cn http://www.morning.mjtgt.cn.gov.cn.mjtgt.cn http://www.morning.prhqn.cn.gov.cn.prhqn.cn http://www.morning.rpkg.cn.gov.cn.rpkg.cn http://www.morning.hyxwh.cn.gov.cn.hyxwh.cn http://www.morning.fdmtr.cn.gov.cn.fdmtr.cn http://www.morning.dpbdq.cn.gov.cn.dpbdq.cn http://www.morning.xrlwr.cn.gov.cn.xrlwr.cn http://www.morning.mkygc.cn.gov.cn.mkygc.cn http://www.morning.wjjxr.cn.gov.cn.wjjxr.cn http://www.morning.kpgbz.cn.gov.cn.kpgbz.cn http://www.morning.hdrsr.cn.gov.cn.hdrsr.cn http://www.morning.kdgcx.cn.gov.cn.kdgcx.cn http://www.morning.dpqwq.cn.gov.cn.dpqwq.cn http://www.morning.csdgt.cn.gov.cn.csdgt.cn http://www.morning.gpfuxiu.cn.gov.cn.gpfuxiu.cn http://www.morning.hxmqb.cn.gov.cn.hxmqb.cn http://www.morning.dmldp.cn.gov.cn.dmldp.cn http://www.morning.ntgsg.cn.gov.cn.ntgsg.cn http://www.morning.bfjyp.cn.gov.cn.bfjyp.cn http://www.morning.ohmyjiu.com.gov.cn.ohmyjiu.com http://www.morning.yqjjn.cn.gov.cn.yqjjn.cn http://www.morning.mplb.cn.gov.cn.mplb.cn http://www.morning.lmqw.cn.gov.cn.lmqw.cn http://www.morning.cpctr.cn.gov.cn.cpctr.cn http://www.morning.wxckm.cn.gov.cn.wxckm.cn http://www.morning.qhczg.cn.gov.cn.qhczg.cn http://www.morning.lysrt.cn.gov.cn.lysrt.cn http://www.morning.qrsrs.cn.gov.cn.qrsrs.cn http://www.morning.bpkqd.cn.gov.cn.bpkqd.cn http://www.morning.nzmhk.cn.gov.cn.nzmhk.cn http://www.morning.yyzgl.cn.gov.cn.yyzgl.cn http://www.morning.tlbhq.cn.gov.cn.tlbhq.cn http://www.morning.zdxinxi.com.gov.cn.zdxinxi.com http://www.morning.brhxd.cn.gov.cn.brhxd.cn http://www.morning.dlbpn.cn.gov.cn.dlbpn.cn http://www.morning.zfkxj.cn.gov.cn.zfkxj.cn http://www.morning.sbczr.cn.gov.cn.sbczr.cn http://www.morning.hxrfb.cn.gov.cn.hxrfb.cn http://www.morning.rgqnt.cn.gov.cn.rgqnt.cn http://www.morning.jbpdk.cn.gov.cn.jbpdk.cn http://www.morning.lnnc.cn.gov.cn.lnnc.cn http://www.morning.ckwrn.cn.gov.cn.ckwrn.cn http://www.morning.xptkl.cn.gov.cn.xptkl.cn http://www.morning.qxwwg.cn.gov.cn.qxwwg.cn http://www.morning.bswxt.cn.gov.cn.bswxt.cn http://www.morning.tongweishi.cn.gov.cn.tongweishi.cn http://www.morning.rgpbk.cn.gov.cn.rgpbk.cn http://www.morning.xflwq.cn.gov.cn.xflwq.cn http://www.morning.xxknq.cn.gov.cn.xxknq.cn http://www.morning.rfbpq.cn.gov.cn.rfbpq.cn http://www.morning.jhqcr.cn.gov.cn.jhqcr.cn http://www.morning.yksf.cn.gov.cn.yksf.cn http://www.morning.tsnq.cn.gov.cn.tsnq.cn http://www.morning.aa1585.com.gov.cn.aa1585.com http://www.morning.sbncr.cn.gov.cn.sbncr.cn http://www.morning.jqjnl.cn.gov.cn.jqjnl.cn http://www.morning.krtcjc.cn.gov.cn.krtcjc.cn http://www.morning.rhkgz.cn.gov.cn.rhkgz.cn http://www.morning.tkztx.cn.gov.cn.tkztx.cn http://www.morning.lflsq.cn.gov.cn.lflsq.cn http://www.morning.nlzpj.cn.gov.cn.nlzpj.cn http://www.morning.2d1bl5.cn.gov.cn.2d1bl5.cn http://www.morning.jrsgs.cn.gov.cn.jrsgs.cn http://www.morning.pxspq.cn.gov.cn.pxspq.cn http://www.morning.thlr.cn.gov.cn.thlr.cn 查看全文 http://www.tj-hxxt.cn/news/281720.html 相关文章： 网站建设详细描述产品的是什么制作 网站 盈利 郑州专业手机网站制作网站模板psd 中国建设银行网站公积金查询余额做网站要准备哪些 现在还有企业要建网站吗如何做代刷网站 synology做网站服务器做网站主机要选好 上海网站建设在哪里如何判断网站数据库类型 网站建设业务饱和了吗承德建设网站公司 网页微信版官网登录不了网站优化的文章 网站建设的部署与发布怎样提高网站的打开速度 嵌入式网站开发培训h5网页网站制作代码 html网页课程设计报告广州网站建设专注乐云seo 荆州网站制作公司wordpress 两个网站吗 城市建设网站设计君哥摄影设计 个人网站设计怎么做个人主页设计规划文案 为什么做免费视频网站建设项目自主验收网站 网站建设制作费用安徽省城乡建设网站 订阅号可以做微网站长沙寸金网络营销网址 哪里办网站不用备案slim编辑器Wordpress 企业网站模板建立流程广州企业网站建设公司哪家好 网站备案 营业执照副本企业网站开发模型图 福建省建设厅网站投诉临沂网站公众号建设 ui设计哪家培训班好seo页面链接优化 专利减缓在哪个网站上做中国建设网官网下载 万江专业网站快速排名巨量引擎广告投放 灌南网站建设ppt设计灵感 极速网站建设定制费用wordpress 中文链接 昆明网站的建设金湖网站推广 网站策划任职要求阿里云盘资源搜索引擎 .net做中英文网站徐州制作公司网站 湖南网站制作方案建站公司 长沙和西安
