spring boot整合RabbitMQ（Direct模式）

以下是Spring Boot整合RabbitMQ（Direct模式）的完整攻略，包含两个示例说明。

示例1：发送消息到RabbitMQ

步骤1：添加依赖

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

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

步骤2：配置RabbitMQ连接

在application.properties文件中添加以下配置：

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

步骤3：创建消息发送者

创建一个消息发送者类，用于发送消息到RabbitMQ：

@Component
public class MessageSender {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void sendMessage(String message) {
        rabbitTemplate.convertAndSend("direct-exchange", "direct-routing-key", message);
    }
}

步骤4：发送消息

在需要发送消息的地方，注入消息发送者并调用sendMessage方法：

@Autowired
private MessageSender messageSender;

public void send() {
    messageSender.sendMessage("Hello, RabbitMQ!");
}

示例2：从RabbitMQ接收消息

步骤1：添加依赖

同示例1。

步骤2：配置RabbitMQ连接

同示例1。

步骤3：创建消息接收者

创建一个消息接收者类，用于接收消息：

@Component
public class MessageReceiver {

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

步骤4：启动消息接收者

在Spring Boot应用程序的启动类上添加@EnableRabbit注解，启用RabbitMQ的消息监听功能：

@SpringBootApplication
@EnableRabbit
public class Application {

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

步骤5：启动应用程序

启动Spring Boot应用程序，并在控制台中查看消息接收情况。

以上就是Spring Boot整合RabbitMQ（Direct模式）的完整攻略，包含两个示例说明。