Spring Boot整合RabbitMQ:消息发送与接收

后端

2023-07-09 17:22:47

Spring Boot整合RabbitMQ：拥抱消息传递的魅力

春暖花开，消息送达

在春日暖阳的映照下，消息犹如一封封温暖的问候，从发送者的手中传递而出。使用RabbitMQ来实现消息传递，如同在春天里种下一颗希望的种子，它将承载着美好的祝愿，在消息队列中静静等待着被接收。

萌动的心，消息接收

当消息抵达接收者手中，那一刻就像收到了一份甜蜜的礼物。RabbitMQ让消息接收变得轻而易举，如同在春天里采摘一朵芬芳的花朵，它将香气四溢，带来喜悦和满足。

春风拂面，消息处理

处理消息就像在春天里描绘一幅美丽的画卷，每一笔都饱含着创造的激情。RabbitMQ赋予我们消息处理的无限可能，如同在春天里谱写一首动听的歌曲，它将悦耳的旋律回荡在耳边。

激情飞扬，监听消息

监听消息就像在春天里等待一场盛大的邂逅，期待着来自未知的消息。RabbitMQ的消息监听机制如同一位细心的向导，它将引导消息抵达我们的面前，点亮我们的世界。

Spring Boot整合RabbitMQ教程

1. 创建Spring Boot项目

使用Spring Boot创建一个新的项目：

spring init --name spring-boot-rabbitmq

2. 添加RabbitMQ依赖

在pom.xml文件中添加RabbitMQ依赖：

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

3. 配置RabbitMQ连接

在application.properties文件中配置RabbitMQ连接：

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

4. 创建消息发送者

创建一个消息发送者类：

@SpringBootApplication
public class SpringBootRabbitmqApplication {

  public static void main(String[] args) {
    SpringApplication.run(SpringBootRabbitmqApplication.class, args);
  }

  @Bean
  public RabbitTemplate rabbitTemplate() {
    return new RabbitTemplate(connectionFactory());
  }

  @EventListener(ApplicationReadyEvent.class)
  public void sendMessage() {
    rabbitTemplate().convertAndSend("my-queue", "Hello, RabbitMQ!");
  }
}

5. 创建消息接收者

创建一个消息接收者类：

@SpringBootApplication
public class SpringBootRabbitmqApplication {

  public static void main(String[] args) {
    SpringApplication.run(SpringBootRabbitmqApplication.class, args);
  }

  @Bean
  public SimpleMessageListenerContainer container() {
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
    container.setConnectionFactory(connectionFactory());
    container.setQueues(new Queue("my-queue"));
    container.setMessageListener(new MessageListener() {
      @Override
      public void onMessage(Message message) {
        System.out.println("Received message: " + new String(message.getBody()));
      }
    });
    return container;
  }
}