tcpservice

package

v0.0.0-...-1905027 Latest Latest Go to latest Published: Mar 30, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Details

View Source

const (
	MaxNodeId = 1<<14 - 1 //最大值 16383
	MaxSeed   = 1<<19 - 1 //最大值 524287
	MaxTime   = 1<<31 - 1 //最大值 2147483647
)

This section is empty.

func GetNodeId(agentId uint64) int

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

func (slf *Client) GetId() uint64

func (slf *Client) OnClose()

func (slf *Client) Run()

type TcpPack struct {
	Type     TcpPackType //0表示连接 1表示断开 2表示数据
	ClientId uint64
	Data     interface{}
}

type TcpPackType int8

const (
	TPT_Connected    TcpPackType = 0
	TPT_DisConnected TcpPackType = 1
	TPT_Pack         TcpPackType = 2
	TPT_UnknownPack  TcpPackType = 3
)

type TcpService struct {
	service.Service
	// contains filtered or unexported fields
}

func (tcpService *TcpService) Close(clientId uint64)

func (tcpService *TcpService) GetClientIp(clientid uint64) string

func (tcpService *TcpService) GetConnNum() int

func (server *TcpService) GetNetMempool() network.INetMempool

func (tcpService *TcpService) NewClient(conn *network.TCPConn) network.Agent

func (tcpService *TcpService) OnInit() error

func (server *TcpService) ReleaseNetMem(byteBuff []byte)

func (tcpService *TcpService) SendMsg(clientId uint64, msg interface{}) error

func (tcpService *TcpService) SendRawData(clientId uint64, data []byte) error

func (tcpService *TcpService) SendRawMsg(clientId uint64, msg []byte) error

func (server *TcpService) SetNetMempool(mempool network.INetMempool)

func (tcpService *TcpService) SetProcessor(process processor.IProcessor, handler event.IEventHandler)

func (tcpService *TcpService) TcpEventHandler(ev event.IEvent)