比如说：我项目的服务接口，需要给调用者返回一个是否成功结果。因为可能并发量比较大，用rocketmq来流量削峰。我将生产者写入到接口中，每次调这个接口，生产者发送消息，消费者监听，并处理接口的实际业务。但是如何返回给生产者处理结果？我没找到具体代码方法。还是说我上面做的方法，是不可行的？求解答
1 回答
白猪掌柜的
TA贡献1893条经验 获得超10个赞
首先要明白消息队列是用于什么场景的；
绝大部分用于削峰和解耦，也有用于处理分布式事务！
然后再想想削峰的目的是什么，削峰是用于当应用处理不过来过大的并发请求时，将请求存于队列中，用单个或多个消费者来处理请求！
这时候想要拿到请求怎么办呢？
1.每个消费者处理完成请求，再发送消息到消息队列中，你的生产者那方再实现消费者来消费这些处理结果信息；
然后处理你的逻辑！
2.将处理结果存于缓存等高性能组件中，通过轮询的方式获取任务处理结果
不管什么方式，你的请求方都应该是在你将请求消息发到队列后立即返回的！消息结果可以用推送的方式告知(移动端的话),也可以让请求方每个几秒轮询一次
处理结果；
希望对你有帮助...
添加回答
举报
0/150
提交
取消