3.2.2 Log4j Appender

3.2.3 Log4j2 Appender

3.2.4 Logback Appender

3.2.5 定制Messages

簡(jiǎn)化 String 屬性

Log4j和logback先進(jìn)技術(shù)

3.3 樣例應(yīng)用程序

3.3.1 介紹

3.3.2 Hello World

介紹

在src/main/java 目錄中，導(dǎo)航到org.springframework.amqp.helloworld 包中.

打開HelloWorldConfiguration 類，你可以注意到它包含了@Configuration 類級(jí)注解和一些@Bean 方法級(jí)注解. 

這是Spring 的基于Java的配置．你可進(jìn)一步的了解here.

@Bean

public ConnectionFactory connectionFactory() {
    CachingConnectionFactory connectionFactory =null;
    connectionFactory =new CachingConnectionFactory("localhost");
    connectionFactory.setUsername("guest");
    connectionFactory.setPassword("guest");
    return connectionFactory;
}

配置中同樣也包含了RabbitAdmin的實(shí)例, 它會(huì)默認(rèn)查找類型為Exchange, Queue, 或 Binding的bean并在broker中進(jìn)行聲明.
事實(shí)上,"helloWorldQueue" bean是在HelloWorldConfiguration 中生成的，因?yàn)樗?Queue的實(shí)例.

@Bean

public Queue helloWorldQueue() {
    returnnew Queue(this.helloWorldQueueName);
}

重看"rabbitTemplate"bean配置,你會(huì)看到它將helloWorldQueue的名稱設(shè)成了"queue"屬性(用于接收消息) 以及"routingKey" 屬性(用于發(fā)送消息).

publicstaticvoid main(String[] args) {

    ApplicationContext context =
        new AnnotationConfigApplicationContext(HelloWorldConfiguration.class);
    AmqpTemplate amqpTemplate = context.getBean(AmqpTemplate.class);
    amqpTemplate.convertAndSend("Hello World");
    System.out.println("Sent: Hello World");
}

在上面的例子中你可以看到， 取回的AmqpTemplate用來(lái)發(fā)送消息.因?yàn)榭蛻舳舜a應(yīng)該盡可能地依賴于接口，因此類型是AmqpTemplate而不是RabbitTemplate.
即使在HelloWorldConfiguration中創(chuàng)建的bean是RabbitTemplate的實(shí)例,依賴于接口則意味著這端代碼更具有便攜性(portable) (配置可以獨(dú)立于代碼進(jìn)行修改).
因?yàn)閏onvertAndSend() 方法是通過(guò)模板來(lái)調(diào)用的，因此模板會(huì)將調(diào)用委派給它的MessageConverter實(shí)例.在這種情況下,它默認(rèn)使用的是SimpleMessageConverter,但也可以在HelloWorldConfiguration中為"rabbitTemplate"指定其它的實(shí)現(xiàn).

現(xiàn)在打開Consumer類. 它實(shí)際上共享了同一個(gè)配置基類，這意味著它將共享"rabbitTemplate" bean. 這就是為什么我們要使用"routingKey" (發(fā)送) 和"queue" (接收)來(lái)配置模板的原因.
正如你在Section 3.1.4, “AmqpTemplate”中看到的,你可以代替在發(fā)送方法中傳遞routingKey參數(shù)，代替在接收方法中傳遞queue 參數(shù)．  Consumer 代碼基本上是Producer的鏡子,只不過(guò)調(diào)用的是receiveAndConvert()而非convertAndSend()方法.

publicstaticvoid main(String[] args) {
    ApplicationContext context =
        new AnnotationConfigApplicationContext(RabbitConfiguration.class);
    AmqpTemplate amqpTemplate = context.getBean(AmqpTemplate.class);
    System.out.println("Received: " + amqpTemplate.receiveAndConvert());
}

你如果運(yùn)行Producer,然后再運(yùn)行Consumer, 在控制臺(tái)輸出中，你應(yīng)該能看到消息"Received: Hello World" 

我們已經(jīng)講解了同步Hello World樣例, 是時(shí)候移動(dòng)到一個(gè)稍微先進(jìn)，但更強(qiáng)大的選擇上了.稍微修改一下代碼，Hello World 樣例就可以可以提供異步接收的示例了,又名 Message-driven POJOs. 事實(shí)上,有一個(gè)子包明確地提供了這種功能: org.springframework.amqp.samples.helloworld.async.

