提示：文章写完后，目录可以自动生成，如何生成可参考右边的帮助文档

文章目录

• 前言
• 一、rabbitmq是什么？
• 二、使用步骤
• • 1.引入库
  • 2.rabbitmq相关配置
  • 3.生产者代码
  • 4.多个消费者，消费同一条数据。
• 总结

---

前言

使用springboot整合rabbitmq实现，一个生产者生产一条数据，多个消费者消费同一条数据案例，可以解决微服务分布式事务控制。保证最终一致性原则。

---

提示：以下是本篇文章正文内容，下面案例可供参考

一、rabbitmq是什么？

相对简易得一种消息中间件，功能强大，性能中等，吞吐量一般。

二、使用步骤

1.引入库

代码如下（示例）：

 
        
            org.springframework.boot
            spring-boot-starter-amqp
        
        
            com.alibaba
            fastjson
            1.2.62
        
1
2
3
4
5
6
7
8
9
10

2.rabbitmq相关配置

@Configuration
public class RabbitmqConfig {
	@Bean
    public Queue queue1() {
        return new Queue("queue1",true);
    }

    @Bean
    public FanoutExchange exchange1() {
        return new FanoutExchange("exchange1",true, false);
    }

    @Bean
    public Binding binding1() {
        return BindingBuilder.bind(queue1()).to(exchange1());
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

注：因为是fanout广播模式，所以不用配置路由键。

3.生产者代码

代码如下（示例）：

@Resource
private RabbitTemplate rabbitTemplate;

@Test
public void pushMessage() {
    HashMap hashMap = new HashMap<>();
    hashMap.put("name","zhangsan");
    hashMap.put("age","18");
    rabbitTemplate.convertAndSend("exchange1","", hashMap);
}
1
2
3
4
5
6
7
8
9
10

4.多个消费者，消费同一条数据。

消费者1号：
代码如下（示例）：

@Component
public class RabbitMqConsumer {
//    @RabbitListener(queues = "queue1")
    @RabbitListener(bindings = @QueueBinding(
            // value = @Queue(value = "queue1"),
		value = @Queue(), //切记： 此处无需设置队列名称，否在得话，多个消费者只有一个消费者能消费数据。其它消费者无法消费数据。
        exchange = @Exchange(value = "exchange1",type = ExchangeTypes.FANOUT)
    ))
    public void getData(Message message) {
        try {
            String str = new String(message.getBody(),"utf-8");
            System.out.println(str);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

消费者2号：
代码如下（示例）：

@Component
public class RabbitMqConsumer {
	// @RabbitListener(queues = "queue1")
    @RabbitListener(bindings = @QueueBinding(
	// value = @Queue(value = "queue1"),
		value = @Queue(), //切记： 此处无需设置队列名称，否在得话，多个消费者只有一个消费者能消费数据。其它消费者无法消费数据。
        exchange = @Exchange(value = "exchange1",type = ExchangeTypes.FANOUT)
    ))
    public void getData(Message message) {
        try {
            String str = new String(message.getBody(),"utf-8");
            System.out.println(str);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17

结束，希望能够帮助各位。

---

总结

人生物语：活得优雅些。也许你的生活并不富裕；也许你的工作不够好；也许你正处在困境中；也许你被情所弃。不论什么原因，请你在出门时，一定要让自己面带微笑，从容自若地去面对生活。只要你自己真正撑起来了，别人无论如何是压不垮你的。

先自我介绍一下，小编13年上师交大毕业，曾经在小公司待过，去过华为OPPO等大厂，18年进入阿里，直到现在。深知大多数初中级java工程师，想要升技能，往往是需要自己摸索成长或是报班学习，但对于培训机构动则近万元的学费，着实压力不小。自己不成体系的自学效率很低又漫长，而且容易碰到天花板技术停止不前。因此我收集了一份《java开发全套学习资料》送给大家，初衷也很简单，就是希望帮助到想自学又不知道该从何学起的朋友，同时减轻大家的负担。添加下方名片，即可获取全套学习资料哦