springboot整合rabbitmq配置

在 Spring Boot 中整合 RabbitMQ 需要在 pom.xml 文件中添加 RabbitMQ 的依赖，并在 application.properties 或 application.yml 中配置 RabbitMQ 的连接信息。

在 pom.xml 中添加以下依赖:

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

在 application.properties 或 application.yml 中配置 RabbitMQ 的连接信息,如下:

spring:
  rabbitmq:
    host: localhost
    port: 5672
    username: guest
    password: guest

然后创建一个RabbitTemplate 和 RabbitConfig（可选）来配置连接工厂，最后在你的代码中使用RabbitTemplate来发送和接收消息即可。

相关问题

springboot整合rabbitmq配置死信队列

要在Spring Boot中配置死信队列（Dead Letter Queue），您可以按照以下步骤进行操作：

1. 添加RabbitMQ依赖：在您的Spring Boot项目的pom.xml文件中，添加RabbitMQ依赖。例如，使用以下Maven依赖项：

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

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

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

3. 创建交换机和队列：使用RabbitAdmin或通过注解方式，在您的代码中创建交换机和队列。例如，可以使用@Bean注解创建一个RabbitAdmin bean，并在其上使用@PostConstruct注解来创建交换机和队列。

@Bean
public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory) {
    return new RabbitAdmin(connectionFactory);
}

@PostConstruct
public void setupQueues() {
    rabbitAdmin().declareExchange(new DirectExchange("myExchange"));
    rabbitAdmin().declareQueue(new Queue("myQueue"));
    rabbitAdmin().declareBinding(new Binding("myQueue", Binding.DestinationType.QUEUE, "myExchange", "myRoutingKey", null));
}

4. 配置死信队列：创建一个专用的队列来作为死信队列，并将其与原始队列绑定。您可以在队列声明时设置x-dead-letter-exchange和x-dead-letter-routing-key参数来指定死信队列的交换机和路由键。

@PostConstruct
public void setupQueues() {
    rabbitAdmin().declareExchange(new DirectExchange("myExchange"));
    rabbitAdmin().declareQueue(new Queue("myQueue", false, false, false, 
        new HashMap<String, Object>() {{
            put("x-dead-letter-exchange", "dlxExchange");
            put("x-dead-letter-routing-key", "dlxRoutingKey");

springboot整合rabbitmq配置 延时消息队列

1. 添加rabbitmq依赖

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

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

2. 配置rabbitmq连接信息

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

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

3. 创建消息队列

在代码中创建消息队列，可以使用@Bean注解进行创建：

@Bean
public Queue delayQueue() {
    return new Queue("delay_queue");
}

4. 创建交换机

创建交换机，可以使用@Bean注解进行创建：

@Bean
public DirectExchange delayExchange() {
    return new DirectExchange("delay_exchange");
}

5. 绑定队列和交换机

将队列和交换机进行绑定，可以使用@Bean注解进行创建：

@Bean
public Binding delayBinding() {
    return BindingBuilder.bind(delayQueue()).to(delayExchange()).with("delay_key");
}

6. 设置延时消息的TTL

设置延时消息的TTL，可以使用@Bean注解进行创建：

@Bean
public CustomExchange customExchange() {
    Map<String, Object> args = new HashMap<>();
    args.put("x-delayed-type", "direct");
    return new CustomExchange("delayed_exchange", "x-delayed-message", true, false, args);
}

7. 发送延时消息

发送延时消息，可以使用rabbitTemplate发送消息：

rabbitTemplate.convertAndSend("delayed_exchange", "delay_key", message, message1 -> {
    message1.getMessageProperties().setHeader("x-delay", delayTime);
    return message1;
});

其中，delayTime为延时时间，单位为毫秒。

完整代码如下：

@Configuration
public class RabbitmqConfig {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @Bean
    public Queue delayQueue() {
        return new Queue("delay_queue");
    }

    @Bean
    public DirectExchange delayExchange() {
        return new DirectExchange("delay_exchange");
    }

    @Bean
    public Binding delayBinding() {
        return BindingBuilder.bind(delayQueue()).to(delayExchange()).with("delay_key");
    }

    @Bean
    public CustomExchange customExchange() {
        Map<String, Object> args = new HashMap<>();
        args.put("x-delayed-type", "direct");
        return new CustomExchange("delayed_exchange", "x-delayed-message", true, false, args);
    }

    public void sendDelayMessage(Object message, Integer delayTime) {
        rabbitTemplate.convertAndSend("delayed_exchange", "delay_key", message, message1 -> {
            message1.getMessageProperties().setHeader("x-delay", delayTime);
            return message1;
        });
    }
}

调用sendDelayMessage方法即可发送延时消息。