spring整合rabbitmq
spring整合rabbitmq的步骤:
在maven的pom文件中添加如下:
<dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>3.6.5</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId><version>2.1.3</version></dependency>
在bean工厂中添加连接工厂和rabbitAdmin实例
@Beanpublic ConnectionFactory connectionFactory(){ CachingConnectionFactory connectionFactory = new CachingConnectionFactory(); connectionFactory.setAddresses("192.168.1.177:5672"); connectionFactory.setUserName("guest"); connectionFactory.setUserName("guest"); connectionFactory.setVirtualHost("/"); return connectionFactory;}
@Beanpublic 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方法
声明:本站所有文章资源内容,如无特殊说明或标注,均为采集网络资源。如若本站内容侵犯了原著者的合法权益,可联系本站删除。