SpringBoot整合RabbitMQ 手动应答(简单demo)

以下是“SpringBoot整合RabbitMQ 手动应答(简单demo)”的完整攻略，包含两个示例说明。

简介

在本文中，我们将介绍如何使用Spring Boot和RabbitMQ实现手动应答。我们将提供两个示例说明，演示如何使用手动应答来确保消息的可靠性。

示例1：生产者

以下是一个简单的Spring Boot RabbitMQ生产者示例，演示了如何发送消息到RabbitMQ：

package com.example.demo;

import org.springframework.amqp.core.Queue;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.CommandLineRunner;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;

@SpringBootApplication
public class ProducerApplication implements CommandLineRunner {

    @Autowired
    private RabbitTemplate rabbitTemplate;

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

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

    @Override
    public void run(String... args) throws Exception {
        rabbitTemplate.convertAndSend("hello", "Hello World!");
        System.out.println("Message sent.");
    }
}

示例2：消费者

以下是一个简单的Spring Boot RabbitMQ消费者示例，演示了如何使用手动应答来确保消息的可靠性：

package com.example.demo;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class ConsumerApplication {

    @Autowired
    private RabbitTemplate rabbitTemplate;

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

    @RabbitListener(queues = "hello")
    public void receiveMessage(Message message) {
        System.out.println("Received message: " + new String(message.getBody()));
        rabbitTemplate.convertAndSend(message.getMessageProperties().getReplyTo(), "Received message: " + new String(message.getBody()));
        rabbitTemplate.convertAndSend(message.getMessageProperties().getReceivedExchange(), message.getMessageProperties().getReceivedRoutingKey(), "ACK");
    }
}

在这个示例中，我们使用了@RabbitListener注释来接收消息。在处理消息时，我们使用了rabbitTemplate来发送回复消息和确认消息。这确保了消息的可靠性。

结论

使用手动应答可以确保消息的可靠性，但也会增加代码的复杂性。在使用手动应答时，需要注意处理异常情况和确保消息的顺序性。