再一次地我們將從發(fā)送端開始. 打開ProducerConfiguration類可注意到它創(chuàng)建了一個(gè)"connectionFactory"和"rabbitTemplate" bean.
這次，由于配置是專用于消息發(fā)送端，因此我們不需要任何隊(duì)列定義,RabbitTemplate只須設(shè)置routingKey屬性.
回想一下，消息是發(fā)送到交換器上的而不是直接發(fā)到隊(duì)列上的. AMQP默認(rèn)交換器是無(wú)名稱的direct類型交換器.
所有隊(duì)列都是通過(guò)使用它們的名稱作為路由鍵綁定到默認(rèn)交換器上的.這就是為什么在這里我們只提供路由鍵的原因．

public RabbitTemplate rabbitTemplate() {
    RabbitTemplate template = new RabbitTemplate(connectionFactory());
    template.setRoutingKey(this.helloWorldQueueName);
    return template;
}

由于這個(gè)示例展示的是異步消息處理，生產(chǎn)方設(shè)計(jì)為連續(xù)發(fā)送消息(盡管類似于同步版本中的 message-per-execution模型,但不太明顯，實(shí)際上它是消息驅(qū)動(dòng)消費(fèi)者)負(fù)責(zé)連續(xù)發(fā)送消息的組件是作為ProducerConfiguration類中的內(nèi)部類來(lái)定義的，每３秒執(zhí)行一次．

static　class ScheduledProducer {

   @Autowired

　private　volatile RabbitTemplate rabbitTemplate;

    private　final AtomicInteger counter = new AtomicInteger();

    @Scheduled(fixedRate = 3000)

　public　void sendMessage() {
        rabbitTemplate.convertAndSend("Hello World " + counter.incrementAndGet());
    }
}

你不必要完全了解這些細(xì)節(jié)，因?yàn)檎嬲年P(guān)注點(diǎn)是接收方(我們馬上就會(huì)講解).然而，如果你還熟悉Spring 3.0 任務(wù)調(diào)度支持,你可從here這里來(lái)了解.
簡(jiǎn)短故事是：在 ProducerConfiguration 中的"postProcessor" bean使用調(diào)度器來(lái)注冊(cè)了任務(wù).

現(xiàn)在，讓我們轉(zhuǎn)向接收方. 為強(qiáng)調(diào) Message-driven POJO 行為，將從對(duì)消息起反應(yīng)的組件開始. 

此類被稱為HelloWorldHandler.

publicclass HelloWorldHandler {

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

}

相當(dāng)明顯的, 這是一個(gè)POJO. 它沒(méi)有繼承任何基類,它沒(méi)有實(shí)現(xiàn)任何接口,它甚至不包含任何導(dǎo)入. 它將通過(guò)Spring AMQP MessageListenerAdapter來(lái)適配MessageListener接口.然后適配器可配置在SimpleMessageListenerContainer上.
在這個(gè)例子中，容器是在ConsumerConfiguration類中創(chuàng)建的.你可以看到POJO是包裝在適配器中的.

@Bean

public SimpleMessageListenerContainer listenerContainer() {
    SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
    container.setConnectionFactory(connectionFactory());
    container.setQueueName(this.helloWorldQueueName);
    container.setMessageListener(new MessageListenerAdapter(new HelloWorldHandler()));
    return container;
}

SimpleMessageListenerContainer是一個(gè)Spring生命周期組件，默認(rèn)會(huì)自動(dòng)啟動(dòng).如果你看了Consumer類的內(nèi)部,你會(huì)看到main()方法中除了一行啟動(dòng)創(chuàng)建ApplicationContext的代碼外，其它什么都沒(méi)有.
Producer的main()方法也只有一行啟動(dòng),因?yàn)橐?@Scheduled注解的組件會(huì)自動(dòng)開始執(zhí)行.你可以任何順序來(lái)啟動(dòng)Producer 和Consumer,你會(huì)看每秒就會(huì)發(fā)送消息和接收到消息．

