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:listenerqueues="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进行编码。如果想要发送对象信息，按照类实例的序列化和反序列化进行操作即可。
页:
[1]