RabbitMQ学习以及与Spring的集成(三)

小洪維尼

　　本文介绍RabbitMQ与Spring的简单集成以及消息的发送和接收。
　　在RabbitMQ的Spring配置文件中，首先需要增加命名空间。



xmlns:rabbit="http://www.springframework.org/schema/rabbit"
　　其次是模式文档，这里按1.0的来。



xsi:schemaLocation="
http://www.springframework.org/schema/rabbit
http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd"
　　配置connection-factory元素。



<rabbit:connection-factory id="connectionFactory"
username="mmq" password="mmq" host="192.168.1.138" port="5672" virtual-host="/vhost1" />
　　配置connection-factory元素实际是注册一个org.springframework.amqp.rabbit.connection.CachingConnectionFactory实例。
　　参数介绍:
　　id:bean的id值。
　　host:RabbitMQ服务器地址。默认值"localhost"。
　　port:RabbitMQ服务端口，默认值"5672"。
　　virtual-host:虚拟主机，默认是"/"。
　　username和password就是访问RabbitMQ服务的账户和密码了。
　　channel-cache-size:channel的缓存数量。新版本默认是25。
　　消息队列queue的配置。



<!--定义queue queueTest -->
<rabbit:queue name="queueTest" durable="true" auto-delete="false" exclusive="false"  />
　　参数介绍:
　　name:queue的名字。
　　durable:是否为持久的。默认是true，RabbitMQ重启后queue依然存在。
　　auto-delete:表示消息队列没有在使用时将被自动删除。默认是false。
　　exclusive:表示该消息队列是否只在当前connection生效。默认false。
　　交换器exchange的配置。



<rabbit:direct-exchange name="exchangeTest" durable="true" auto-delete="false">
<rabbit:bindings>
<rabbit:binding queue="queueTest" key="queueTestKey"></rabbit:binding>
</rabbit:bindings>
</rabbit:direct-exchange>
　　参数介绍:
　　name:exchange的名字。
　　durable:是否为持久的，默认为true，RabbitMQ重启后exhange依然存在。
　　auto-delete:表示exchange在未被使用时是否自动删除，默认是false。
　　key:queue在该direct-exchange中的key值。当消息发送给该direct-exchange中指定key为设置值时，消息将会转发给queue参数指定的消息队列。
　　Spring为方便使用RabbitMQ服务，提供一个操作模板类:org.springframework.amqp.rabbit.core.RabbitTemplate。



<rabbit:template id="amqpTemplate"  connection-factory="connectionFactory" exchange="exchangeTest" />
　　配置也很简单。template还有其他的配置项，可以自己查看xsd文件中的说明。
　　最后一个配置项是消息consumer。其实也可以叫做listener。简单的配置如下。



<rabbit:listener-container connection-factory="connectionFactory">
<rabbit:listener  queues="queueTest" ref="messageConsumer"/>
</rabbit:listener-container>
　　messageConsumer是一个简单bean类，可以用注解标识。



@Component("messageConsumer")
public class MessageConsumer implements MessageListener {
public void onMessage(Message message) {}  
}
　　类作为消息监听器，必须实现接口MessageListener或者是接口ChannelAwareMessageListener。
　　另一种配置方式是使用method参数，指定消息处理的方法，以org.springframework.amqp.core.Message类作为方法参数。
　　配置完成并写好消息监听处理类后就可以尝试发送消息了。



public class MessageProducer{
@Resource
private AmqpTemplate amqpTemplate;
public void sendMessage(){
Message message = MessageBuilder.withBody("hello rabbit".getBytes("utf-8"))
.setMessageId(System.currentTimeMillis()+"")
.build();
this.amqpTemplate.send("queueTestKey", message);
}  
}
　　消息监听方法。



public void onMessage(Message message){
String content = new String(message.getBody(),"utf-8");
system.out.println(content);
}
　　消息内容发送时会被转换为字节数组，默认以UTF-8进行编码。如果想要发送对象信息，按照类实例的序列化和反序列化进行操作即可。