Stock Trading 示例演示了比Hello World示例更高級(jí)的消息場(chǎng)景.然而，配置卻是很相似的 - 只是有一點(diǎn)復(fù)雜.
由于我們已經(jīng)詳細(xì)講解了Hello World配置,因此在這里我們將重點(diǎn)關(guān)注不一樣的東西. 有一個(gè)服務(wù)器發(fā)送市場(chǎng)數(shù)據(jù)(股票報(bào)價(jià))到Topic交換器中.
然后，客戶端可訂閱市場(chǎng)數(shù)據(jù)，即通過(guò)使用路由模式(如. "app.stock.quotes.nasdaq.*")來(lái)綁定隊(duì)列(e.g. "app.stock.quotes.nasdaq.*").
這個(gè)例子的其它主要功能是 有一個(gè)請(qǐng)求回復(fù)“股票交易”的互動(dòng)，它是由客戶發(fā)起并由服務(wù)器來(lái)處理的. 這涉及到一個(gè)私有的“回復(fù)(replyTo)”隊(duì)列，發(fā)送客戶端的信息在請(qǐng)求消息中。

服務(wù)器的核心配置在RabbitServerConfiguration類中(位于 org.springframework.amqp.rabbit.stocks.config.server 包中).
它繼承了 AbstractStockAppRabbitConfiguration. 這是服務(wù)器和客戶端定義常用資源的地方，包括市場(chǎng)數(shù)據(jù)Topic交換器(其名稱為app.stock.marketdata) 以及服務(wù)器公開股票交易的隊(duì)列(其名稱為app.stock.request).
在那個(gè)公共配置文件中,你會(huì)看到在RabbitTemplate上配置了一個(gè)JsonMessageConverter．

服務(wù)器特有配置由２部分組成.首先，它在RabbitTemplate上配置了市場(chǎng)數(shù)據(jù)交換器，這樣在發(fā)送消息時(shí)，就不必提供交換器名稱．它是通過(guò)基礎(chǔ)配置類中的抽象回調(diào)方法中定義做到這一點(diǎn)的．

public　void configureRabbitTemplate(RabbitTemplate rabbitTemplate) {
    rabbitTemplate.setExchange(MARKET_DATA_EXCHANGE_NAME);
}

其次, 聲明了股票請(qǐng)求隊(duì)列.在這里，它不需要任何明確的綁定，因?yàn)樗鼘⒁运约旱拿Q作為路由鍵來(lái)綁定到無(wú)名稱的默認(rèn)交換器上.正如先前提到的，AMQP規(guī)范定義了此種行為.

@Beanpublic Queue stockRequestQueue() {
    returnnew Queue(STOCK_REQUEST_QUEUE_NAME);
}

現(xiàn)在你已經(jīng)看過(guò)了服務(wù)器的AMQP資源配置，導(dǎo)航到src/test/java目錄下的org.springframework.amqp.rabbit.stocks包.在那里你會(huì)實(shí)際的 提供了main()方法的Server類．
它基于server-bootstrap.xml 創(chuàng)建了一個(gè)ApplicationContext.在那里，你會(huì)看到發(fā)布虛假市場(chǎng)數(shù)據(jù)的調(diào)度任務(wù).

那個(gè)配置依賴于Spring 3.0的"task"命名空間支持.bootstrap配置文件也導(dǎo)入了其它一些文件.最令人關(guān)注的是位于src/main/resources目錄下的server-messaging.xml.在那里，你會(huì)看到"messageListenerContainer" bean，它負(fù)責(zé)處理股票交易請(qǐng)求.
最后在看一下定義在src/main/resources目錄下的server-handlers.xml，其中定義了一個(gè) "serverHandler" bean.這個(gè)bean是ServerHandler類的實(shí)例，它是Message-driven POJO 的好例子，它也有發(fā)送回復(fù)消息的能力.
注意，它自身并沒(méi)有與框架或任何AMQP概念耦合.它只是簡(jiǎn)單地接受TradeRequest并返回一個(gè)TradeResponse.

public TradeResponse handleMessage(TradeRequest tradeRequest) { ...
}

現(xiàn)在我們已經(jīng)看了服務(wù)端的重要配置和代碼，讓我們轉(zhuǎn)向客戶端．最佳起點(diǎn)是從 org.springframework.amqp.rabbit.stocks.config.client 包下的RabbitClientConfiguration開始. 

注意，它聲明了兩個(gè)不帶明確參數(shù)的隊(duì)列．

@Bean

public Queue marketDataQueue() {
    return amqpAdmin().declareQueue();
}

@Bean

public Queue traderJoeQueue() {
    return amqpAdmin().declareQueue();
}

