eventmachine

    2

    1답변

    저는 Cramp 프레임 워크를 Redis gem 및 em-synchrony 및 WebSocket과 함께 사용하여 채팅 관련 웹 응용 프로그램을 빌드하고 몇 가지 문제가 있습니다. class DrawingAction < Cramp::Action use_fiber_pool self.transport = :websocket on_s

    5

    6답변

    나는 찾을 수있는 모든 곳을 보았지만 이것에 대한 해결책을 찾지 못했습니다. Lion 10.8.2에서 xcode 4.5.1을 사용하고 있습니다. 저는 레일즈 프로젝트를 위해 번들을 실행하려고하는데이 문제가 계속 발생합니다. 나는 '엷은'보석을 히로쿠에게 사용하고 있습니다. 지금은 희박함이없는 것입니다. 해결책을 찾은 사람은 누구입니까? [email prot

    1

    2답변

    EventMachine을 사용하여 채팅 서버에 쓰려고합니다. 어떻게 하나의 EventMachine 연결에서 다른 스레드로 안전하게 메시지를 전달할 수 있습니까? 메시징 프로토콜 (Stomp)이 지원되는 것을 볼 수 있지만 사용 방법을 알 수는 없습니다. 어떤 도움을 주셔서 감사합니다. EventMachine에서 스톰프 - http://eventmachine

    0

    1답변

    일부 세션에서 서버에 em-http-request 다중 요청을해야합니다. 가능한가? sessionId 매개 변수에 대한 응답으로 url을받습니다. 모든 요청에 ​​대해 동일합니다. 하지만 다를 수 있습니다. 즉 : example.com?sessionId=AabBcC example.com?sessionId=DdEeFf

    1

    1답변

    레일 응용 프로그램에서 faye 서버를 실행할 때이 오류가 발생합니다. 나는 eventmachine gem을 설치했고 또한 faye에 대한 초기화 파일에 이벤트 머신을 요구했다. /Users/vivekvivek/.rvm/gems/ruby-1.9.3-p194/gems/eventmachine-1.0.0/lib/eventmachine.rb:664:in `conn

    0

    1답변

    Ruby EventMachine에서 PeriodicTimer를 생성 할 때 매우 부정확하고 무작위 적으로 올바르지 않은 것처럼 보입니다. 문제를 해결할 수있는 방법이 있는지, 아니면 잘못된 방식으로 사용하고 있는지 궁금합니다. 다음은 예제입니다. 매 10 초마다 (mysql 문을 포함하는) 전역 배열을 가져오고 mysql 명령을 실행하는 PeriodicTi

    4

    1답변

    나는 eventmachine을 사용하여 HornetQ 주제를 읽으며 EM websocket 연결에서 가입 한 채널로 푸시합니다. @ topic.receive 루프가 차단되지 않도록해야하므로 proc을 만들고 콜백없이 EventMachine.defer를 호출해야합니다. 이것은 무기한으로 실행됩니다. 이것은 잘 작동합니다. Thread.new를 방금 사용했을

    1

    1답변

    자바 스크립트 클라이언트 연결 (eventmachine 1.0.0) : EM.run { # WebSocket Server EM::WebSocket.start(:host => "0.0.0.0", :port => 8080) do |ws| ws.onopen do sid = @channel.subscribe{|msg| ws.

    3

    1답변

    씬 서버는 EventMachine을 기반으로하므로 EM.synchrony 블록에서 중지 할 수 없습니다. 그러나이 경우 출력은 2, 1이지만 1,2는 아닙니다. 어떻게 해결할 수 있습니까? EM.synchrony do update_ads ads_hash, invalid_ads, ip, params, user_agent, request EM

    3

    1답변

    예제 코드는 here에서 뒤에 논리를 설명해주십시오 : def http_get(url) f = Fiber.current http = EventMachine::HttpRequest.new(url).get # resume fiber once http call is done http.callback { f.resume(htt