如何在同一个端口上提供Cramp::Websocket和普通的Rack应用程序？
我试图使用相同的端口来提供正常的HTTP流量，以及使用Ruby1.9.3和HTML5 1.3.1通过抽筋 (构建在EventMachine之上)的抽筋 websocket。下面是一个最小的、独立的示例：
require 'thin'
require 'cramp'
require 'http_router'
Cramp::Websocket.backend = :thin
class SocketApp < Cramp::Action
self.transport = :websocket
on_start = :connected
on_finish = :disconnected
on_data = :message
def connected
puts 'Client connected'
end
def disconnected
puts 'Client disconnected'
end
def message(msg)
puts "Got message: #{msg}"
render 'Here is your reply'
end
end
class WebApp
def call(env)
[ 200, { 'Content-Type' => 'text/html' }, <<EOF
<html><head>
<script>
function init() {
function log(msg) { document.getElementById('log').innerHTML += msg + '<br>'; }
var socketUri = 'ws://' + document.location.host + '/socket';
log('Socket URI: ' + socketUri);
var socket = new WebSocket(socketUri);
socket.onopen = function(e) {
log('onopen');
socket.send('Is there anybody out there?');
log('sent message');
};
socket.onclose = function(e) {
log('onclose; code = ' + e.code + ', reason = ' + e.reason);
};
socket.onerror = function(e) {
log('onerror');
};
socket.onmessage = function(e) {
log('onmessage; data = ' + e.data);
};
}
</script>
</head><body onload='init();'>
<h1>Serving Cramp::Websocket and normal Rack app on the same port</h1>
<p id='log'></p>
</body></html>
EOF
]
end
end
app = HttpRouter.new do
add('/socket').to SocketApp
add('/').to WebApp.new
end
run app如果您想自己尝试这一点，请将此代码放入名为config.ru的文件中并运行thin start。您需要安装宝石thin、cramp和http_router。
这样做的想法是，JavaScript代码与ws://localhost:3000/socket建立一个WebSocket连接，该连接与发送给它的消息相呼应，但这并不像预期的那样工作。open事件触发，在发送消息时没有错误，但我们永远得不到响应。
从服务器的角度来看，由于没有打印Client connected消息，因此没有建立连接。
使用thin start -D，我可以看到HTTP101正在发生，并且正在交换一些二进制数据。
我做错了什么？
Update：如果我将文件分成两部分，取出HttpRouter，并在不同的端口上运行两个thin实例，它仍然不能工作。因此，问题在于套接字代码，而不是HttpRouter或WebApp。
回答 1
Stack Overflow用户
发布于 2012-05-05 21:32:48
嗯，这是作弊，但我最终通过切换到另一个库：websocket机架解决了这个问题。对于好奇的人，更正后的代码如下：
require 'thin'
require 'http_router'
require 'rack/websocket'
class SocketApp < Rack::WebSocket::Application
def on_open(env)
puts 'Client connected'
end
def on_close(env)
puts 'Client disconnected'
end
def on_message(env, message)
puts "Got message: #{message}"
send_data 'Here is your reply'
end
end
class WebApp
def call(env)
[200, { 'Content-Type' => 'text/html' }, <<EOF
<html><head>
<script>
function init() {
function log(msg) { document.getElementById('log').innerHTML += msg + '<br>'; }
var socketUri = 'ws://' + document.location.host + '/socket';
log('Socket URI: ' + socketUri);
var socket = new WebSocket(socketUri);
socket.onopen = function(e) {
log('onopen');
socket.send('Is there anybody out there?');
log('sent message');
};
socket.onclose = function(e) {
log('onclose; code = ' + e.code + ', reason = ' + e.reason);
};
socket.onerror = function(e) {
log('onerror');
};
socket.onmessage = function(e) {
log('onmessage; data = ' + e.data);
};
}
</script>
</head><body onload='init();'>
<h1>Serving WebSocket and normal Rack app on the same port</h1>
<p id='log'></p>
</body></html>
EOF
]
end
end
app = HttpRouter.new do
add('/socket').to(SocketApp.new)
add('/').to(WebApp.new)
end
run apphttps://stackoverflow.com/questions/10465659
复制相似问题
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号