要在golang websocket服务器上启用压缩，请按照以下步骤操作：
- 导入“github.com/gorilla/websocket”包
import “github.com/gorilla/websocket”
- 创建一个websocket.Upgrader实例，并设置EnableCompression为true
upgrader := websocket.Upgrader{ EnableCompression: true, }
- 使用Upgrader将HTTP请求升级为websocket连接
conn, err := upgrader.Upgrade(w, r, nil)
注意：w和r是http.ResponseWriter和*http.Request实例。
- 现在，您的websocket服务器已启用压缩。
完整例子：
package main
import (
"fmt""log""net/http""github.com/gorilla/websocket"
)
func main() {
http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {upgrader := websocket.Upgrader{EnableCompression: true,}conn, err := upgrader.Upgrade(w, r, nil)if err != nil {log.Println("websocket upgrade error:", err)return}defer conn.Close()for {_, msg, err := conn.ReadMessage()if err != nil {log.Println("read message error:", err)break}log.Printf("received message: %s\n", msg)reply := []byte(fmt.Sprintf("reply to: %s", msg))err = conn.WriteMessage(websocket.TextMessage, reply)if err != nil {log.Println("write message error:", err)break}}})fmt.Println("websocket server is running...")err := http.ListenAndServe(":8080", nil)if err != nil {log.Fatal("listen and serve error:", err)}
}
注意：在实际使用中，应该对错误进行适当的处理。
