码迷,mamicode.com
首页 > 其他好文 > 详细

长轮询实现消息推送

时间:2014-09-20 11:04:57      阅读:314      评论:0      收藏:0      [点我收藏+]

标签:style   blog   http   color   io   ar   strong   for   数据   

一、应用场景
浏览器与服务器之间保持一个长连接(http链接),服务器有最新的数据生成时及时推送到前端展现。典型场景:新邮件到达通知。
 
二、业界常用的解决方案
定时轮询,长轮询,websocket(HTML5新增的能力)
其中长轮询兼容性较好,应用的较为广泛,但是切忌在移动网络中应用该技术。
 
三、长连接前端代码
/**
 *pns模型层
 *@constructs M2012.Model.Pns.PnsModel
 *@extends Backbone.Model
 *@example
 *new M2012.Model.Pns().startRequestPns();
 */
M139.namespace("M2012.Model.Pns", {
    PnsModel : Backbone.Model.extend({
        callApi : M139.RichMail.API.call,
        pnsUrl : ‘/pns/poll?sid=‘ + top.sid + ‘&comeFrom=1003‘, // PNS接口地址负责推送消息到前端
        pnsErrorInterval : 1000 * 120, // 接口报错后下一次重新调接口的时间间隔
        pnsTimer : null, // 接口报错后需要用定时器再调一次接口,pnsTimer用于报错定时器ID
        msgTypes : {//pns推送过来的消息类型
            mailMsg : 70
        },
        logger : new top.M139.Logger({
            name : "M2012.Model.Pns"
        }),
        initialize : function() {
            $App.registerModel("pnsModel", this);
        },

        startRequestPns : function() {
            var self = this;

            var options = {};
            options.method = ‘get‘;
            options.timeout = self.pnsErrorInterval;
            options.error = function() {
                self.callPns();
                self.logger.error("newMailArrival callPns error");
            };
            options.ontimeout = function() {
                self.callPns();
                self.logger.error("newMailArrival callPns timeout");
            };
            options.isSendClientLog = false;

            M139.RichMail.API.call(self.pnsUrl, null, function(e) {
                var result = e.responseData;
                if (result) {
                    console.log(result);
                    if (result.errorCode) {
                        self.callPns();
                        self.logger.error("newMailArrival returndata error", "[pns/poll]", result);
                    } else {
                        self.pnsResultHandle(result);
                        $App.trigger("pnsNewArrival", result);
                        //留给以后扩展
                        self.callPns(500);
                        //self.autoReceiveMail();
                    }
                } else {
                    self.callPns();
                    self.logger.error("newMailArrival returndata error", "[pns/poll]", result);
                }
            }, options);
        },

        callPns : function(seconds) {
            var self = this;

            // 判断用户是否登录超时
            if (top.$App.isSessionOut()) {
                console.log(‘登录超时!不再请求PNS‘);
                return;
            }

            if (self.pnsTimer) {
                clearTimeout(self.pnsTimer);
            }
            self.pnsTimer = setTimeout(function() {
                self.startRequestPns();
            }, seconds || self.pnsErrorInterval);
        },

        /*
         * 此函数可用于单元测试
         * $App.getModel("pnsModel").pnsResultHandle({});
         */
        pnsResultHandle : function(result) {
            var self = this;
            if (result.c > 0) {//c代表数量
                var msgArr = result.msg;
                for (var i = 0, l = msgArr.length; i < l; i++) {
                    // TODO 根据消息类型处理业务逻辑
                }
            } else if (result.c == 0) {
                console.log(‘超时返回!autoReceiveMail‘);
            }
        }
    })
});
 
四、异常捕获及应用服务器
(1)客户端捕获到xhr的error事件或者接口超时之后可500毫秒之后开始下次轮询。
(2)服务端接口报错,不要立即开始下次轮询,可考虑2分钟甚至更长时间后再开始轮询,因为服务端通常需要较长时间恢复正常。
(3)服务端要保持大量的长连接通常需要用特殊的应用服务器,比如:jetty 。tomcat是肯定不行的。
 
五、参考资料
书籍:《web性能权威指南》
竞品:163邮箱收信
 
bubuko.com,布布扣
bubuko.com,布布扣

 

长轮询实现消息推送

标签:style   blog   http   color   io   ar   strong   for   数据   

原文地址:http://www.cnblogs.com/hellohuman/p/3983025.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!