簡介

為了更好更快速的去開發Rabbitmq應用,spring封裝client ;目的是簡化我們的使用.

開發整合

maven依賴

org.springframework.amqp
spring-rabbit
1.7.5.RELEASE

生產者

public class SpringMain {
    public static void main(final String... args) throws Exception {
        AbstractApplicationContext ctx = new
 
 ClassPathXmlApplicationContext("classpath:context.xml");
        //RabbitMQ模板
        RabbitTemplate template = ctx.getBean(RabbitTemplate.class);
        //傳送訊息
        template.convertAndSend("Hello, world!");
        Thread.sleep(1000);// 休眠1秒
        ctx.destroy(); //容器銷燬
    }
}

消費者

public class MyConsumer {

    //具體執行業務的方法
 

    public void listen(String foo) {
        System.out.println("消費者： " + foo);
    }
}

Context.xml配置檔案

<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"
    xsi:schemaLocation="http://www.springframework.org/schema/rabbit
    http://www.springframework.org/schema/rabbit/spring-rabbit-1.4.xsd
    http://www.springframework.org/schema/beans
    http://www.springframework.org/schema/beans/spring-beans-4.0.xsd"
 
>

    <!—1.定義RabbitMQ的連線工廠 -->
    <rabbit:connection-factory id="connectionFactory"
        host="127.0.0.1" port="5672" username="user_mmr" password="admin"
        virtual-host="/vhost_mmr" />

    <!—2.定義Rabbit模板，指定連線工廠以及定義exchange -->
    <rabbit:template id="amqpTemplate" connection-factory="connectionFactory" exchange="fanoutExchange" />
    如果不想將訊息傳送到交換機 可以將它設定成佇列 將交換機刪除

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

    <!-- 定義佇列，自動宣告 -->
    <rabbit:queue name="myQueue" auto-declare="true" durable="true"/>

    <!-- 定義交換器，自動宣告 -->
    <rabbit:fanout-exchange name="fanoutExchange" auto-declare="true">
        <rabbit:bindings>
            <rabbit:binding queue="myQueue"/>
        </rabbit:bindings>
    </rabbit:fanout-exchange>

    <!-- 佇列監聽 -->
    <rabbit:listener-container connection-factory="connectionFactory">
        <rabbit:listener ref="foo" method="listen" queue-names="myQueue" />
    </rabbit:listener-container>

    <!-- 消費者 -->
    <bean id="foo" class="com.mmr.rabbitmq.spring.MyConsumer" />

</bean>