Documentation
¶
Index ¶
- Variables
- type WebSocket
- func (ws *WebSocket) Close()
- func (ws *WebSocket) Done() <-chan struct{}
- func (ws *WebSocket) IsClosed() bool
- func (ws *WebSocket) LocalAddr() string
- func (ws *WebSocket) OnMessage(handleFunc func(messageType int, payload []byte)) error
- func (ws *WebSocket) RemoteAddr() string
- func (ws *WebSocket) SendMessage(messageType int, payload []byte) error
- func (ws *WebSocket) SetLogger(logger *log.Logger)
- func (ws *WebSocket) SetReadTimeout(timeout time.Duration)
- func (ws *WebSocket) StartHeartbeat(interval time.Duration)
- func (ws *WebSocket) StopHeartbeat()
Constants ¶
This section is empty.
Variables ¶
View Source
var WSServer = websocket.Upgrader{ CheckOrigin: func(r *http.Request) bool { return true }, }
WSServer 全局WebSocket升级器
Functions ¶
This section is empty.
Types ¶
type WebSocket ¶
type WebSocket struct {
// contains filtered or unexported fields
}
func NewWebSocketByDial ¶ added in v1.0.5
NewWebSocketByDial 主动建立连接
func NewWebSocketByUpgrade ¶ added in v1.0.5
func NewWebSocketByUpgrade(w http.ResponseWriter, r *http.Request, responseHeader http.Header) (*WebSocket, error)
NewWebSocketByUpgrade 升级HTTP连接
func (*WebSocket) RemoteAddr ¶ added in v1.1.0
RemoteAddr 获取对端地址
func (*WebSocket) SendMessage ¶
SendMessage 线程安全的消息发送
func (*WebSocket) SetReadTimeout ¶ added in v1.1.0
SetReadTimeout 设置读取超时
func (*WebSocket) StartHeartbeat ¶ added in v1.1.9
StartHeartbeat 启动心跳机制
func (*WebSocket) StopHeartbeat ¶ added in v1.1.9
func (ws *WebSocket) StopHeartbeat()
StopHeartbeat 停止心跳机制
Source Files
Click to show internal directories.
Click to hide internal directories.