network

Documentation

Index

• Constants
• Variables
• func Byte4ToUint32(data []byte) (result uint32)
• func CombineMsgWithId(msgId int32, data []byte) []byte
• func Uint32ToByte4(data uint32) (result []byte)
• type Client
  • func NewTcpClient(addr string, newCodec func() DecodeEncoder, op ...OptionClient) Client
• type DecodeEncoder
• type EchoCode
  • func (s *EchoCode) Decode(data []byte) ([][]byte, error)
  • func (s *EchoCode) Encode(data []byte) []byte
• type Listener
  • func StartTcpListen(addr string, newCodec func() DecodeEncoder, ...) Listener
• type Message
  • func NewBytesMessageParse(data []byte, mm *tools.ProtoIndex) *Message
  • func NewPbMessage(pb proto.Message, msgId int32) *Message
  • func (s *Message) Buffer() []byte
  • func (s *Message) MsgId() int32
  • func (s *Message) Proto() proto.Message
• type NetSession
• type NetSessionHandler
• type OptionClient
• type OptionListen
• type SessionType
• type StreamCode
  • func (s *StreamCode) Decode(data []byte) ([][]byte, error)
  • func (s *StreamCode) Encode(data []byte) []byte
• type TcpClient
  • func (s *TcpClient) AddLast(hander func() NetSessionHandler)
  • func (s *TcpClient) SendMsg(data []byte) error
  • func (s *TcpClient) Start(reconnect bool) error
  • func (s *TcpClient) Stop()
• type TcpListener
  • func (s *TcpListener) Start() error
  • func (s *TcpListener) Stop()
• type TcpSession
  • func (s *TcpSession) DeleteKV(key interface{})
  • func (s *TcpSession) Id() uint32
  • func (s *TcpSession) Load(key interface{}) (value interface{}, ok bool)
  • func (s *TcpSession) LocalAddr() net.Addr
  • func (s *TcpSession) RemoteAddr() net.Addr
  • func (s *TcpSession) RemoteIP() string
  • func (s *TcpSession) SendMsg(msg []byte) error
  • func (s *TcpSession) Stop()
  • func (s *TcpSession) StoreKV(key, value interface{})
  • func (s *TcpSession) Type() SessionType

Constants

const STREAM_HEADLEN = 4

Variables

var ErrRecvLen = errors.New("data is too long")

var GenNetSessionId = _gen_net_session_id()

Functions

func Byte4ToUint32

func Byte4ToUint32(data []byte) (result uint32)

func CombineMsgWithId

func CombineMsgWithId(msgId int32, data []byte) []byte

func Uint32ToByte4

func Uint32ToByte4(data uint32) (result []byte)

Types

type Client

type Client interface {
	SendMsg([]byte) error
	AddLast(hander func() NetSessionHandler)
	Start(reconect bool) error
	Stop()
}

func NewTcpClient

func NewTcpClient(addr string, newCodec func() DecodeEncoder, op ...OptionClient) Client

type DecodeEncoder

type DecodeEncoder interface {
	Decode([]byte) ([][]byte, error)
	Encode(data []byte) []byte
}

type EchoCode

type EchoCode struct {
	MaxDecode int
	// contains filtered or unexported fields
}

func (*EchoCode) Decode

func (s *EchoCode) Decode(data []byte) ([][]byte, error)

func (*EchoCode) Encode

func (s *EchoCode) Encode(data []byte) []byte

type Listener

type Listener interface {
	Start() error
	Stop()
}

func StartTcpListen

func StartTcpListen(addr string, newCodec func() DecodeEncoder, newHandler func() NetSessionHandler, op ...OptionListen) Listener

type Message

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

func NewBytesMessageParse

func NewBytesMessageParse(data []byte, mm *tools.ProtoIndex) *Message

远端actor通信主要使用接口

func NewPbMessage

func NewPbMessage(pb proto.Message, msgId int32) *Message

业务逻辑层主要使用接口

func (*Message) Buffer

func (s *Message) Buffer() []byte

func (*Message) MsgId

func (s *Message) MsgId() int32

func (*Message) Proto

func (s *Message) Proto() proto.Message

type NetSession

type NetSession interface {
	Id() uint32
	LocalAddr() net.Addr
	RemoteAddr() net.Addr
	RemoteIP() string
	SendMsg([]byte) error
	Stop()
	StoreKV(interface{}, interface{})
	DeleteKV(interface{})
	Load(interface{}) (interface{}, bool)
	Type() SessionType
}

type NetSessionHandler

type NetSessionHandler interface {
	OnSessionCreated(NetSession)
	OnSessionClosed()
	OnRecv([]byte)
}

type OptionClient

type OptionClient func(l *TcpClient)

type OptionListen

type OptionListen func(l *TcpListener)

type SessionType

type SessionType int

const (
	TYPE_TCP SessionType = 1
	TYPE_UDP SessionType = 2
	TYPE_WS  SessionType = 3
)

type StreamCode

type StreamCode struct {
	MaxDecode int
	// contains filtered or unexported fields
}

	├──── 4bytes ─────┼────────────── body size ─────────────────┤
	┏━━━━━━━━━━━━━━━━━┳━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┓
	┃ head(body size) ┃               body (data)                ┃
	┗━━━━━━━━━━━━━━━━━┻━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━━┛
    ├──────────── MAX Size:StreamCode.MaxDecode ────────────────┤

func (*StreamCode) Decode

func (s *StreamCode) Decode(data []byte) ([][]byte, error)

func (*StreamCode) Encode

func (s *StreamCode) Encode(data []byte) []byte

type TcpClient

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

func (*TcpClient) AddLast

func (s *TcpClient) AddLast(hander func() NetSessionHandler)

add handler to last of list

func (*TcpClient) SendMsg

func (s *TcpClient) SendMsg(data []byte) error

func (*TcpClient) Start

func (s *TcpClient) Start(reconnect bool) error

func (*TcpClient) Stop

func (s *TcpClient) Stop()

type TcpListener

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

func (*TcpListener) Start

func (s *TcpListener) Start() error

func (*TcpListener) Stop

func (s *TcpListener) Stop()

type TcpSession

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

func (*TcpSession) DeleteKV

func (s *TcpSession) DeleteKV(key interface{})

func (*TcpSession) Id

func (s *TcpSession) Id() uint32

func (*TcpSession) Load

func (s *TcpSession) Load(key interface{}) (value interface{}, ok bool)

func (*TcpSession) LocalAddr

func (s *TcpSession) LocalAddr() net.Addr

func (*TcpSession) RemoteAddr

func (s *TcpSession) RemoteAddr() net.Addr

func (*TcpSession) RemoteIP

func (s *TcpSession) RemoteIP() string

func (*TcpSession) SendMsg

func (s *TcpSession) SendMsg(msg []byte) error

func (*TcpSession) Stop

func (s *TcpSession) Stop()

func (*TcpSession) StoreKV

func (s *TcpSession) StoreKV(key, value interface{})

func (*TcpSession) Type

func (s *TcpSession) Type() SessionType