SpringBoot中怎么使用RabbitMQ

96次阅读

共计 1454 个字符，预计需要花费 4 分钟才能阅读完成。

在 SpringBoot 中使用 RabbitMQ，需要引入相关的依赖并配置 RabbitMQ 的连接信息。以下是具体的步骤：

引入 RabbitMQ 的依赖：

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

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

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

创建一个 RabbitMQ 的消息生产者：

import org.springframework.amqp.core.AmqpTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

@Component
public class RabbitMQProducer {@Autowired
    private AmqpTemplate rabbitTemplate;

    public void send(String message) {rabbitTemplate.convertAndSend("exchange", "routingKey", message);
    }
}

创建一个 RabbitMQ 的消息消费者：

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class RabbitMQConsumer {@RabbitListener(queues = "queue")
    public void receiveMessage(String message) {System.out.println("Received message: " + message);
    }
}

在启动类中添加 @EnableRabbit 注解启用 RabbitMQ 支持：

import org.springframework.amqp.rabbit.annotation.EnableRabbit;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@EnableRabbit
public class Application {public static void main(String[] args) {SpringApplication.run(Application.class, args);
    }
}