网站首页> 文章专栏> RabbitMQ-消息转换器
RabbitMQ-消息转换器
原创 时间:2024-05-22 11:22 作者:AI智能 浏览量:2826

1716346842329.webp

1716346848746.webp



1,在生产中和消费中引入jackson包

<dependency>

<groupId>com.fasterxml.jackson.core</groupId> <artifactId>jackson-databind</artifactId> </dependency>


并在某个地方注入bean,这里使用启动类

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


2,创建生产者

@Slf4j
@Component
public class SpringRabbitListener {

    @RabbitListener(bindings = @QueueBinding(
            value = @Queue(name = "object.queue",durable = "true"),
            exchange = @Exchange(name = "object.fanout",type = ExchangeTypes.FANOUT)))


    public void listenFanoutQueueMessage3(Map msg){
        System.out.println("object.queue" + msg);
    }
}



3,消费者发送

@Test
void testSendObjectQueue() {
    Map map = new HashMap<>();
    map.put("name","jack");
    map.put("age",21);
    rabbitTemplate.convertAndSend("object.fanout","object.queue",map);
}



消费者接收

1716348008506.webp


代码很简单,可以尝试一下


动动小手 !!!
来说两句吧
最新评论
  • 恬淡春风
    总结的很全面,点赞

  • 我本帅哥
    博主讲解的很详细,结构严谨。感谢博主分享,期待博主持续输出好文,同时也希望可以来我博客指导我一番!

  • 冷月
    超级厉害呢!