使用rabbitmq和rails，如何创建无限循环过程？

Question

在rails web应用程序中，如果我将消息写入像rabbitmq这样的队列，当生产者向队列发送消息时，如何通知客户端？

我猜我必须创建一个在后台运行的单独进程来响应正确的消息？即此代码超出了 Web 应用程序的范围。

如果是这种情况，是否可以重用 Rails 应用程序中已有的模型/库？那我必须把这段代码复制到两个地方吗？

Answer 1

看起来您的应用程序需要通常所谓的后台或工作进程。对于任何中等复杂的 Web 应用程序来说，这是一个相当常见的要求。

我猜我必须创建一个在后台运行的单独进程来正确响应消息？

是的 - 你是对的。虽然完全可以使用线程来处理后台任务（在您的情况下，从 RabbitMQ 读取和处理消息），但 Rails 应用程序的标准和推荐路线是运行单独的后台进程。

如果是这种情况，是否可以重用 Rails 应用程序中已有的模型/库？

绝对地。实现此功能的最简单方法是使用 Rails 的内置运行程序命令。

另一种选择是创建一个 ruby​​ 脚本来加载 Rails 应用程序。例如，您可以在项目的根目录中创建文件 my_script.rb，该文件可能如下所示：

# Load my application:
require File.join(File.dirname(__FILE__), 'config/environment.rb')

# Now you can access your Rails environment as normal:
MyModel.all.each { |x| x.do_something }

如果您的需求变得更加复杂，或者您发现需要运行多个后台进程以跟上您需要处理的数据量，您可能需要查看 许多可用的库和框架可以帮助解决这个问题。

创建后台进程后，当您将其部署到生产服务器时，您将需要一种连续运行它的方法。虽然可以使用像 daemons 这样的库，正如 ctcherry 所建议的，但我建议使用像 upstart（如果部署到 ubuntu）或 runit。 此处提供了最流行选项的详细总结。

Answer 2

你是对的，你确实需要一个后台进程。如果您愿意，您可以将该过程的代码保留在 Rails 项目的 lib 文件夹中，我之前已经这样做过，没有出现问题，并且它将相关代码保留在一起，这很好。

我使用这个库来创建我的长时间运行的进程，它非常简单：

http://daemons.rubyforge.org/

为了重用 Rails 应用程序中的模型，您可以在 config/environment.rb 文件上运行 require 来加载所有内容。 （首先将 RAILS_ENV 设置为环境变量以选择正确的环境）从那时起，脚本的行为就像您处于 Rails 控制台会话中一样。