比如说:我项目的服务接口,需要给调用者返回一个是否成功结果。因为可能并发量比较大,用rocketmq来流量削峰。我将生产者写入到接口中,每次调这个接口,生产者发送消息,消费者监听,并处理接口的实际业务。但是如何返回给生产者处理结果?我没找到具体代码方法。
还是说我上面做的方法,是不可行的?求解答
首先要明白消息队列是用于什么场景的;
绝大部分用于削峰和解耦,也有用于处理分布式事务!
然后再想想削峰的目的是什么,削峰是用于当应用处理不过来过大的并发请求时,将请求存于队列中,用单个或多个消费者来处理请求!
这时候想要拿到请求怎么办呢?
1.每个消费者处理完成请求,再发送消息到消息队列中,你的生产者那方再实现消费者来消费这些处理结果信息;
然后处理你的逻辑!
2.将处理结果存于缓存等高性能组件中,通过轮询的方式获取任务处理结果
不管什么方式,你的请求方都应该是在你将请求消息发到队列后立即返回的!消息结果可以用推送的方式告知(移动端的话),也可以让请求方每个几秒轮询一次
处理结果;
希望对你有帮助...
非常感谢你的回答。我现在大概明白了。实际上我们有一个webservice接口,组长说以后可能调这个接口的人会越来越多,并发量较大。所以让我了解一下mq,但mq可能更适合处理一些延时性的业务,不太适合需要实时返回结果。对于这种实时的接口削峰你有什么技术推荐吗
你的问题思路就不对,一般用rabbitmq都是异步调用,就是说发送消息的人,不会想知道别人什么时候处理,处理完成了没有。如果你想知道别人处理咋样了,应该使用同步调用,不要使用rabbitmq。如果是两个进程之间,可以考虑RPC。