那些是私有隊(duì)列, 唯一名稱會(huì)自動(dòng)自成.客戶端會(huì)用第一個(gè)生成的隊(duì)列來(lái)綁定由服務(wù)端公開的市場(chǎng)交換器.
記住在AMQP中,消費(fèi)者與隊(duì)列交互，而生產(chǎn)者與交換器交互. 隊(duì)列和交換器之間的綁定指示broker從給定的交換器中投遞或路由什么消息給隊(duì)列.
由于市場(chǎng)交換器是一個(gè)Topic交換器,綁定可通過(guò)路由正則表達(dá)式來(lái)表達(dá). 

RabbitClientConfiguration聲明了一個(gè)Binding對(duì)象,其對(duì)象是通過(guò)BindingBuilder的便利API來(lái)生成的.

@Value("${stocks.quote.pattern}")

private String marketDataRoutingKey;

@Bean

public Binding marketDataBinding() {
    return BindingBuilder.bind(
        marketDataQueue()).to(marketDataExchange()).with(marketDataRoutingKey);
}

注意，實(shí)際值已經(jīng)在屬性文件(src/main/resources目錄下的"client.properties")中外部化了,因此我們使用Spring的@Value 注解來(lái)注入值.這通常是一個(gè)好主意，否則值就會(huì)硬編碼在類中，沒(méi)有修改就沒(méi)有重新編譯.

在這種情況下，通過(guò)修改綁定中的路由正則表達(dá)式，可很容易地運(yùn)行多個(gè)版本的Client．讓我們立即嘗試．

啟動(dòng)運(yùn)行org.springframework.amqp.rabbit.stocks.Server然后再運(yùn)行 org.springframework.amqp.rabbit.stocks.Client.你將會(huì)看到NASDAQ股票的交易報(bào)價(jià)，因?yàn)殛P(guān)聯(lián)stocks.quote.pattern 鍵的值在client.properties中是app.stock.quotes.nasdaq.
現(xiàn)在，保持現(xiàn)有Server 和Client 運(yùn)行，將其屬性值修改為app.stock.quotes.nyse.再啟動(dòng)第二個(gè)Client實(shí)例.你會(huì)看到第一個(gè)client仍然接收NASDAQ 報(bào)價(jià)，而第二個(gè)client接收的NYSE報(bào)價(jià). 你可以改變模式，獲取所有的股票報(bào)價(jià)或個(gè)別股票的報(bào)價(jià)。

最后一個(gè)我們將暴露的特性是從客戶端的角度來(lái)看待請(qǐng)求－回復(fù)交互.記住我們已經(jīng)看了ServerHandler，它會(huì)接受TradeRequest對(duì)象并返回TradeResponse對(duì)象. 客戶端相應(yīng)的代碼是 RabbitStockServiceGateway（位于org.springframework.amqp.rabbit.stocks.gateway 包).為發(fā)送消息，它會(huì)委派給RabbitTemplate.

public　void send(TradeRequest tradeRequest) {
    getRabbitTemplate().convertAndSend(tradeRequest, new MessagePostProcessor() {
        public Message postProcessMessage(Message message) throws AmqpException {
            message.getMessageProperties().setReplyTo(new Address(defaultReplyToQueue));
            try {
                message.getMessageProperties().setCorrelationId(
                    UUID.randomUUID().toString().getBytes("UTF-8"));
            }
            catch (UnsupportedEncodingException e) {
                thrownew AmqpException(e);
            }
            return message;
        }
    });
}

注意，在發(fā)送消息前，它設(shè)置了"replyTo"地址． 這提供了隊(duì)列，此隊(duì)列是由上面的"traderJoeQueue" bean 定義生成的. 以下是StockServiceGateway類的@Bean定義.

@Bean

public StockServiceGateway stockServiceGateway() {
    RabbitStockServiceGateway gateway = new RabbitStockServiceGateway();
    gateway.setRabbitTemplate(rabbitTemplate());
    gateway.setDefaultReplyToQueue(traderJoeQueue());
    return gateway;
}

如果你沒(méi)有運(yùn)行服務(wù)器和客戶端，現(xiàn)在就啟動(dòng)它們. 嘗試使用100 TCKR的格式來(lái)發(fā)送請(qǐng)求．經(jīng)過(guò)一個(gè)簡(jiǎn)短的人工延遲來(lái)模擬“處理”請(qǐng)求，你應(yīng)該看到一個(gè)確認(rèn)消息出現(xiàn)在客戶端上。

