spring整合rabbitmq-创新互联
                                            spring整合rabbitmq的步骤:
在maven的pom文件中添加如下:

com.rabbitmq 
amqp-client 
3.6.5 
 
org.springframework.boot 
spring-boot-starter-amqp 
2.1.3 
 在bean工厂中添加连接工厂和rabbitAdmin实例
@Bean
public ConnectionFactory connectionFactory(){
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setAddresses("192.168.1.177:5672");
        connectionFactory.setUserName("guest");
        connectionFactory.setUserName("guest");
        connectionFactory.setVirtualHost("/");
        return connectionFactory;
}@Bean
public RabbitAdmin rabbitAdmin(ConnectionFactory connectionFactory){
        RabbitAdmin rabbitAdmin = new RabbitAdmini(connectionFactory);
        rabbitAdmin.setAutoStartup(true);
        return rabbitAdmin;
}利用rabbitAdmin声明:
rabbitAdmin.declareBinding(BindingBuilder.bind(new Queue("topic.queue"),false).to(new TopicExchange("topic".false,false)).with("test.#"));
bind:创建队列
to :绑定交换机
with :路由key
底层是通过rabbitTemplate调用execute方法
创新互联www.cdcxhl.cn,专业提供香港、美国云服务器,动态BGP最优骨干路由自动选择,持续稳定高效的网络助力业务部署。公司持有工信部办法的idc、isp许可证, 机房独有T级流量清洗系统配攻击溯源,准确进行流量调度,确保服务器高可用性。佳节活动现已开启,新人活动云服务器买多久送多久。
本文名称:spring整合rabbitmq-创新互联
标题网址:http://www.scyingshan.cn/article/diipee.html

 建站
建站
 咨询
咨询 售后
售后
 建站咨询
建站咨询 
 