先貼上一份基於Java配置的RabbitMQ部分的程式碼：

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

    @Bean
    public RabbitTemplate rabbitTemplate() {
        RabbitTemplate template = new RabbitTemplate(rabbitConnectionFactory());
        template.setMessageConverter(jsonMessageConverter());
        return template;
    }

    @Bean
    public MessageConverter jsonMessageConverter
 
() {
        return new JsonMessageConverter();
    }

    @Bean
    TopicExchange paySuccessExchange() {
        return new TopicExchange("pay-success-exchange");
    }

    @Bean
    Queue queue() {
        return new Queue("pay-success-queue", false);
    }

    @Bean
    Binding binding(Queue queue, TopicExchange exchange) {
        return
 
 BindingBuilder.bind(queue).to(exchange).with("pay-success");
    }

    @Bean
    RabbitAdmin admin() {
        RabbitAdmin admin = new RabbitAdmin(rabbitConnectionFactory());
        admin.setIgnoreDeclarationExceptions(true); //這樣即使有關rabbitmq的bean初始化失敗整個web應用還能正常啟動
        return admin;
    }

    @Bean
    SimpleMessageListenerContainer container(ConnectionFactory rabbitConnectionFactory,
                                             MessageListenerAdapter listenerAdapter) {
        SimpleMessageListenerContainer container = new SimpleMessageListenerContainer();
        container.setConnectionFactory(rabbitConnectionFactory);
        container.setQueueNames("pay-success-queue");
        container.setMessageListener(listenerAdapter);
        container.setMessageConverter(jsonMessageConverter());
        return container;
    }

    @Bean
    MessageListenerAdapter listenerAdapter(PaySuccessReceiver receiver) {
        MessageListenerAdapter m = new MessageListenerAdapter(receiver, "handleMessage");
        m.setMessageConverter(jsonMessageConverter());
        return m;
    }

    @Bean
    public PaySuccessReceiver receiver() {
        return new PaySuccessReceiver();
    }

需要注意的是：

1. 把RabbitAdmin設定成admin.setIgnoreDeclarationExceptions(true);，這樣的好處是即使配置出現了錯誤也不至於整個應用程式都啟動失敗的情況。預設情況下，當出現異常時， RabbitAdmin 會立即停止所有宣告的處理過程，這就有可能會導致一些問題- 如監聽器容器會初始化失敗，因另外的佇列沒有宣告，從而web應用啟動失敗。
2. 最好顯式地設定SimpleMessageListenerContainer和RabbitTemplate的MessageConverter。如果沒有啟用配置的JsonMessageConverter，那麼會出現這樣的錯誤：org.springframework.amqp.rabbit.listener.ListenerExecutionFailedException: Failed to invoke target method 'handleMessage' with argument type = [class [B], value = [{[[email protected]}]
，這裡的[B還有class [B]代表的是位元組陣列byte[]的意思，也就是說，由於沒有啟用JsonMessageConverter，所以傳送的POJO（在我的例子中是一個BaobiaoOrder訂單物件）被包裝成一個Message物件，所以此時在監聽器POJO的處理函式接收的引數實際是一個位元組陣列，需要手動地解析成需要的BaobiaoOrder物件。解決的方法就是顯式地給SimpleMessageListenerContainer和RabbitTemplate的MessageConverter設定JsonMessageConverter，這樣在handleMessage函式的引數可以直接寫成BaobiaoOrder。
3. 需要在訊息中傳送的POJO物件（BaobiaoOrder）必須有一個空的建構函式，否則會出現org.codehaus.jackson.map.JsonMappingException: No suitable constructor found for type [simple type, class com.iot.baobiao.pojo.BaobiaoOrder]: can not instantiate from JSON object (need to add/enable type information?)這樣的錯誤。