packet

Documentation

Index

• Constants
• func NewMessageCallback(f SessionMessageFunc) cellnet.EventFunc
• func SendVariableLengthPacket(outputStream io.Writer, pktWriter PacketWriter) error
• type MsgEvent
• type PacketReader
  • func RecvVariableLengthPacket(inputStream io.Reader) (pktReader PacketReader, err error)
  • func (p *PacketReader) Init(raw []byte)
  • func (p *PacketReader) Raw() []byte
  • func (p *PacketReader) ReadString(str *string) error
  • func (p *PacketReader) ReadValue(v interface{}) error
  • func (p *PacketReader) RemainBytes() []byte
  • func (p *PacketReader) RemainLen() int
• type PacketWriter
  • func (p *PacketWriter) Len() uint16
  • func (p *PacketWriter) Raw() []byte
  • func (p *PacketWriter) WriteString(v string) error
  • func (p *PacketWriter) WriteValue(v interface{}) error
• type SessionMessageFunc

Constants

const LengthSize = 2

Functions

func NewMessageCallback

func NewMessageCallback(f SessionMessageFunc) cellnet.EventFunc

func SendVariableLengthPacket

func SendVariableLengthPacket(outputStream io.Writer, pktWriter PacketWriter) error

发送变长封包

Types

type MsgEvent

type MsgEvent struct {
	Ses cellnet.Session
	Msg interface{}
}

type PacketReader

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

func RecvVariableLengthPacket

func RecvVariableLengthPacket(inputStream io.Reader) (pktReader PacketReader, err error)

接收变长封包

func (*PacketReader) Init

func (p *PacketReader) Init(raw []byte)

初始化缓冲，清空读取器

func (*PacketReader) Raw

func (p *PacketReader) Raw() []byte

func (*PacketReader) ReadString

func (p *PacketReader) ReadString(str *string) error

读取字符串

func (*PacketReader) ReadValue

func (p *PacketReader) ReadValue(v interface{}) error

从字节数组中读取值

func (*PacketReader) RemainBytes

func (p *PacketReader) RemainBytes() []byte

剩下的未读取的字节

func (*PacketReader) RemainLen

func (p *PacketReader) RemainLen() int

未读取的数据字节数

type PacketWriter

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

封包写入

func (*PacketWriter) Len

func (p *PacketWriter) Len() uint16

写入的数据字节数

func (*PacketWriter) Raw

func (p *PacketWriter) Raw() []byte

写入的字节数组

func (*PacketWriter) WriteString

func (p *PacketWriter) WriteString(v string) error

func (*PacketWriter) WriteValue

func (p *PacketWriter) WriteValue(v interface{}) error

写入任意值

type SessionMessageFunc

type SessionMessageFunc func(ses cellnet.Session, raw interface{})