拉模式與推送模式
拉模式的缺點 數(shù)據(jù)更新頻率低，則大多數(shù)的請求是無效的
在線用戶數(shù)量多脐彩，則服務端的查詢負載高碎乃。
定時查詢拉取，無法滿足時效性要求
推送模式 盡在數(shù)據(jù)更新才推送惠奸，需要維護大量的在線長連接梅誓，數(shù)據(jù)更新后立即推送。
WebSocket推送
瀏覽器支持的socket編程佛南，輕松維護服務端長連接梗掰，基于TCP可靠傳輸之上的協(xié)議，無需開發(fā)者關心通訊細節(jié)嗅回。提供了高度抽象的編程接口及穗，業(yè)務開發(fā)成本低。
websocket協(xié)議
來源于慕課網(wǎng)
協(xié)議升級后妈拌，繼續(xù)復用HTTP的底層socket完成后續(xù)操作
message底層被切分成多個frame 幀傳輸拥坛。
編程是只需要操作message不需要關心frame
框架底層完成TCP網(wǎng)絡I/O,WebSocker協(xié)議解析蓬蝶，開發(fā)者不需要關心尘分。
package main
import "net/http"
func wsHandle(writer http.ResponseWriter, request *http.Request) {
writer.Write([]byte("hello world"))
}
func main() {
http.HandleFunc("/ws", wsHandle)
http.ListenAndServe(":8888",nil)
}
服務請求參數(shù)
Request URL: http://localhost:8888/ws
Request Method: GET
Status Code: 200 OK
Remote Address: [::1]:8888
websocket的服務器端代碼
package main
import (
"fmt"
"github.com/gorilla/websocket"
"net/http"
"time"
)
func wsHandle(writer http.ResponseWriter, request *http.Request) {
upgrader:= websocket.Upgrader{CheckOrigin: func(r *http.Request) bool {
return true
}}
con,err := upgrader.Upgrade(writer,request,nil)
defer con.Close()
if err!=nil {
writer.Write([]byte(err.Error()))
}
for{
_, p, err := con.ReadMessage()
if err!= nil {
writer.Write([]byte(err.Error()))
break
}
fmt.Println("client message "+string(p))
con.WriteMessage(websocket.TextMessage,[]byte(time.Now().String()))
}
}
func main() {
http.HandleFunc("/ws", wsHandle)
http.ListenAndServe(":8888",nil)
}
image.png
websocket 客戶端代碼
<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8">
<script>
window.addEventListener("load", function(evt) {
var output = document.getElementById("output");
var input = document.getElementById("input");
var ws;
var print = function(message) {
var d = document.createElement("div");
d.innerHTML = message;
output.appendChild(d);
};
document.getElementById("open").onclick = function(evt) {
if (ws) {
return false;
}
ws = new WebSocket("ws://localhost:8888/ws");
ws.onopen = function(evt) {
print("連接websocket");
}
ws.onclose = function(evt) {
print("CLOSE");
ws = null;
}
ws.onmessage = function(evt) {
print("收到消息: " + evt.data);
}
ws.onerror = function(evt) {
print("ERROR: " + evt.data);
}
return false;
};
document.getElementById("send").onclick = function(evt) {
if (!ws) {
return false;
}
print("發(fā)送消息: " + input.value);
ws.send(input.value);
return false;
};
document.getElementById("close").onclick = function(evt) {
if (!ws) {
return false;
}
ws.close();
return false;
};
});
</script>
</head>
<body>
<table>
<tr><td valign="top" width="50%">
<p>點擊啟動按鈕創(chuàng)建websocket連接<br/>
點擊發(fā)送按鈕可以發(fā)送任意消息給服務器<br/>
點擊關閉按鈕斷開websocket連接
</p>
<form>
<button id="open">啟動</button>
<button id="close">關閉</button>
<input id="input" type="text" value="Hello golang!">
<button id="send">發(fā)送</button>
</form>
</td><td valign="top" width="50%">
<div id="output"></div>
</td></tr></table>
</body>
</html>
運行client.html,效果如下
數(shù)據(jù)抓包
image.png
