是否可以从 Thin/Rack/Sinatra 访问 Ruby EventMachine 通道？

Question

我希望利用 Sinatra 为内部项目构建一个简单的、RESTful 通知系统。我过去曾使用 EventMachine 通道来订阅/发布事件，但在之前的所有案例中，我都是直接使用 EventMachine。

有谁知道是否可以从 Sinatra 应用程序甚至从某些 Rack 中间件创建、订阅和发布到 EventMachine 通道（在 Thin 中运行）？

Answer 1

看看async_sinatra。

基本上，为了在 Thin 中运行时能够使用 EventMachine，您需要让它知道您想要异步处理请求。 Rack 协议在设计上是同步的，Thin 期望在处理程序返回时完成请求。有多种方法可以让 Thin 知道您想要异步处理请求（有关示例，请参阅 think_async） ，并且 async_sinatra 使其变得非常简单。

Answer 2

布莱恩，
您可以使用 em-http-request 库 (https://github.com/igrigorik/em-http-request)，这将允许您引用在 A. 同一服务器、B. a 上运行的特定 EventMachine 应用程序不同的服务器，或者 C. 任何你想要的地方。

require 'eventmachine'
require 'em-http-request'
require 'sinatra/base'
require 'thin'

class ServerClass < EventMachine::Connection
  def initialize(*args)
    # ruby singleton - store channel data in global hash
    ($channels ||= [])
  end

  def post_init
    puts "initialized"
    $cb.call("initialized");
  end

  def receive_data(data)
    # got information from client connection
  end

  def channel_send(msg,channel)
    $channels[channel].send_data(msg)
  end

  def channels_send(msg)
    $channels.each{|channel| channel.send_data(msg)}
  end

  def unbind
    # puts user left
  end

end

EventMachine.run do
  $cb = EM.callback {|msg| puts msg #do something creative}
  $ems = EventMachine::start_server('0.0.0.0',ServerClass,args)

  class App < Sinatra::Base
    set :public, File.dirname(__FILE__) + '/public'

    get '/' do
      erb :index          
    end

  end

  App.run!({:port => 3000})

end

上面是一个基本的线框图。根据您想要发送数据的方式，您可以使用 WebSockets (em-websocket) 并在登录时绑定每个用户（必须添加登录系统），或者您可以将其用于任何用途。只要您拥有对 Eventmachine 对象（连接、websocket、通道）的全局引用，您就可以从应用程序内传递消息。

顺便说一句 - 添加 EventMachine.run do;....end 循环是可选的，因为 Thin 无论如何都会执行此操作。了解它是如何工作的还是有帮助的。

祝你好运