Java使用RabbitMQ之整合Spring（消費者）

 依賴包：

        <!--RabbitMQ集成spring-->
        <!-- https://mvnrepository.com/artifact/org.springframework.amqp/spring-rabbit -->
        <dependency>
            <groupId>org.springframework.amqp</groupId>
            <artifactId>spring-rabbit</artifactId>
            <version>2.0.6.RELEASE</version>
        </dependency>

 

消息者Spring配置文件

<?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:rabbit="http://www.springframework.org/schema/rabbit"
       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/rabbit
                http://www.springframework.org/schema/rabbit/spring-rabbit-1.0.xsd">

    <!-- 連接服務配置 -->
    <rabbit:connection-factory id="connectionFactory"
                               host="10.15.1.26" username="admin" password="admin" port="5672"
                               virtual-host="/test_host" channel-cache-size="5"/>

    <!--MQ的管理，包括隊列、交換器的聲明等-->
    <rabbit:admin connection-factory="connectionFactory"/>

    <!-- queue 隊列聲明 -->
    <rabbit:queue durable="true"
                  auto-delete="false" exclusive="false" name="test.spring.queue"/>

    <!-- exchange queue binging key 綁定 -->
    <rabbit:direct-exchange name="spring.exchange"
                            durable="true" auto-delete="false">
        <rabbit:bindings>
            <rabbit:binding queue="test.spring.queue" key="spring.queue.key"/>
        </rabbit:bindings>
    </rabbit:direct-exchange>

    <!-- spring template聲明 -->
    <rabbit:template id="amqpTemplate" exchange="spring.exchange" routing-key="spring.queue.key"
                     connection-factory="connectionFactory"/>


    <!-- 監聽生產者發送的消息開始 -->

    <!-- 聲明消息轉換器為SimpleMessageConverter -->
    <bean id="messageConverter"
          class="org.springframework.amqp.support.converter.SimpleMessageConverter">
    </bean>

    <!-- 用於接收消息的處理類 -->
    <bean id="myListener" class="org.study.model.MyListener"/>

    <!-- 用於消息的監聽的代理類MessageListenerAdapter -->
    <bean id="receiveListenerAdapter"
          class="org.springframework.amqp.rabbit.listener.adapter.MessageListenerAdapter">
        <constructor-arg ref="myListener" />
        <property name="defaultListenerMethod" value="onMessage"></property>
    </bean>

    <!-- 用於消息的監聽的容器類SimpleMessageListenerContainer，對於queueName的值一定要與定義的Queue的值相同 -->
    <bean id="listenerContainer"
          class="org.springframework.amqp.rabbit.listener.SimpleMessageListenerContainer">
        <property name="queueNames" value="test.spring.queue"></property>
        <property name="connectionFactory" ref="connectionFactory"></property>
        <property name="messageListener" ref="receiveListenerAdapter"></property>
    </bean>

</beans>

 

消費者消息處理代碼：

package org.study.model;

/**
 * RabbitMQ與Spring整合
 * 消費者消息處理類
 */
public class MyListener {
    public void onMessage(String message) {
        System.out.println(" [RECV] : " + message);
    }

}

 

運行代碼：

package org.study.spring5;

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

/**
 * RabbitMQ與Spring整合
 * 消費者
 */
public class SpringConsumer {

    public static void main(String args[]) {
        ApplicationContext applicationContext = new ClassPathXmlApplicationContext("spring/consumer-spring-config.xml");

    }
}