SpringBoot整合RabbitMQ

流程图概括

1.引入依靠

2. <dependency>
3.        <groupId>org.springframework.boot</groupId>
4.        <artifactId>spring-boot-starter-amqp</artifactId>
5. </dependency>

复制代码

2. 设置RabbitMQ毗连

在application.properties或application.yml中设置RabbitMQ服务器的毗连参数：

3.DirectExchange 直连型交换机

3.1消耗者

2. @Configuration
3. public class DirectConsumer {
4.     //注册一个队列
5.     @Bean  //启动多次为什么不报错？启动的时候，它会根据这个名称Direct_Q01先去查找有没有这个队列，如果有什么都不做，如果没有创建一个新的
6.     public Queue queue(){
7.       return   QueueBuilder.durable("Direct_Q01").maxLength(100).build();
8.     }
9.     //注册交换机
10.     @Bean
11.     public DirectExchange exchange(){
12.         //1.启动的时候，它会根据这个名称Direct_E01先去查找有没有这个交换机，如果有什么都不做，如果没有创建一个新的
13.         return  ExchangeBuilder.directExchange("Direct_E01").build();
14.     }
15.     //绑定交换机与队列关系
16.     @Bean
17.     public Binding binding(Queue queue,DirectExchange exchange){
18.         return BindingBuilder.bind(queue).to(exchange).with("RK01");
19.     }
20.     //启动一个消费者
21.     @RabbitListener(queues = "Direct_Q01")
22.     public void receiveMessage(String msg){
23.         System.out.println("收到消息："+msg);
24.     }
27. }

复制代码

3.2生产者

2. @Service
3. public class DirectProvider {
5.     @Autowired
6.     private RabbitTemplate rabbitTemplate;
8.     public void send(Object message) {
9.         rabbitTemplate.convertAndSend("Direct_E01", "RK01", message);
10.     }
11. }

复制代码

3.3 一个交换机对多个队列的特点：

3.4 一个队列对多个消耗者特点：要包管消息的有序性肯定要一个消息队列只毗连一个消耗者

4.FanoutExchange

4.1 消耗者

4.2生产者

5.TopicExchange

5.1 消耗者

5.1 生产者

6.业务对象作为消息

6.1 自界说转换器（须要举行范例转换）

2. @Configuration
3. public class RabiitConfig {
5.     @Bean // 将对象转化成json字符串
6.     public MessageConverter  messageConverter(){
7.         return new  Jackson2JsonMessageConverter();
8.     }
11. }

复制代码

6.2 消耗者直接继承业务对象

2.     @RabbitListener(bindings=@QueueBinding(
3.             value = @Queue(name = "Q01", durable = "true",autoDelete = "false",
4.                     arguments = @Argument(name="x-queue-mode",value = "lazy")),
5.             exchange =@Exchange(name = "E01", durable = "true",autoDelete = "false"),
6.             key = "RK01"))
7.     public void receiveMessage(RegisterOk registerOk){
8.         System.out.println("消费者 收到消息："+registerOk);
10.         //新用户注册后，送100积分。
11.       
15.     }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！qidao123.com:ToB企服之家，中国第一个企服评测及软件市场,开放入驻,技术点评得现金