SpringBoot中使用RabbitMQ消息中间件

叁歲伎倆 2022-04-04 05:54 365阅读 0赞

## 一、创建SpringBoot工程并配置RabbitMQ ##

###### 1、创建SpringBoot工程，选择RabbitMQ ######

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 1]

###### 2、在application.properties文件中配置RabbitMQ ######

//RabbitMQ的url
    spring.rabbitmq.addresses=192.168.1.108
    
    //用户名和密码，默认为guest
    spring.rabbitmq.username=guest
    spring.rabbitmq.password=guest

RabbitProperties代码中片段  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 2]

## 二、测试RabbitMQ ##

###### 1、向RabbitMQ发送Map类型消息 ######

@RunWith(SpringRunner.class)
    	@SpringBootTest
    	public class SpringbootDataAmqpApplicationTests { 
    
    		@Autowired
    		RabbitTemplate rabbitTemplate;
    	
    		@Test
    		public void contextLoads() { 
    			Map<String,Object> map = new HashMap<>();
    			map.put("msg","the first message from springboot");
    			map.put("data","来自SpringBoot");
    			向交换器exchange.direct中路由键为scorpios，发送Map类型消息
    			rabbitTemplate.convertAndSend("exchange.direct","scorpios",map);
    		}
    	}

web控制台测试结果：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 3]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 4]

接收消息，看看消息的内容：

//接收数据，如何将数据自动的转为json发送出去
    	    @Test
    	    public void receive(){ 
    	
    	        Object o = rabbitTemplate.receiveAndConvert("scorpios");
    	        System.out.println(o.getClass());
    	        System.out.println(o);
    	
    	    }

测试结果为正确消息内容：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 5]

在使用RabbitMQ发送消息时，默认会将对象序列化之后发出，所以看到上面类似乱码后的结果。但如何让数据自动转为Json，然后发送出去呢？我们需要改变默认的MessageConverter类型，默认使用的是：SimpleMessageConverter  
下面是RabbitTemplate类的代码片段：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 6]

###### 自定义配置MessageConverter ######

@Configuration
    	public class MyAMQPConfig { 
    	
    	    @Bean
    	    public MessageConverter messageConverter(){ 
    	    //使用Jackson2JsonMessageConverter类型的MessageConverter
    	       return new Jackson2JsonMessageConverter();
    	    }
    	}

重新运行上述发送消息的测试代码,，结果如下：

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 7]  
![在这里插入图片描述][2018121514273978.png]

###### 2、向RabbitMQ发送自定义类型（MyBook）消息 ######

@RunWith(SpringRunner.class)
    	@SpringBootTest
    	public class SpringbootDataAmqpApplicationTests { 
    
    		@Autowired
    		RabbitTemplate rabbitTemplate;
    	
    		@Test
    		public void contextLoads() { 
    		//向交换器exchange.direct中路由键为scorpios，发送MyBook类型消息
    			rabbitTemplate.convertAndSend("exchange.direct","scorpios",new MyBook("西游记","吴承恩"));
    		}
    	}

web控制台测试结果：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 8]

## 三、消费消息 ##

对于RabbitMQ队列中有消息后，我们希望立刻消费消息。比如在订单系统有消息后，库存系统就应该立即接收消息，并消费消息，把库存信息及时更新。下面来模拟消费消息的情况。

###### 1、让项目开启EnableRabbit ######

@EnableRabbit		//开启EnableRabbit
    	@SpringBootApplication
    	public class SpringbootDataAmqpApplication { 
    	
    	    public static void main(String[] args) { 
    	        SpringApplication.run(SpringbootDataAmqpApplication.class, args);
    	    }
    	
    	}

###### 2、在服务方法上添加@RabbitListener注解，并标明接收哪个队列消息 ######

@Service
    	public class bookService { 
    	
    		//接收队列scorpios的消息，并消费它
    	    @RabbitListener(queues = "scorpios")
    	    public void receiveMessage(MyBook myBook){ 
    	        System.out.println("收到消息为："+myBook);
    	    }
    	}

