SpringBoot 官方文档示例：(74)整合RabbitMQ时使用自定义的SimpleRabbitListenerContainerFactory

Posted 2023-03-02 amadeus_liu2

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.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);