WebSocket

WebSocket API是下一代客户端-服务器的异步通信方法。该通信取代了单个的TCP套接字,使用ws或wss协议,可用于任意的客户端和服务器程序。WebSocket目前由W3C进行标准化。WebSocket已经受到Firefox 4、Chrome 4、Opera 10.70以及Safari 5等浏览器的支持。

WebSocket API最伟大之处在于服务器和客户端可以在给定的时间范围内的任意时刻,相互推送信息。WebSocket并不限于以Ajax(或XHR)方式通信,因为Ajax技术需要客户端发起请求,而WebSocket服务器和客户端可以彼此相互推送信息;XHR受到域的限制,而WebSocket允许跨域通信。

Ajax技术很聪明的一点是没有设计要使用的方式。WebSocket为指定目标创建,用于双向推送消息。

ajax轮询

客户端:啦啦啦,有没有新信息(Request)
服务端:没有(Response)
客户端:啦啦啦,有没有新信息(Request)
服务端:没有。。(Response)
客户端:啦啦啦,有没有新信息(Request)
服务端:你好烦啊,没有啊。。(Response)
客户端:啦啦啦,有没有新消息(Request)
服务端:好啦好啦,有啦给你。(Response)
客户端:啦啦啦,有没有新消息(Request)
服务端:。。。。。没。。。。没。。。没有(Response) —- loop

WebSocket

客户端:啦啦啦,我要建立Websocket协议,需要的服务:chat,Websocket协议版本:17(HTTP Request)
服务端:ok,确认,已升级为Websocket协议(HTTP Protocols Switched)
客户端:麻烦你有信息的时候推送给我噢。。
服务端:ok,有的时候会告诉你的。
服务端:balabalabalabala
服务端:balabalabalabala
服务端:哈哈哈哈哈啊哈哈哈哈
服务端:笑死我了哈哈哈哈哈哈哈

socket.io

node.js提供了高效的服务端运行环境,但是由于浏览器端对HTML5的支持不一,为了兼容所有浏览器,提供卓越的实时的用户体验,并且为程序员提供客户端与服务端一致的编程体验,于是socket.io诞生。Socket.io将Websocket和轮询 (Polling)机制以及其它的实时通信方式封装成了通用的接口,并且在服务端实现了这些实时机制的相应代码。也就是说,Websocket仅仅是 Socket.io实现实时通信的一个子集。那么,Socket.io都实现了Polling中的那些通信机制呢?

  • Adobe® Flash® Socket
  • AJAX long polling
  • AJAX multipart streaming
  • Forever Iframe
  • JSONP Polling

