我应该如何使用EventMachine处理这个用例？

Question

我有一个应用程序,可以响应客户端发送的消息.一条消息是reload_credentials,应用程序会在新客户端注册时随时收到.然后,此消息将连接到PostgreSQL数据库,对所有凭据执行查询,然后将它们存储在常规Ruby哈希(client_id => client_token)中.

该应用程序可能会收到一些其他的消息是start,stop,pause这是用来跟踪一些会话倍.我的观点是,我设想应用程序以下列方式运行:

• 客户端发送消息
• 消息排队
• 队列正在处理中

但是,例如,我不想阻止反应堆.此外,让我们想象一下,我的reload_credentials消息是下一个队列中的消息.在从数据库重新加载凭据之前,我不希望处理队列中的任何其他消息.此外,当我处理某个消息(如等待凭据查询完成)时,我想允许其他消息入队.

你能指导我解决这个问题吗？我想我可能要用em-synchrony,但我不确定.

Answer 1

使用Postgresql EM驱动程序之一或EM.defer,以便您不会阻止反应堆.

当您收到'reload_credentials'消息时,只需翻转一个标志,导致所有后续消息入队.'reload_credentials'完成后,处理队列中的所有消息.在队列为空之后,翻转导致消息在接收时被处理的标志.

这里列出了Postgresql的EM驱动程序:https://github.com/eventmachine/eventmachine/wiki/Protocol-Implementations

module Server
  def post_init
    @queue               = []
    @loading_credentials = false
  end

  def recieve_message(type, data)
    return @queue << [type, data] if @loading_credentials || !@queue.empty?
    return process_msg(type, data) unless :reload_credentials == type
    @loading_credentials = true
    reload_credentials do
      @loading_credentials = false
      process_queue
    end
  end

  def reload_credentials(&when_done)
    EM.defer( proc { query_and_load_credentials }, when_done )
  end


  def process_queue
    while (type, data = @queue.shift)
      process_msg(type, data)
    end
  end

  # lots of other methods
end

EM.start_server(HOST, PORT, Server)

如果您希望所有连接在任何连接收到"reload_connections"消息时对消息进行排队,则必须通过本征类进行协调.