41 lines
746 B
Go
41 lines
746 B
Go
|
package hpds_net_framework
|
||
|
|
|
||
|
|
import (
|
||
|
|
"net"
|
||
|
|
)
|
||
|
|
|
||
|
|
// Server interface
|
||
|
|
type Server interface {
|
||
|
|
Run() error
|
||
|
|
Handle(conn net.Conn)
|
||
|
|
}
|
||
|
|
|
||
|
|
// INode 网络同步节点，如消息节点,聊天室节点
|
||
|
|
type INode interface {
|
||
|
|
AddConn(IConnection) error
|
||
|
|
DelConn(string) error
|
||
|
|
Serve()
|
||
|
|
OnRawMessage([]byte) error
|
||
|
|
OnProtocolMessage(interface{}) error
|
||
|
|
GetAllMessage() chan []interface{}
|
||
|
|
Destroy() error
|
||
|
|
Complete() error
|
||
|
|
}
|
||
|
|
|
||
|
|
// IConnection 网络连接
|
||
|
|
type IConnection interface {
|
||
|
|
GetUuid() string
|
||
|
|
ReadMsg()
|
||
|
|
WriteMsg(message interface{})
|
||
|
|
Close() error
|
||
|
|
AfterClose(func())
|
||
|
|
//SetData 设置自定义数据
|
||
|
|
SetData(interface{})
|
||
|
|
GetData() interface{}
|
||
|
|
//SetNode 设置节点
|
||
|
|
SetNode(INode)
|
||
|
|
GetNode() INode
|
||
|
|
//IsClosed 是否关闭
|
||
|
|
IsClosed() bool
|
||
|
|
}
|