我想转移到一个消息系统,我们已经转到谷歌应用引擎环境,但我有一些问题,我希望有人能帮助我。
我们当前的消息环境使用兔子mq来处理消息,然后使用连接到que的大约10个使用者发送消息。这对我们来说很好,因为有10个消费者实例来处理消息,显着地提高了传递率。
我知道应用程序引擎不支持兔子mq,所以我想知道实现相同结果的最佳选择是什么。我看到,您可以在后台运行任务,这是很好的,但这将只作为一个实例,这将减慢交付率。
还有其他选择吗?
发布于 2013-10-08 01:09:51
我以前从未使用过rabbitmq,但是您的需求看起来非常适合在应用程序引擎上使用taskqueue和管道。
TaskQueue提供了设置使用者和设置他们的处理速率的能力。https://developers.google.com/appengine/docs/python/taskqueue/
使用任务队列API,应用程序可以在用户请求之外执行由用户请求发起的工作。如果一个应用程序需要执行一些后台工作,它可以使用Task将该工作组织成称为任务的小的、离散的单元。该应用程序将任务添加到任务队列中,以便稍后执行。
压电线基于任务队列,提供了更多的流量控制特性。https://code.google.com/p/appengine-pipeline/
管道API将复杂、耗时的工作流(包括人工任务)连接在一起。目标是灵活性、工作流重用和可测试性。API的一个主要用例是将各种App连接到一个计算管道中。
https://stackoverflow.com/questions/19236836
复制相似问题