RabbitMQ：使用Spring将消息映射到课堂

Question

我有2种通过兔子通信的不同微服务。第一个微服务具有发布者的逻辑，我被要求创建消费者以在新的微服务中消费邮件中的所有消息。

到目前为止，我所做的就是这样的消费者服务类：

@Service
public class RabbitMQService {

    private final Logger logger = LoggerFactory.getLogger(RabbitMQService.class);

    @RabbitListener(queues = "${peopleevents.queue}")
    public void receivedMessage(@Payload Country country) {
        logger.info("Received message is.. " + country.toString());
        System.out.println(country);
    }

但是我不知道如何在适当的课程中映射我在有效载荷中获得的内容。

我的配置类如下：

@EnableRabbit
@Configuration
public class MQConfig {


    @Value("${peopleevents.queue}")
    public String queue;

    @Value("${peopleevents.exchange}")
    public String exchange;

    @Value("${peopleevents.routingkey}")
    public String routingKey;

    @Value("${spring.rabbitmq.username}")
    private String username;

    @Value("${spring.rabbitmq.password}")
    private String password;

    @Value("${spring.rabbitmq.addresses}")
    private String address;

    @Value("${spring.rabbitmq.vhost}")
    private String vHost;


    @Bean
    public Queue queue() {
        return new Queue(queue, true, false, false);
    }


    @Bean
    Exchange myExchange() {
        return ExchangeBuilder.topicExchange(exchange).durable(true).build();
    }


    @Bean
    public Binding binding(Queue queue, TopicExchange exchange) {
        return BindingBuilder
                .bind(queue)
                .to(exchange)
                .with(routingKey);
    }

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

    @Bean
    public AmqpTemplate template(ConnectionFactory connectionFactory) {
        final RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
        rabbitTemplate.setMandatory(true);
        return rabbitTemplate;
    }

    @Bean
    public ConnectionFactory connectionFactory() throws IOException {
        CachingConnectionFactory connectionFactory = new CachingConnectionFactory();
        connectionFactory.setAddresses(address);
        connectionFactory.setUsername(username);
        connectionFactory.setPassword(password);
        connectionFactory.setVirtualHost(vHost);
        connectionFactory.setPublisherReturns(true);

        return connectionFactory;
    }

    @Bean
    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) {
        final RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
        rabbitTemplate.setMessageConverter(jsonMessageConverter());
        return rabbitTemplate;
    }

    @Bean
    public AmqpAdmin amqpAdmin() throws IOException {
        return new RabbitAdmin(connectionFactory());
    }


}

Answer 1

AMQP消息包含字节[] 的身体。因此，使其转换为 country ，您必须提供相应的转换器。请参阅 MessageConverter @rabbitlistener 的属性。或提供全局BEAN，Spring Boot的自动配置将其设置为 RabbitListenerContainerFactory 。

在文档中查看有关转换的更多信息：