io.on 在 Laravel 5.2 中使用 socket.io 进行连接时不起作用

Question

我在连接io.on函数时遇到问题（我真的很沮丧）。 我正在使用Express，Iredis和 socket.io。 Redis工作正常，但 socket.io 无法正常工作。 它不起作用。请帮忙。

var app = require('express')();
var server = require('http').Server(app);
var io = require('socket.io')(server);
var Redis = require('ioredis');
var redis = new Redis();
//port connection
server.listen(3000);
console.log('server listening 3000');
//redis sub (working fine)
redis.subscribe('test-channel', function () {
    console.log('Redis: test-channel subscribed');
});
//this code is not working (stop execution)
io.on('connection', function(socket){
    console.log("new client connected");
});

io.on('connection', function (socket) {
    console.log("new client connected");
    redis.subscribe('message');
    console.log("redis start");
    //send message to frontend
    redis.on("message", function(channel, message) {
        console.log("mew message in queue "+ message + "channel");
        socket.emit(channel, message);
    });
    //close socket
    socket.on('disconnect', function() {
        redis.quit();
        console.log('redis disconnected!');
    });
});

客户端

     <link rel="stylesheet" href="http://maxcdn.bootstrapcdn.com/bootstrap/3.3.6/css/bootstrap.min.css">
     <script src="https://ajax.googleapis.com/ajax/libs/jquery/1.12.2/jquery.min.js"></script>
    <script src="http://maxcdn.bootstrapcdn.com/bootstrap/3.3.6/js/bootstrap.min.js"></script>
    <script src="http://code.jquery.com/jquery-1.11.2.min.js"></script>
    <script src="http://code.jquery.com/jquery-migrate-1.2.1.min.js"></script>
    <script src="https://cdn.socket.io/socket.io-1.3.4.js"></script>
   <script>
        var socket = io.connect('http://localhost:3000');
        socket.on('message', function (data) {
            $(".progress-bar").css('width',+data+'%');
            alert('connection established');
            $("#messages").append( "<p>"+data+"</p>" );
        });
    </script>

Answer 1

服务器端

var express = require('express');
var app = express();
var server = require('http').createServer(app);
var io = require('socket.io').listen(server); // it was require('socket.io')(server);
server.listen(3000);

客户端

io.sockets.on('connection', function(socket){
    console.log("new client connected");
});

Answer 2

const { server } = require（"socket.io"）const io = new server（server）