基于Bean的方法声明交换机队列以绑定

2023-12-13 14:44:53

创建交换机以及队列可以手动实现,但在生产环境中不太合适,故用java代码生成更为方便一些。

@Configuration
public class FanoutConfigution {
//      声明交换机
    @Bean
    public FanoutExchange fanoutExchange(){
//        ExchangeBuilder.fanoutExchange("fanout1").build();
            return new FanoutExchange("fanout1");
    }
//      声明队列
    @Bean
    public Queue queue(){
//        QueueBuilder.durable("queue2")return  new Queue("queue2");
    }
//      绑定
    @Bean
    public Binding binding(){
         return BindingBuilder.bind(queue()).to(fanoutExchange());
//         该处的的被调用的方法因为加Bean了都被动态代理了,实际还是从spring中取对象
    }
}

配置完该配置类后启动该项目,登录rabbitmq后便可发现已经生成并绑定
在这里插入图片描述

文章来源:https://blog.csdn.net/qq_45706306/article/details/134906359
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。