go的websocket实现原理与用法详解

2020-01-28 12:04:19刘景俊

Masking-key:0或4个字节,客户端发送给服务端的数据,都是通过内嵌的一个32位值作为掩码的;掩码键只有在掩码位设置为1的时候存在。

Payload data: (x+y)位,负载数据为扩展数据及应用数据长度之和。

Extension data:x位,如果客户端与服务端之间没有特殊约定,那么扩展数据的长度始终为0,任何的扩展都必须指定扩展数据的长度,或者长度的计算方式,以及在握手时如何确定正确的握手方式。如果存在扩展数据,则扩展数据就会包括在负载数据的长度之内。

Application data:y位,任意的应用数据,放在扩展数据之后,应用数据的长度=负载数据的长度-扩展数据的长度。

实例

具体使用go的实现例子:

客户端:

html:


<html>
  <head>
    <script type="text/javascript" src="./jquery.min.js"></script>
  </head>
  <body>
    <input type="button" id="connect" value="websocket connect" />
    <input type="button" id="send" value="websocket send" />
    <input type="button" id="close" value="websocket close" />
  </body>
  <script type="text/javascript" src="./websocket.js"></script>
</html>

js:


var socket;
$("#connect").click(function(event){
  socket = new WebSocket("ws://127.0.0.1:8000");
  socket.onopen = function(){
    alert("Socket has been opened");
  }
  socket.onmessage = function(msg){
    alert(msg.data);
  }
  socket.onclose = function() {
    alert("Socket has been closed");
  }
});
$("#send").click(function(event){
  socket.send("send from client");
});
$("#close").click(function(event){
  socket.close();
})

服务端:
package main
import(
    "net"
    "log"
    "strings"
    "crypto/sha1"
    "io"
    "encoding/base64"
    "errors"
)
func main() {
    ln, err := net.Listen("tcp", ":8000")
    if err != nil {
        log.Panic(err)
    }
    for {
        conn, err := ln.Accept()
        if err != nil {
            log.Println("Accept err:", err)
        }
        for {
            handleConnection(conn)
        }
    }
}
func handleConnection(conn net.Conn) {
    content := make([]byte, 1024)
    _, err := conn.Read(content)