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

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

应用程序可能接收的一些其他消息是启动,停止,暂停,用于跟踪某些会话时间.我的观点是,我设想应用程序以下列方式运行：

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

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

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

解决方法

使用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”消息时对消息进行排队,则必须通过本征类进行协调.

原文地址：https://www.jb51.cc/ruby/270497.html