wordpress前台如何删除文章,百度seo关键词排名查询,钓鱼网站盗号,专业做seo的网站目录 部署demo项目 什么是Work消息模型 实现Work消息模型 1.创建队列 2.生产者代码 3.消费者代码 4.配置yml 部署demo项目 通过消息队列demo项目进行练习 相关配置看此贴 http://t.csdnimg.cn/hPk2T 注意 生产者消费者的yml文件也要配置好 什么是Work消息模型 工作…目录 部署demo项目 什么是Work消息模型 实现Work消息模型 1.创建队列 2.生产者代码 3.消费者代码 4.配置yml 部署demo项目 通过消息队列demo项目进行练习  相关配置看此贴   http://t.csdnimg.cn/hPk2T 注意  生产者消费者的yml文件也要配置好 什么是Work消息模型 工作Work消息模型是一种基本的消息队列模型也称为任务队列模型。在工作消息模型中多个消费者workers同时监听同一个队列其中的消息将被平均分配给不同的消费者进行处理。 工作消息模型的特点包括 消息队列生产者将消息发送到一个共享的队列中。多个消费者多个消费者同时监听这个队列竞争消费消息。消息分发消息将按照一定的算法均匀地分发给不同的消费者每个消息只能被消费一次。负载均衡通过多个消费者来处理消息实现负载均衡提高系统的处理能力和效率。 在工作消息模型中消息的处理是并发的多个消费者可以同时处理不同的消息从而加快消息处理速度。然而由于消息的分发是平均的可能会导致某些消费者处理的消息比较多而其他消费者处理的消息比较少因此在实际应用中需要根据业务需求和系统性能进行合理的调整和优化。 实现Work消息模型 1.创建队列 2.生产者代码 package cn.itcast.mq.helloworld;import org.junit.jupiter.api.Test; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; import org.springframework.messaging.Message; import org.springframework.messaging.converter.StringMessageConverter;SpringBootTest public class SpringAMQPTest {Autowiredprivate RabbitTemplate rabbitTemplate;// work消息模型Testvoid testWorkQueue() throws InterruptedException {String queueName work.queue;for (int i 1; i 51; i) {String message hello, Work MQ - i;rabbitTemplate.convertAndSend(queueName,message);Thread.sleep(20);}}} 3.消费者代码 package cn.itcast.mq.lintener;import lombok.extern.slf4j.Slf4j; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component;Slf4j Component public class MQListener {RabbitListener(queues work.queue)public void listenWorkQueue1(String message) throws InterruptedException {log.info(消费者1收到了消息:........... {}, message);Thread.sleep(20); // 每秒处理 50 条消息 // System.out.println(消费者收到了消息: message);}RabbitListener(queues work.queue)public void listenWorkQueue2(String message) throws InterruptedException {log.info(消费者2收到了消息: {}, message);Thread.sleep(200); // 每秒处理 5 条消息 // System.out.println(消费者收到了消息: message);}} 4.配置yml 消费者的yml需要补充下面的配置 work消息模型是采用轮询的方式获取消息队列的消息的,如果一个服务器性能高,另一个低,性能高的就得等待性能低的读取完后才能接着读取下一个 加上这些代码就能实现能者多劳,性能高的多读取 如图 消息2读取一条 消息1已经读取了6条了 总结 Work模型的使用 多个消费者绑定到一个队列同一条消息只会被一个消费者处理 通过设置prefetch来控制消费者预取的消息数量