rabbitMq发送、接受对象消息

时间:2025-03-10 08:37:51
//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);
       
    }
}