//jar包
<dependency>
<groupId></groupId>
<artifactId>jackson-core</artifactId>
<version>2.13.3</version>
</dependency>
<dependency>
<groupId></groupId>
<artifactId>jackson-annotations</artifactId>
<version>2.13.3</version>
</dependency>
<dependency>
<groupId></groupId>
<artifactId>jackson-databind</artifactId>
<version>2.13.3</version>
</dependency>
2//发送对象消息
UserDto userDto=new UserDto();
("1233");
("中国人民");
ObjectMapper objectMapper=new ObjectMapper();
String string = (userDto);
sendMessage(string);
3//接收消息
@Component
@RabbitListener(queues = "监听队列名")
public class Receiver {
@RabbitHandler
public void handle(String str) throws IOException {
("========================================");
ObjectMapper objectMapper=new ObjectMapper();
UserDto userDto = (str, );
(());
("receive message str:{}",userDto);
}
}