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