<!-- RabbitMQ -->
<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <
 
version>3.5.1</version>
</dependency>
<dependency>
    <groupId>org.springframework.amqp</groupId>
    <artifactId>spring-rabbit</artifactId>
    <version>1.4.5.RELEASE</version>
</dependency>

<?xml version
 
="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:rabbit="http://www.springframework.org/schema/rabbit"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:
 
util="http://www.springframework.org/schema/util"
xsi:schemaLocation="http://www.springframework.org/schema/rabbit
       http://www.springframework.org/schema/rabbit/spring-rabbit-1.5.xsd
       http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd
       http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd">

    <context:property-placeholder location="classpath*:/META-INF/env/*.properties" />

    <!--<util:properties id="appConfig" location="classpath:/META-INF/env/rabbit.properties"></util:properties>-->
    <!--配置connection-factory，指定連線rabbit server引數-->
<rabbit:connection-factory id="connectionFactory" username="guest" password="guest"
host="localhost"
port="5672"
virtual-host="/"/> <!-- virtual-host="/"是預設的虛擬機器路徑-->
    <!--通過指定下面的admin資訊，當前producer中的exchange和queue會在rabbitmq伺服器上自動生成-->
<rabbit:admin connection-factory="connectionFactory"/>

    <!--定義queue-->
<rabbit:queue id="com.mj.test" name="com.mj.test" durable="true" auto-delete="false" exclusive="false"/>

    <!-- 定義direct exchange，繫結com.mj.test queue -->
<rabbit:direct-exchange name="myChange" durable="true" auto-delete="false">
        <rabbit:bindings>
            <rabbit:binding queue="com.mj.test" key="testKey"></rabbit:binding>
        </rabbit:bindings>
    </rabbit:direct-exchange>

    <!--定義rabbit template用於資料的接收和傳送-->
<rabbit:template id="amqpTemplate" connection-factory="connectionFactory" exchange="myChange" />

    <bean id="messageReceiver" class="com.hp.netpro.rf.web.utils.RabbitMQConsumer"/>

    <rabbit:listener-container connection-factory="connectionFactory">
        <rabbit:listener queues="com.mj.test" ref="messageReceiver"/>
    </rabbit:listener-container>

</beans>

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans
       http://www.springframework.org/schema/beans/spring-beans.xsd
       http://www.springframework.org/schema/context
       http://www.springframework.org/schema/context/spring-context.xsd
       http://www.springframework.org/schema/aop
       http://www.springframework.org/schema/aop/spring-aop.xsd">

    <import resource="classpath*:/META-INF/spring/spring-api-mybatis.xml" />
    <import resource="classpath*:/META-INF/spring/spring-rabbit.xml" />
    <!--<import resource="/META-INF/spring/spring-rabbit.xml"/>-->
    <!-- 使能AOP-->
<aop:aspectj-autoproxy/>
    <!-- 自動裝載bean使能-->
<context:component-scan base-package="com.hp.netpro.rf.web.utils"/>
    <context:annotation-config/>

    <context:property-placeholder location="classpath*:/META-INF/env/*.properties" />
    <!--<util:properties id="appConfig" location="classpath:/META-INF/env/rabbit.properties"></util:properties>-->

    <!-- 啟用annotation功能 -->
<context:spring-configured />

</beans>

packagecom.hp.netpro.rf.web.utils;importorg.springframework.amqp.core.AmqpTemplate;importorg.springframework.stereotype.Service;importjavax.annotation.Resource;/** * @Description:訊息生產者 * @Author:*@CreateTime:*/@Servicepublic classRabbitMQProducer {@ResourceprivateAmqpTemplateamqpTemplate;public voidsendMessage(Object message){amqpTemplate.convertAndSend("testKey",message);//testKey為配置檔案中queue對應的key,指明發送給哪個queue。    }}

package com.hp.netpro.rf.web.utils;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageListener;
import org.springframework.stereotype.Service;
/** * @Description:訊息佇列接收者 * @Author:*@CreateTime:*/@Servicepublic class RabbitMQConsumerimplementsMessageListener {public voidonMessage(Message message) {
       System.out.println("訊息！");
       System.out.println(message);
       System.out.println("訊息getMessageProperties！");
       System.out.println(message.getMessageProperties());
       System.out.println("訊息getBody");
       System.out.println(message.getBody());

    }
}

/** * @Description:訊息佇列 * @Author:*@CreateTime:

*/

@Resource
private RabbitMQProducer rabbitMQProducer; //注意：這裡必須以這種注入的方式 不能使用new來建立物件，

@ResponseBody@RequestMapping("/sendMessage")publicString testQueue() {try{rabbitMQProducer.sendMessage("I am amq sender");return"傳送完畢";    }catch(Exception e){        e.printStackTrace();return"傳送失敗！！";    }}