Spring整合RabbitMQ

1.生产者Spring-Producer

1.1 创建生产者工程

整合用到的maven坐标,主要有：spring-context（Spring核心）、spring-test（测试）、junit和spring-rabbit（官方整合方案）。

org.springframeworkspring-context5.1.7.RELEASEorg.springframeworkspring-test5.1.7.RELEASEtestjunitjunit4.12testorg.springframework.amqpspring-rabbit2.1.8.RELEASE

1.2 创建RabbitMQ配置文件

这里我们创建的是一个RabbitMQ配置文件，名称为rabbitmq.properties。目的是方便将配置文件中的信息加载到Spring中，就无需在xml文件中修改了。

# RabbitMQ地址
rabbitmq.host=192.168.52.128
# RabbitMQ端口
rabbitmq.port=5672
# 用户名
rabbitmq.username=admin
# 密码
rabbitmq.password=admin
# 虚拟机
rabbitmq.virtual-host=/test

1.3 创建整合配置文件

RabbitMQ和Spring使用xml文件进行整合，意味着大部分的配置类或模板都在xml文件中，我们默认的文件名为：spring-rabbitmq-producer.xml。

xml文件用到的默认约束

（1）加载配置文件，并创建连接工程connectionFactory

在这里我们需要注意的是加载配置文件的路径，classpath:rabbitmq.properties。

（2）定义管理交换机、队列

（3）定义普通队列

不绑定到交换机则绑定到默认交换机，默认交换机类型为direct，名字为：“”，路由键为队列的名称。

• id：表示bean的id
• name：表示队列的名称
• auto-declare：如果没有是否自动创建
• auto-delete：是否自动删除队列（当最后一个消费者断开连接时）

（4）定义广播类型交换机

（5）定义定向类型交换机

上述定义的是定向类型交换机，表示当routing key为direct_key_1的时候，会发送到spring_direct_queue_1，当routing key为direct_key_2的时候，会发送到spring_direct_queue_2。

（6）定义通配符类型交换机

上述代码表示：

（1）以abc.开头的routing key会转到spring_topic_queue_1，例如：abc、abc.xx、abc.xx.xxx。

（2）以abc.开头的且只有一个单词的会转到spring_topic_queue_2，例如：abc.xx。

（3）以".cd"结尾的的routing key会转到spring_topic_queue_3，例如：abc.cd,xx.cd。

• pattern：表示的路由器的通配符
  • * 表示0或多个单词
  • # 表示一个单词

（7）定义rabbitTemplate

1.4 代码测试

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath:spring-rabbitmq-producer.xml")
public class ProducerTest {/*** 注入RabbitTemplate*/@Autowiredprivate RabbitTemplate rabbitTemplate;/*** 测试默认的队列发送消息*/@Testpublic void test() {rabbitTemplate.convertAndSend("spring_queue", "hello world");}/*** 测试广播模式发送消息*/@Testpublic void testFanout() {rabbitTemplate.convertAndSend("spring_fanout_exchange", "", "spring_fanout_exchange");}/*** 测试使用定向路由发送消息*/public void testDirect() {// 将spring_direct_exchange_direct_key_1消息发送给路由key为direct_key_1的队列，即发送给spring_direct_queue_1rabbitTemplate.convertAndSend("spring_direct_exchange", "direct_key_1","spring_direct_exchange_direct_key_1");// 将spring_direct_exchange_direct_key_2消息发送给路由key为direct_key_2的队列，即发送给spring_direct_queue_2rabbitTemplate.convertAndSend("spring_direct_exchange", "direct_key_2","spring_direct_exchange_direct_key_2");}/*** 测试通配符模式*/@Testpublic void testTopics() {rabbitTemplate.convertAndSend("spring_topic_exchange", "abc.cd", "spring_test_topics_abc.cd");rabbitTemplate.convertAndSend("spring_topic_exchange", "abc.x", "spring_test_topics_abc.x");rabbitTemplate.convertAndSend("spring_topic_exchange", "x.cd", "spring_test_topics_x.cd");}}

2.消费者Spring-Consumer

2.1 创建消费者工程

消费者Spring-Consumer使用的jar包和生产者一样，无需修改。

org.springframeworkspring-context5.1.7.RELEASEorg.springframeworkspring-test5.1.7.RELEASEtestjunitjunit4.12testorg.springframework.amqpspring-rabbit2.1.8.RELEASE

1.2 创建RabbitMQ配置文件

这里我们创建的是一个RabbitMQ配置文件，名称为rabbitmq.properties。目的是方便将配置文件中的信息加载到Spring中，就无需在xml文件中修改。

# RabbitMQ地址
rabbitmq.host=192.168.52.128
# RabbitMQ端口
rabbitmq.port=5672
# 用户名
rabbitmq.username=admin
# 密码
rabbitmq.password=admin
# 虚拟机
rabbitmq.virtual-host=/test

1.3 创建整合配置文件

RabbitMQ和Spring使用xml文件进行整合，意味着大部分的配置类或模板都在xml文件中，我们默认的文件名为：spring-rabbitmq-producer.xml。

xml文件用到的默认约束

（1）加载配置文件，并创建连接工程connectionFactory

在这里我们需要注意的是加载配置文件的路径，classpath:rabbitmq.properties。

（2）创建监听器Listener负责监听对应的队列消息

我们创建一个默认普通的监听器，用来监听spring_queue队列中的消息。

监听器默认要实现MessageListener接口，并实现onMessage方法。

public class SpringQueueListener implements MessageListener {@Overridepublic void onMessage(Message message) {System.out.println("SpringQueueListener:" + new String(message.getBody()));}
}

（3）单元测试

@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations = "classpath:spring-rabbitmq-consumer.xml")
public class ConsumerTest {@Testpublic void test() {while (true) {}}
}

控制台：SpringQueueListener:hello world