如何从客户端发出消息 [node.js + socket.io]

Question

我正在尝试使用 socket.io 从客户端发出消息...

这是我的客户端代码：

var socket = io.connect('http://localhost/');
          socket.on('connect', function(data){
                setStatus('connected');
                socket.emit('subscribe', {channel:'update.comment'});
            });

服务器：

io.sockets.on('connection', function (socket) {
  socket.emit('message', { text : 'Welcome!' });
  socket.on('subscribe', function (data) {
    socket.join(data.channel);
    redisClient.subscribe(data.channel);
  });
});

我在控制台中也收到此错误消息：

获取 http://localhost/socket.io?EIO=3&transport=polling&t=1442169984269-1 404（未找到）

完整的服务器：

var app = require('express')();
var http = require('http').Server(app);
var redis = require('ioredis');
var io = require('socket.io')(http);

redisClient = redis.createClient();

//look for connection errors and log
redisClient.on("error", function (err) {
    console.log("error event - " + redisClient.host + ":" + redisClient.port + " - " + err);
});

io.sockets.on('connection', function (socket) {
  socket.emit('message', { text : 'Welcome!' });
  //on subscription request joins specified room
  //later messages are broadcasted on the rooms
  socket.on('subscribe', function (data) {
    socket.join(data.channel);
    redisClient.subscribe(data.channel);
  });
});

redisClient.on('ready', function(data) {
  console.log('#redis ready');
});

redisClient.on("message", function(channel, message){
    console.log(channel);
    var resp = {'text': message, 'channel':channel};
    io.sockets.in(channel).emit('message', resp);
});

http.listen(3000, function(){
    console.log('Listening on Port 3000');
});

Answer 1

发现新问题：

您的服务器正在侦听端口 3000，但您正尝试连接端口 80。错误消息 http://localhost/socket.io?EIO=3&transport=polling&t=1442169984269-1 上没有端口号，因此默认为端口 80。

---

该错误消息意味着您的服务器端 socket.io 代码未正确初始化，因此未侦听启动所有 webSocket 连接的 HTTP 请求，因此当浏览器尝试连接该 URL 以启动 socket.io连接，服务器端没有人在监听，所以网络服务器返回一个 404 错误给浏览器。

如果您使用 Express，这是将其挂接到服务器的最小 socket.io 初始化：

var express = require('express');
var app = express();
var server = app.listen(8081);
var io = require('socket.io').listen(server);

对于普通的 HTTP 服务器，这是最小的 socket.io 初始化：

var app = require('http').createServer(handler)
var io = require('socket.io')(app);
app.listen(80);

与往常一样，如果您向我们展示您正在使用的 socket.io 和 Web 服务器初始化代码，我们可以帮助您更好地解决您的特定代码问题。