2016-07-08 7 views
2

나는 express, ioredis 및 socket.io를 사용하고 있습니다. redis 제대로 작동하지만 socket.io 작동하지 않습니다. it'nt working.please 도움을.laovel 5.2에서 socket.io를 사용하여 연결하는 동안 io.on이 작동하지 않습니다. io.on 함수를 연결하는 동안 문제가 발생했습니다 (실제로 좌절했습니다).

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> 
+0

당신이'io.on'가 변경할 수'io.sockets.on'? 중복 된 코드를 제거하십시오. – Gintoki

+0

나는 이것을 이미 시도했지만 이것이 작동하지 않는다. 심지어 –

+0

? 너의 클라이언트 설정? – Gintoki

답변

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"); 
});