我目前参考一篇文章: https://www.cnblogs.com/ityouknow/p/6120544.html
但我产生了一些疑问,麻烦先看代码:
HelloSender.java 生产消息
public void send(User user) {
System.out.println("Sender object: " + user.toString());
this.rabbitTemplate.convertAndSend("hello", user);
}
HelloReceiver.java 消费消息
@RabbitHandler
public void process(User user) {
System.out.println("Receiver object : " + user);
}
RabbitmqController.java 调用发送消息返回结果
Sender object: {"uid":3825,"name":"用户名","pass":"123456"}
Receiver object : {"uid":3825,"name":"用户名","pass":"123456"}
现在通过文中的 Demo,可以配置交换机,队列,发送消息,接收消息,但是我到底要怎么用呢?比如发送消息的时候,用户 id 是 100,接收 id 是 101,我该怎么做呢?