springboot 集成RabbitMQ异步执行任务

当我们使用RabbitMQ处理任务时，通常需要将任务分发到多个工作者节点进行异步执行。下面是一个基于Spring Boot和RabbitMQ的异步任务处理示例。

首先，我们需要创建一个工作者节点来处理任务。这个工作者节点需要监听RabbitMQ队列，并在队列中有任务时进行处理。下面是一个简单的工作者节点示例：

@Component
public class Worker {

    @RabbitListener(queues = "taskQueue")
    public void processTask(String task) {
        // 处理任务逻辑
        System.out.println("Processing task: " + task);
    }

}

注意，使用@RabbitListener注解来监听名为“taskQueue”的队列，并在队列中有任务时调用processTask方法进行处理。

接下来，我们需要创建一个生产者节点来发布任务。下面是一个简单的生产者节点示例：

@RestController
public class TaskController {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    @PostMapping("/task")
    public void publishTask(@RequestBody String task) {
        rabbitTemplate.convertAndSend("taskExchange", "taskQueue", task);
    }

}

注意，使用RabbitTemplate将任务发送到名为“taskExchange”的交换机，并将其路由到名为“taskQueue”的队列。

最后，我们需要在应用程序中配置RabbitMQ连接和队列等信息。下面是一个简单的配置类示例：

@Configuration
public class RabbitMQConfig {

    @Value("${spring.rabbitmq.host}")
    private String host;

    @Value("${spring.rabbitmq.port}")
    private int port;

    @Value("${spring.rabbitmq.username}")
    private String username;

    @Value("${spring.rabbitmq.password}")
    private String password;

    @Bean
    public ConnectionFactory connectionFactory() {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setHost(host);
        connectionFactory.setPort(port);
        connectionFactory.setUsername(username);
        connectionFactory.setPassword(password);
        return connectionFactory;
    }

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

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

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

    @Bean
    public Binding binding() {
        return BindingBuilder.bind(taskQueue()).to(taskExchange()).with("taskQueue");
    }

}

这个配置类中，我们首先使用@Value注解读取application.properties文件中的RabbitMQ配置信息，然后创建一个ConnectionFactory和RabbitTemplate来连接RabbitMQ。接着，我们创建一个名为“taskQueue”的队列和一个名为“taskExchange”的交换机，并将这个队列绑定到这个交换机上。最后，我们将这个队列绑定到“taskQueue”路由键上。

现在，我们可以使用以上示例，在基于Spring Boot和RabbitMQ的应用程序中异步执行任务了！