3.4 測(cè)試支持

3.4.1 介紹

第一個(gè), LatchCountDownAndCallRealMethodAnswer 提供了返回null和計(jì)數(shù)下一個(gè)鎖存器的Answer<Void>.

LatchCountDownAndCallRealMethodAnswer answer = new LatchCountDownAndCallRealMethodAnswer(2);
doAnswer(answer)
    .when(listener).foo(anyString(), anyString());

...

assertTrue(answer.getLatch().await(10, TimeUnit.SECONDS));

第二個(gè)， LambdaAnswer<T> 提供了一種調(diào)用真正方法的機(jī)制，并提供機(jī)會(huì)來(lái)返回定制結(jié)果（基于InvocationOnMock和結(jié)果）.

public　class Foo {

    public String foo(String foo) {
        return foo.toUpperCase();
    }

}

Foo foo = spy(new Foo());

doAnswer(new LambdaAnswer<String>(true, (i, r) -> r + r))
    .when(foo).foo(anyString());
assertEquals("FOOFOO", foo.foo("foo"));

doAnswer(new LambdaAnswer<String>(true, (i, r) -> r + i.getArguments()[0]))
    .when(foo).foo(anyString());
assertEquals("FOOfoo", foo.foo("foo"));

doAnswer(new LambdaAnswer<String>(false, (i, r) ->
    "" + i.getArguments()[0] + i.getArguments()[0])).when(foo).foo(anyString());
assertEquals("foofoo", foo.foo("foo"));

When using Java 7 or earlier:

doAnswer(new LambdaAnswer<String>(true, new ValueToReturn<String>() {
    @Overridepublic String apply(InvocationOnMock i, String r) {
        return r + r;
    }
})).when(foo).foo(anyString());

在你的@Configuration 類中使用 @RabbitListenerTest (它也會(huì)通過(guò)@EnableRabbit來(lái)啟用@RabbitListener 探測(cè)).注解會(huì)導(dǎo)致框架使用子類RabbitListenerTestHarness來(lái)代替標(biāo)準(zhǔn)RabbitListenerAnnotationBeanPostProcessor．

RabbitListenerTestHarness 通過(guò)兩種方式來(lái)增強(qiáng)監(jiān)聽器 - 將其包裝進(jìn)Mockito Spy, 啟用了Mockito 存根和驗(yàn)證操作．也可在監(jiān)聽器添加Advice 來(lái)啟用對(duì)參數(shù)，結(jié)果或異常的訪問(wèn).
你可以控制哪一個(gè)(或兩個(gè))來(lái)在@RabbitListenerTest上啟用屬性. 后者用于訪問(wèn)調(diào)用中更為低級(jí)數(shù)據(jù)- 它也支持測(cè)試線程阻塞，直到異步監(jiān)聽器被調(diào)用.

重要

final @RabbitListener 不能被發(fā)現(xiàn)或通知 ，同時(shí)，只有帶id屬性的監(jiān)聽器才能發(fā)現(xiàn)或通知．

讓我們看一些例子.

使用spy:

@Configuration

@RabbitListenerTest

public　class Config {

    @Bean

　public Listener listener() {
        returnnew Listener();
    }

    ...

}

public　class Listener {

    @RabbitListener(id="foo", queues="#{queue1.name}")

　public String foo(String foo) {
        return foo.toUpperCase();
    }

    @RabbitListener(id="bar", queues="#{queue2.name}")

　public　void foo(@Payload String foo, @Header("amqp_receivedRoutingKey") String rk) {
        ...
    }

}

public　class MyTests {

    @Autowired

    private RabbitListenerTestHarness harness;

@Test

　public　void testTwoWay() throws Exception {
        assertEquals("FOO", this.rabbitTemplate.convertSendAndReceive(this.queue1.getName(), "foo"    ));

        Listener listener = this.harness.getSpy("foo"); 
        assertNotNull(listener);
        verify(listener).foo("foo");
    }

    @Test

public　void testOneWay() throws Exception {
        Listener listener = this.harness.getSpy("bar");
        assertNotNull(listener);

        LatchCountDownAndCallRealMethodAnswer answer = new LatchCountDownAndCallRealMethodAnswer(2); 
        doAnswer(answer).when(listener).foo(anyString(), anyString());

　　this.rabbitTemplate.convertAndSend(this.queue2.getName(), "bar");

　　this.rabbitTemplate.convertAndSend(this.queue2.getName(), "baz");

        assertTrue(answer.getLatch().await(10, TimeUnit.SECONDS));
        verify(listener).foo("bar", this.queue2.getName());
        verify(listener).foo("baz", this.queue2.getName());
    }

}

