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级流量清洗系统配攻击溯源，准确进行流量调度，确保服务器高可用性。佳节活动现已开启，新人活动云服务器买多久送多久。