如何在使用rabbitmq时分别配置消费者和生产者spring boot app？

在使用RabbitMQ时，我们可以通过配置消费者和生产者的Spring Boot应用程序来实现消息的发送和接收。

配置消费者：

首先，确保在pom.xml文件中添加了RabbitMQ的依赖项，例如：

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

在application.properties或application.yml文件中配置RabbitMQ连接信息，例如：

spring.rabbitmq.host=your-rabbitmq-host
spring.rabbitmq.port=5672
spring.rabbitmq.username=your-username
spring.rabbitmq.password=your-password

创建一个消息监听器类，使用@RabbitListener注解指定监听的队列，例如：

@Component
public class MessageListener {

    @RabbitListener(queues = "your-queue-name")
    public void handleMessage(String message) {
        // 处理接收到的消息
        System.out.println("Received message: " + message);
    }
}

在启动类上添加@EnableRabbit注解，启用RabbitMQ的消息监听功能，例如：

@SpringBootApplication
@EnableRabbit
public class Application {

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

配置生产者：

确保在pom.xml文件中添加了RabbitMQ的依赖项，同样使用上述依赖项。
在application.properties或application.yml文件中配置RabbitMQ连接信息，同样使用上述配置。
创建一个消息发送者类，使用RabbitTemplate来发送消息，例如：

@Component
public class MessageSender {

    private final RabbitTemplate rabbitTemplate;

    public MessageSender(RabbitTemplate rabbitTemplate) {
        this.rabbitTemplate = rabbitTemplate;
    }

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