2011-07-27 21 views
21

我試圖在Socket.io v.7中使用新的「房間」功能來創建動態聊天室,但我在獲取靜態房間時遇到問題。根據用戶選擇的URL,它們應該在room1或room2中結束。用戶在聊天中輸入的任何內容都應廣播給同一個房間的用戶。我有兩個瀏覽器(chrome & ff),每個瀏覽器都有一個打開/ room1和/ room2的選項卡,但是我輸入的任何東西似乎都不會播放到其他選項卡。我究竟做錯了什麼?帶有Socket.io和節點的動態房間

Server代碼

var app = require('express').createServer(); 
var io = require("socket.io").listen(app); 

io.sockets.on('connection', function (socket) { 

    // join to room and save the room name 
    socket.on('join room', function (room) { 
     socket.set('room', room, function() { console.log('room ' + room + ' saved'); }); 
     socket.join(room); 
    }) 

    socket.on('message', function(data) { 
     console.log("Client data: " + data); 

     // lookup room and broadcast to that room 
     socket.get('room', function(err, room) { 
      //room example - https://github.com/learnboost/socket.io 
      // neither method works for me 
      socket.broadcast.to(room).emit('new fan'); 
      io.sockets.in(room).emit('new non-fan'); 
     }) 
    }) 
}); 

app.get('/room1', function(req, res){  
    res.render('example2-client.ejs', {layout:false}); 
}); 

app.get('/room2', function(req, res){  
    res.render('example2-client-2.ejs', {layout:false}); 
}); 

app.listen(4000); 

客戶端代碼室1

<!DOCTYPE HTML> 
<html><head> 
<title>Code review for Snipet</title> 
<script type="text/javascript" src="http://ajax.googleapis.com/ajax/libs/jquery/1.4.4/jquery.min.js"></script> 
<script type="text/javascript" src="http://localhost:4000/socket.io/socket.io.js"></script> 
<script> 
$(document).ready(function() { 
    var socket = io.connect('http://localhost:4000'); 

    $("#msgbox").keypress(function(event) { 
     if (event.which == '13') { 
      sendmsg(); 
      event.preventDefault(); 
     } 
    });  

    socket.on('connect', function (data) { 
     socket.emit('join room', 'room1'); 
    }); 

    socket.on('message', function (data) { 
     add_message(data); 
    }); 

    function add_message(m) { 
     $("#chatlog").append(m); 
     $("#chatlog").append("<BR>"); 
    } 

    function sendmsg() 
    { 
     var r = $("#msgbox").val(); 
     socket.emit('message', r); 
     add_message(r); 
     $("#msgbox").val(''); 
    }  

}); 
</script> 
</head> 
<body> 
<div id="chat" style="height: 200px; width: 200px; border: 1px solid grey;"> 
<div id="chatlog" style="height: 178px; width: 200px; overflow-y: scroll;"></div> 
<input type="text" id="msgbox" style="margin-left: 2px; width: 193px;"> 
</div> 
</body> 
</html> 

客戶端代碼2

<!DOCTYPE HTML> 
<html><head> 
<title>Code review for Snipet</title> 
<script type="text/javascript" src="http://ajax.googleapis.com/ajax/libs/jquery/1.4.4/jquery.min.js"></script> 
<script type="text/javascript" src="http://localhost:4000/socket.io/socket.io.js"></script> 
<script> 
$(document).ready(function() { 
    var socket = io.connect('http://localhost:4000'); 

    $("#msgbox").keypress(function(event) { 
     if (event.which == '13') { 
      sendmsg(); 
      event.preventDefault(); 
     } 
    });  

    socket.on('connect', function (data) { 
     socket.emit('join room', 'room2'); 
    }); 

    socket.on('message', function (data) { 
     add_message(data); 
    }); 

    function add_message(m) { 
     $("#chatlog").append(m); 
     $("#chatlog").append("<BR>"); 
    } 

    function sendmsg() 
    { 
     var r = $("#msgbox").val(); 
     socket.emit('message', r); 
     add_message(r); 
     $("#msgbox").val(''); 
    }  

}); 
</script> 
</head> 
<body> 
<div id="chat" style="height: 200px; width: 200px; border: 1px solid grey;"> 
<div id="chatlog" style="height: 178px; width: 200px; overflow-y: scroll;"></div> 
<input type="text" id="msgbox" style="margin-left: 2px; width: 193px;"> 
</div> 
</body> 
</html> 

回答

34

你似乎並不爲b e聆聽這些事件

socket.broadcast.to(room).emit('new fan'); 
io.sockets.in(room).emit('new non-fan'); 

在您需要的客戶端:

socket.on('new fan', function (data) { 
    console.log('new fan'); 
}); 

你還沒有將消息發送到客戶端。 內部:

socket.on('message', function(data) { }) 

在服務器上,你需要做的:

io.sockets.in(room).emit('message', data); 
+0

我雖然該客戶會從服務器接收的所有消息在socket.on(「信息」,...函數? 其實我正在發送消息給客戶端。在上面的示例中,我從發送客戶端收到消息,查找房間並試圖調用socket.broadcast.to(room).emit('some文字') – Rick

+2

你的客戶正在收聽socket.on('message'...),但你的服務器沒有發出'信息' 您需要將「io.sockets.in(room).emit('message',data);」添加到您的服務器代碼中。 –

+0

在工作的服務器上添加通道「消息」。謝謝。 – Rick