RabbitMQ學習之基於spring-rabbitmq的消息異步發送

spring-rabbitmq的源碼到http://github.com/momania/spring-rabbitmq下載，並可以下載實例代碼。由於我使用的rabbitmq版本是3.0.4，部分代碼做了調整。

具體實例如下（創建自動刪除非持久隊列）：

1.資源配置application.properties

 

#============== rabbitmq config ====================
rabbit.hosts=192.168.36.102
rabbit.username=admin
rabbit.password=admin
rabbit.virtualHost=/
rabbit.exchange=spring-queue-async
rabbit.queue=spring-queue-async
rabbit.routingKey=spring-queue-async

2..發送端配置applicationContext-rabbitmq-async-send.xml

 

 

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

     <context:property-placeholder location="classpath:application.properties"/>

     <bean id="rabbitConnectionFactory" class="com.rabbitmq.spring.connection.RabbitConnectionFactory">
        <property name="connectionFactory">
            <bean class="com.rabbitmq.client.ConnectionFactory">
               <property name="username" value="${rabbit.username}"/>
               <property name="password" value="${rabbit.password}"/>
               <property name="virtualHost" value="${rabbit.virtualHost}"/>
            </bean>
        </property>
        <property name="hosts" value="${rabbit.hosts}"/>
    </bean>
     <bean id="rabbitChannelFactory" class="com.rabbitmq.spring.channel.RabbitChannelFactory">
        <property name="connectionFactory" ref="rabbitConnectionFactory"/>
    </bean>

    <bean id="rabbitTemplate" class="com.rabbitmq.spring.template.ASyncRabbitTemplate">
        <property name="channelFactory" ref="rabbitChannelFactory"/>
        <property name="exchange" value="${rabbit.exchange}"/>
        <property name="routingKey" value="${rabbit.routingKey}"/>
        <!--optional-->
        <property name="exchangeType" value="TOPIC"/>
<!--         mandatory是否強制發送       -->
        <property name="mandatory" value="false"/>
<!--         immediate是否立即發送   -->
        <property name="immediate" value="false"/>
    </bean>

</beans>

3.接收端配置applicationContext-rabbitmq-async-receive.xml

 

 

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

     <context:property-placeholder location="classpath:application.properties"/>

     <bean id="rabbitConnectionFactory" class="com.rabbitmq.spring.connection.RabbitConnectionFactory">
        <property name="connectionFactory">
            <bean class="com.rabbitmq.client.ConnectionFactory">
               <property name="username" value="${rabbit.username}"/>
               <property name="password" value="${rabbit.password}"/>
               <property name="virtualHost" value="${rabbit.virtualHost}"/>
            </bean>
        </property>
        <property name="hosts" value="${rabbit.hosts}"/>
    </bean>
     <bean id="rabbitChannelFactory" class="com.rabbitmq.spring.channel.RabbitChannelFactory">
        <property name="connectionFactory" ref="rabbitConnectionFactory"/>
    </bean>

    <bean id="receiveMsgHandler" class="cn.slimsmart.rabbitmq.spring.rabbitmq.demo.async.ReceiveMsgHandler"/>

     <bean id="quotingParamtersTopicAdapter" class="com.rabbitmq.spring.listener.RabbitMessageListenerAdapter">
        <property name="channelFactory" ref="rabbitChannelFactory"/>
        <property name="delegate" ref="receiveMsgHandler"/>
        <property name="listenerMethod" value="handleMessage"/>
        <property name="exchange" value="${rabbit.exchange}"/>
        <!--optional-->
        <property name="exchangeType" value="TOPIC"/>
        <property name="routingKey" value="${rabbit.routingKey}"/>
        <property name="queueName" value="${rabbit.queue}"/>
        <property name="poolsize" value="5"/>
    </bean>
</beans>

 

 

4.消息處理服務ReceiveMsgHandler.Java

 

package cn.slimsmart.rabbitmq.spring.rabbitmq.demo.async;

public class ReceiveMsgHandler {

    public void handleMessage(String text) {
        System.out.println("Received: " + text);
    }
}

5.發送端啟動代碼Send.java

 

 

package cn.slimsmart.rabbitmq.spring.rabbitmq.demo.async;

import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.rabbitmq.spring.template.ASyncRabbitTemplate;

public class Send {

    public static void main(String[] args) throws InterruptedException {
        ApplicationContext context = new ClassPathXmlApplicationContext("applicationContext-rabbitmq-async-send.xml");
        ASyncRabbitTemplate amqpTemplate = context.getBean(ASyncRabbitTemplate.class);
        for(int i=0;i<10000;i++){
            amqpTemplate.send("test spring async=>"+i);
            Thread.sleep(100);
        }
    }
}

6.接收端啟動代碼Send.java

 

 

package cn.slimsmart.rabbitmq.spring.rabbitmq.demo.async;

import org.springframework.context.support.ClassPathXmlApplicationContext;

public class Receive {

    public static void main(String[] args) {
         new ClassPathXmlApplicationContext("applicationContext-rabbitmq-async-receive.xml");
    }
}

先啟動接收端，再啟動發送端。接收到消息如下：

 

 

Received: test spring async=>0
Received: test spring async=>1
Received: test spring async=>2
Received: test spring async=>3
Received: test spring async=>4
Received: test spring async=>5
Received: test spring async=>6
Received: test spring async=>7
......

 

實例代碼：http://download.csdn.net/detail/tianwei7518/8135637