springboot声明（创建）RabbitMQ交换机和队列-1. 使用@Bean

@Configuration
public class FanoutConfig {

    /**
     * 创建一个FanoutExchange实例，用于将消息广播到多个队列。
     * @return FanoutExchange实例
     */
    @Bean
    public FanoutExchange fanoutExchange() {
        return new FanoutExchange("springboot.fanout");
    }

    /**
     * 创建一个队列实例，用于接收广播的消息。
     * @return 队列实例
     */
    @Bean
    public Queue fanoutQueue1() {
        return new Queue("springboot.fanout.queue1");
    }

    /**
     * 创建一个Binding实例，将队列与FanoutExchange绑定。
     * @param fanoutExchange FanoutExchange实例
     * @param fanoutQueue1 队列实例
     * @return Binding实例
     */
    @Bean
    public Binding bindingFanoutQueue1(FanoutExchange fanoutExchange, Queue fanoutQueue1) {
        return BindingBuilder.bind(fanoutQueue1).to(fanoutExchange);
    }

    /**
     * 创建一个队列实例，用于接收广播的消息。
     * @return 队列实例
     */
    @Bean
    public Queue fanoutQueue2() {
        return new Queue("springboot.fanout.queue2");
    }

    /**
     * 创建一个Binding实例，将队列与FanoutExchange绑定。
     * @param fanoutExchange FanoutExchange实例
     * @param fanoutQueue2 队列实例
     * @return Binding实例
     */
    @Bean
    public Binding bindingFanoutQueue2(FanoutExchange fanoutExchange, Queue fanoutQueue2) {
        return BindingBuilder.bind(fanoutQueue2).to(fanoutExchange);
    }
}

@Configuration
public class DirectConfig {
    /**
     * 创建一个直接交换机
     *
     * @return DirectExchange实例
     */
    @Bean
    public DirectExchange directExchange() {
        return ExchangeBuilder.directExchange("springboot.direct").build();
    }

    /**
     * 创建一个队列
     *
     * @return Queue实例
     */
    @Bean
    public Queue directQueue1() {
        return new Queue("springboot.direct.queue1");
    }

    /**
     * 创建一个绑定队列到交换机的Binding
     *
     * @param directQueue1   队列
     * @param directExchange 交换机
     * @return Binding实例
     */
    @Bean
    public Binding bindingQueue1WithRed(Queue directQueue1, DirectExchange directExchange) {
        return BindingBuilder.bind(directQueue1).to(directExchange).with("red");
    }

    /**
     * 创建一个绑定队列到交换机的Binding
     *
     * @param directQueue1   队列
     * @param directExchange 交换机
     * @return Binding实例
     */
    @Bean
    public Binding bindingQueue1WithBlue(Queue directQueue1, DirectExchange directExchange) {
        return BindingBuilder.bind(directQueue1).to(directExchange).with("blue");
    }

    /**
     * 创建一个队列
     *
     * @return Queue实例
     */
    @Bean
    public Queue directQueue2() {
        return new Queue("springboot.direct.queue2");
    }

    /**
     * 创建一个绑定队列到交换机的Binding
     *
     * @param directQueue2   队列
     * @param directExchange 交换机
     * @return Binding实例
     */
    @Bean
    public Binding bindingQueue2WithRed(Queue directQueue2, DirectExchange directExchange) {
        return BindingBuilder.bind(directQueue2).to(directExchange).with("red");
    }

    /**
     * 创建一个绑定队列到交换机的Binding
     *
     * @param directQueue2   队列
     * @param directExchange 交换机
     * @return Binding实例
     */
    @Bean
    public Binding bindingQueue2WithYellow(Queue directQueue2, DirectExchange directExchange) {
        return BindingBuilder.bind(directQueue2).to(directExchange).with("yellow");
    }
}