在 Sinatra 应用程序中维护单个持久的 EM 连接

Question

我是一个 EventMachine 新手，所以我的做法可能是完全错误的。我想做的是在应用程序启动时创建一个 EM 连接（实际上是 Blather 流，但那是 EM::Connection），然后我可以在需要时点击该连接。现在，我能让 Blather 在这个 Sinatra 应用程序中正常工作的唯一方法是每次创建一个新连接，该连接包装在 EM.run 块内。

我一直在尝试确定 async_sinatra 是否有帮助。不过，我实际上并不关心请求是否异步发生。我想这会很好，但我仍然不知道如何保持请求之间的连接。

在我看来最有意义的解决方案是在 Sinatra 配置块内的 EM 块中设置连接，但随后我不确定如何访问它。不过，也许我错过了一些基本的东西。

ps 这最终将在 Heroku 上运行，因此虽然我非常感谢任何见解，但已知可在 Heroku 上运行的解决方案将是最有用的。

编辑：

这似乎正在做我想要的事情，至少在本地：

class Dashboard < Sinatra::Base
  configure do
    Thread.start do
      EM.run do
        @@xmpp_stream = Blather::Client.setup('jid', 'password')
        @@xmpp_stream.connect
      end
    end
  end
end

Answer 1

首先是：

require 'rack'
require 'sinatra/base'
require 'eventmachine'

class EMHandler < EM::Connection
  attr_reader :data

  def initialize(obj)
    @obj = obj
    @data = ""
  end

  def receive_data(data)
    @data << data
  end
end

class PersistentConnection
  def initialize(app, options = {})
    @app = app
    EM::next_tick do
      @server = EM::connect('127.0.0.1', 4000, EMHandler, self)
    end
  end

  def call(env)
    env['my_connection'] = @server
    @app.call(env)
  end
end

class Dashboard < Sinatra::Base
 get '/' do
   env['my_connection'].data
 end
end

use PersistentConnection
run Dashboard

这将打开一个到本地主机上端口 4000 的服务器的持久连接，它将存储从该服务器接收到的任何内容，并在通过 Web 浏览器请求索引页面时显示它。

将其保存在“config.ru”文件中并运行：

$ thin start -V

在我的例子中，端口 4000 上的服务器是（我在 mac os x 上，linux 也有）：

$ nc -l 4000

只需将我打开的连接替换为您想要的连接即可。