如何从 Rails 应用程序中的守护进程创建队列而不出现“IOError:已关闭流”
在跟踪 twitter-stream 的守护进程中,我有这样的结构: client.track(*hashtags) do |status| if status.coordinates != nil EventMachine.synchrony…
EventMachine 中是否会出现竞争条件?
"run" 块是否在 EM 中作为一个整体执行(没有上下文切换)?在这个例子中,if 子句中是否会存在竞争条件? EventMachine.run { @current_value = 0 Ev…
使用 ruby 进行异步 HTTP 请求
我有一个充满请求的rabbitmq队列,我想以HTTP GET方式异步发送请求,而不需要等待每个请求响应。现在我很困惑,线程还是 EM 哪个更好用?我目前使用它…
在 Sinatra 应用程序中维护单个持久的 EM 连接
我是一个 EventMachine 新手,所以我的做法可能是完全错误的。我想做的是在应用程序启动时创建一个 EM 连接(实际上是 Blather 流,但那是 EM::Connec…
Ruby 并发:非阻塞 I/O 与线程
我正在 Ruby (1.9.3-p0) 中尝试并发,并创建了一个非常简单、I/O 繁重的代理任务。首先,我尝试了非阻塞方法: require 'rack' require 'rack/fiber_p…
请求-响应模式不适用于 em-zeromq
我正在尝试使用 em-zeromq gem 实现请求-响应模式,但我无法让响应套接字将消息发送回其处理程序中的请求套接字。我编写了一些非常简单的代码来测试它…
为什么 EventMachine 出站数据缓冲区可能会停止发送并永远填满(而其他连接仍然可以发送)
我有一个 EventMachine 服务器将 TCP 数据发送到 Mac 客户端(通过 GCDAsyncSocket)。它总是在一段时间内完美地工作,但不可避免的是服务器突然停止…
是否可以使用 NewRelic 监控 EventMachine 进程?
我有一个 Eventmachine 进程,是从 Heroku 上的 Procfile 启动的。我想知道是否有人想出用 NewRelic 来监控这个? 我感兴趣的是在哪里优化数据库查询…
为什么在 Ruby Event Machine 中使用线程?
既然事件机据说是一个基于事件的模型异步I/O库(如node.js),它是单线程的,并使用事件循环来处理并发请求,那么在Ruby应用程序上是否真的有必要关心…
如何使用 web-socket 以某种格式(JSON/XML/等)从服务器向客户端发送数据
通过遵循 em-websocket gem 中的示例,我刚刚创建了与 Sinatra 框架一起运行的简单回显服务器。问题是我不明白如何使用某种格式而不是纯文本来发送消…
EventMachine/em-http-request 检测 http 流连接何时停止
我正在使用 EventMachine + em-http-request 来请求 Twitter 流 API。 它工作得很好,但现在我想得到它的错误证明。 检测连接是否停止的最佳方法是什…
Em-synchrony 示例代码未按预期工作
em-synchrony 文档链接到本文 这意味着使用 Fiber: require 'eventmachine' require 'fiber' require 'em-http-request' def http_get(url) f = Fiber…