RabbitMQ 消息响应的问题

[xss]

之前都是用 gearman 的,现在想问一下 rabbitmq 能不能满足如下场景:

1. Client 向 RabbitMQ 发送一条消息
2. Customer 监听 RabbitMQ 上 Client 发送过来的消息,处理后得到结果 A
3. Client 通过 RabbitMQ 接收 Customer 的处理结果 A

看文档,RabbitMQ 都是单向处理的,即只有上面的 1&2 好像并不能实现 3 这个过程?

如果可以,能否给几个链接地址看下?

[adrianzhang]

建立两个 queue

[lijinma]

一楼思路正确啊，两个 queue 就解决了吧

[xss]

@adrianzhang
@lijinma

两个 queue 会丢失上下文关系,比如我的应用场景是一个 web 页面,那么一个 session 传过来的数据,在第二个 queue 里面如何确定返回给哪个 session?
或者换句话说,如何保证一个用户提交的数据可以得到被正确处理的结果?

[iloveyou]

你这就不是异步了

[domty]

3 这种需求本身就不适合消息队列吧。
这种场景为什么不考虑用 RPC 而是用 MQ 呢？

[pubby]

这需求用 gearman 不是挺好的吗

[lijinma]

@xss 确实是我没看清你的题目。

看你的介绍，这本身就不是异步的啊？这明显是同步操作吧？

[xss]

@domty
@pubby
@lijinma

gearman 的确能满足需求,目前主要是 gearman 的界面监控比较搓,所以看看有没有什么替代的方案.
因为 RabbitMQ 本身提供一个监控用的界面,所以问一下各位能否满足这个需求.
如果不能那就只能看看别的消息框架了.

[pubby]

非要用的话

保持 gearman 调用不变（因为你的业务需求其实是同步的）
设计一个新的 worker ，
功能就是分发任务到 RabbitMQ 队列，再开一个结果队列， worker 里内部维护一个缓冲区，把结果和 task 对应起来返回。


这个 worker 实现起来会稍微复杂，感觉用 go 这种支持协程的写会省力点。

[adrianzhang]

实践中可考虑工作流与数据分离 session 放在 memcache

[rrfeng]

这叫强行用队列吧……

[azhw]

@xss 这其实是用 rabbitmqmq 实现 rpc 调用，看官方文档，专门提到一种模式，事实现 rpC 的