akNet

package
v0.0.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 21, 2020 License: MIT Imports: 31 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	EnMessage_MainIDPackLen = 2  //主命令
	EnMessage_SubIDPackLen  = 2  //次命令
	EnMessage_PostType      = 2  //发送类型
	EnMessage_DataPackLen   = 6  //真实数据长度 (主命令+次命令+发送类型)
	EnMessage_NoDataLen     = 10 //非data数据长度(包体之前的)->(主命令+次命令+发送类型+datalen)

	EnMessage_SvrDataPackLen  = 50 //真实数据长度 (主命令+次命令+发送类型+ Identify长度 + Identify内容+RemoteAddr 长度+RemoteAddr 内容)
	EnMessage_SvrNoDataLen    = 54 //非data数据长度(包体之前的)->(主命令+次命令+发送类型+ Identify长度 + Identify内容+datalen+RemoteAddr 长度+RemoteAddr 内容)
	EnMessage_IdentifyEixst   = 1  //Identify 长度
	EnMessage_IdentifyLen     = 21 //Identify 内容
	EnMessage_RemoteAddrEixst = 1  //RemoteAddr 长度
	EnMessage_RemoteAddrLen   = 21 //RemoteAddr 内容
)

- 协议格式，小端字节序

转发目的位置 |主命令号 | 次命令号 | 包长度 | 包体 ------------|--------| --------| -------- | ---- 2字节 |2字节 | 2字节 | 4字节 | 包体

View Source 
const (
	MsgPostType_Single    = uint16(1)
	MsgPostType_Broadcast = uint16(2)
)

message Post type

View Source 
const (
	ESessionBeginNum = uint64(10000)
)

session begin number with 10000

Variables

View Source 
var (
	GTrustedList   = map[string]bool{}
	GUnTrustedList = map[string]bool{}
)
View Source 
var (
	GClientSessionPool *TClientSession
	GServerSessionPool *TServerSession
)

Functions

func DecodeCmd 

func DecodeCmd(cmd uint32) (uint16, uint16)

func: DecodeCmd purpose: DecodeCmd message cmd to mainid and subid.

func EncodeCmd 

func EncodeCmd(mainID, subID uint16) uint32

func: EncodeCmd purpose: Encode message mainid and subid to cmd.

func GetAllMessageIDs 

func GetAllMessageIDs() (msgs []uint32)

func GetModuleDef 

func GetModuleDef(routeid define.ERouteId) string

func InitTrusted 

func InitTrusted()

func Int64Toip 

func Int64Toip(ipn int64) net.IP

ip地址int64转string

func IpToInt64 

func IpToInt64(ip net.IP) int64

ip地址string转int64

func IsTrusted 

func IsTrusted(ip string) bool

func IsUnTrusted 

func IsUnTrusted(ip string) bool

func MSGConsumer 

func MSGConsumer(Addr string, session TcpSession)

会话消息消费者 session message consumer.

func MSGProducer 

func MSGProducer(addr string, data []byte, topic string, session TcpSession)

会话消息生产者 session message producer.

func RegisterMessage 

func RegisterMessage(mainID, subID uint16, proc interface{})

func RegisterMessageRet 

func RegisterMessageRet(session TcpSession) (succ bool, err error)

func ResponseHeartBeat 

func ResponseHeartBeat(session TcpSession) (succ bool, err error)

func SpecialLoginMsgFilter 

func SpecialLoginMsgFilter(main, sub uint16) (ok bool)

func UnPackExternalMsg 

func UnPackExternalMsg(c *net.TCPConn, pack IMessagePack) (succ bool)

@func: UnPackExternalMsg 解服务器外部消息（客户端，clientsession 注册消息） @parma1: 连接对象 c *net.TCPConn @param2: 解包对象 pack IMessagePack

func UnPackInnerMsg 

func UnPackInnerMsg(c *net.TCPConn, pack IMessagePack) (succ bool)

@func: UnPackInnerMsg 解服务器内部消息（server 间客户端发来的请求或者其他rpc消息传递） @parma1: 连接对象 c *net.TCPConn @param2: 解包对象 pack IMessagePack

Types

type AfterDialAct 

type AfterDialAct func(s TcpSession)

after dial connect todo action.

type ClientProtocol 

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

model: ClientProtocol Client to Server, message

func (*ClientProtocol) Clean 

func (this *ClientProtocol) Clean()

func (*ClientProtocol) GetDataLen 

