2019.7.15
Http协议
Http: 超文本传输协议 传输&＃xff1a;Socket TCP 3次握手 断开 四次挥手
无状态请求连接
TCP 3次握手 发起一次请求 - 一次响应 - 连接就断开了
http://www.baidu.com 长时间无请求时&＃xff0c;不占用任何资源
劣势&＃xff1a;
无状态 -
比如 &＃xff1a;
客户端1向服务器发起请求 - 服务器确认客户端1的身份 - 处理 - 响应 - 断开
客户端1向服务器发起请求 - 服务器确认客户端1的身份 - 处理 - 响应 - 断开
服务器主动向客户端推送消息
WeChat - 微信
‘你’发送一条微信 - 给服务器 - ‘你好&＃xff01;’ - 服务器收到消息 - 服务器寻找 ‘我’ - 对着我的连接 &＃xff08;客户端&＃xff09; - 发送 你好&＃xff01;WeChatPay
AliPay
1.轮询 对客户端 以及服务器要求最高
客户端轮询 - 由客户端向服务器发起请求 每秒10次左右&＃xff08;QPS 每秒发起请求的次数限制&＃xff09;
场景模拟
传达室 收发快递模型 1.大爷&＃xff08;接收快递&＃xff09; - 小二 半年之后 扔掉
2.大爷&＃xff08;接收快递&＃xff09; - 小二 -小二从宿舍跑到传达室 - 问大爷 有我快递吗&＃xff1f;-大爷回答&＃xff1a;你丫谁呀&＃xff1f; 我是大三小二- 我知道了&＃xff0c;你找我什么事儿&＃xff1f; - 小二 &＃xff1a; 有我快递吗&＃xff1f; - 大爷&＃xff1a;我给你找找&＃xff0c;没找着&＃xff0c;你回去把&＃xff0c;一会过来- 小二 &＃xff1a;大爷再见 再见 再见 再见- 小二到宿舍想起来快递没拿- 又去传达室取快递&＃xff08;重复上面的过程&＃xff09;- 很多个小二 同事问大爷快递
知道很久以后
- 小二 我是大三的小二
- 我知道了&＃xff0c;你汇总啊我什么事儿&＃xff1f;
- 小二 &＃xff1a; 有我快递吗&＃xff1f;
- 大爷&＃xff1a; 我这儿真有你的快递
- 小二 拿走快递&＃xff0c;飞奔二区
- 小二&＃xff1a;大爷再见 再见 再见 再见
小资源访问时 优势很明显 - 因为客户端较少
2.长轮询
服务器长轮询 - 服务器不响应客户端而是将连接暂时保持住 5 秒之后 没有消息&＃xff0c;响应客户端
一定时间之后 5s之后 断开连接&＃xff0c; 客户端重新发起请求
情景模拟&＃xff1a;
大爷&＃xff08;接收快递&＃xff09; - 小二
传达室装修了 - 建立了一个茶室 - 服务升级了
小二到传达室 - 问大爷有我快递吗&＃xff1f;
- 大爷&＃xff1a; 你丫谁呀&＃xff1f;
- 小二&＃xff1a;我是大三小二
- 大爷&＃xff1a;我知道了&＃xff0c;你找我什么事儿&＃xff1f;
- 小二&＃xff1a; 有我快递吗&＃xff1f;
- 大爷&＃xff1a;进屋做做&＃xff0c;屋里有差&＃xff0c;我给你找找快递
- 小二喝茶中。。。。。。
- 大爷&＃xff1a;你多等会
- 小二喝茶中。。。。。。
- 大爷&＃xff1a;你多等会
- 小二喝茶中。。。。。。
- 小二&＃xff1a; 大爷&＃xff0c;我去趟厕所
- 断开
- 小二上完厕所&＃xff0c;不对呀&＃xff0c;我又不是去喝茶的
- 小二来到传达室 loop小二到传达室 - 问大爷有我快递吗&＃xff1f;
- 大爷&＃xff1a; 你丫谁呀&＃xff1f;
- 小二&＃xff1a;我是大三小二
- 大爷&＃xff1a;我知道了&＃xff0c;你找我什么事儿&＃xff1f;
- 小二&＃xff1a; 有我快递吗&＃xff1f;
- 大爷&＃xff1a;进屋做做&＃xff0c;屋里有差&＃xff0c;我给你找找快递
- 小二喝茶中。。。。。。
- 大爷说 找到了&＃xff0c;你的快递
- 小二拿着快递美美的回去了 断开了
优势&＃xff1a;
小二不用那么累了 客户端不用大量QPS
劣势&＃xff1a;
传达室的茶室空间 严重浪费服务器资源
大爷学会了影分身 开启多线程服务客户端
3.长连接 客户端和 服务器资源 消耗没有那么严重了
连接保持 - Http 发起请求在请求中写一个协议 - WebSocket - 收到请求&＃xff0c;自动保持此连接 - 永久不断开&＃xff0c; 除非主动断开 - 可以通过此连接主动找到客户端
场景模拟
大爷&＃xff08;接收快递&＃xff09; - 小二
传达室进入信息化时代&＃xff0c;装电话了 2万台电话
小二到传达室 - 问大爷有我快递吗&＃xff1f;
- 大爷&＃xff1a; 你丫谁呀&＃xff1f;
- 小二&＃xff1a;我是大三小二
- 大爷&＃xff1a;我知道了&＃xff0c;你找我什么事儿&＃xff1f;
- 小二&＃xff1a; 有我快递吗&＃xff1f;
- 大爷&＃xff1a;你把电话号码留下&＃xff0c;回去等我电话&＃xff0c;接了之后别挂
- 小二回到宿舍证号听见大爷来电话了
- 小二接电话 &＃xff0c; 对面&＃xff0c;我是你大爷&＃xff0c;电话别挂&＃xff0c;随时听着&＃xff0c;有快递就过来取
- 保持通话
优势&＃xff1a;数据实时性
劣势&＃xff1a;服务器和客户端需要一个线程来等待消息
玩游戏&＃xff1a;一个服务器有资源限制&＃xff0c;所以分区&＃xff0c;很多个服务器
服务器 完成 IO多路复用
2 . GeventWebsocket &＃43; Flask
Web (Http) &＃43; Socket (连接保持)
Flask中运行WebSocket - GeventWebsocket
wsgi?
wsgi ---> envir ---> view
wsgi ---> http ---> envir ---> view
wsgi ---> websockethandler ---> envir ---> view
websockethandler 监听了 请求头中的&＃xff1f;
ws environ 和 headers
ws请求 environ 原始信息
{&＃39;GATEWAY_INTERFACE&＃39;: &＃39;CGI/1.1&＃39;, &＃39;SERVER_SOFTWARE&＃39;: &＃39;gevent/1.4 Python/3.6&＃39;, &＃39;SCRIPT_NAME&＃39;: &＃39;&＃39;, &＃39;wsgi.version&＃39;: (1, 0), &＃39;wsgi.multithread&＃39;: False, &＃39;wsgi.multiprocess&＃39;: False, &＃39;wsgi.run_once&＃39;: False, &＃39;wsgi.url_scheme&＃39;: &＃39;http&＃39;, &＃39;wsgi.errors&＃39;: <_io.TextIOWrapper name&＃61;&＃39;
&＃39;wsgi.websocket&＃39;:
http environ
#{&＃39;GATEWAY_INTERFACE&＃39;: &＃39;CGI/1.1&＃39;, &＃39;SERVER_SOFTWARE&＃39;: &＃39;gevent/1.4 Python/3.6&＃39;, &＃39;SCRIPT_NAME&＃39;: &＃39;&＃39;, &＃39;wsgi.version&＃39;: (1, 0), &＃39;wsgi.multithread&＃39;: False, &＃39;wsgi.multiprocess&＃39;: False, &＃39;wsgi.run_once&＃39;: False, &＃39;wsgi.url_scheme&＃39;: &＃39;http&＃39;, &＃39;wsgi.errors&＃39;: <_io.TextIOWrapper name&＃61;&＃39;
http - readers
Host: 127.0.0.1:9537
Connection: keep-alive
Cache-Control: max-age&＃61;0
Upgrade-Insecure-Requests: 1
User-Agent: Mozilla/5.0 (Windows NT 6.1; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/74.0.3729.108 Safari/537.36
Accept: text/html,application/xhtml&＃43;xml,application/xml;q&＃61;0.9,image/webp,image/apng,*/*;q&＃61;0.8,application/signed-exchange;v&＃61;b3
Accept-Encoding: gzip, deflate, br
Accept-Language: zh-CN,zh;q&＃61;0.9
COOKIE: csrftoken&＃61;5L4cgBIxsjanDPXGuTBlOk5ihhrn8LYnSppNIG4LyEclJHsC6MOC7AR9K1jbDJUO
ws
WebSocket {url: "ws://127.0.0.1:9537/my_socket", readyState: 3, bufferedAmount: 0, onopen: null, onerror: null, …}
ws - headers
Host: 127.0.0.1:9537
Connection: Upgrade
Pragma: no-cache
Cache-Control: no-cache
User-Agent: Mozilla/5.0 (Windows NT 6.1; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/74.0.3729.108 Safari/537.36
Upgrade: websocket # &＃61;&＃61; websocket 请求 websockethandler处理的key 握手的信息
Origin: http://localhost:49419
Sec-Websocket-Version: 13 #
Accept-Encoding: gzip, deflate, br
Accept-Language: zh-CN,zh;q&＃61;0.9
COOKIE: csrftoken&＃61;5L4cgBIxsjanDPXGuTBlOk5ihhrn8LYnSppNIG4LyEclJHsC6MOC7AR9K1jbDJUO; sessionid&＃61;ofv3e4j3kmwo26wrimax68wz5t56rmr3
Sec-Websocket-Key: jiytsu3cA3JWnElexaajjA&＃61;&＃61; # 公钥
Sec-Websocket-Extensions: permessage-deflate; client_max_window_bits
和一个东西计算出私钥 &＃xff0c; 匹配出来的值能不能建立起联系
html 代码&＃xff1a;
py
# 客户端
# 服务端
# Http Flask 浏览器
# Websocket GeventWebsocket&＃43;Flask 客户端Javascript&＃xff08;Websocket客户端&＃xff09;from flask import Flask,request,render_template
from geventwebsocket.handler import WebSocketHandler # 提供WS协议处理
from geventwebsocket.server import WSGIServer # 承载服务
from geventwebsocket.websocket import WebSocket # 语法提示app &＃61; Flask(__name__)user_socket_list &＃61; []&＃64;app.route("/my_socket")
def my_socket():# 获取当前客户端与服务器的Socket连接user_socket &＃61; request.environ.get("wsgi.websocket") # type:WebSocketif user_socket:user_socket_list.append(user_socket)print(len(user_socket_list),user_socket_list)# print(user_socket,"OK 连接已经建立好了&＃xff0c;接下来发消息吧")while 1:msg &＃61; user_socket.receive()print(msg)for usocket in user_socket_list:try:usocket.send(msg)except:continue# user_socket.send(msg)# print(request.headers)&＃64;app.route("/gc")
def gc():return render_template("gc.html")if __name__ &＃61;&＃61; &＃39;__main__&＃39;:# app.run("0.0.0.0",9527)http_serv &＃61; WSGIServer(("0.0.0.0",9527),app,handler_class&＃61;WebSocketHandler)http_serv.serve_forever()
sl.html
我的昵称&＃xff1a; 给发送
py
# 客户端
# 服务端
# Http Flask 浏览器
# Websocket GeventWebsocket&＃43;Flask 客户端Javascript&＃xff08;Websocket客户端&＃xff09;
import jsonfrom flask import Flask,request,render_template
from geventwebsocket.handler import WebSocketHandler # 提供WS协议处理
from geventwebsocket.server import WSGIServer # 承载服务
from geventwebsocket.websocket import WebSocket # 语法提示app &＃61; Flask(__name__)# user_socket_dict &＃61; {nicheng:lianjie}
user_socket_dict &＃61; {}&＃64;app.route("/my_socket/
def my_socket(username):# 获取当前客户端与服务器的Socket连接user_socket &＃61; request.environ.get("wsgi.websocket") # type:WebSocketif user_socket:user_socket_dict[username] &＃61; user_socketprint(len(user_socket_dict),user_socket_dict)# print(user_socket,"OK 连接已经建立好了&＃xff0c;接下来发消息吧")while 1:msg &＃61; user_socket.receive()msg_dict &＃61; json.loads(msg)# msg &＃61; user_socket.receive()to_user_nick &＃61; msg_dict.get("to_user")print(to_user_nick)to_user_socket &＃61; user_socket_dict.get(to_user_nick)to_user_socket.send(msg)&＃64;app.route("/sl")
def sl():return render_template("sl.html")if __name__ &＃61;&＃61; &＃39;__main__&＃39;:# app.run("0.0.0.0",9527)http_serv &＃61; WSGIServer(("0.0.0.0",9527),app,handler_class&＃61;WebSocketHandler)http_serv.serve_forever()
错误 1 net::ERR_CONNECTION_REFUSED
ws &＃61; new WebSocket(&＃39;ws://192.168.16.40:9537/gc&＃39;);
WebSocket is already in CLOSING or CLOSED state.
错误 2
ws &＃61; new WebSocket(&＃39;ws://192.168.16.40:9537/my_socket&＃39;);
WebSocket {url: "ws://192.168.16.40:9537/my_socket", readyState: 0, bufferedAmount: 0, onopen: null, onerror: null, …}
VM65:1 WebSocket connection to &＃39;ws://192.168.16.40:9537/my_socket&＃39; failed: Error in connection establishment:
发错了地址&＃xff0c;发到了 40端口&＃xff0c;老师的端口了
gc.html
老 gc .html
我的昵称&＃xff1a;
ws.onmessage &＃61; function (eventMessage) {
eventMessage : 和request似的&＃xff1f;
函数作用&＃xff1f;
function send_msg() {var content &＃61; document.getElementById("content").value;ws.send(content);}
Uncaught ReferenceError: send_msg is not defined
var ws &＃61; new WebSocket("ws://192.168.16.90:9537/my_socket");// 监听电话ws.onmessage &＃61; function (eventMessage) {console.log(eventMessage.data);var p &＃61; document.createElement("p");p.innerText &＃61; eventMessage.data;document.getElementById("chat_list").appendChild(p);};
没有发送函数也可以实现增加信息&＃xff0c;只不过服务器端不显示
并不是&＃xff0c;好像是没有数据了&＃xff1f; 这样 数据是发过去又发回来的&＃xff0c;为什么不直接使用呢
for usocket in user_socket_list:
try:
usocket.send(msg) #前端接收的eventmesaage.data 就是这个msg
# print(&＃39;haole&＃39;)
except:
continue
也不知道改动的什么地方&＃xff0c;莫名其妙就好了
因为看不出那里有错&＃xff0c;照抄的老师的&＃xff0c;还把前端后端都换成老师的&＃xff0c;然后去看视频&＃xff0c;发现老师是没放在群聊的文件夹里&＃xff0c;所以就把他提了出来&＃xff0c;就好使了&＃xff0c;然后再去运行之前的&＃xff0c;也好使了。不知道错误在哪&＃xff1f;还会出错的&＃xff0c;对吗&＃xff1f;
告诉你&＃xff1a;
不是 from flask import Flask,request,render_template
而是 import json 脑子怎么长的&＃xff1f;奇特&＃xff01;
前端写 JSON 大写 额
ws.send(JSON.stringify(sendStr));
laoqunliao
我的昵称&＃xff1a;
str_obj &＃61; JSON.parse(eventMessage.data);
p.innerText &＃61; str_obj.from_user &＃43;" : "&＃43;str_obj.chat;
显示 ----> dasf : adfas
p.innerText &＃61; eventMessage.data;
显示 ----> {"from_user":"adas","chat":"ada"}
这个函数果然没大有实际作用&＃xff0c;因为通过直接打开html , 错误因为没法识别 tmplates 吗&＃xff1f;
# &＃64;app.route("/gcs")
# def gc():
# return render_template("gcs.html")
那个make jinja 了 哪个可以被识别好像 那就可以蓝图文件夹用公有资源了把&＃xff1f;&＃xff01;
错误原因&＃xff1f;好几次了
ws.send(JSON.stringify(sendStr));
是我没点登陆 &＃xff1f; 发的是空
Uncaught TypeError: Cannot read property &＃39;send&＃39; of null
AttributeError: &＃39;NoneType&＃39; object has no attribute &＃39;send&＃39; # kong不能打.send
Cannot read property &＃39;send&＃39; of null
是因为没有用户&＃xff0c;不支持离线。亮哥说。解决了&＃xff0c;好似&＃xff0c;但是我之前怎么可已发过去&＃xff1f;也没有确认用户存在所以接收功能吧&＃xff1f;
多个人聊天&＃xff0c;所以需要另外一个人&＃xff0c;不能自己和自己聊吧
源码讲解 &＃xff1a;当http直接访问 而不是ws
错误返回&＃xff1a;
null not revice()
大意&＃xff1a;
websockethandler 也是 WSGI的 只不过封装了
继承的WSGIHandler 除了能够处理标准的http&＃xff0c;还可以处理webserver
GUID magic_string 用来做通信协议验证的
self.environ.update ({&＃39;wsgi.websocket&＃39;:None}) #http还是web都有environ原始信息
self.websocket &＃61; None #都给了None
只有websocket 才有http_update , http请求没有
读源码的时候各种记笔记&＃xff1a; 防止忘了 #
ws登录 ws://192.168.16.90 登录 aaa sec 密钥 。。。
self.websocket &＃61; Websocket(self.environ,) #夯住了 新的长连接一直保持着
http -> websocket
environ.update &＃61; {&＃39;&＃39;} # http请求进来 没有http-upgrate 只有None , None没法receive
明天讲websocket 握手原理 和 加密 (有时间的话)
源码&＃xff1a;
SUPPORTED_VERSIONS &＃61; (&＃39;13&＃39;, &＃39;8&＃39;, &＃39;7&＃39;)
GUID &＃61; "258EAFA5-E914-47DA-95CA-C5AB0DC85B11"
self.environ.update({&＃39;wsgi.websocket&＃39;: None
})
self.websocket &＃61; None
upgrade &＃61; self.environ.get(&＃39;HTTP_UPGRADE&＃39;, &＃39;&＃39;).lower()
&＃39;HTTP_UPGRADE&＃39;: &＃39;websocket&＃39;
if upgrade &＃61;&＃61; &＃39;websocket&＃39;:connection &＃61; self.environ.get(&＃39;HTTP_CONNECTION&＃39;, &＃39;&＃39;).lower() #加到了connection里面
&＃39;HTTP_CONNECTION&＃39;: &＃39;Upgrade&＃39; ws都有 这两个key
if &＃39;upgrade&＃39; not in connection:# This is not a websocket request, so we must not handle itself.logger.warning("Client didn&＃39;t ask for a connection ""upgrade")return
else:# This is not a websocket request, so we must not handle itreturn
if self.request_version !&＃61; &＃39;HTTP/1.1&＃39;: # websocket 默认是http/1.1 略过
&＃39;HTTP_SEC_WEBSOCKET_VERSION&＃39;: &＃39;13&＃39;, #
if self.environ.get(&＃39;HTTP_SEC_WEBSOCKET_VERSION&＃39;):return self.upgrade_connection()
def upgrade_connection(self):
version &＃61; self.environ.get("HTTP_SEC_WEBSOCKET_VERSION")
SUPPORTED_VERSIONS &＃61; (&＃39;13&＃39;, &＃39;8&＃39;, &＃39;7&＃39;)
为Sec-WebSocket-Accept 做准备
key &＃61; self.environ.get("HTTP_SEC_WEBSOCKET_KEY", &＃39;&＃39;).strip()
key_len &＃61; len(base64.b64decode(key))
http 请求不就是tcp请求&＃xff0c;tcp请求本质上不就是socket请求&＃xff0c;所以把 def upgrade_connection(self):
#Validate and &＃39;upgrade&＃39; the HTTP request to a WebSocket request. ---> self.websocket
如果Sec-WebSocket-Accept匹配对了&＃xff0c;一直保持着
self.websocket &＃61; WebSocket(self.environ, Stream(self), self) #创建一个新的连接 保持长连接 # 里面是init函数
self.environ.update({&＃39;wsgi.websocket_version&＃39;: version,&＃39;wsgi.websocket&＃39;: self.websocket #把连接放到wsig里了
})
class WebSocket(object):def __init__(self, environ, stream, handler): #self &＃61;&＃61; WSGIServer? ?WebSocketHandler
if PY3:accept &＃61; base64.b64encode( #accept验证通过的字符串hashlib.sha1((key &＃43; self.GUID).encode("latin-1")).digest()).decode("latin-1") #通过之后才能一直连接
else:accept &＃61; base64.b64encode(hashlib.sha1(key &＃43; self.GUID).digest())
headers &＃61; [("Upgrade", "websocket"),("Connection", "Upgrade"),("Sec-WebSocket-Accept", accept)
]
走了这么多&＃xff0c;给http请求的返回了none&＃xff0c;给ws请求的返回了 websocket(不知道是什么)
程序的部分&＃xff0c;为什么会错
http请求&＃xff0c;源码里&＃xff0c;wsgi.websocket 给的none 然后就返回了
user_socket &＃61; request.environ.get("wsgi.websocket") # type:WebSocket
if user_socket:user_socket_list.append(user_socket)print(len(user_socket_list),user_socket_list)
# print(user_socket,"OK 连接已经建立好了&＃xff0c;接下来发消息吧")
while 1:msg &＃61; user_socket.receive() # send_msg 发过来的信息 # http请求这里是None &＃xff0c;print(msg)
所以&＃xff0c;AttributeError: &＃39;NoneType&＃39; object has no attribute &＃39;receive&＃39;
代码整理一下
一个发送框&＃xff0c;一直发送&＃xff0c;因为while了的&＃xff0c;还得跳出来吗&＃xff1f; .py
from flask import Flask,request,render_template
from geventwebsocket.handler import WebSocketHandler #提供WS协议
from geventwebsocket.server import WSGIServer #承载服务
from geventwebsocket.websocket import WebSocket # 语法提示app &＃61; Flask(__name__)
user_socket_list &＃61; [] #存放每个socket的列表&＃64;app.route(&＃39;/ql&＃39;)
def ql():return render_template(&＃39;ql1.html&＃39;)&＃64;app.route(&＃39;/my_socket&＃39;)
def my_socket():# 获取当前客户端与服务器的socket连接user_socket &＃61; request.environ.get(&＃39;wsgi.websocket&＃39;) #type:WebSocketif user_socket:user_socket_list.append(user_socket) # 加入多个用户print(len(user_socket_list),user_socket_list) #1 [
一个的前端.html
群昵称.html
我的昵称&＃xff1a;
群聊昵称.py
import jsonuser_socket_dict &＃61; {}&＃64;app.route("/my_socket/
def my_socket(username):# 获取当前客户端与服务器的Socket连接user_socket &＃61; request.environ.get("wsgi.websocket") # type:WebSocketif user_socket:user_socket_dict[username] &＃61; user_socketprint(len(user_socket_dict),user_socket_dict)# print(user_socket,"OK 连接已经建立好了&＃xff0c;接下来发消息吧")while 1:# msg &＃61; json.loads(user_socket.receive())msg &＃61; user_socket.receive()print(msg)for usocket in user_socket_dict.values():print(usocket)try:usocket.send(msg)except:continue
私聊.html
我的昵称&＃xff1a; 给发送
私聊.html
app &＃61; Flask(__name__)# user_socket_dict &＃61; {nicheng:lianjie}
user_socket_dict &＃61; {}&＃64;app.route("/my_socket/
def my_socket(username):# 获取当前客户端与服务器的Socket连接user_socket &＃61; request.environ.get("wsgi.websocket") # type:WebSocketif user_socket:user_socket_dict[username] &＃61; user_socket # bbbb &＃61; {geventprint(len(user_socket_dict),&＃39;dict&＃39;,user_socket_dict)# print(user_socket,"OK 连接已经建立好了&＃xff0c;接下来发消息吧")while 1:msg &＃61; user_socket.receive()msg_dict &＃61; json.loads(msg)# msg &＃61; user_socket.receive()to_user_nick &＃61; msg_dict.get("to_user") #&＃39;bbbb&＃39;print(&＃39;toueser-nick&＃39;,to_user_nick)to_user_socket &＃61; user_socket_dict.get(to_user_nick) #&＃39;bbbb&＃39;to_user_socket.send(msg)&＃64;app.route("/sl")
def sl():return render_template("sl.html")
京公网安备 11010802041100号