上篇博客已经搭建了基本的RabbitMQ环境，接下来要把它整合到项目中,项目是基于SSM框架，首先需要引入依赖

    			
     
      org.springframework.amqp
     			
     
      spring-rabbit
     			
     
      1.4.5.RELEASE
     		
    

加入spring-rabbitmq.xml配置文件

创建消息监听类

package com.pactera.business.mq;import org.springframework.amqp.core.Message;import org.springframework.amqp.core.MessageListener;import org.springframework.stereotype.Component;import com.pactera.base.utils.JsonUtils;import com.pactera.business.bean.vo.UserInfoVo;@Componentpublic class QueueListenter implements MessageListener {	@Override	public void onMessage(Message msg) {		String message = new String(msg.getBody());		System.out.println(message);		UserInfoVo user = JsonUtils.jsonToPojo(message, UserInfoVo.class);		System.out.println(user.getUsername());	}}

创建发送消息类

package com.pactera.business.service.impl;import org.springframework.amqp.core.AmqpTemplate;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.stereotype.Service;import com.pactera.business.service.MQProducerService;@Servicepublic class MQProducerServiceImpl implements MQProducerService {	@Autowired	private AmqpTemplate amqpTemplate;	@Override	public void sendDataToQueue(String queueKey, Object object) {		// TODO Auto-generated method stub		 amqpTemplate.convertAndSend(queueKey, object);	}}

编写测试用例

package com.pactera.business.service;import org.junit.Test;import org.springframework.beans.factory.annotation.Autowired;import com.pactera.base.BaseTest;import com.pactera.business.bean.vo.UserInfoVo;public class QueueTest extends BaseTest {	@Autowired	MQProducerService mqProducerService;	final String queue_key = "test_queue_key";	@Test	public void send() {		UserInfoVo userInfo = new UserInfoVo();		userInfo.setUsername("zhangsan");		mqProducerService.sendDataToQueue(queue_key, userInfo);	}}

至此spring和RabbitMQ整合完毕