updated: 2021-10-20 20:46:13.145
url: https://hututu.fit/archives/java-rabbitmq-send-object
categories: java
tags: java | rabbitMQ

rabbitMQ中傳送和接收的都是字串/位元組陣列型別的訊息

1.序列化物件

實體類需實現Serializable介面;
生產者和消費者中的包名、類名、屬性名必須一致;
生產者和消費者使用的queue佇列一致

1.1生產者

@Service
public class MQService {

    @Resource
    private AmqpTemplate amqpTemplate;

    public void sendGoodsToMq(Dog dog){
        //訊息佇列可以傳送 字串、位元組陣列、序列化物件
        amqpTemplate.convertAndSend("","queue_A",dog);
    }
}
 

1.2消費者

@Component
public class ConsumerService {

    @RabbitListener(queues = "queue_A")
    @RabbitHandler
    public void consumeMessage(Dog dog){
        System.out.println("dog---"+dog);
    }
}

2.序列化位元組陣列

實體類需實現Serializable介面;
生產者和消費者中的包名、類名、屬性名必須一致;
生產者和消費者使用的queue佇列一致

2.1 生產者

@Service
public class MQService {

    @Resource
    private AmqpTemplate amqpTemplate;

    public void sendGoodsToMq(Dog dog){
        //訊息佇列可以傳送 字串、位元組陣列、序列化物件
        byte[] bytes = SerializationUtils.serialize(dog);
        amqpTemplate.convertAndSend("","queue_A",bytes);
    }
}
 

2.2消費者

@Component
public class ConsumerService {

    @RabbitListener(queues = "queue_A")
    @RabbitHandler
    public void consumeMessage(byte[] bs){
        Dog dog = (Goods) SerializationUtils.deserialize(bs);
        System.out.println("byte[]---"+dog);
    }
}

3.JSON字串

物件的屬性名需一致

3.1 生產者

@Service
public class MQService {

    @Resource
    private AmqpTemplate amqpTemplate;

    public void sendGoodsToMq(Dog dog) throws JsonProcessingException {
        //訊息佇列可以傳送 字串、位元組陣列、序列化物件
        ObjectMapper objectMapper = new ObjectMapper();
        String msg = objectMapper.writeValueAsString(dog);
        amqpTemplate.convertAndSend("","queue_A",msg);
    }

}
 

3.2消費者

@Component
public class ReceiveService {

    @RabbitListener(queues = "queue_A")
    @RabbitHandler
    public void receiveMsg(String msg) throws JsonProcessingException {
        ObjectMapper objectMapper = new ObjectMapper();
        Dog dog = objectMapper.readValue(msg,Dog.class);
        System.out.println("String---"+msg);
    }
}

本文來自部落格園，作者：胡圖人，轉載請註明原文連結：https://www.cnblogs.com/huturen/p/15467845.html