内容推荐流python_Python3.4阅读内容流web请求

实际上&＃xff0c;在服务器和客户机上实现text/event-stream相对容易。假设位于example.com的服务器是在端口80(默认端口)上运行的简单服务器&＃xff1a;import http.server

import json

import socketserver

import time

class RequestHandler(http.server.SimpleHTTPRequestHandler):

def do_GET(self):

self.send_response(200)

self.send_header(&＃39;Connection&＃39;, &＃39;Keep-Alive&＃39;)

self.send_header(&＃39;Content-Type&＃39;, &＃39;text/event-stream&＃39;)

self.end_headers()

name &＃61; self.path.strip(&＃39;/&＃39;).encode(&＃39;UTF-8&＃39;)

old_value &＃61; None

new_value &＃61; None

while True:

old_value, new_value &＃61; new_value, time.time()

data &＃61; json.dumps({

&＃39;old_value&＃39;: old_value,

&＃39;new_value&＃39;: new_value,

}).encode(&＃39;UTF-8&＃39;)

self.wfile.write(b&＃39;name: &＃39;)

self.wfile.write(name)

self.wfile.write(b&＃39;\r\n&＃39;)

self.wfile.write(b&＃39;data: &＃39;)

self.wfile.write(data)

self.wfile.write(b&＃39;\r\n&＃39;)

self.wfile.write(b&＃39;\r\n&＃39;)

self.wfile.flush()

time.sleep(30)

server &＃61; socketserver.TCPServer((&＃39;&＃39;, 80), RequestHandler)

server.serve_forever()

每隔30秒&＃xff0c;它输出一个事件&＃xff1a;

^{pr2}$

然后&＃xff0c;客户端可以连接到端口http://example.com/value121&＃xff0c;并解析每个事件&＃xff1a;import http.client

import json

connection &＃61; http.client.HTTPConnection(&＃39;http://example.com&＃39;, 80)

connection.request(&＃39;GET&＃39;, &＃39;/value121&＃39;, headers&＃61;{

&＃39;Accept&＃39;: &＃39;text/event-source&＃39;,

&＃39;Connection&＃39;: &＃39;Keep-Alive&＃39;,

})

with connection.getresponse() as response:

while not response.closed:

event &＃61; {}

for line in response:

line &＃61; line.decode(&＃39;UTF-8&＃39;)

if line &＃61;&＃61; &＃39;\r\n&＃39;:

# End of event.

break

elif line.startswith(&＃39;:&＃39;):

# Comment, ignore.

pass

else:

# Data line.

key, value &＃61; line.split(&＃39;:&＃39;, 1)

value &＃61; value.strip()

if key &＃61;&＃61; &＃39;data&＃39;:

value &＃61; json.loads(value)

event[key] &＃61; value

# Handle event, extract values, etc.

print(event)

每隔30秒客户就会打印出&＃xff1a;&＃39;data&＃39;: {&＃39;old_value&＃39;: , &＃39;new_value&＃39;: }, &＃39;name&＃39;: &＃39;value121&＃39;}