func (this *ClientProtocol) GetDataLen() (datalen uint32)

func (*ClientProtocol) GetIdentify 

func (this *ClientProtocol) GetIdentify() string

func (*ClientProtocol) GetMessageID 

func (this *ClientProtocol) GetMessageID() (mainID uint16, subID uint16)

func (*ClientProtocol) GetPostType 

func (this *ClientProtocol) GetPostType() (pt uint16)

func (*ClientProtocol) GetRemoteAddr 

func (this *ClientProtocol) GetRemoteAddr() (addr string)

func (*ClientProtocol) GetRouteID 

func (this *ClientProtocol) GetRouteID() (route uint16)

func (*ClientProtocol) GetSrcMsg 

func (this *ClientProtocol) GetSrcMsg() (data []byte)

func (*ClientProtocol) PackAction 

func (this *ClientProtocol) PackAction(Output []byte) (err error)

func (*ClientProtocol) PackAction4Client 

func (this *ClientProtocol) PackAction4Client(Output []byte) (err error)

func (*ClientProtocol) PackClientMsg 

func (this *ClientProtocol) PackClientMsg(mainid, subid uint16, msg proto.Message) (out []byte, err error)

func (*ClientProtocol) PackData 

func (this *ClientProtocol) PackData(msg proto.Message) (data []byte, err error)

func (*ClientProtocol) PackInnerMsg 

func (this *ClientProtocol) PackInnerMsg(mainid, subid uint16, msg proto.Message) (out []byte, err error)

func (*ClientProtocol) SetCmd 

func (this *ClientProtocol) SetCmd(mainid, subid uint16, data []byte)

func (*ClientProtocol) SetIdentify 

func (this *ClientProtocol) SetIdentify(identify string)

func (*ClientProtocol) SetPostType 

func (this *ClientProtocol) SetPostType(pt uint16)

func (*ClientProtocol) SetRemoteAddr 

func (this *ClientProtocol) SetRemoteAddr(addr string)

func (*ClientProtocol) UnPackData 

func (this *ClientProtocol) UnPackData() (msg proto.Message, cb reflect.Value, err error, exist bool)

func (*ClientProtocol) UnPackMsg4Client 

func (this *ClientProtocol) UnPackMsg4Client(InData []byte) (pos int, err error)

func (*ClientProtocol) UnPackMsg4Svr 

func (this *ClientProtocol) UnPackMsg4Svr(InData []byte) (pos int, err error)

type ClientTcpSession 

type ClientTcpSession struct {
	sync.Mutex

	RemoteAddr string

	// session id
	SessionID uint64
	//Dest point
	SvrType define.ERouteId
	//src point
	RegPoint define.ERouteId
	//person StrIdentify
	StrIdentify string
	//
	Name string
	// contains filtered or unexported fields
}

func NewClientSession 

func NewClientSession(addr string,
	conn *net.TCPConn,
	ctx context.Context,
	SvrType define.ERouteId,
	off chan *ClientTcpSession,
	pack IMessagePack,
	procName string) *ClientTcpSession

func (*ClientTcpSession) Alive 

func (this *ClientTcpSession) Alive() bool

func (*ClientTcpSession) GetIdentify 

func (this *ClientTcpSession) GetIdentify() string

func (*ClientTcpSession) GetModuleName 

func (this *ClientTcpSession) GetModuleName() string

func (*ClientTcpSession) GetPack 

func (this *ClientTcpSession) GetPack() (obj IMessagePack)

func (*ClientTcpSession) GetRegPoint 

func (this *ClientTcpSession) GetRegPoint() (RegPoint define.ERouteId)

func (*ClientTcpSession) GetRemoteAddr 

func (this *ClientTcpSession) GetRemoteAddr() string

func (*ClientTcpSession) HandleSession 

func (this *ClientTcpSession) HandleSession(sw *sync.WaitGroup)

func (*ClientTcpSession) IsUser 

func (this *ClientTcpSession) IsUser() bool

func (*ClientTcpSession) Offline 

func (this *ClientTcpSession) Offline()

func (*ClientTcpSession) Push 

func (this *ClientTcpSession) Push(RegPoint define.ERouteId)

func (*ClientTcpSession) RefreshHeartBeat 

func (this *ClientTcpSession) RefreshHeartBeat(mainid, subid uint16) bool

func (*ClientTcpSession) SendInnerBroadcastMsg 

func (this *ClientTcpSession) SendInnerBroadcastMsg(mainid, subid uint16, msg proto.Message) (succ bool, err error)

