websocket

Documentation

Index

• Constants
• Variables
• type Client
  • func NewClient(url string) (*Client, error)
  • func (c *Client) Close()
  • func (c *Client) Push(data string) error
  • func (c *Client) Recv() (string, error)
  • func (c *Client) Upgrade() error
• type Conn
  • func Upgrade(r *http.Request, w *http.Response) (c *Conn, err error)
  • func (c *Conn) Close()
  • func (c *Conn) ReadData() (data []byte, err error)
  • func (c *Conn) SendData(data []byte) error

Constants

const (

	/*
	 * 文本帧类型
	 * 0 0 0 0 0 0 0 1
	 */
	TextMessage = 1
	/*
	 * 关闭数据帧类型
	 * 0 0 0 0 1 0 0 0
	 */
	CloseMessage = 8
)

Variables

var KeyGUID = []byte("258EAFA5-E914-47DA-95CA-C5AB0DC85B11")

Types

type Client

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

func NewClient

func NewClient(url string) (*Client, error)

NewCient new http client NewClient("http://10.0.2.15:8080/")

func (*Client) Close

func (c *Client) Close()

func (*Client) Push

func (c *Client) Push(data string) error

Push push to websocket server data

func (*Client) Recv

func (c *Client) Recv() (string, error)

Recv recvData

func (*Client) Upgrade

func (c *Client) Upgrade() error

Upgrade http 协议升级为websocket协议 GET /path HTTP/1.1 Host: server.example.com Upgrade: websocket Connection: Upgrade Sec-WebSocket-Key: dGhlIHNhbXBsZSBub25jZQ== Origin: http://example.com Sec-WebSocket-Protcol: chat, superchat Sec-WebSocket-Version: 13

type Conn

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

websocket 连接

func Upgrade

func Upgrade(r *http.Request, w *http.Response) (c *Conn, err error)

func (*Conn) Close

func (c *Conn) Close()

func (*Conn) ReadData

func (c *Conn) ReadData() (data []byte, err error)

读取数据

func (*Conn) SendData

func (c *Conn) SendData(data []byte) error

发送数据