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方法