tcp_server

Documentation

Index

• type ConnTcpSvr
  • func NewTcpSvr() *ConnTcpSvr
  • func (t *ConnTcpSvr) BroadcastByZone(zone int32, data1 []byte, data2 []byte)
  • func (t *ConnTcpSvr) InitAndRun(ip string, port int) error
  • func (t *ConnTcpSvr) Kick(uid uint64, reason g1_protocol.EKickOutReason)
  • func (t *ConnTcpSvr) KickByRemoteAddr(uid uint64, reason g1_protocol.EKickOutReason, remoteAddr string)
  • func (t *ConnTcpSvr) OnClose(conn net.Conn)
  • func (t *ConnTcpSvr) OnConn(conn net.Conn)
  • func (t *ConnTcpSvr) OnPacket(conn net.Conn, data []byte)
  • func (t *ConnTcpSvr) SendByUid(uid uint64, data1 []byte, data2 []byte) error

Types

type ConnTcpSvr

type ConnTcpSvr struct {
	tcp_server.TcpPacketSvr
	// contains filtered or unexported fields
}

必须实现 tcpserver.ITcpPacketSvrEventHandler

func NewTcpSvr

func NewTcpSvr() *ConnTcpSvr

func (*ConnTcpSvr) BroadcastByZone

func (t *ConnTcpSvr) BroadcastByZone(zone int32, data1 []byte, data2 []byte)

func (*ConnTcpSvr) InitAndRun

func (t *ConnTcpSvr) InitAndRun(ip string, port int) error

func (*ConnTcpSvr) Kick

func (t *ConnTcpSvr) Kick(uid uint64, reason g1_protocol.EKickOutReason)

func (*ConnTcpSvr) KickByRemoteAddr

func (t *ConnTcpSvr) KickByRemoteAddr(uid uint64, reason g1_protocol.EKickOutReason, remoteAddr string)

func (*ConnTcpSvr) OnClose

func (t *ConnTcpSvr) OnClose(conn net.Conn)

被Read协程调用，每个Connection对应一个Read协调

func (*ConnTcpSvr) OnConn

func (t *ConnTcpSvr) OnConn(conn net.Conn)

被Listener协程调用，一个TcpSvr对应一个Listener协程

func (*ConnTcpSvr) OnPacket

func (t *ConnTcpSvr) OnPacket(conn net.Conn, data []byte)

被Read协程调用，每个Connection对应一个Read协调

func (*ConnTcpSvr) SendByUid

func (t *ConnTcpSvr) SendByUid(uid uint64, data1 []byte, data2 []byte) error