2

我正在将 Cramp 框架与 Redis gem 和 em-synchrony 以及 WebSockets 一起使用来构建与聊天相关的 Web 应用程序，但遇到了一些问题。

考虑以下代码：

class DrawingAction < Cramp::Action
  use_fiber_pool

  self.transport = :websocket

  on_start :user_joined
  on_data :message_received
  on_finish :user_left

  def user_joined
    # Create pub/sub clients for the user who just joined
    initialize_pub_sub
  end

 def initialize_pub_sub
   @@redis_client ||= Redis.new(:driver => :synchrony)

   @publisher ||= Redis.new(:driver => :synchrony)
   @subscriber ||= Redis.new(:driver => :synchrony)
 end


def handle_join(join_data)
  room_name = join_data[:room_name]

  @subscriber.subscribe(room_name) do |on|
    on.message do |channel, message|
      render message
    end
  end

  puts "fetching history items"
  history_items = history_for_room(room_name)
  render "{ \"history\": true, \"time:\": #{Time.now.to_f}, \"data\": [#{history_items.join(',')}] }"
end

handle_join正在从on_message我的 Cramp 操作的事件处理程序中调用，因为 cramp 支持同步和光纤，在客户端加入频道后，@subscriber.subscribe 块像它应该的那样以非阻塞方式运行，这意味着它接受在 pubsub 上获取的消息通道，并且不会阻止进程中的其他所有内容（应用程序没有被阻止），但它不会移动到下一行（puts "fetching history items"），这对我来说是一个主要问题，有没有人暗示可以做什么纠正这个问题？

4

1 回答 1

0

我没有发现 Cramp 这么有用，可以使用普通的 Sinatra，这里有一个例子。考虑添加rack-fiber_pool到混合物中。同步适配器不能用于相同的目的（示例）。

于 2012-10-08T10:49:58.157 回答