spring-rabbit的使用

本文主要是介绍spring-rabbit的使用，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

目前mq中，spring对rabbit做了很好的封装。

rabbit有5种队列：简单队列、work队列、订阅模式、路由模式、通配符模式。

简单队列：生产者将消息发送到队列，消费者从队列中获取消息。

work队列：一个生产者、多个消费者。一个消息只能被一个消费者获取。

订阅模式：一个生产者、多个消费者。每一个消费者都有自己的一个队列，生产者没有将消息直接发送到队列，而是发送到了交换机，每个消费者队列都要绑定到交换机，生产者发送的消息，经过交换机，到达队列，实现，一个消息被多个消费者获取的目的。

使用订阅模式可以实现商品数据的同步，但由于不同系统需要的消息类型不同，比如商品缓存，那么insert 操作不需要通知，而其他系统insert操作可能需要通知。所以这种方式不是很好。

路由模式：在订阅模式的基础上，使用一个Routing key （路由Key），将Routing key绑定到交换机，哪种队列需要，就通知。

通配符模式：是在路由模式的基础上将Routing key用#和*，其中#匹配一个或多个词。*匹配一个词。

我们最终选用的模式就是路由模式。

我们使用spring和rabbit结合。

<dependency>
<groupId>org.springframework.amqp</groupId>
<artifactId>spring-rabbit</artifactId>
<version>1.6.0.RELEASE</version>
</dependency>

引入spring-rabbit的jar。

在后台系统的spring配置文件中添加如下配置：（注意要有xmlns:rabbit="http://www.springframework.org/schema/rabbit"）

<rabbit:connection-factory id="rabbitMQConnectionFactory"
host="${rabbitmq.host}" port="${rabbitmq.port}" username="${rabbitmq.username}" password="${rabbitmq.password}"
virtual-host="${rabbitmq.vhost}" />

<rabbit:admin connection-factory="rabbitMQConnectionFactory"/>

<rabbit:topic-exchange name="XXX" auto-declare="true" durable="true"></rabbit:topic-exchange>

<rabbit:template id="rabbitTemplate" connection-factory="rabbitMQConnectionFactory" exchange="XXX" />

后台系统没有定义前台系统或其他系统的队列。后台系统就算配好了。durable表示是否持久化，auto-declare表示当容器启动后调用rabbitTemplate方法后就会创建XXX交换机。

后台代码中一般在增删改方法中，调用rabbitTemplate.convertAndSend("Routing key",json字符串)。Routing key可以自定义，比如iteminfo.update表示将消息发送到exchange中与该iteminfo.update绑定的队列上

在前台系统中spring配置文件中添加如下配置：

<rabbit:connection-factory id="rabbitMQConnectionFactory"
host="${rabbitmq.host}" port="${rabbitmq.port}" username="${rabbitmq.username}" password="${rabbitmq.password}"
virtual-host="${rabbitmq.vhost}" />

<rabbit:admin connection-factory="rabbitMQConnectionFactory"/>

<rabbit:queue name="XXX-QUEUE" auto-declare="true" durable="true" />

<bean id="xxx" class="com.xxx.Xxx"></bean> Xxx类就是收到消息后要做的逻辑。我们假设这个类中有一个execute方法

<rabbit:listener-container connection-factory="rabbitMQConnectionFactory">
<rabbit:listener ref="xxx" method="execute" queue-names="XXX-QUEUE"/>
</rabbit:listener-container>

自定义一个Xxx类，里面有个execute（可以自定义）方法，专门做监听到消息后的处理，比如删除redis缓存操作。

这两个系统做如下配置后，其实还没有关联起来，即交换机要与队列绑定。在哪里做呢？在rabbit的管理界面。即15672端口的界面：

找到exchange里面的名为XXX的交换机，然后点击进去，找到bindings，然后添加要绑定的队列，并指定Routing key，比如iteminfo.update，并添加一个队列，比如XXX-QUEUE，这样就算绑定了。当后台修改后，会发送消息到交换机，交换机将消息发送到指定Routing key的队列，该队列由前台系统监听并接收后，执行execute方法。这个方法中的参数是一个json字符串，用ObjectMapper就可以进行解析。比如包含商品信息id等。

以上就是spring-rabbit的一个简单应用。

这篇关于spring-rabbit的使用的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！