使用socket.io制作聊天室

  1. 初始化package.json文件
    在项目文件夹主目录下执行以下命令

    $ cnpm init -y
    
  2. 安装对应的包

    • express 服务器端路由的制作

      $ cnpm install --save express
      

    • socket.io WebScoket的封装库

      $ cnpm install --save socket.io
      
  3. 编写server.js服务器文件
    创建server.js文件,作为服务器,使用express模块进行路由的编写

    // 引入对应的模块
    var app = require('express')();
    var http = require('http').Server(app);
    
    // 访问首页即访问index.html文件
    app.get('/', function(req, res) {
        res.sendfile(__dirname + '/index.html');
    });
    
    // 设置端口以及回调
    http.listen(8888, function() {
        console.log('listening on *:3000');
    });
    
  4. 编写index.html文件

    <!DOCTYPE html>
    <html>
        <head>
            <meta name="viewport" content="width=device-width, initial-scale=1.0, maximum-scale=1.0, user-scalable=no">
            <meta charset="utf-8">
            <title></title>
            <style media="screen">
                * { margin: 0; padding: 0; }
                html, body { width: 100%; height: 100%; }
                #messages { list-style-type: none; }
                #messages li { padding: 5px 10px; }
                #messages li:nth-child(odd) { background: #eee; }
                form { position: fixed; left: 0; right: 0; bottom: 0; height: 50px; background-color: #333; }
                form input { width: 80%; height: 40px; margin-top: 5px; border: none; }
                form button { width: 18%; height: 100%; background-color: cyan; border: none; }
            </style>
        </head>
        <body>
    
            <div class="container">
                <ul id="messages"></ul>
                <form action="">
                    <input id="m" type="text" name="" value="">
                    <button type="submit">Send</button>
                </form>
            </div>
    
        </body>
    </html>
    
  5. 在终端执行node server.js命令,即可运行服务器,打开浏览器输入http://localhost:8888,即可看到效果

  6. server.js中添加代码,进行socket.io的数据传输事件的注册,并重启服务

    // 引入对应的模块
    var app = require('express')();
    var http = require('http').Server(app);
    
    // 新增代码++++++++++++++++++++++++++
    // 引入socket.io模块
    var io = require('socket.io')(http);
    
    // 访问首页即访问index.html文件
    app.get('/', function(req, res) {
        res.sendFile(__dirname + '/index.html');
    });
    
    // 新增代码++++++++++++++++++++++++++
    // 注册事件,连接成功即可执行
    io.on('connection', function (socket) {
        console.log('链接已成功');
    
        // 注册事件,连接断开即可执行
        io.on('disconnection', function (socket) {
            console.log('链接已断开');
        });
    });
    
    // 设置端口以及回调
    http.listen(8888, function() {
        console.log('listening on *:3000');
    });
    
  7. index.html中添加代码,创建一个socket对象,即可触发server.js中注册的事件

    <script src="/socket.io/socket.io.js"></script>
    <script type="text/javascript">
        var socket = io();
    </script>
    

    刷新网页的时候,即可看到如下的输出结果:

    lidaze-MBP-2:chat-room lidaze$ node server.js
    listening on *:3000
    链接已成功
    链接已断开
    链接已成功
    链接已断开
    链接已成功
    
  8. 继续index.html文件代码的编写

    <script src="/socket.io/socket.io.js"></script>
    <script src="https://code.jquery.com/jquery-1.11.1.js"></script>
    <script type="text/javascript">
        $(function () {
            // 创建socket对象
            var socket = io();
    
            // 设置表单提交事件
            $('form').submit(function () {
                // 使用socket触发事件,通过传参的方式将数据传递给服务器
                socket.emit('chat message to server', $('#m').val());
                $('#m').val('');
                return false;
            });
        });
    </script>
    
  9. 当点击网页中的发送按钮时,会触发socket触发事件,进行数据的传递,同样的,也需要在服务器端进行事件的监听
    server.js中添加如下代码,进行数据的获取

    // 注册事件,连接成功即可执行
    io.on('connection', function (socket) {
        console.log('链接已成功');
    
        // 新增代码++++++++++++++++++++++++++
        // 用于接收数据的监听
        socket.on('chat message to server', function (msg) {
            console.log('message: ' + msg);
        });
    
        // 注册事件,连接断开即可执行
        socket.on('disconnect', function (socket) {
            console.log('链接已断开');
        });
    });
    

    重启服务器,在网页中输入内容,然后点击发送按钮,即可看到控制台中有内容输出

  10. 现在已经实现了前端向后台发送数据,下面来实现服务器向浏览器返回数据。并重启服务

// 用于接收数据的监听
socket.on('chat message to server', function (msg) {
    console.log('message: ' + msg);
    // 新增代码++++++++++++++++++++++++++
    // 使用io对象进行事件的触发,将数据从服务器发送到浏览器
    io.emit('chat message to browser', msg);
});
  1. index.html中接收服务器返回的数据

    // 注册事件,用于接收浏览器返回的数据
    socket.on('chat message to browser', function (msg) {
        // 接收到数据后创建li标签,并拼接到页面中
        $('#messages').append($('<li>').text(msg));
    });
    
  2. 代码至此已经编写完毕,使用浏览器打开两个网页,均访问http://localhost:8888地址,在一张网页中输入内容,即可发现在另一个网页中效果同步。这就是借助了WebSocket的及时通讯。

    除了实现浏览器端向服务器端发送数据外,服务器端也可以同时发送数据到浏览器中.

参考资料

https://socket.io/

https://socket.io/get-started/chat/

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,362评论 5 477
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,330评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,247评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,560评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,580评论 5 365
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,569评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,929评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,587评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,840评论 1 297
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,596评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,678评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,366评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,945评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,929评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,165评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 43,271评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,403评论 2 342

推荐阅读更多精彩内容

  • WebSocket简介 谈到Web实时推送,就不得不说WebSocket。在WebSocket出现之前,很多网站为...
    吧啦啦小汤圆阅读 8,120评论 15 75
  • 带来两大好处:1:Header互相沟通的Header是很小的,大概只有2 Bytes2:Server Push服务...
    liuboxx1阅读 472评论 0 2
  • Web领域的实时推送技术,也被称作Realtime技术。这种技术要达到的目的是让用户不需要刷新浏览器就可以获得实时...
    潘良虎阅读 44,549评论 6 78
  • websocket的原理和应用 在继续本文之前,让我们了解下websocket的原理: websocket通信协议...
    蒋跑跑转圈阅读 1,177评论 0 1
  • 为了最大程度的吸收笑来老师专栏内容;为了最大程度的理解笑来老师言传身教的概念;为了能够做到通过这些概念,结结实...
    李建勇阅读 180评论 0 0