func (*ClientTcpSession) SendInnerClientMsg 

func (this *ClientTcpSession) SendInnerClientMsg(mainid, subid uint16, msg proto.Message) (succ bool, err error)

func (*ClientTcpSession) SendInnerSvrMsg 

func (this *ClientTcpSession) SendInnerSvrMsg(mainid, subid uint16, msg proto.Message) (succ bool, err error)

func (*ClientTcpSession) SendSvrClientMsg 

func (this *ClientTcpSession) SendSvrClientMsg(mainid, subid uint16, msg proto.Message) (succ bool, err error)

func (*ClientTcpSession) SetIdentify 

func (this *ClientTcpSession) SetIdentify(StrIdentify string)

func (*ClientTcpSession) SetSendCache 

func (this *ClientTcpSession) SetSendCache(data []byte)

func (*ClientTcpSession) WriteMessage 

func (this *ClientTcpSession) WriteMessage(data []byte) (succ bool)

type ESessionGetType 

type ESessionGetType int
const (
	ESessionGetType_Identify ESessionGetType = 1
	ESessionGetType_RegPoint ESessionGetType = 2
)

type ESessionType 

type ESessionType int8
const (
	ESessionType_Server ESessionType = 1
	ESessionType_Client ESessionType = 2
)

type IMessagePack 

type IMessagePack interface {
	PackAction(Output []byte) (err error)
	PackAction4Client(Output []byte) (err error)
	PackData(msg proto.Message) (data []byte, err error)
	UnPackMsg4Client(InData []byte) (pos int, err error)
	UnPackData() (msg proto.Message, cb reflect.Value, err error, exist bool)
	GetRouteID() (route uint16)
	GetMessageID() (mainID uint16, subID uint16)
	Clean()
	SetCmd(mainid, subid uint16, data []byte)
	PackInnerMsg(mainid, subid uint16, msg proto.Message) (out []byte, err error)
	PackClientMsg(mainid, subid uint16, msg proto.Message) (out []byte, err error)
	GetSrcMsg() (data []byte)
	SetIdentify(identify string)
	GetIdentify() string
	UnPackMsg4Svr(InData []byte) (pos int, err error)
	GetDataLen() (datalen uint32)
	SetRemoteAddr(addr string)
	GetRemoteAddr() (addr string)
	SetPostType(pt uint16)
	GetPostType() (pt uint16)
}

type IProcessConnSession 

type IProcessConnSession interface {
	RemoveSession(key interface{})
	AddSession(key interface{}, session TcpSession)
	GetSession(key interface{}) (session TcpSession)
	GetSessionByIdentify(key interface{}) (session TcpSession)
	GetAllSession() (sessions sync.Map)
}

type MessageCb 

type MessageCb func(c net.Conn, mainID uint16, subID uint16, msg proto.Message)

session, data, data len

type ServerProtocol 

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

model: ServerProtocol server to server, message

func (*ServerProtocol) Clean 

func (this *ServerProtocol) Clean()

func (*ServerProtocol) GetDataLen 

func (this *ServerProtocol) GetDataLen() (datalen uint32)

func (*ServerProtocol) GetIdentify 

func (this *ServerProtocol) GetIdentify() string

func (*ServerProtocol) GetMessageID 

func (this *ServerProtocol) GetMessageID() (mainID uint16, subID uint16)

func (*ServerProtocol) GetPostType 

func (this *ServerProtocol) GetPostType() (pt uint16)

func (*ServerProtocol) GetRemoteAddr 

func (this *ServerProtocol) GetRemoteAddr() (addr string)

func (*ServerProtocol) GetRouteID 

func (this *ServerProtocol) GetRouteID() (route uint16)

func (*ServerProtocol) GetSrcMsg 

func (this *ServerProtocol) GetSrcMsg() (data []byte)

func (*ServerProtocol) PackAction 

func (this *ServerProtocol) PackAction(Output []byte) (err error)

func (*ServerProtocol) PackAction4Client 

func (this *ServerProtocol) PackAction4Client(Output []byte) (err error)

func (*ServerProtocol) PackClientMsg 

func (this *ServerProtocol) PackClientMsg(mainid, subid uint16, msg proto.Message) (out []byte, err error)

func (*ServerProtocol) PackData 

func (this *ServerProtocol) PackData(msg proto.Message) (data []byte, err error)

func (*ServerProtocol) PackInnerMsg 

