以下是一个使用gzip压缩算法的Golang WebSocket客户端和服务器示例：
客户端代码：
package mainimport ("compress/gzip""fmt""net/http""net/url""github.com/gorilla/websocket")func main() {u := url.URL{Scheme: "ws", Host: "localhost:8080", Path: "/"}header := http.Header{}header.Set("Sec-WebSocket-Extensions", "permessage-deflate; client_max_window_bits, x-webkit-deflate-frame")dialer := websocket.Dialer{Subprotocols: []string{"chat"},ReadBufferSize: 1024,WriteBufferSize: 1024,}conn, _, err := dialer.Dial(u.String(), header)if err != nil {fmt.Printf("error: %v\n", err)return}defer conn.Close()writer, err := conn.NextWriter(websocket.BinaryMessage)if err != nil {fmt.Printf("error: %v\n", err)return}compressor, _ := gzip.NewWriterLevel(writer, gzip.BestCompression)message := []byte("Hello, world!")if _, err := compressor.Write(message); err != nil {fmt.Printf("error: %v\n", err)return}if err := compressor.Close(); err != nil {fmt.Printf("error: %v\n", err)return}if err := writer.Close(); err != nil {fmt.Printf("error: %v\n", err)return}}
在此示例中，我们使用了gorilla/websocket库通过WebSocket与服务器通信。我们将连接的URL设置为“ws://localhost:8080/”并添加了一个名为“chat”的子协议。
我们还将Sec-WebSocket-Extensions标头设置为“permessage-deflate; client_max_window_bits, x-webkit-deflate-frame”，这是告诉服务器我们使用了压缩算法。
在获取连接后，我们使用NextWriter()函数创建一个写入器以发送消息，并使用gzip.NewWriterLevel()函数创建一个gzip压缩器来压缩消息。我们将原始消息作为Write()方法的参数传递给gzip Writer，并关闭它们以确保所有数据都被刷新。最后，我们关闭写入器以完成消息发送。
服务端代码：
package mainimport ("compress/gzip""fmt""net/http""github.com/gorilla/websocket")func main() {upgrader := websocket.Upgrader{CheckOrigin: func(r *http.Request) bool { return true },}http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {conn, err := upgrader.Upgrade(w, r, http.Header{"Sec-WebSocket-Extensions": {"permessage-deflate; client_max_window_bits, x-webkit-deflate-frame"}})if err != nil {fmt.Printf("error: %v\n", err)return}defer conn.Close()reader, err := conn.NextReader()if err != nil {fmt.Printf("error: %v\n", err)return}decompressor, _ := gzip.NewReader(reader)message := make([]byte, 1024)n, err := decompressor.Read(message)if err != nil {fmt.Printf("error: %v\n", err)return}fmt.Printf("received: %s\n", message[:n])})http.ListenAndServe(":8080", nil)}
在此示例中，我们首先创建一个websocket.Upgrader并将其用于HTTP服务器。每当收到WebSocket连接请求时，我们使用Upgrader的Upgrade()方法来升级连接，并设置Sec-WebSocket-Extensions标头以指定支持的压缩算法。
然后，我们使用NextReader()函数获取读取器以接收消息。我们使用gzip.NewReader()函数创建一个gzip解压缩器来解压消息。接下来，我们尝试从解压缩器中读取数据，并处理任何错误。最后，我们打印接收到的消息以进行调试。
运行客户端和服务端代码后，您应该能够在服务器日志中看到“Hello, world！”消息。
