ws

package

v1.7.3 Latest Latest Go to latest Published: Jul 22, 2026 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

View Source

var Upgrader = websocket.Upgrader{
	ReadBufferSize:  10240,
	WriteBufferSize: 10240,
	CheckOrigin: func(r *http.Request) bool {
		return true
	},
}

Upgrader 升级 HTTP 连接为 WebSocket 连接

This section is empty.

type Config struct {
	WriteWait      time.Duration
	PingPeriod     time.Duration
	PongWait       time.Duration
	MaxMessageSize int64
}

Config 配置

type Transport struct {
	// contains filtered or unexported fields
}

Transport WebSocket 传输

func New(conn *websocket.Conn, cfgs ...Config) *Transport

New 创建一个新的 WebSocket 传输

func (t *Transport) Close() error

Close 关闭连接

func (t *Transport) ReadMessage() ([]byte, error)

ReadMessage 读取消息

func (t *Transport) RemoteAddr() string

RemoteAddr 获取远程地址

func (t *Transport) WriteMessage(data []byte) error

WriteMessage 写入消息