go中的WebSocket
WebSocket是HTML5的重要特性,它實現了基于瀏覽器的遠程socket,它使瀏覽器和服務器可以進行全雙工通信,許多瀏覽器(Firefox、Google Chrome和Safari)都已對此做了支持。
在WebSocket出現之前,為了實現即時通信,采用的技術都是“輪詢”,即在特定的時間間隔內,由瀏覽器對服務器發出HTTP Request,服務器在收到請求后,返回最新的數據給瀏覽器刷新,“輪詢”使得瀏覽器需要對服務器不斷發出請求,這樣會占用大量帶寬。
WebSocket采用了一些特殊的報頭,使得瀏覽器和服務器只需要做一個握手的動作,就可以在瀏覽器和服務器之間建立一條連接通道。且此連接會保持在活動狀態,你可以使用JavaScript來向連接寫入或從中接收數據,就像在使用一個常規的TCP Socket一樣。它解決了Web實時化的問題,相比傳統HTTP有如下好處:
- 一個Web客戶端只建立一個TCP連接
- Websocket服務端可以推送(push)數據到web客戶端.
- 有更加輕量級的頭,減少數據傳送量
WebSocket URL的起始輸入是ws://或是wss://(在SSL上)。下圖展示了WebSocket的通信過程,一個帶有特定報頭的HTTP握手被發送到了服務器端,接著在服務器端或是客戶端就可以通過JavaScript來使用某種套接口(socket),這一套接口可被用來通過事件句柄異步地接收數據。
?
?
WebSocket原理
WebSocket的協議頗為簡單,在第一次handshake通過以后,連接便建立成功,其后的通訊數據都是以”\x00″開頭,以”\xFF”結尾。在客戶端,這個是透明的,WebSocket組件會自動將原始數據“掐頭去尾”。
?
在請求中的"Sec-WebSocket-Key"是隨機的,對于整天跟編碼打交到的程序員,一眼就可以看出來:這個是一個經過base64編碼后的數據。服務器端接收到這個請求之后需要把這個字符串連接上一個固定的字符串:
258EAFA5-E914-47DA-95CA-C5AB0DC85B11即:f7cb4ezEAl6C3wRaU6JORA==連接上那一串固定字符串,生成一個這樣的字符串:
f7cb4ezEAl6C3wRaU6JORA==258EAFA5-E914-47DA-95CA-C5AB0DC85B11對該字符串先用 sha1安全散列算法計算出二進制的值,然后用base64對其進行編碼,即可以得到握手后的字符串:
rE91AJhfC+6JdVcVXOGJEADEJdQ=將之作為響應頭Sec-WebSocket-Accept的值反饋給客戶端。
Go實現WebSocket
Go語言標準包里面沒有提供對WebSocket的支持,但是在由官方維護的go.net子包中有對這個的支持,你可以通過如下的命令獲取該包:
go get code.google.com/p/go.net/websocketWebSocket分為客戶端和服務端,接下來我們將實現一個簡單的例子:用戶輸入信息,客戶端通過WebSocket將信息發送給服務器端,服務器端收到信息之后主動Push信息到客戶端,然后客戶端將輸出其收到的信息,客戶端的代碼如下:
<html> <head></head> <body><script type="text/javascript">var sock = null;var wsuri = "ws://127.0.0.1:1234";window.onload = function() {console.log("onload");sock = new WebSocket(wsuri);sock.onopen = function() {console.log("connected to " + wsuri);}sock.onclose = function(e) {console.log("connection closed (" + e.code + ")");}sock.onmessage = function(e) {console.log("message received: " + e.data);}};function send() {var msg = document.getElementById('message').value;sock.send(msg);};</script><h1>WebSocket Echo Test</h1><form><p>Message: <input id="message" type="text" value="Hello, world!"></p></form><button onclick="send();">Send Message</button> </body> </html>可以看到客戶端JS,很容易的就通過WebSocket函數建立了一個與服務器的連接sock,當握手成功后,會觸發WebScoket對象的onopen事件,告訴客戶端連接已經成功建立。客戶端一共綁定了四個事件。
- 1)onopen 建立連接后觸發
- 2)onmessage 收到消息后觸發
- 3)onerror 發生錯誤時觸發
- 4)onclose 關閉連接時觸發
我們服務器端的實現如下:
package mainimport ("code.google.com/p/go.net/websocket""fmt""log""net/http" )func Echo(ws *websocket.Conn) {var err errorfor {var reply stringif err = websocket.Message.Receive(ws, &reply); err != nil {fmt.Println("Can't receive")break}fmt.Println("Received back from client: " + reply)msg := "Received: " + replyfmt.Println("Sending to client: " + msg)if err = websocket.Message.Send(ws, msg); err != nil {fmt.Println("Can't send")break}} }func main() {http.Handle("/", websocket.Handler(Echo))if err := http.ListenAndServe(":1234", nil); err != nil {log.Fatal("ListenAndServe:", err)} }當客戶端將用戶輸入的信息Send之后,服務器端通過Receive接收到了相應信息,然后通過Send發送了應答信息。
總結
以上是生活随笔為你收集整理的go中的WebSocket的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: Go中的Socket编程
- 下一篇: go中的REST