品索智能

RabbitMQ-消息转换器

原创时间:2024-05-22 11:22 作者:AI智能浏览量:2708

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

消费者接收

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

动动小手 !!!

来说两句吧