eventmachine

    3热度

    2回答

    有没有办法在EventMachine中创建非阻塞SOAP请求? 我正在使用adwords4r gem创建一个与google adwords api(基于SOAP)交互的ruby应用程序。应用程序使用EM通过stomp连接接收消息,然后通过对adwords API进行SOAP调用来处理这些消息。显然我需要这些调用是非阻塞的,因为处理将在反应器线程内。一种选择是使用EM.defer,但我宁愿没有线程池

    12热度

    1回答

    为了不阻塞反应堆,我想异步地读取文件,但是我没有发现使用EventMachine执行它的明显方法。我已经尝试了几种不同的方法,但没有人觉得不对劲: 只需读取该文件,它会阻止反应堆,但到底是什么,它不是是慢(除非它是一个大的文件,然后它肯定是)。 打开读取文件并在每个刻度上读取一个块(但要读多少?太多了,它会阻塞反应堆,太少并且读数会比所需的慢)。 EM.popen('cat some/file',

    2热度

    4回答

    我正在研究定期需要执行大量IO绑定操作的Rails应用程序。这些操作可以异步执行。例如,每天一次,对于每个用户,系统需要查询Salesforce.com以获取用户当前正在跟踪的帐户(公司)列表。这导致大量的数据(可能大于10万)的小型查询。 我们目前的方法是使用ActiveMQ和ActiveMessaging。我们的每个用户都会作为不同的消息被推送到队列中。然后,消费者将用户从队列中拉出,查询Sa

    7热度

    3回答

    我是EventMachine的新手,所以我不确定这是什么意思。我得到这个例外: EventMachine::ConnectionNotBound recieved ConnectionUnbound for an unknown signature: ef93a97d4d6441cb80d30fe2313d7de73 该程序相当复杂,所以我不能真正解释可能导致它的一切。我需要的只是一个指向寻找

    4热度

    3回答

    我在轨道上使用EventMachine和ruby构建聊天系统。这是为了学习的目的。 这是客户端连接到服务器的方式。 c = TCPSocket.open(ip_address, port) data = {:user_id => 2, :message => 'hello world'} c.send(data) response = c.gets c.close 它的工作原理。然而,

    0热度

    1回答

    虽然我在Fedora 12中启动服务器,但是客户端在Ubuntu 9.10中。客户端收到此错误消息。 但是,当我在Ubuntu 9.10中启动服务器时,这是Fedora 12中的一个客户端。 我已经关闭了FireWall。

    4热度

    3回答

    我有一个小型的HTTP服务器脚本,我写了使用eventmachine需要调用外部脚本/命令,并通过反引号(``)。当提供不运行反拨代码的请求时,一切都很好,但是,只要我的EM代码执行任何反向外部脚本,它就会停止服务请求并一般停止执行。 我注意到eventmachine似乎对子进程和/或线程很敏感,并且似乎有用于此目的的popen方法,但EM的源警告说此方法在Windows下不起作用。运行这个脚本的

    0热度

    2回答

    我目前正在研究一个嵌入Flash游戏的项目,该项目使用Smartfoxserver进行闪光通讯。这种沟通主要是让两个玩家之间的光标和物体移动同步。由于我不是一个闪光的家伙,但一个红宝石程序员,我很好奇:闪存提供了什么样的通信选择这种时间敏感的数据交换?我正在考虑编写一个基于ruby-eventmachine的通信服务器,以尽量减少对外部程序的依赖。这甚至可行吗?

    3热度

    2回答

    我已经在JRuby中插入了EventMachine(我正在使用Win32)。当我尝试在服务器的例子,我得到一个错误,当 require 'eventmachine' 的错误是: C:\dev\em>jruby server.rb server.rb:1:'需要':没有这样的文件来加载 - EventMachine的( LoadError) from server.rb:1 但是,宝石已安装

    3热度

    1回答

    我正在写一个ruby脚本来用作Postfix SMTP访问策略委托。该脚本需要访问东京暴君数据库。我正在使用EventMachine来处理网络连接。 EventMachine需要一个EventMachine :: Connection类,每当创建一个新的连接时,EventMachine的处理循环就会实例化这个EventMachine :: Connection类。所以对于每个连接,一个类被实例化并