使用gevent wsgi实现长轮询Long Polling和comet

就不罗嗦了,对于实时数据的输出也这么几种,客户端自己ajax,Long Polling长轮询,comet,websocket…

当然websocket是我比较常用的,也算擅长的,曾经在实时大屏幕监控中用过websocket的协议…. 

今天,咱们就先说下Long Polling

首先我们先看轮询(Polling)是什么?  Polling是指不管服务器端有没有更新,客户端(通常是指浏览器)都定时的发送请求进行查询,轮询的结果可能是服务器端有新的更新过来,也可能什么也没有,只是返回个空的信息。不管结果如何,客户端处理完后到下一个定时时间点将继续下一轮的轮询。 在前端代码体现就是,不断的ajax请求,除非服务端给你返回一个stop的标记,你才终止这样的行为。

var interId = null;
//先调用耗时接口,就是你开始点菜
.ajax({
  url: "/api",
  success:function(data){
    //成功后,就可以取消轮询了。
    clearInterval(interId);('body').append('<div>'+data+'</div>');
  }
})

//使用轮询去查状态,开始叫服务员去问菜烧到几分熟了
function queryPercent(){
    .ajax({
      url: "/pencent",
      success:function(pencent){('body').append('<div>当前进度'+pencent+'</div>');
      }
    })
}
interId = setInterval(queryPercent,500)

推送或叫长连接(Long-Polling)的服务其客户端是不做轮询的,客户端在发起一次请求后立即挂起,一直到服务器端有更新的时候,服务器才会主动推送信息到客户端。 在服务器端有更新并推送信息过来之前这个周期内,客户端不会有新的多余的请求发生,服务器端对此客户端也啥都不用干,只保留最基本的连接信息,一旦服务器有更新将推送给客户端,客户端将相应的做出处理,处理完后再重新发起下一轮请求。

//先调用耗时接口,就是你开始点菜
.ajax({
  url: "/api",
  success:function(data){('body').append('<div>'+data+'</div>');
  }
})

//叫服务员去问菜烧到几分熟了,状态更新了再回来告诉我,没到100%就立即再去问。
function queryPercent(){
    .ajax({
      url: "/pencent",
      success:function(pencent){('body').append('<div>当前进度'+pencent+'</div>');

        if (pencent != '100%') {
          queryPercent();
        }

      }
    })
}
queryPercent();

那么comet是啥? 基于Long Polling的概念上,他可以实时的片段的返回数据…    Long Polling 主要是客户端的逻辑实现,而comet主要还是在服务端实现…. 

举个例子说明下就很清楚了:

轮询模式,假设是客户端每2秒轮询一次,那么客户端每2秒就会发送一次请求,相应的服务器端每2秒就要响应这个客户端的一次请求。而实际上服务器端可能1秒钟后就有更新,也可能1分钟后才有更新。对于1秒钟就有更新的,客户端至少会有1秒钟的延时;而1分钟后才有更新的,只有最后一次查询有意义,这一分钟内的轮询其实都是没有必要的,服务器端和客户端均有资源的浪费。


推送模式,客户端发送一次请求后马上挂起等待服务器端响应,可能1秒,也可能10秒钟,也可能1分钟。如果服务器端是1秒就有更新,那么到1秒钟时客户端马上就收到更新了,如果是1分钟才有更新,那么整个一分钟客户端也只请求一次,服务器也只会相应一次,这个跟轮询的区别是不是已经很清楚了。

轮询:客户端定时向服务器发送Ajax请求,服务器接到请求后马上返回响应信息并关闭连接。 
优点:后端程序编写比较容易。 
缺点:请求中有大半是无用,浪费带宽和服务器资源。 

长轮询:客户端向服务器发送Ajax请求,服务器接到请求后hold住连接,直到有新消息才返回响应信息并关闭连接,客户端处理完响应信息后再向服务器发送新的请求。 
优点:在无消息的情况下不会频繁的请求,耗费资源小。 
缺点:服务器hold连接会消耗资源,返回数据顺序无保证,难于管理维护。 

上面说完了,轮询和长轮询的优缺点,为了解决他们的问题可以用comet  ,  首先服务端hold住客户端的一个长连接,然后实时的给他push数据…. 


#coding:utf-8
import gevent
from gevent.queue import Queue, Empty
from gevent.pywsgi import WSGIServer
import json

data_source = Queue()

def producer():
    while True:
        data_source.put_nowait('Hello World')
        gevent.sleep(1)

def ajax_endpoint(environ, start_response):
    status = '200 OK'
    headers = [
        ('Content-Type', 'application/json')
    ]

    start_response(status, headers)

    while True:
        try:
            datum = data_source.get(timeout=5)
            yield json.dumps(datum) + '\n'
        except Empty:
            pass

gevent.spawn(producer)

WSGIServer(('', 8000), ajax_endpoint).serve_forever()

最近爬虫太肆掠了,这边里面下博文的原文地址, http://xiaorui.cc/?p=1686


大家觉得文章对你有些作用! 如果想赏钱,可以用微信扫描下面的二维码,感谢!
另外再次标注博客原地址  xiaorui.cc

发表评论

邮箱地址不会被公开。 必填项已用*标注