func (this *ServerProtocol) PackInnerMsg(mainid, subid uint16, msg proto.Message) (out []byte, err error)

func (*ServerProtocol) SetCmd 

func (this *ServerProtocol) SetCmd(mainid, subid uint16, data []byte)

func (*ServerProtocol) SetIdentify 

func (this *ServerProtocol) SetIdentify(identify string)

func (*ServerProtocol) SetPostType 

func (this *ServerProtocol) SetPostType(pt uint16)

func (*ServerProtocol) SetRemoteAddr 

func (this *ServerProtocol) SetRemoteAddr(addr string)

func (*ServerProtocol) UnPackData 

func (this *ServerProtocol) UnPackData() (msg proto.Message, cb reflect.Value, err error, exist bool)

func (*ServerProtocol) UnPackMsg4Client 

func (this *ServerProtocol) UnPackMsg4Client(InData []byte) (pos int, err error)

func (*ServerProtocol) UnPackMsg4Svr 

func (this *ServerProtocol) UnPackMsg4Svr(InData []byte) (pos int, err error)

type SvrTcpSession 

type SvrTcpSession struct {
	sync.Mutex

	RemoteAddr string

	// session id
	SessionID uint64
	//Dest point
	SvrType define.ERouteId
	//src point
	RegPoint define.ERouteId
	//person StrIdentify
	StrIdentify string

	//
	Name string
	// contains filtered or unexported fields
}

func NewSvrSession 

func NewSvrSession(addr string,
	conn *net.TCPConn,
	ctx context.Context,
	SvrType define.ERouteId,
	off chan *SvrTcpSession,
	pack IMessagePack,
	procName string) *SvrTcpSession

func (*SvrTcpSession) Alive 

func (this *SvrTcpSession) Alive() bool

func (*SvrTcpSession) GetIdentify 

func (this *SvrTcpSession) GetIdentify() string

func (*SvrTcpSession) GetModuleName 

func (this *SvrTcpSession) GetModuleName() string

func (*SvrTcpSession) GetPack 

func (this *SvrTcpSession) GetPack() (obj IMessagePack)

func (*SvrTcpSession) GetRegPoint 

func (this *SvrTcpSession) GetRegPoint() (RegPoint define.ERouteId)

func (*SvrTcpSession) GetRemoteAddr 

func (this *SvrTcpSession) GetRemoteAddr() string

func (*SvrTcpSession) HandleSession 

func (this *SvrTcpSession) HandleSession(sw *sync.WaitGroup)

func (*SvrTcpSession) IsUser 

func (this *SvrTcpSession) IsUser() bool

func (*SvrTcpSession) Offline 

func (this *SvrTcpSession) Offline()

func (*SvrTcpSession) Push 

func (this *SvrTcpSession) Push(RegPoint define.ERouteId)

func (*SvrTcpSession) RefreshHeartBeat 

func (this *SvrTcpSession) RefreshHeartBeat(mainid, subid uint16) bool

func (*SvrTcpSession) SendInnerBroadcastMsg 

func (this *SvrTcpSession) SendInnerBroadcastMsg(mainid, subid uint16, msg proto.Message) (succ bool, err error)

func (*SvrTcpSession) SendInnerClientMsg 

func (this *SvrTcpSession) SendInnerClientMsg(mainid, subid uint16, msg proto.Message) (succ bool, err error)

func (*SvrTcpSession) SendInnerSvrMsg 

func (this *SvrTcpSession) SendInnerSvrMsg(mainid, subid uint16, msg proto.Message) (succ bool, err error)

func (*SvrTcpSession) SendSvrClientMsg 

func (this *SvrTcpSession) SendSvrClientMsg(mainid, subid uint16, msg proto.Message) (succ bool, err error)

func (*SvrTcpSession) SetIdentify 

func (this *SvrTcpSession) SetIdentify(StrIdentify string)

func (*SvrTcpSession) SetSendCache 

func (this *SvrTcpSession) SetSendCache(data []byte)

func (*SvrTcpSession) WriteMessage 

func (this *SvrTcpSession) WriteMessage(data []byte) (succ bool)

type TClient2ServerSession 

type TClient2ServerSession struct {
	sync.Mutex
	// contains filtered or unexported fields
}
var (
	GClient2ServerSession *TClient2ServerSession
)

func (*TClient2ServerSession) AddSession 

func (this *TClient2ServerSession) AddSession(key interface{}, session TcpSession)

func (*TClient2ServerSession) GetAllSession 

