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");
    }
}

這里要注意：我們生產者發送消息時，為了確保發送到消費者監聽的那個隊列中，生產者發送消息時指定的路由鍵必須跟消費者監聽的隊列名一致

六、測試