RabbitMQ与Spring整合

最近一直在玩rebbitMQ，终于抽时间可以写一下关于RebbitMQ与Spring框架整合的东西了。

安装消息队列环境

因为是自己玩，环境安装都是在Windows上进行的，总体来说过程比较简单，Linux上应该也差不多。

Windows上RabbitMQ的开发可以参考：https://www.jianshu.com/p/4c65827edbd1

消息队列安装完后，就可以开始整合测试了。

安装完毕之后可以按照以下说明进行配置，新建virtual-host，交换器和队列，当然这些都可以考代码新建及操作。
https://blog.csdn.net/u013177381/article/details/74011645

引入依赖

      <dependency>
            <groupId>org.springframework.amqp</groupId>
            <artifactId>spring-rabbit</artifactId>
            <version>1.6.5.RELEASE</version>
            <exclusions>
                <exclusion>
                    <artifactId>spring-context</artifactId>
                    <groupId>org.springframework</groupId>
                </exclusion>
            </exclusions>
        </dependency>

<!-- RabbitMQ -->
        <dependency>
            <groupId>com.rabbitmq</groupId>
            <artifactId>amqp-client</artifactId>
            <version>3.5.1</version>
        </dependency>

消息通信使用的是amqp协议通信，这里的<exclusion>是为防止spring包引入冲突

这样前期的准备工作就做好了，接下来就开始整合spring

spring配置

1. 首先是写一个RabbitMQ属性文件 rabbitMQ.properties :

rmq.ip=127.0.0.1
rmq.producer.num=20
rmq.port=5672
rmq.manager.user=guest
rmq.manager.password=guest

当然这是最基本的属性，可以在配置了MQ之后进行修改，如新建用户及密码等，guest仅限于本机访问。

2. spring引入properties文件：

<bean id="propertyConfigurer" class="com.trace.app.framework.toolsmodel.ConvertPwdPropertyConfigurer">
        <property name="locations">
            <list>
                <value>classpath:rabbitMQ.properties</value>
            </list>
        </property>
        <property name="fileEncoding" value="utf-8"></property>
    </bean>

3. 配置连接工厂
   以下给出两种方式，都可行：(提前使用控制台建立了virtual-host)

<rabbit:connection-factory id="connectionFactory" virtual-host="test" host="${rmq.ip}"
                               username="${rmq.manager.user}" password="${rmq.manager.password}" port="${rmq.port}"/>

<bean id="connectionFactory"  class="org.springframework.amqp.rabbit.connection.CachingConnectionFactory">
        <!--<constructor-arg value="localhost" />-->
        <property name="username" value="${rmq.manager.user}" />
        <property name="password" value="${rmq.manager.password}" />
        <property name="host" value="${rmq.ip}" />
        <property name="port" value="${rmq.port}" />
        <property name="virtualHost" value="test"/>
    </bean>

第一种形式是使用Spring提供的<rabbit:xxx>标签，主要有如下4中转发器类型标签
rabbit:fanout-exchange
rabbit:direct-exchange
rabbit:topic-exchange
rabbit:headers-exchange

接下来要声明消息队列管理员管理该连接工厂（同样是两种方法）

<!--<bean id="rabbitAdmin"  class="org.springframework.amqp.rabbit.core.RabbitAdmin">-->
        <!--<constructor-arg ref="connectionFactory" />-->
    <!--</bean>-->

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

还需要声明消息队列中的交换器和队列，这里我是直接在控制台建立了messageExchange交换器和messageQueue队列

<!-- 声明消息队列，消息系统监听队列 -->
    <!-- messageQueue 是在（1）中创建的队列 -->
    <rabbit:queue id="messageQueue" durable="true" auto-delete="false" exclusive="false" name="messageQueue"/>

    <!-- exchange queue binging key 绑定 -->
    <!--声明交换 在（1）配置的交换-->
    <rabbit:topic-exchange name="messageExchange" durable="true" auto-delete="false" id="messageExchange" >
        <rabbit:bindings>
            <rabbit:binding pattern="message.*" queue="messageQueue"/>
        </rabbit:bindings>
    </rabbit:topic-exchange>

    <rabbit:template exchange="messageExchange" id="rabbitTemplate" connection-factory="connectionFactory"/>

4. 声明生产者和消费者
   声明生产者和消费者，下面给出xml配置的声明方式，可以多个生产者和多个消费者。

<!--声明生产者 -->
    <bean id="messageSender"
          class="com.trace.app.framework.services.MessageSender" name="MessageSender">
        <property name="amqpTemplate" ref="rabbitTemplate"/>
        <!-- <property name="routingKey" value="message.test" ></property> -->
    </bean>
    <!--声明消费者 -->
    <bean id="messageConsumer" class="com.trace.app.framework.services.MessageConsumer" name="messageConsumer" />

还需要让消费者监听队列，做以下配置：

<rabbit:listener-container
            connection-factory="connectionFactory" acknowledge="auto">
        <!-- 让消费者监听这个队列 -->
        <rabbit:listener ref="messageConsumer" queues="messageQueue" />
    </rabbit:listener-container>

当然也可以使用注释的方法声明生产者和消费者对象，这里就不赘述了。

5. 测试
   自此spring的整合配置就完成了，再来贴出我的生产者和消费者的测试代码

生产者

/**
 * rabbitMQ生产者
 * */
@Service
public class MessageSender {

    private AmqpTemplate amqpTemplate;
    private String routingKey;

    public AmqpTemplate getAmqpTemplate() {
        return amqpTemplate;
    }

    public void setAmqpTemplate(AmqpTemplate amqpTemplate) {
        this.amqpTemplate = amqpTemplate;
    }

    public String getRoutingKey() {
        return routingKey;
    }

    public void setRoutingKey(String routingKey) {
        this.routingKey = routingKey;
    }

    public void sendDataToQueue(Object obj) {
        System.out.println("routingKey = " + this.routingKey);
        System.out.println("Obj = " + obj);
        amqpTemplate.convertAndSend(this.routingKey, obj);
    }
}

消费者

/**
 * rabbitMQ消费者
 * */
public class MessageConsumer implements MessageListener {

    private Logger logger = LoggerFactory.getLogger(MessageConsumer.class);


    @Override
    public void onMessage(Message message) {
        logger.info("receive message:{}",message);
    }
    
}

自此spring整合RabbitMQ的过程就结束了，在接下会介绍关于RabbitMQ生产者和消费者的具体事例，作为备忘参考。