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

docker run -d --name rabbitmq -p 5672:5672 -p 15672:15672 rabbitmq:management

import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class RabbitMQConfig {

    public static final String QUEUE_NAME = "demoQueue";
    public static final String EXCHANGE_NAME = "demoExchange";
    public static final String ROUTING_KEY = "demoRoutingKey";

    @Bean
    public Queue demoQueue() {
        return new Queue(QUEUE_NAME, true);
    }

    @Bean
    public DirectExchange demoExchange() {
        return new DirectExchange(EXCHANGE_NAME);
    }

    @Bean
    public Binding demoBinding(Queue demoQueue, DirectExchange demoExchange) {
        return BindingBuilder.bind(demoQueue).to(demoExchange).with(ROUTING_KEY);
    }
}

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Service;

@Service
public class RabbitMQProducer {

    private final RabbitTemplate rabbitTemplate;

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

    public void sendMessage(String message) {
        rabbitTemplate.convertAndSend(RabbitMQConfig.EXCHANGE_NAME, RabbitMQConfig.ROUTING_KEY, message);
        System.out.println("Sent message: " + message);
    }
}

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

@Service
public class RabbitMQConsumer {

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

import org.springframework.amqp.core.Queue;

@Bean
public Queue demoQueue() {
    return QueueBuilder.durable(QUEUE_NAME)
            .withArgument("x-dead-letter-exchange", "deadLetterExchange")
            .withArgument("x-dead-letter-routing-key", "deadLetterRoutingKey")
            .withArgument("x-message-ttl", 60000) // 設(shè)置消息在原隊(duì)列的存活時(shí)間（60秒）
            .build();
}

@Bean
public Queue deadLetterQueue() {
    return new Queue("deadLetterQueue", true);
}

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

@Bean
public Binding deadLetterBinding() {
    return BindingBuilder.bind(deadLetterQueue()).to(deadLetterExchange()).with("deadLetterRoutingKey");
}

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;

@Service
public class DelayedMessageConsumer {

    @RabbitListener(queues = "deadLetterQueue")
    public void receiveDelayedMessage(String message) {
        System.out.println("Received delayed message: " + message);
        // 處理延時(shí)消息的邏輯
    }
}

import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Service;

import javax.annotation.PostConstruct;

@Service
public class RabbitMQProducerWithConfirm {

    private final RabbitTemplate rabbitTemplate;

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

    @PostConstruct
    public void init() {
        rabbitTemplate.setConfirmCallback(new RabbitTemplate.ConfirmCallback() {
            @Override
            public void confirm(CorrelationData correlationData, boolean ack, String cause) {
                if (ack) {
                    System.out.println("Message sent successfully");
                } else {
                    System.out.println("Message failed to send: " + cause);
                }
            }
        });
    }

    public void sendMessage(String message) {
        rabbitTemplate.convertAndSend(RabbitMQConfig.EXCHANGE_NAME, RabbitMQConfig.ROUTING_KEY, message);
    }
}

import org.springframework.amqp.core.AcknowledgeMode;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.listener.api.ChannelAwareMessageListener;
import org.springframework.stereotype.Service;
import com.rabbitmq.client.Channel;

@Service
public class RabbitMQConsumerWithAck implements ChannelAwareMessageListener {

    @Override
    @RabbitListener(queues = RabbitMQConfig.QUEUE_NAME, ackMode = "MANUAL")
    public void onMessage(org.springframework.amqp.core.Message message, Channel channel) throws Exception {
        try {
            String body = new String(message.getBody());
            System.out.println("Received message: " + body);

            // 處理消息...
            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
        } catch (Exception e) {
            channel.basicNack(message.getMessageProperties().getDeliveryTag(), false, true);
        }
    }
}

version: '3'
services:
  rabbitmq-node1:
    image: rabbitmq:management
    container_name: rabbitmq-node1
    ports:
      - "5673:5672"
      - "15673:15672"
    environment:
      RABBITMQ_ERLANG_COOKIE: "mycookie"
      RABBITMQ_NODENAME: "rabbit@rabbitmq-node1"
  rabbitmq-node2:
    image: rabbitmq:management
    container_name: rabbitmq-node2
    ports:
      - "5674:5672"
      - "15674:15672"
    environment:
      RABBITMQ_ERLANG_COOKIE: "mycookie"
      RABBITMQ_NODENAME: "rabbit@rabbitmq-node2"
    depends_on:
      - rabbitmq-node1
  rabbitmq-node3:
    image: rabbitmq:management
    container_name: rabbitmq-node3
    ports:
      - "5675:5672"
      - "15675:15672"
    environment:
      RABBITMQ_ERLANG_COOKIE: "mycookie"
      RABBITMQ_NODENAME: "rabbit@rabbitmq-node3"
    depends_on:
      - rabbitmq-node1
      - rabbitmq-node2

docker-compose up -d

docker exec -it rabbitmq-node2 bash
rabbitmqctl stop_app
rabbitmqctl join_cluster rabbit@rabbitmq-node1
rabbitmqctl start_app
exit

docker exec -it rabbitmq-node3 bash
rabbitmqctl stop_app
rabbitmqctl join_cluster rabbit@rabbitmq-node1
rabbitmqctl start_app
exit

helm repo add bitnami https://charts.bitnami.com/bitnami
helm install my-rabbitmq bitnami/rabbitmq

rabbitmqctl set_log_level info