mux

Documentation

Overview

This module is used for port reuse Distinguish client, web manager , HTTP and HTTPS according to the difference of protocol

Index

• Constants
• func NewBufNode(buf []byte, l int) *bufNode
• func NewConn(connId int32, mux *Mux) *conn
• func NewConnMap() *connMap
• func NewQueue() *sliceEntry
• func ReadLenBytes(buf []byte, r io.Reader) (int, error)
• func WriteLenBytes(buf []byte, w io.Writer) (int, error)
• type Element
• type Mux
  • func NewMux(c net.Conn, connType string) *Mux
  • func (s *Mux) Accept() (net.Conn, error)
  • func (s *Mux) Addr() net.Addr
  • func (s *Mux) Close() error
  • func (s *Mux) NewConn() (*conn, error)
• type PortConn
  • func (pConn *PortConn) Close() error
  • func (pConn *PortConn) LocalAddr() net.Addr
  • func (pConn *PortConn) Read(b []byte) (n int, err error)
  • func (pConn *PortConn) RemoteAddr() net.Addr
  • func (pConn *PortConn) SetDeadline(t time.Time) error
  • func (pConn *PortConn) SetReadDeadline(t time.Time) error
  • func (pConn *PortConn) SetWriteDeadline(t time.Time) error
  • func (pConn *PortConn) Write(b []byte) (n int, err error)
• type PortListener
  • func NewPortListener(connCh chan *PortConn, addr net.Addr) *PortListener
  • func (pListener *PortListener) Accept() (net.Conn, error)
  • func (pListener *PortListener) Addr() net.Addr
  • func (pListener *PortListener) Close() error
• type PortMux
  • func NewPortMux(port int, managerHost string) *PortMux
  • func (pMux *PortMux) Close() error
  • func (pMux *PortMux) GetClientListener() net.Listener
  • func (pMux *PortMux) GetHttpListener() net.Listener
  • func (pMux *PortMux) GetHttpsListener() net.Listener
  • func (pMux *PortMux) GetManagerListener() net.Listener
  • func (pMux *PortMux) Start() error
• type Queue

Constants

const (
	MUX_PING_FLAG int32 = iota
	MUX_NEW_CONN_OK
	MUX_NEW_CONN_Fail
	MUX_NEW_MSG
	MUX_MSG_SEND_OK
	MUX_NEW_CONN
	MUX_PING
	MUX_CONN_CLOSE
	MUX_PING_RETURN
)

const (
	HTTP_GET        = 716984
	HTTP_POST       = 807983
	HTTP_HEAD       = 726965
	HTTP_PUT        = 808585
	HTTP_DELETE     = 686976
	HTTP_CONNECT    = 677978
	HTTP_OPTIONS    = 798084
	HTTP_TRACE      = 848265
	CLIENT          = 848384
	ACCEPT_TIME_OUT = 10
)

Functions

func NewBufNode

func NewBufNode(buf []byte, l int) *bufNode

func NewConn

func NewConn(connId int32, mux *Mux) *conn

func NewConnMap

func NewConnMap() *connMap

func NewQueue

func NewQueue() *sliceEntry

func ReadLenBytes

func ReadLenBytes(buf []byte, r io.Reader) (int, error)

read bytes by length

func WriteLenBytes

func WriteLenBytes(buf []byte, w io.Writer) (int, error)

write bytes with int32 length

Types

type Element

type Element *bufNode

type Mux

type Mux struct {
	net.Listener

	IsClose bool

	sync.Mutex
	// contains filtered or unexported fields
}

func NewMux

func NewMux(c net.Conn, connType string) *Mux

func (*Mux) Accept

func (s *Mux) Accept() (net.Conn, error)

func (*Mux) Addr

func (s *Mux) Addr() net.Addr

func (*Mux) Close

func (s *Mux) Close() error

func (*Mux) NewConn

func (s *Mux) NewConn() (*conn, error)

type PortConn

type PortConn struct {
	Conn net.Conn
	// contains filtered or unexported fields
}

func (*PortConn) Close

func (pConn *PortConn) Close() error

func (*PortConn) LocalAddr

func (pConn *PortConn) LocalAddr() net.Addr

func (*PortConn) Read

func (pConn *PortConn) Read(b []byte) (n int, err error)

func (*PortConn) RemoteAddr

func (pConn *PortConn) RemoteAddr() net.Addr

func (*PortConn) SetDeadline

func (pConn *PortConn) SetDeadline(t time.Time) error

func (*PortConn) SetReadDeadline

func (pConn *PortConn) SetReadDeadline(t time.Time) error

func (*PortConn) SetWriteDeadline

func (pConn *PortConn) SetWriteDeadline(t time.Time) error

func (*PortConn) Write

func (pConn *PortConn) Write(b []byte) (n int, err error)

type PortListener

type PortListener struct {
	net.Listener
	// contains filtered or unexported fields
}

func NewPortListener

func NewPortListener(connCh chan *PortConn, addr net.Addr) *PortListener

func (*PortListener) Accept

func (pListener *PortListener) Accept() (net.Conn, error)

func (*PortListener) Addr

func (pListener *PortListener) Addr() net.Addr

func (*PortListener) Close

func (pListener *PortListener) Close() error

type PortMux

type PortMux struct {
	net.Listener
	// contains filtered or unexported fields
}

func NewPortMux

func NewPortMux(port int, managerHost string) *PortMux

func (*PortMux) Close

func (pMux *PortMux) Close() error

func (*PortMux) GetClientListener

func (pMux *PortMux) GetClientListener() net.Listener

func (*PortMux) GetHttpListener

func (pMux *PortMux) GetHttpListener() net.Listener

func (*PortMux) GetHttpsListener

func (pMux *PortMux) GetHttpsListener() net.Listener

func (*PortMux) GetManagerListener

func (pMux *PortMux) GetManagerListener() net.Listener

func (*PortMux) Start

func (pMux *PortMux) Start() error

type Queue

type Queue interface {
	Push(e Element) //向队列中添加元素
	Pop() Element   //移除队列中最前面的元素
	Clear() bool    //清空队列
	Size() int      //获取队列的元素个数
	IsEmpty() bool  //判断队列是否是空
}