Удастся ли Синатре работать вместе с EventMachine WebSockets? - PullRequest
Новая
       52

Удастся ли Синатре работать вместе с EventMachine WebSockets?

36 голосов
/ 08 июня 2010

Я уже некоторое время пользуюсь Sinatra, и я хотел бы добавить некоторые функции реального времени в свое веб-приложение, передавая данные через веб-сокеты.

Я успешно использовал гем 'em-websocket' сам по себе, но не смог написать один файл ruby, который имеет веб-сервер sinatra И сервер веб-сокетов.

Я пробовал крутить бег! или начать! методы отключены в отдельных потоках без успеха.

Кто-нибудь заставил это работать?

Я хочу, чтобы они были в том же файле, что и я, чтобы потом делиться переменными между двумя серверами.

Спасибо!

Ответы [ 5 ]

27 голосов
/ 09 июня 2010

Не пробовал, но не должно быть слишком сложно: 

require 'em-websocket'
require 'sinatra/base'
require 'thin'

EM.run do
  class App < Sinatra::Base
    # Sinatra code here
  end

  EM::WebSocket.start(:host => '0.0.0.0', :port => 3001) do
    # Websocket code here
  end

  # You could also use Rainbows! instead of Thin.
  # Any EM based Rack handler should do.
  Thin::Server.start App, '0.0.0.0', 3000
end

Кроме того, Cramp имеет реализацию websocket, которая работает напрямую с Thin / Rainbows!Вы можете извлечь данные, поэтому вам даже не нужно будет запускать сервер на другом порту.

20 голосов
/ 10 июня 2010

Спасибо, Константин ... это сработало! Мне пришлось немного подправить твой код. Я добавил комментарии, где я его изменил.

-poul 

require 'rubygems'      # <-- Added this require
require 'em-websocket'
require 'sinatra/base'
require 'thin'

EventMachine.run do     # <-- Changed EM to EventMachine
  class App < Sinatra::Base
      get '/' do
          return "foo"
      end
  end

  EventMachine::WebSocket.start(:host => '0.0.0.0', :port => 8080) do |ws| # <-- Added |ws|
      # Websocket code here
      ws.onopen {
          ws.send "connected!!!!"
      }

      ws.onmessage { |msg|
          puts "got message #{msg}"
      }

      ws.onclose   {
          ws.send "WebSocket closed"
      }

  end

  # You could also use Rainbows! instead of Thin.
  # Any EM based Rack handler should do.
  App.run!({:port => 3000})    # <-- Changed this line from Thin.start to App.run!
end
17 голосов
/ 30 марта 2011

Я наткнулся на этот проект websocket-rack github, который в основном представляет собой упрощенный em-websocket , и фактически заставил его работать прекрасно с приложением Sinatra. Вот мой config.ru:

require 'rubygems'
require 'rack/websocket'
require 'sinatra/base'

class WebSocketApp < Rack::WebSocket::Application
  # ...
end

class SinatraApp < Sinatra::Base
  # ...
end

map '/ws' do
  run WebSocketApp.new
end

map '/' do
  run SinatraApp
end

Веселись!
Colin

11 голосов
/ 14 августа 2012

Я использовал sinatra-websocket . Это позволит вам запустить сервер websocket в том же процессе и на том же порту, что и Sinatra.

Отказ от ответственности: я сопровождающий. 

require 'sinatra'
require 'sinatra-websocket'

set :server, 'thin'
set :sockets, []

get '/' do
  if !request.websocket?
    erb :index
  else
    request.websocket do |ws|
      ws.onopen do
        ws.send("Hello World!")
        settings.sockets << ws
      end
      ws.onmessage do |msg|
        EM.next_tick { settings.sockets.each{|s| s.send(msg) } }
      end
      ws.onclose do
        warn("websocket closed")
        settings.sockets.delete(ws)
      end
    end
  end
end

__END__
@@ index
<html>
  <body>
     <h1>Simple Echo & Chat Server</h1>
     <form id="form">
       <input type="text" id="input" value="send a message"></input>
     </form>
     <div id="msgs"></div>
  </body>

  <script type="text/javascript">
    window.onload = function(){
      (function(){
        var show = function(el){
          return function(msg){ el.innerHTML = msg + '<br />' + el.innerHTML; }
        }(document.getElementById('msgs'));

        var ws       = new WebSocket('ws://' + window.location.host + window.location.pathname);
        ws.onopen    = function()  { show('websocket opened'); };
        ws.onclose   = function()  { show('websocket closed'); }
        ws.onmessage = function(m) { show('websocket message: ' +  m.data); };

        var sender = function(f){
          var input     = document.getElementById('input');
          input.onclick = function(){ input.value = "" };
          f.onsubmit    = function(){
            ws.send(input.value);
            input.value = "send a message";
            return false;
          }
        }(document.getElementById('form'));
      })();
    }
  </script>
</html>
8 голосов
/ 17 декабря 2010

К вашему сведению, вы также можете использовать приложения Padrino с EventMachine (поскольку они являются подмножествами приложений Sinatra): 

require 'rubygems'
require 'eventmachine'
require 'padrino-core'
require 'thin'
require ::File.dirname(__FILE__) + '/config/boot.rb'

EM.run do
  Thin::Server.start Padrino.application, '0.0.0.0', 3000
end

Приветствия, Майк

...