RabbitMq七种工作模式，结合简单的java实例使用，别再说你不会( 二 ) _RabbitMq

2、工作队列工作队列也就是简单模式的强化版，一个队列是可以多个生产者，也可以有多个消费者来竞争消费消息，但是我们仍需保证队列的幂等性，队列存在就不能再创建同名队列。

文章插图

下面的每个进程都控制其主线程休眠，让我们可以更好的看到结果。
2.1.1、Sender1.java

import com.rabbitmq.client.Channel;import com.rabbitmq.client.Connection;import top.san.RabbitMq.util.RabbitmqConnectionUtil;import java.io.IOException;public class Sender1 {private finalstatic String QUEUE_NAME = "queue_work";public static void main(String[] args) throws IOException, InterruptedException {Connection connection = RabbitmqConnectionUtil.getConnection();Channel channel = connection.createChannel();channel.queueDeclare(QUEUE_NAME, false, false, false, null);for(int i = 0; i < 100; i++){String message = "lbw" + i;channel.basicPublish("", QUEUE_NAME, null, message.getBytes());System.out.println("[x] Sent '"+message + "'");Thread.sleep(i*10);}channel.close();connection.close();}}

2.1.2、Sender2.java

import com.rabbitmq.client.Channel;import com.rabbitmq.client.Connection;import top.san.RabbitMq.util.RabbitmqConnectionUtil;import java.io.IOException;public class Sender2 {private finalstatic String QUEUE_NAME = "queue_work";public static void main(String[] args) throws IOException, InterruptedException {Connection connection = RabbitmqConnectionUtil.getConnection();Channel channel = connection.createChannel();channel.queueDeclare(QUEUE_NAME, false, false, false, null);for(int i = 0; i < 100; i++){String message = "nb" + i;channel.basicPublish("", QUEUE_NAME, null, message.getBytes());System.out.println("[x] Sent '"+message + "'");Thread.sleep(i*10);}channel.close();connection.close();}}

2.1.3、Receiver1.java

