message

Documentation

Index

• type IMessageFactory
• type Message
  • func NewMessage(routeType Type, messageType Type, verion uint32, seqID uint32, msgID uint16, ...) (this *Message)
  • func NewMessageDirect(routeType Type, messageType Type, verion uint32, seqID uint32, msgID uint16, ...) (this *Message)
  • func NewMessageWith(data []byte) (this *Message)
  • func (msg *Message) Decode(e interface{}) (valid bool)
  • func (msg *Message) Encode() (ret interface{})
  • func (msg *Message) GetSecurityType() int8
  • func (msg *Message) GetSerializeType() int8
  • func (msg *Message) String() string
• type MessageFactory
  • func NewMessageFactory() (this *MessageFactory)
  • func (factory *MessageFactory) GetMessage(buf []byte) (valid bool, ret protocol.IProtocol)
• type Type

Types

type IMessageFactory

type IMessageFactory interface {
	GetMessage(buf []byte) (valid bool, ret protocol.IProtocol)
}

type Message

type Message struct {
	RouteType   Type   // 路由类型: 0-close,1-client,2-hall
	MessageType Type   // 协议类型: 1-proto,2-json
	Verion      uint32 // 协议版本
	SeqID       uint32 // 消息唯一ID,从0开始递增
	Time        int64  // 时间戳
	MsgID       uint16 // 协议ID
	Data        []byte // 协议数据
	ProtoData   protoiface.MessageV1
}

Message represents a unmarshaled message or a message which to be marshaled

func NewMessage

func NewMessage(routeType Type, messageType Type,
	verion uint32, seqID uint32, msgID uint16,
	protoData protoreflect.ProtoMessage) (this *Message)

func NewMessageDirect

func NewMessageDirect(routeType Type, messageType Type,
	verion uint32, seqID uint32, msgID uint16,
	protoData []byte) (this *Message)

func NewMessageWith

func NewMessageWith(data []byte) (this *Message)

func (*Message) Decode

func (msg *Message) Decode(e interface{}) (valid bool)

func (*Message) Encode

func (msg *Message) Encode() (ret interface{})

func (*Message) GetSecurityType

func (msg *Message) GetSecurityType() int8

func (*Message) GetSerializeType

func (msg *Message) GetSerializeType() int8

func (*Message) String

func (msg *Message) String() string

type MessageFactory

type MessageFactory struct {
}

func NewMessageFactory

func NewMessageFactory() (this *MessageFactory)

func (*MessageFactory) GetMessage

func (factory *MessageFactory) GetMessage(buf []byte) (valid bool, ret protocol.IProtocol)

type Type

type Type byte