SpringBoot中如何去集成RabbitMq并使用

一、工程搭建

二、首先需要引入RabbitMq对应的staert启动器

<!-- 引入RabbitMq集成依赖 -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

三、在application.yml文件中对rabbitmq进行相关配置

# 配置服务器端口
server:
  port: 9999

# 配置spring
spring:
  # 配置spring应用名称（目前暂时没用，后面微服务需要用到）
  application:
    name: rabbitmq-springboot

  # 配置rabbitmq
  rabbitmq:
    host: 192.168.7.11
    port: 5672
    fm-port: 5671
    username: fm
    password: 1
    virtual-host: fm

四、提供消费者

消费者需要去监听某个队列，然后从队列中取出消息进行消费

@Component
@RabbitListener(queuesToDeclare = @Queue("myQueue"))
public class RabbitMqListener {

    @RabbitHandler
    public void receiveMsg(String message) {
        System.out.println("message：" + message);
    }

}

五、编写生产者发送消息

@SpringBootTest(classes = RabbitmqdemoApplication.class)
@RunWith(SpringRunner.class)
class RabbitmqdemoApplicationTests {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Test
    void contextLoads() {
    }


    @Test
    public void sendMsg() {
        rabbitTemplate.convertAndSend("myQueue", "Hello Rabbit");
    }
}

这里要注意：我们生产者发送消息时，为了确保发送到消费者监听的那个队列中，生产者发送消息时指定的路由键必须跟消费者监听的队列名一致

六、测试