meim

type Client struct {
	UID      int64       // 用户id
	UserData interface{} // 用户其他私有数据
	DC       DataCreator // 协议数据构建器
	Version  int32
	// contains filtered or unexported fields
}

type ClientSet map[*Client]struct{}

type Conn interface {
	Read([]byte) (int, error)
	Write(b []byte) (int, error) // 写
	RemoteAddr() net.Addr        // 远端地址
	LocalAddr() net.Addr         // 本地地址
	Close() error                // 关闭
}

type DataCreator interface {
	CreateHeader() ProtocolHeader
	CreateBody(cmd int) ProtocolBody
	GetCmd(body interface{}) (int, bool)
	GetCmd2(t reflect.Type) (int, bool)
	GetDescription(cmd int) string
}

type Dispatcher interface {
	DispatchMessage(*InternalMessage) bool
}

type Exchanger struct {
	MessageBroker          //
	Pusher                 //
	InternalMessageHandler //
	// contains filtered or unexported fields
}

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

type ExternalPlugin interface {
	HandleAuthClient(*Client) bool              // run的第一步, auth 认证客户端,至少确定协议方式,亦即 DataCreator
	HandleMessage(*Client, *Message)            // 消息处理函数
	HandleClientClosed(*Client)                 // 关闭客户端之后的处理
	HandleBeforeWriteMessage(*Client, *Message) //
}

type Filter func(MessageHandler) MessageHandler

type InternalMessage struct {
	*Message        // 发送的消息体
	Sender    int64 // 发送人
	Receiver  int64 // 接收人
	Timestamp int64 // 时间戳,ms
}

type InternalMessageHandler interface {
	HandleInternalMessage(msg *InternalMessage) // 和Client不一样的地方
}

type ListenerConfig struct {
	Network   string
	Address   string
	TLSConfig *tls.Config
	Options   map[string]interface{} // 为了在不囊括某些配置的时候,能够支持自定义listener的配置信息
}

type MakeListener func(cfg *ListenerConfig) (ln net.Listener, err error)

type Message struct {
	Header ProtocolHeader
	Body   ProtocolBody
}

type MessageBroker interface {
	Connect()                                                   // 连接
	Subscribe(uid int64)                                        // 注册用户
	UnSubscribe(uid int64)                                      // 注销用户
	SendMessage(msg *InternalMessage) error                     // 发布消息
	ReceiveMessage() (*InternalMessage, error)                  // 接收消息
	SyncMessage(msg *InternalMessage) (*InternalMessage, error) // 同步消息请求
	Close()
}

type MessageExchanger interface {
	MessageBroker
	Dispatcher
	Publisher
	InternalMessageHandler
}

type MessageHandler func(client *Client, msg *Message)

type NetConn struct {
	net.Conn
	// contains filtered or unexported fields
}

type NopPusher struct{}

type OptionFn func(*Server)

type ProtocolBody = ProtocolData

type ProtocolData interface {
	Decode(b []byte) error   // 从字节中读取
	Encode() ([]byte, error) // 编码
}

type ProtocolHeader interface {
	ProtocolData
	Length() int
	Cmd() int   // 协议指令
	SetCmd(int) // 指定协议指令
	Seq() int
	SetSeq(int)
	BodyLength() int
	SetBodyLength(n int)
	Ver() int
	SetVer(v int)
	Clone() ProtocolHeader
}

type Publisher interface {
	PublishMessage(*InternalMessage) bool
}

type Pusher interface {
	PushMessage(msg *InternalMessage) bool
}

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

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