@Configuration

@ComponentScan

@RabbitListenerTest(spy = false, capture = true)

public　class Config {

}

@Service

public　class Listener {

    private　boolean failed;

    @RabbitListener(id="foo", queues="#{queue1.name}")

　public String foo(String foo) {
        return foo.toUpperCase();
    }

    @RabbitListener(id="bar", queues="#{queue2.name}")

public　void foo(@Payload String foo, @Header("amqp_receivedRoutingKey") String rk) {
        if (!failed && foo.equals("ex")) {
            failed = true;
            thrownew RuntimeException(foo);
        }
        failed = false;
    }

}

public　class MyTests {

    　@Autowired

　　private RabbitListenerTestHarness harness; 

　　@Test

　　public　void testTwoWay() throws Exception {
        assertEquals("FOO", this.rabbitTemplate.convertSendAndReceive(this.queue1.getName(), "foo"　　));

        InvocationData invocationData =
            this.harness.getNextInvocationDataFor("foo", 0, TimeUnit.SECONDS); 
        assertThat(invocationData.getArguments()[0], equalTo("foo"));     
        assertThat((String) invocationData.getResult(), equalTo("FOO"));
    }

    @Test

　　public　void testOneWay() throws Exception {
        this.rabbitTemplate.convertAndSend(this.queue2.getName(), "bar");
        this.rabbitTemplate.convertAndSend(this.queue2.getName(), "baz");
        this.rabbitTemplate.convertAndSend(this.queue2.getName(), "ex");

        InvocationData invocationData =
            this.harness.getNextInvocationDataFor("bar", 10, TimeUnit.SECONDS); 
        Object[] args = invocationData.getArguments();
        assertThat((String) args[0], equalTo("bar"));
        assertThat((String) args[1], equalTo(queue2.getName()));

        invocationData = this.harness.getNextInvocationDataFor("bar", 10, TimeUnit.SECONDS);
        args = invocationData.getArguments();
        assertThat((String) args[0], equalTo("baz"));

        invocationData = this.harness.getNextInvocationDataFor("bar", 10, TimeUnit.SECONDS);
        args = invocationData.getArguments();
        assertThat((String) args[0], equalTo("ex"));
        assertEquals("ex", invocationData.getThrowable().getMessage()); 
    }

}

這部分參考文檔提供了在Spring集成項(xiàng)目中提供AMQP支持的快速介紹．

Spring Integration 項(xiàng)目包含了構(gòu)建于Spring AMQP項(xiàng)目之上的AMQP 通道適配器(Channel Adapters)和網(wǎng)關(guān)(Gateways). 那些適配器是在Spring集成項(xiàng)目中開發(fā)和發(fā)布的.在Spring 集成中, "通道適配器" 是單向的,而網(wǎng)關(guān)是雙向的(請(qǐng)求－響應(yīng)).
我們提供了入站通道適配器(inbound-channel-adapter),出站通道適配器( outbound-channel-adapter), 入站網(wǎng)關(guān)(inbound-gateway),以及出站網(wǎng)關(guān)(outbound-gateway).

由于AMQP 適配器只是Spring集成版本的一部分，因?yàn)槲臋n也只針對(duì)Spring集成發(fā)行版本部分可用. 

<amqp:inbound-channel-adapter　channel="fromAMQP"　queue-names="some.queue"　connection-factory="rabbitConnectionFactory"/>

<amqp:outbound-channel-adapter　channel="toAMQP"　exchange-name="some.exchange"　　　　routing-key="foo"　amqp-template="rabbitTemplate"/>

<amqp:inbound-gateway　request-channel="fromAMQP"　reply-channel="toAMQP"　　　　　　　　　queue-names="some.queue"　connection-factory="rabbitConnectionFactory"/>

<amqp:outbound-gateway　request-channel="toAMQP"　reply-channel="fromAMQP"　　　　　　　exchange-name="some.exchange"　routing-key="foo"　amqp-template="rabbitTemplate"/>

除了這份參考文檔，還有其它資源可幫助你了解AMQP.