欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

HTML5+NodeJs实现WebSocket即时通讯

程序员文章站 2022-10-31 14:58:50
 最近都在学习html5,做canvas游戏之类的,发现html5中除了canvas这个强大的工具外,还有websocket也很值得注意。可以用来做双屏互动游戏,何为双屏互动游戏?就是通过移动端设备...
 最近都在学习html5,做canvas游戏之类的,发现html5中除了canvas这个强大的工具外,还有websocket也很值得注意。可以用来做双屏互动游戏,何为双屏互动游戏?就是通过移动端设备来控制pc端网页游戏。这样的话就要用到实时通讯了,而websocket无疑是最合适的。websocket相较于http来说,有很多的优点,主要表现在websocket只建立一个tcp连接,可以主动推送数据到客户端,而且还有更轻量级的协议头,减少数据传送量。所以websocket暂时来说是实时通讯的最佳协议了。

 

  至于服务器语言选择nodejs,一是因为自己是做前端的,对javascript比较熟悉,相比于其他后台语言,自然会更喜欢nodejs了,二是nodejs本身事件驱动的方式很擅长与大量客户端保持高并发的连接。所以就选择nodejs了。

 

  服务器的实现很简单,先装一个nodejs的模块,叫nodejs-websocket , 直接在nodejs命令行中敲入:npm install nodejs-websocket回车就可以安装好了,然后就可以开始建立服务器了,因为有了nodejs-websocket模块,所以很多工作都不用我们自己做,直接调用别人封装好的方法就行了:

 

  【服务端代码】,根据客户端传来的消息判断哪个是game1,哪个是game2,保存connection对象。

 

复制代码

var ws = require("nodejs-websocket");

console.log("开始建立连接...")

 

var game1 = null,game2 = null , game1ready = false , game2ready = false;

var server = ws.createserver(function(conn){

    conn.on("text", function (str) {

        console.log("收到的信息为:"+str)

        if(str==="game1"){

            game1 = conn;

            game1ready = true;

            conn.sendtext("success");

        }

        if(str==="game2"){

            game2 = conn;

            game2ready = true;

        }

 

        if(game1ready&&game2ready){

            game2.sendtext(str);

        }

 

        conn.sendtext(str)

    })

    conn.on("close", function (code, reason) {

        console.log("关闭连接")

    });

    conn.on("error", function (code, reason) {

        console.log("异常关闭")

    });

}).listen(8001)

console.log("websocket建立完毕")

复制代码

 

 

【game1代码】:通过点击获取三个框的内容,传到服务器

 

复制代码

<!doctype html>

<html lang="en">

<head>

    <meta charset="utf-8">

    <title>document</title>

    <style>

        .kuang{text-align: center;margin-top:200px;}

        #mess{text-align: center}

        .value{width: 200px;height:200px;border:1px solid;text-align: center;line-height: 200px;display: inline-block;}

    </style>

</head>

<body>

    <p id="mess">正在连接...</p>

    <p class="kuang">

        <p class="value" id="value1">小明小明</p>

        <p class="value" id="value2">大胸大胸</p>

        <p class="value" id="value3">小张小张</p>

    </p>

 

    <script>

        var mess = document.getelementbyid("mess");

        if(window.websocket){

            var ws = new websocket('ws://192.168.17.80:8001');

 

            ws.onopen = function(e){

                console.log("连接服务器成功");

                ws.send("game1");

            }

            ws.onclose = function(e){

                console.log("服务器关闭");

            }

            ws.onerror = function(){

                console.log("连接出错");

            }

 

            ws.onmessage = function(e){

                mess.innerhtml = "连接成功"

                document.queryselector(".kuang").onclick = function(e){

                    var time = new date();

                    ws.send(time + "  game1点击了“" + e.target.innerhtml+"”");

                }

            }

        }

    </script>

</body>

</html>

复制代码

 

 

【game2代码】:获取服务推送来的消息,并且显示

 

复制代码

<!doctype html>

<html lang="en">

<head>

    <meta charset="utf-8">

    <title>document</title>

    <style>

        .kuang{text-align: center;margin-top:200px;}

        #mess{text-align: center}

    </style>

</head>

<body>

    <p id="mess"></p>

 

    <script>

        var mess = document.getelementbyid("mess");

        if(window.websocket){

            var ws = new websocket('ws://192.168.17.80:8001');

 

            ws.onopen = function(e){

                console.log("连接服务器成功");

                ws.send("game2");

            }

            ws.onclose = function(e){

                console.log("服务器关闭");

            }

            ws.onerror = function(){

                console.log("连接出错");

            }

 

            ws.onmessage = function(e){

                var time = new date();

                mess.innerhtml+=time+"的消息:"+e.data+"<br>"

            }

        }

    </script>

</body>

</html>