func (this *TClient2ServerSession) GetAllSession() (sessions sync.Map)

func (*TClient2ServerSession) GetSession 

func (this *TClient2ServerSession) GetSession(key interface{}) (session TcpSession)

func (*TClient2ServerSession) GetSessionByIdentify 

func (this *TClient2ServerSession) GetSessionByIdentify(key interface{}) (session TcpSession)

func (*TClient2ServerSession) RemoveSession 

func (this *TClient2ServerSession) RemoveSession(key interface{})

type TClientSession 

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

func (*TClientSession) Get 

func (this *TClientSession) Get() (s *TConnSession)

func (*TClientSession) Push 

func (this *TClientSession) Push(s *TConnSession)

type TConnSession 

type TConnSession struct {
	Connsess *TcpSession
	Svr      int32
}

type TMessageProc 

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

func GetMessageInfo 

func GetMessageInfo(mainID, subID uint16) (proc *TMessageProc, finded bool)

type TServerSession 

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

func (*TServerSession) Get 

func (this *TServerSession) Get() (s *TConnSession)

func (*TServerSession) Push 

func (this *TServerSession) Push(s *TConnSession)

type TSvr2SvrSession 

type TSvr2SvrSession struct {
	sync.Mutex
	// contains filtered or unexported fields
}
var (
	GServer2ServerSession *TSvr2SvrSession
)

func (*TSvr2SvrSession) AddSession 

func (this *TSvr2SvrSession) AddSession(key interface{}, session TcpSession)

func (*TSvr2SvrSession) GetAllSession 

func (this *TSvr2SvrSession) GetAllSession() (sessions sync.Map)

func (*TSvr2SvrSession) GetSession 

func (this *TSvr2SvrSession) GetSession(key interface{}) (session TcpSession)

func (*TSvr2SvrSession) GetSessionByIdentify 

func (this *TSvr2SvrSession) GetSessionByIdentify(key interface{}) (session TcpSession)

func (*TSvr2SvrSession) RemoveSession 

func (this *TSvr2SvrSession) RemoveSession(key interface{})

type TcpClient 

type TcpClient struct {
	sync.Mutex

	SvrType define.ERouteId
	Adacb   AfterDialAct
	// contains filtered or unexported fields
}

func NewClient 

func NewClient(host, pprofAddr string, SvrType define.ERouteId, Ada AfterDialAct, procName string) *TcpClient

func (*TcpClient) Exit 

func (this *TcpClient) Exit(sw *sync.WaitGroup)

func (*TcpClient) Run 

func (this *TcpClient) Run()

func (*TcpClient) Send 

func (this *TcpClient) Send(data []byte)

func (*TcpClient) SendMessage 

func (this *TcpClient) SendMessage()

func (*TcpClient) SessionType 

func (this *TcpClient) SessionType() (st ESessionType)

type TcpServer 

type TcpServer struct {
	sync.Mutex

	SvrType define.ERouteId

	// session id
	SessionID uint64
	// contains filtered or unexported fields
}

func NewTcpServer 

func NewTcpServer(listenAddr, pprofAddr string, SvrType define.ERouteId, procName string) *TcpServer

func (*TcpServer) Exit 

func (this *TcpServer) Exit(sw *sync.WaitGroup)

func (*TcpServer) Run 

func (this *TcpServer) Run()

func (*TcpServer) SendMessage 

func (this *TcpServer) SendMessage()

func (*TcpServer) SessionType 

func (this *TcpServer) SessionType() (st ESessionType)

type TcpSession 

type TcpSession interface {
	GetRemoteAddr() string
	GetRegPoint() (RegPoint define.ERouteId)
	GetIdentify() string
	SetSendCache(data []byte)
	Push(RegPoint define.ERouteId)
	SetIdentify(StrIdentify string)
	SendInnerSvrMsg(mainid, subid uint16, msg proto.Message) (succ bool, err error)
	SendSvrClientMsg(mainid, subid uint16, msg proto.Message) (succ bool, err error)
	SendInnerClientMsg(mainid, subid uint16, msg proto.Message) (succ bool, err error)
	SendInnerBroadcastMsg(mainid, subid uint16, msg proto.Message) (succ bool, err error)
	WriteMessage(data []byte) (succ bool)
	Alive() bool
	GetPack() (obj IMessagePack)
	IsUser() bool
	RefreshHeartBeat(mainid, subid uint16) bool
	GetModuleName() string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.