import com.rabbitmq.client.Channel;import com.rabbitmq.client.Connection;import com.rabbitmq.client.QueueingConsumer;import top.san.RabbitMq.util.RabbitmqConnectionUtil;import java.io.IOException;/** * Created by san */public class Receiver1 {private final staticString QUEUE_NAME = "queue_work";public static void main(String[] args) throws IOException, InterruptedException {Connection connection = RabbitmqConnectionUtil.getConnection();Channel channel = connection.createChannel();channel.queueDeclare(QUEUE_NAME, false,false, false,null);//同一时刻服务器只会发送一条消息给消费者channel.basicQos(1);QueueingConsumer consumer = new QueueingConsumer(channel);//关于手工确认 待之后有时间研究下channel.basicConsume(QUEUE_NAME, false, consumer);while(true){QueueingConsumer.Delivery delivery = consumer.nextDelivery();String message = new String(delivery.getBody());System.out.println("[x] Received1 '"+message+"'");Thread.sleep(10);//返回确认状态channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);}}}

2.1.4、Receiver2.java

import com.rabbitmq.client.Channel;import com.rabbitmq.client.Connection;import com.rabbitmq.client.QueueingConsumer;import top.san.RabbitMq.util.RabbitmqConnectionUtil;import java.io.IOException;/** * Created by san */public class Receiver2 {private final staticString QUEUE_NAME = "queue_work";public static void main(String[] args) throws IOException, InterruptedException {Connection connection = RabbitmqConnectionUtil.getConnection();Channel channel = connection.createChannel();channel.queueDeclare(QUEUE_NAME, false,false, false,null);//同一时刻服务器只会发送一条消息给消费者channel.basicQos(1);QueueingConsumer consumer = new QueueingConsumer(channel);channel.basicConsume(QUEUE_NAME, false, consumer);while(true){QueueingConsumer.Delivery delivery = consumer.nextDelivery();String message = new String(delivery.getBody());System.out.println("[x] Received2 '"+message+"'");Thread.sleep(1000);//返回确认状态channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);}}}

2.1.5、结果上面的四个程序都运行起来，结果可以看到如下，依据结果分析，可知，同一个消息队列，是可以有多个生产者和消费者的。

文章插图

文章插图

3、发布/订阅（fanout）

文章插图

3.1.1、Sender.java

import com.rabbitmq.client.Channel;import com.rabbitmq.client.Connection;import com.rabbitmq.client.ConnectionFactory;import top.san.RabbitMq.util.RabbitmqConnectionUtil;public class Sender {private final static String EXCHANGE_NAME = "test_exchange_fanout";public static void main(String[] args){try{//获取连接Connection connection = RabbitmqConnectionUtil.getConnection();//从连接中获取一个通道Channel channel = connection.createChannel();//声明交换机（分发:发布/订阅模式）channel.exchangeDeclare(EXCHANGE_NAME, "fanout");//发送消息for (int i = 0; i < 5; i++){String message = "卢本伟广场" + i;System.out.println("[send]：" + message);//发送消息channel.basicPublish(EXCHANGE_NAME, "", null, message.getBytes("utf-8"));Thread.sleep(5 * i);}channel.close();connection.close();}catch (Exception e){e.printStackTrace();}}}
上一页
1
2
3
4
5
下一页
		  	





























推荐阅读

           
                  
              
                  上观新闻|首次跌破20℃，今天是今年下半年以来最冷一天，这场雨什么时候才会停？ 
                
                   
                
              
            

                  
              
                  李贺的资料简介100字 李贺的资料 
                
                   
                
              
            

                  
              
                  TVB|万绮雯：错过甄子丹，嫁陈十三20年，50岁仍是”马小玲“模样 
                
                   
                
              
            

                  
              
                  『快科技』AMD RX 6000系列旗舰级显卡曝光：别太当真 
                
                   
                
              
            

                  
              
                  lck|IG肉鸡解说s赛，评价两个赛区差别时，LCK解说的脸色不好看了 
                
                   
                
              
            

                  
              
                  |此人是彻头彻尾的民族败类, 但现在某些人却在竭尽所能地美化他! 
                
                   
                
              
            

                  
              
                  体坛焦点但我们都会慢慢适应的，托马斯：对和队友保持距离训练不习惯 
                
                   
                
              
            

                  
              
                  金属加工|在线测量技术在标准动车组构架加工中的开发应用 
                
                   
                
              
            

                  
              
                  适应生活|只有短短的三句，读完不禁黯然，李白生前最后一首诗 
                
                   
                
              
            

                  
              
                  孕妈咪育儿经罪魁祸首并非糖果，而是父母的不当回事，三岁孩子满嘴“鲨鱼牙” 
                
                   
                
              
            

                  
              
                  去黄山看日出旅游攻略和注意事项 
                
                   
                
              
            

                  
              
                  教你葡萄酒在家做，酸酸甜甜 家酿葡萄酒 
                
                   
                
              
            

                  
              
                  「湖北」最新！湖北新增确诊570例，湖北以外地区新增3例 
                
                   
                
              
            

                  
              
                   爷青|【爷青回】静安公安“我型我秀”，等你来SHOW 
                
                   
                
              
            

                  
              
                  O科技|高通与中国伙伴合力推动5G万物互联，手机、XR、机器人只是开始 
                
                   
                
              
            

                  
              
                  最新项目融资需求分析模板 融资需求怎么写范本 
                
                   
                
              
            

                  
              
                  金融|中国平安：每年15%至20%的新增金融客户来自医疗生态圈 
                
                   
                
              
            

                  
              
                  珠宝|求婚戒指戴哪只手指？8个有关钻石戒指的迷思 
                
                   
                
              
            

                  
              
                  闹大了！西安取消多场演唱会，刘若英张杰受牵连，TF组合被骂惨 
                
                   
                
              
            

                  
              
                  沈腾|曝沈腾已停工赶赴日本做恢复治疗，妻子王琦深夜与友人聚餐！ 
                
                   
                
              
            

          

计算机专业学什么语言好找工作？ 

残疾人|本科没拿到学位证对以后找工作有多大影响？ 

鲜虾萝卜饼的做法 

没有工作的一年|《没有工作的一年》赚钱还是躺平？小雨租房也乐观，却源于这一点 

招聘|考研究生反而不好找工作，日本人这点很认真，大家觉得应该学吗？ 

教师|想上岸入编找到理想工作，该如何选择单位？随我一起来看看吧！ 

犀角化毒丸怎么样 

戴尔Precision 5750移动工作站深度测试 

教你快速清除Excel工作表保护密码 

excel批量拆分工作簿，用VBA一键拆分，把数据分解到N个工作簿