Gevent的长轮询实现方法详解

亦凉 2022-07-15 16:26 108阅读 0赞

**长轮询**

1.浏览网页时，浏览器会传HTTP 请求到服务器，服务器会根据请求将网页的内容传给浏览器，但是在很多的情况下，使用者会需要看到最新的即时性资讯，例如观看股票市场行情，而在以前只能靠着重新载入网页才能获得最新信息，但是这样不但很浪费时间，也会佔用很多不必要的网络资源，并不是一个好的方式；

2.长轮询就是解决这个问题的一个办法。

**什么是长轮询**

1.长时间轮询（long-polling）是让服务器在接收到浏览器发出的HTTP 请求后，服务器会等待一段时间，若在这段时间里面伺服器有新的数据更新，它就会把最新的数据传给浏览器，如果等待的时间到了之后也没有新资料的话，就会送一个回应给浏览器，告知浏览器资料没有更新；

2.长时间轮询可以减少产生轮询（polling）造成网路频宽浪费的状况。

**浏览器如何长轮询**

浏览器向服务器发送Ajax请求，当接收到服务器响应后，需要向服务求发送新的请求。

**服务器如何处理长轮询**

1.服务器端要能够一直保持住客户端的请求，直到有响应消息；同时服务器对请求的处理要支持非阻塞模式；

2.需要使用Event，python内置Event是阻塞的，gevent的却是非阻塞的。

**设计场景**

1.浏览器请求获取当前的字符信息，并显示；

2.服务器后天接受某个请求以产生随机字符并存储下来，同时推送给浏览器。

**涉及问题**

1.服务器需知道浏览器获取信息的标识来推送最新的信息；

2.当浏览器请求更新信息时，服务器可通过Event来保留当前信息，当有新信息来的时候，重设Event来唤醒之前的处理。

**实践**

**html代码**

<!doctype html>

<html>

<head>

<title>Long Pooling</title>

<style>

\#main \{

position: absolute;

bottom: 50px;

left: 200px;

\#state\{

float:right;

width:400px;

</style>

<head>

<body>

</div>

var id = null;

function longPolling() \{

$.ajax(\{

url: "update",

data: \{"id": id\},

type: "POST",

error: function (XMLHttpRequest, textStatus, errorThrown) \{

$("\#state").append("\[state: " + textStatus + ", error: " + errorThrown + " \]<br/>");

\},

success: function (result, textStatus) \{

console.log(result)

msg\_data = eval("(" + result + ")");

$("\#inbox").append(msg\_data.html);

id = msg\_data.id;

console.log(msg\_data)

$("\#message").val("");

$("\#state").append("\[state: " + textStatus + " \]<br/>");

\},

complete: longPolling

\});

function sendNewMessage() \{

$.ajax(\{

type: "POST",

url: "new",

\});

$(function()\{

longPolling();

\})

</script>

</body>

</html>

test.py

from gevent.pywsgi import WSGIServer

from gevent.event import Event

from cgi import escape

import uuid

import urlparse

import string

import random

def get\_request\_data(field, env):

try:

request\_body\_size = int(env.get('CONTENT\_LENGTH', 0))

except (ValueError):

request\_body\_size = 0

request\_body = env\['wsgi.input'\].read(request\_body\_size)

d = urlparse.parse\_qs(request\_body)

data = d.get(field, \[''\])\[0\]

return data

def generate\_response\_data(response\_body, start\_response):

response\_headers = \[('Content-Type', 'text/html'), ('Content-Length', str(len(response\_body)))\]

start\_response('200 OK', response\_headers)

return \[response\_body\]

def generate\_json\_data(msg\_list):

msg\_dict = \{\}

msg\_dict\["html"\] = ""

for msg in msg\_list:

msg\_dict\["html"\] += "<div>\{0\}</div>".format(msg\["msg"\])

msg\_dict\["id"\] = msg\_list\[-1\]\["id"\]

res =  str(msg\_dict)

return res

def id\_generator(size=6, chars=string.ascii\_uppercase + string.digits):

return ''.join(random.choice(chars) for \_ in range(size))

file = open('longpooling.html')

chat\_html = file.read()

class MessgaeBuffer(object):

def \_\_init\_\_(self):

self.cache = \[\]

self.message\_event = Event()

def empty(self):

return len(self.cache) == 0

def application(env, start\_response):

env\_val = env\['PATH\_INFO'\]

if env\_val == "/create":

msg\_item = \{\}

msg\_item\["id"\] = str(uuid.uuid4())

msg\_item\["msg"\] = id\_generator()

print "create msg %s" % str(msg\_item)

msgBuffer.cache.append(msg\_item)

msgBuffer.message\_event.set()

msgBuffer.message\_event.clear()

return generate\_response\_data("", start\_response)

elif env\_val == "/update":

lastid = escape(get\_request\_data("id", env))

if msgBuffer.empty() or msgBuffer.cache\[-1\]\["id"\] == lastid:

msgBuffer.message\_event.wait()

for index,m in enumerate(msgBuffer.cache):

if m\["id"\] == lastid:

return generate\_response\_data(generate\_json\_data(msgBuffer.cache\[index+1:\])

, start\_response)

return generate\_response\_data(generate\_json\_data(msgBuffer.cache), start\_response)

else:

return generate\_response\_data(chat\_html, start\_response)

msgBuffer = MessgaeBuffer()

WSGIServer(('localhost', 8080), application).serve\_forever()

原文链接：[http://www.maiziedu.com/wiki/frame/polling/][http_www.maiziedu.com_wiki_frame_polling]

[http_www.maiziedu.com_wiki_frame_polling]: http://www.maiziedu.com/wiki/frame/polling/

Gevent的长轮询实现方法详解

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关轮询、长轮询与Web Socket的前端实现

相关轮询、长轮询、长连接、websocket

相关多个ajax分别实现实现长轮询,ajax长轮询、轮询应用和介绍

相关使用icomet 实现长轮询

相关 Gevent的长轮询实现方法详解

相关【PHP】实现ajax长轮询

相关长轮询

相关 springboot 长轮询实现

相关轮询和长轮询优缺点分析

相关轮询、长轮询、长连接、websocket