Rabbitmq怎么知道消费者执行是否成功.
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了Rabbitmq怎么知道消费者执行是否成功.,小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含1567字,纯文字阅读大概需要3分钟。
内容图文
![Rabbitmq怎么知道消费者执行是否成功.](/upload/InfoBanner/zyjiaocheng/152/8efeb765f0444ac181968005a2335fb2.jpg)
我的想法是把下订单的任务放到队列里面 一个个进行处理,这样库存在扣减的时候,就不会出错了。
就是生产者与消费者
用户在UI中点击“提交订单”时,把任务放到队列,等待队列处理这个任务的结果,根据结果(成功或者失败)进行页面跳转
但是有一个问题:队列处理后,如何把结果通知生产者?
以RabbitMQ为例子,有哪位大神可以给出代码.
回复内容:
场景:下订单,扣库存。
我的想法是把下订单的任务放到队列里面 一个个进行处理,这样库存在扣减的时候,就不会出错了。
就是生产者与消费者
用户在UI中点击“提交订单”时,把任务放到队列,等待队列处理这个任务的结果,根据结果(成功或者失败)进行页面跳转
但是有一个问题:队列处理后,如何把结果通知生产者?
以RabbitMQ为例子,有哪位大神可以给出代码.
quene
只能保证消息到达与否,具体你业务是否执行成功。这个消息队列可不保证。
生产者发布消息之后监听另外一个返回消息队列,例如队列b。
消费者消费完后把结果消息压入队列b。
这样原来的生产者就能获取返回结果了。
RabbitMQ中实现RPC的机制是:
客户端发送请求(消息)时,在消息的属性(MessageProperties,在AMQP协议中定义了14中properties,这些属性会随着消息一起发送)中设置两个值replyTo(一个Queue名称,用于告诉服务器处理完成后将通知我的消息发送到这个Queue中)和correlationId(此次请求的标识号,服务器处理完成后需要将此属性返还,客户端将根据这个id了解哪条请求被成功执行了或执行失败)
服务器端收到消息并处理
服务器端处理完消息后,将生成一条应答消息到replyTo指定的Queue,同时带上correlationId属性
客户端之前已订阅replyTo指定的Queue,从中收到服务器的应答消息后,根据其中的correlationId属性分析哪条请求被执行了,根据执行结果进行后续业务处理
这里面有指出生产者会监听另一个replyTo的队列,从中取得对应应答消息触发后续操作。
内容总结
以上是互联网集市为您收集整理的Rabbitmq怎么知道消费者执行是否成功.全部内容,希望文章能够帮你解决Rabbitmq怎么知道消费者执行是否成功.所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。