Springboot整合RabbitMq-用心看完这一篇就够了(最新)_springboot整合rabbitmq,用心

第一步创建一个springboot的项目

创建springboot项目 选好所需要的骨架

1—HelloWorld模型

springboot-整合mq-第一种模型 Hello World 简单模式
一个生产者丶默认交换机丶一个队列丶一个消费者。

第一步配置好自己的yml

server:
  port: 8001

spring:
  rabbitmq:
    username: guest 
    password: guest 
    virtual-host: /  
    port: 5672
    host: 192.168.192.168
1
2
3
4
5
6
7
8
9
10

创建生产者

第一个：HelloWorld模型
1、一个生产者
2、默认交换机
3、一个队列
4、一个消费者

@SpringBootTest
// 1--生产者
class SpringBootBuliangrenApplicationTests {

    @Autowired//RabbitTemplate是模板对象,用来简化mq操作
    private RabbitTemplate rabbitTemplate;
// 2--不用写就是默认交换机
// 3--队列名称是：hello
// 发送的消息是HelloWorld
    @Test
    void contextLoads() {       // 3--队列名字是：hello
        rabbitTemplate.convertAndSend("hello", "HelloWorld");
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14

创建消费者

@Component
                        //@RabbitListener 这个注解代表消费者的 一个监听
                        //消费者监听hello队列
@RabbitListener(queuesToDeclare = @Queue(value = "hello"))
public class HelloCustomer {
   
                        //消费者 - 消费 - 提供者 的消息
    @RabbitHandler
    public void receival(String message){
   
        System.out.println("消费接收到了消息----->"+message);
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13

运行

此时hello队列也创建出了

2—Work模型

springboot-整合mq-第二种模型:work-工作模式
一个生产者丶默认交换机丶一个队列丶多个消费者。

第一步配置好自己的yml

server:
  port: 8001

spring:
  rabbitmq:
    username: guest 
    password: guest 
    virtual-host: /  
    port: 5672
    host: 192.168.192.168
1
2
3
4
5
6
7
8
9
10

创建生产者

第二个：Work模型
1、一个生产者
2、默认交换机
3、一个队列
4、多个消费者

@SpringBootTest	//1 一个生产者
class SpringBootBuliangren2ApplicationTests {
   
// 2--不用写就是默认交换机

    @Autowired    //RabbitTemplate是模板对象,用来简化mq操作
    private RabbitTemplate rabbitTemplatel;
// 3--队列名称是：workTest
//发送的消息是hello,work模型 我们发送多条消息 应为有多个消费者
    @Test
    void contextLoads() {
   //消费者发送10 条消息
        for (int i = 0;i<10;i++){
   
            rabbitTemplatel.convertAndSend("workTest","hello,work模型");
        }
    }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

创建消费者

@Component
public class HelloCustomer {
   

    //1号消费者   ---监听workTest队列
    @RabbitListener(queuesToDeclare = @Queue("workTest"))
    public void receive01(String message){
   
    //消费者 - 消费 - 提供者 的消息
        System.out.println("消费者1号 - 接收到了消息----->"+m
1
2
3
4
5
6
7
8
9