|
@@ -0,0 +1,26 @@
|
|
|
|
|
+//引用http和socket.io模块
|
|
|
|
|
+var us = {}
|
|
|
|
|
+us.http = require('http'), socketio = require('socket.io');
|
|
|
|
|
+us.app = us.http.createServer(function (req, res) {});
|
|
|
|
|
+//服务开始监听
|
|
|
|
|
+us.app.listen(888);
|
|
|
|
|
+//输出调试信息
|
|
|
|
|
+//console.log("Http Server start at 888");
|
|
|
|
|
+
|
|
|
|
|
+//socketio开始监听
|
|
|
|
|
+us.socketio = socketio.listen(us.app);
|
|
|
|
|
+
|
|
|
|
|
+//webSocket协议握手成功
|
|
|
|
|
+////'connection' 是socket.io 保留的.不能错,结果在变量socket中
|
|
|
|
|
+us.socketio.sockets.on('connection', function (socket) {
|
|
|
|
|
+ //socket.emit('sSayhello', { hi: 'Happy new year.' }); //sSayHello是自己定义的,客户端听取的时候要
|
|
|
|
|
+ //指定同名的事件。'cSayhello'需要和客户端发送时定义的事件名相同。
|
|
|
|
|
+ socket.on('msg', function (data) {
|
|
|
|
|
+ //console.log('Get a msg from client ...');
|
|
|
|
|
+ //console.log(data);
|
|
|
|
|
+ socket.broadcast.emit('user message', data);
|
|
|
|
|
+ });
|
|
|
|
|
+ //console.log("WebSocket connect ok....");
|
|
|
|
|
+})
|
|
|
|
|
+
|
|
|
|
|
+
|