SpringBoot 官方文档示例：(74)整合RabbitMQ时使用自定义的SimpleRabbitListenerContainerFactory_wx62e0d796b5814的技术博客_

相关文章推荐

淡定的枇杷 · velocity的使用简介 - ...· 2 周前 ·

咆哮的酱肘子 · 可视化: ...· 6 月前 ·

豪气的消防车 · pg数据库时间戳转换日期格式-掘金· 1 年前 ·

睿智的柿子 · python获取指定日期的前一天-掘金· 1 年前 ·

道上混的杯子 · 详细记录solov2的ncnn实现和优化 - 知乎· 1 年前 ·

import org.springframework.amqp.core.Message; import org.springframework.amqp.core.MessageProperties; import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory; import org.springframework.amqp.rabbit.connection.CachingConnectionFactory; import org.springframework.amqp.rabbit.connection.ConnectionFactory; import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter; import org.springframework.amqp.support.converter.MessageConversionException; import org.springframework.amqp.support.converter.MessageConverter; import org.springframework.boot.autoconfigure.amqp.SimpleRabbitListenerContainerFactoryConfigurer; import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; @Configuration public class MyRabbitConfiguration { @Bean public MessageConverter messageConverter(){ return new Jackson2JsonMessageConverter(); @Bean public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(CachingConnectionFactory cachingConnectionFactory) { SimpleRabbitListenerContainerFactory factory = new SimpleRabbitListenerContainerFactory(); factory.setConnectionFactory(cachingConnectionFactory); factory.setMessageConverter(messageConverter()); // ack模式 //factory.setAcknowledgeMode(AcknowledgeMode.MANUAL); return factory;

这里使用了Jackson2JsonMessageConverter用来实现把java对象转换为AMQP Message和把AMQP Message转换为java 对象

package cn.edu.tju.config;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.core.MessageProperties;
import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConversionException;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.amqp.SimpleRabbitListenerContainerFactoryConfigurer;
import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class MyRabbitConfiguration {
    @Bean
    public MessageConverter messageConverter(){
        return new Jackson2JsonMessageConverter();
    @Autowired
    private CachingConnectionFactory cachingConnectionFactory;
    @Bean
    public SimpleRabbitListenerContainerFactory
    myFactory(SimpleRabbitListenerContainerFactoryConfigurer configurer) {
        SimpleRabbitListenerContainerFactory factory = new
                SimpleRabbitListenerContainerFactory();
        ConnectionFactory connectionFactory = getCustomConnectionFactory();
        configurer.configure(factory, connectionFactory);
        factory.setMessageConverter(new Jackson2JsonMessageConverter());
        return factory;
    private ConnectionFactory getCustomConnectionFactory() {
        return cachingConnectionFactory;
在@RabbitListener注解中可以使用containerFactory属性来指定container factory 
package cn.edu.tju.service;
import cn.edu.tju.domain.Student;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;
@Service
public class MyConsumerService {
    @RabbitListener(queues = "queueHello",containerFactory = "myFactory")
    public void receiveMessage(Student student){
        System.out.println("received message: "+student);