连接关闭后如何停止 Sinatra 中的后台线程
我正在尝试使用 Sinatra 来使用 Twitter Streaming API,并在用户搜索关键字时为他们提供实时更新。 require 'sinatra' require 'eventmachine' requi…
如何捕获 EventMachine 服务器上的顶级故障?
我有一个 EventMachine 服务器,正在使用 monit 进行监控。有时它会崩溃,我试图找出原因,但我不清楚如何记录所有顶级故障。我尝试了这样的代码: be…
使用 eventmachine 流式传输视频?
在我看来, EM::FileStreamer 应该可以开箱即用,但我尝试使用 标签和嵌入的 Quicktime 插件,但两者都不会真正显示视频。 我已经使用 telnet 连…
EventMachine::HttpRequest 和保持连接
我使用以下代码运行几个 HTTP 请求,但第二个请求 (req2) 始终返回 errback。 我在这里遗漏了一些明显的东西吗? request_options = { :body => " ", …
如何在同一个 EventMachine 反应器中运行 Net::SSH 和 AMQP?
一些背景信息:Gerrit 通过 SSH 公开事件流。这是一个可爱的技巧,但我需要将这些事件转换为 AMQP 消息。我尝试使用 ruby-amqp 和 Net::SSH 但是,好…
Ruby EventMachine 与 PostgreSQL
我知道对于 mysql em-mysql 作为 MySQL 和 Active Record 的异步接口驱动程序存在,经过一些修改,可以立即使用。我相信Sequel已经具备了这个能力。我…
帕德里诺&&网络套接字
我正在寻找一种从 Padrino 应用程序中打开和使用 websocket 的方法。我知道 Padrino 使用单线程,但我正在寻找一种方法来打开 websockets 并在其“ono…
如何在 Ruby 中使用 Eventmachine 并行获取多个 JSON
我是 EM 新手,正在遵循这个示例: EventMachine.run { http = EventMachine::HttpRequest.new('http://google.com/').get :query => {'keyname' => '…
如今在 ruby 上制作异步 Web 应用程序有哪些好方法?
我正在寻找一个带有 WebSocket 组件的 web 应用程序,以及基于磨坊机架的前端。我最初的计划是使用 Camping 作为前端,在瘦网络上运行服务器,机架 co…
如何使用 eventmachine 异步处理 ruby post 请求
在 Rails 应用程序中发出请求的过程中,我想将数据发布到另一台服务器并完成原始请求,而不必等待外部帖子解析。我有以下可以正确发布的代码,但仍然…
从 Rails 到 EventMachine 服务器安排作业的最佳方式是什么?
我创建了执行一些后台作业的 eventmachine 应用程序。我想知道将数据从 Rails 应用程序发送到 eventmachine 应用程序的最佳方式是什么。 目前我正在考…
将大量消息发布到AMQP队列
使用 Ruby amqp 库的 v0.7.1 和 Ruby 1.8.7,我尝试将大量(数百万)短(~40 字节)消息发布到 RabbitMQ 服务器。我的程序的主循环(好吧,不是真正的…