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

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class RabbitMQConfig {
    // 定義常量表示交換機(jī)、隊(duì)列和路由鍵
    public static final String SECKILL_EXCHANGE = "seckill.exchange";
    public static final String SECKILL_QUEUE = "seckill.queue";
    public static final String SECKILL_ROUTINGKEY = "seckill.routingkey";
    // 1. 定義秒殺交換機(jī)
    @Bean
    public TopicExchange seckillExchange() {
        return new TopicExchange(SECKILL_EXCHANGE);
    }
    // 2. 定義秒殺隊(duì)列
    @Bean
    public Queue seckillQueue() {
        return new Queue(SECKILL_QUEUE);
    }
    // 3. 綁定隊(duì)列到交換機(jī)，并指定路由鍵
    @Bean
    public Binding bindingSeckillQueue(Queue seckillQueue, TopicExchange seckillExchange) {
        return BindingBuilder.bind(seckillQueue).to(seckillExchange).with(SECKILL_ROUTINGKEY);
    }
}

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class SeckillMessageSender {
    @Autowired
    private RabbitTemplate rabbitTemplate;
    // 發(fā)送秒殺訂單消息
    public void sendSeckillOrderMessage(String message) {
        rabbitTemplate.convertAndSend(RabbitMQConfig.SECKILL_EXCHANGE, RabbitMQConfig.SECKILL_ROUTINGKEY, message);
        System.out.println("秒殺消息已發(fā)送：" + message);
    }
}

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
@Component
public class SeckillMessageReceiver {
    // 監(jiān)聽(tīng)秒殺隊(duì)列
    @RabbitListener(queues = RabbitMQConfig.SECKILL_QUEUE)
    public void receiveMessage(String message) {
        System.out.println("接收到秒殺消息：" + message);
        // 處理消息的邏輯
    }
}

@Bean
public DirectExchange directExchange() {
    return new DirectExchange("direct.exchange");
}
@Bean
public Binding bindingDirectQueue(Queue seckillQueue, DirectExchange directExchange) {
    return BindingBuilder.bind(seckillQueue).to(directExchange).with("direct.routingkey");
}

@Bean
public FanoutExchange fanoutExchange() {
    return new FanoutExchange("fanout.exchange");
}
@Bean
public Binding bindingFanoutQueue(Queue seckillQueue, FanoutExchange fanoutExchange) {
    return BindingBuilder.bind(seckillQueue).to(fanoutExchange);
}