php - Rabbitmq怎么知道消费者执行是否成功.

问题描述

问 题

场景：下订单，扣库存。
我的想法是把下订单的任务放到队列里面 一个个进行处理，这样库存在扣减的时候，就不会出错了。
就是生产者与消费者
用户在UI中点击提交订单时，把任务放到队列，等待队列处理这个任务的结果，根据结果（成功或者失败）进行页面跳转

但是有一个问题：队列处理后，如何把结果通知生产者？
以RabbitMQ为例子，有哪位大神可以给出代码.

解决方案

RabbitMQ中实现RPC的机制是：

• 客户端发送请求（消息）时，在消息的属性（MessageProperties，在AMQP协议中定义了14中properties，这些属性会随着消息一起发送）中设置两个值replyTo（一个Queue名称，用于告诉服务器处理完成后将通知我的消息发送到这个Queue中）和correlationId（此次请求的标识号，服务器处理完成后需要将此属性返还，客户端将根据这个id了解哪条请求被成功执行了或执行失败）

• 服务器端收到消息并处理

• 服务器端处理完消息后，将生成一条应答消息到replyTo指定的Queue，同时带上correlationId属性

• 客户端之前已订阅replyTo指定的Queue，从中收到服务器的应答消息后，根据其中的correlationId属性分析哪条请求被执行了，根据执行结果进行后续业务处理

这里面有指出生产者会监听另一个replyTo的队列，从中取得对应应答消息触发后续操作。

这篇关于php - Rabbitmq怎么知道消费者执行是否成功.的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！