Node.js socket.io-client connect_failed/connect_error 事件

Question

我在玩 node.js 和 socket.io-client。我正在尝试连接到不存在的 channel 以触发事件“connect_failed”(在 https://github.com/LearnBoost/socket.io-client 中指定)。

但是我无法让事件正常进行:

var clientio = require('socket.io-client');
console.log('Trying stuff ...');

// the channel does not exist
var socket = clientio.connect( 'http://localhost:4000/news' );

// I expect this event to be triggered
socket.on('connect_error', function(){
    console.log('Connection Failed');
});
socket.on('connect', function(){
    console.log('Connected');
});
socket.on('disconnect', function () {
  console.log('Disconnected');
});
socket.send('hi there');

如果我执行会发生这种情况:

$ node tmp_clientio.js 
Trying stuff ...

关于如果连接到不存在的 channel 时如何触发错误的任何想法？

更新:将 connect_failed 重命名为 connect_error

Answer 1

我遇到了同样的问题。我也遇到过命名空间模式开启和关闭之间存在未记录的差异，最后我不得不使用 chrome 调试器来解决。

// Bind to the news namespace, also get the underlying socket
var ns_news = clientio.connect( 'http://localhost:4000/news' );
var socket = ns_news.socket

因此，您在上面看到，如果您想绑定(bind)“套接字级别”事件(例如连接失败)，则必须从命名空间中获取 实际套接字 ns_news.socket ，断开连接等

// Global events are bound against socket
socket.on('connect_failed', function(){
    console.log('Connection Failed');
});
socket.on('connect', function(){
    console.log('Connected');
});
socket.on('disconnect', function () {
  console.log('Disconnected');
});


// Your events are bound against your namespace(s)
ns_news.on('myevent', function() {
    // Custom event code here
});

请注意，您现在使用 ns_news 发送或接收事件

ns_news.send('hi there');

最后，一定要绑定(bind) socket.on('error', ...) 事件 - 如果端口不可用，它会发生

完全实现 8080 连接并回退到端口 80

我在我的实现中这样做了(尝试端口 8080，如果失败，通过 nginx 尝试端口 80)

socket_port = 8080;

ns_dash = io.connect("http://your.gridspy.co.nz/dash", {
  port: socket_port,
  'connect timeout': 5000,
  'flash policy port': 10843
});

socket = ns_dash.socket;

try_other_port = function() {
  if (socket_port !== 80) {
    if (typeof console !== "undefined" && console !== null) {
      console.log("Trying other port, instead of port " + socket_port + ", attempting port 80");
    }
    socket_port = 80;
    socket.options.port = socket_port;
    socket.options.transports = ['htmlfile', 'xhr-multipart', 'xhr-polling', 'jsonp-polling'];
    return socket.connect();
  } else {
    return typeof console !== "undefined" && console !== null ? console.log("No other ports to try.") : void 0;
  }
};
socket.on('connect_failed', function() {
  if (typeof console !== "undefined" && console !== null) {
    console.log("Connect failed (port " + socket_port + ")");
  }
  return try_other_port();
});
socket.on('error', function() {
  if (typeof console !== "undefined" && console !== null) {
    console.log("Socket.io reported a generic error");
  }
  return try_other_port();
});

我还添加了一个 nginx proxy_pass 规则，看起来像这样

location ~ ^/(socket.io)/ {
    proxy_pass http://127.0.0.1:8080;
    proxy_http_version 1.1;
    proxy_set_header Host $http_host;
    proxy_set_header Upgrade $http_upgrade;
    proxy_set_header Connection $connection_upgrade;
}

这里的升级和连接选项(来自 nginx 的更新版本)是升级 nginx 和 socket.io 之间的连接以支持 websockets 所必需的。这意味着您的网络服务器可以支持端口 80 上的 websocket。

此外，如果您的服务器支持 ssl/https，这将代理 wss，这是 websockets 的安全版本。