美文网首页程序员
nodejs websocket

nodejs websocket

作者: IT小C | 来源:发表于2016-03-25 14:43 被阅读949次

    Node.js中使用socket的一个包。使用它可以很方便地建立服务器到客户端的sockets连接,发送事件与接收特定事件

    npm install socket.io

    老版本的所有文件都是在一个socket.io文件夹下
    最新的socket.io安装完之后把功能分成了4个文件夹

    我们需要将socket.io-client目录下的socket.io.js文件拷贝到客户端目录下
    这样在客户端可以直接调用

    //建立到服务器的socket连接
    var socket = io.connect();
    //监听socket的connect事件,此事件表示连接已经建立
    socket.on('connect', function() {
        //连接到服务器后的操作
    });
    

    1.客户端发送消息到服务器

    socket.emit('login', username, password);
    

    这里我们通过socket发起一个login登陆事件,将用户名,密码发送到服务器端

    2.服务器端接收消息

    var express = require("express"),
        http = require("http"),
        app = express(),
        server = http.createServer(app),
        io = require("socket.io").listen(server),/*在服务器监听socket.io*/
        app.use('/',express.static(__dirname+'/public'));
    server.listen(8082);
    console.log("server start");
    
    //socket部分
    io.on('connection',function(socket){
        //接收并处理客户端发送的login事件
        socket.on('login',function(username,password){
            //登陆认证操作
        })
    });
    

    3.服务器端发送消息到客户端
    需要说明一下的是,在connection事件的回调函数中,socket表示的是当前连接到服务器的那个客户端。
    所以如果希望只有自己收得到这个事件消息,可以通过

    socket.emit('error');
    

    如果希望给除了自己以外的所有人发送消息,则可以通过

    socket.broadcast.emit('result','username离线了');
    

    如果希望所有人都可以收到消息(包括自己),则可以通过

    io.sockets.emit('result','username上线了');
    

    4.客户端接收服务器端发送过来的消息

    socket.on('error', function() {
        //错误提示          
    });
    
    socket.on('result', function(info) { 
        //判断用户是连接还是离开以显示不同的信息
    });
    

    5.判断用户离线事件可以通过socket.io自带的disconnect事件完成,当一个用户断开连接,disconnect事件就会触发。

    socket.on('disconnect', function() {
        //用户离线通知    
    });
    

    注:在做聊天室的时候经常会遇到非正常离线的情况,需要在disconnect判断保存的用户Id是否存在,防止非正常离线

    socket.on('disconnect', function() {
        if(socket.userId){
            //用户离线通知 
        }
    });
    

    6.存储和读取当前用户的数据
    我们可以在socket中存储一些客户端的消息数据

    socket.userId = rows[0].id;
    socket.username = username;
    

    这样在服务器端的其他socket消息里可以直接访问存储的信息

    socket.broadcast.emit('system', socket.userId, 'logout');
    

    相关文章

      网友评论

        本文标题:nodejs websocket

        本文链接:https://www.haomeiwen.com/subject/gkzrlttx.html