wsKit

Documentation

Index

• Constants
• Variables
• func DefaultUpgrader() *websocket.Upgrader
• func PolyfillWebSocketRequest(r *http.Request)
• type WsChannel
  • func (channel *WsChannel) Close() (err error)
  • func (channel *WsChannel) Push(data []byte) error
  • func (channel *WsChannel) PushMessage(messageType messageType, data []byte) (err error)
• type WsProcessor
  • func NewProcessor(upgrader *websocket.Upgrader, idGenerator func() (string, error), ...) (*WsProcessor, error)
  • func (p *WsProcessor) Handle(w http.ResponseWriter, r *http.Request)
  • func (p *WsProcessor) HandleWithGin(ctx *gin.Context)

Constants

const (
	MessageTypeText   messageType = websocket.TextMessage
	MessageTypeBinary messageType = websocket.BinaryMessage
)

Variables

var IsWebSocketUpgrade func(r *http.Request) bool = websocket.IsWebSocketUpgrade

IsWebSocketUpgrade 是否是WebSocket请求？

Functions

func DefaultUpgrader

func DefaultUpgrader() *websocket.Upgrader

DefaultUpgrader 默认的Upgrader.

@return 并发安全的

func PolyfillWebSocketRequest

func PolyfillWebSocketRequest(r *http.Request)

PolyfillWebSocketRequest

此函数是为了避免情况: 代理（e.g.Nginx）没有设置WebSocket穿透，导致WebSocket服务收到的WebSocket请求的header有问题.

Types

type WsChannel

type WsChannel struct {
	*pushKit.BaseChannel
	// contains filtered or unexported fields
}

func (*WsChannel) Close

func (channel *WsChannel) Close() (err error)

Close 后端主动关闭通道.

func (*WsChannel) Push

func (channel *WsChannel) Push(data []byte) error

func (*WsChannel) PushMessage

func (channel *WsChannel) PushMessage(messageType messageType, data []byte) (err error)

PushMessage 推送消息给客户端.

@param messageType MessageTypeText || MessageTypeBinary

type WsProcessor

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

func NewProcessor

func NewProcessor(upgrader *websocket.Upgrader, idGenerator func() (string, error), listener pushKit.Listener, messageType messageType) (*WsProcessor, error)

NewProcessor

@param upgrader 可以为nil @param idGenerator 可以为nil（使用xid） @param listener 不能为nil

func (*WsProcessor) Handle

func (p *WsProcessor) Handle(w http.ResponseWriter, r *http.Request)

func (*WsProcessor) HandleWithGin

func (p *WsProcessor) HandleWithGin(ctx *gin.Context)