SpringBoot 使用Rabbitmq

1.Springboot默认MQ支持rabbitmq或者kafka

maven引入依赖

<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>

propertis添加配置

#
spring.rabbitmq.host=192.168.68.238
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
spring.rabbitmq.virtual-host=/

#rabbitmq 每次消费1条消息
spring.rabbitmq.listener.simple.prefetch=1

docker启动服务器

 docker run -it -d --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:4-management
 

打开网页控制台http://192.168.68.238:15672/#/queues 默认用户名密码都是guest

queue增加一个test

在Exchange: amq.fanout增加一个绑定test队列

写个测试类

@SpringBootTest
class Demo1ApplicationTests {

    @Autowired
    AmqpTemplate rabbitTemplate;
    @Test
    void contextLoads() {
        
        for (int i = 0; i < Integer.MAX_VALUE; i++)
        {
            // 给amq.fanout交换机发送测试消息
            rabbitTemplate.convertAndSend("amq.fanout","", "xiaoxi"+i);
            System.out.println("发送消息：xiaoxi"+i);
        }



    }

    //接收rabbitmq消息

    @Test
    @RabbitListener(queues = "test")
    public void receive(Message message)
    {
        System.out.println("接收到消息："+new String(message.getBody()));
    }
}

启动生产者

在网页控制台能看到大量的消息进入了队列

同时消费方法被回调

测试成功！