###### 3、测试：先发送消息，看看bookService服务能不能及时消费该消息 ######

点击运行测试发送消息的代码后，可以发现bookService服务立刻消费了该消息

![在这里插入图片描述][20181215143841828.png]

## 四、在SpringBoot中代码创建Exchange和Queue ##

在上面的所有例子中，exchange.direct和scorpios都是之前在RabbitMQ的web页面中创建的，下面我们在SpringBoot中用代码来创建exchange和queue。需要使用到RabbitAdmin类

###### 1、创建exchange ######

@RunWith(SpringRunner.class)
    	@SpringBootTest
    	public class SpringbootDataAmqpApplicationTests { 
    	
    	    @Autowired
    	    RabbitAdmin rabbitAdmin;
    	
    	    @Test
    	    public void createExchange(){ 
    			//使用RabbitAdmin来创建RabbitAdmin.exchange交换器
    	        rabbitAdmin.declareExchange(new DirectExchange("RabbitAdmin.exchange"));
    	        System.out.println("创建完成");
    	    }
    	}

运行上述代码，结果：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 9]

###### 2、创建Queue ######

@RunWith(SpringRunner.class)
    	@SpringBootTest
    	public class SpringbootDataAmqpApplicationTests { 
    	
    	    @Autowired
    	    RabbitAdmin rabbitAdmin;
    	
    	    @Test
    	    public void createExchange(){ 
    			//使用RabbitAdmin来创建RabbitAdmin.queue队列
    	        rabbitAdmin.declareQueue(new Queue("RabbitAdmin.queue",true));
    	        System.out.println("创建完成");
    	    }
    	}

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 10]

###### 3、exchange和队列绑定 ######

@RunWith(SpringRunner.class)
    	@SpringBootTest
    	public class SpringbootDataAmqpApplicationTests { 
    	
    	    @Autowired
    	    RabbitAdmin rabbitAdmin;
    	
    	    @Test
    	    public void createExchange(){ 
    			//将RabbitAdmin.exchange和RabbitAdmin.queue绑定，路由键为：RabbitAdmin.key
    	        rabbitAdmin.declareBinding(new Binding("RabbitAdmin.queue", 
    	        		Binding.DestinationType.QUEUE,"RabbitAdmin.exchange","RabbitAdmin.key",null));
    	    }
    	}

绑定前  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 11]  
绑定后：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 12]

## 五、小结 ##

本文在SpringBoot中整合了RabbitMQ，并给出了如何发送消息和修改消息默认的序列化规则。  
模拟了bookService消费消息的场景，最后使用RabbitAdmin来创建exchange和queue。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70]: /images/20220404/8f24271ea13d4007a2c7d4be9cf137dc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 1]: /images/20220404/51e1f2dd643e4b37a66a31c8aeac7e7d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 2]: /images/20220404/123cafc1692a4e17a24ce30a8800561d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 3]: /images/20220404/0eb3bffb514640f7b505579f69dc2c78.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 4]: /images/20220404/4a70c19486ed457f9698fbcc39bd99ed.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 5]: /images/20220404/9687e840946c407c868fdfd4e576495e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 6]: /images/20220404/523faaaaaa2a424fa5a33559fb5a0af8.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 7]: /images/20220404/e036691dec724dabb8aaa5fb419f0aef.png
[2018121514273978.png]: /images/20220404/6d8b483b4d784758bdeb2052c74f16a5.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 8]: /images/20220404/8da5ea5d9fbe448fa2d4e89c8baf2412.png
[20181215143841828.png]: /images/20220404/1cf76ed56b184b0191bf12f006fc617b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 9]: /images/20220404/b6fbb1726ac74918a967d78b0395f1e2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 10]: /images/20220404/3acf784da16546a1b837700be50dc811.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 11]: /images/20220404/c89fbfadbd3043f9aa26a4f66cfbe1c7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3p4ZDE0MzU1MTM3NzU_size_16_color_FFFFFF_t_70 12]: /images/20220404/b60139b23c3e482a8aad94e1802d2e1c.png