Receivers

Documentation

Index

• type DynamicReceiver
  • func NewDynamicReceiver() *DynamicReceiver
  • func (d *DynamicReceiver) Receiver(conn netConn.IConnection, buffer []byte, offset int, count int) (err error)
• type SpliceSymbolReceiver
  • func NewSpliceSymbolReceiver(startSymbol byte, finishSymbol byte) *SpliceSymbolReceiver
  • func (s *SpliceSymbolReceiver) Receiver(conn netConn.IConnection, buffer []byte) ([]byte, int, bool)

Types

type DynamicReceiver

type DynamicReceiver struct {
	CurrentReceiver netConn.IReceiver   //当前分包器
	Receivers       []netConn.IReceiver //分包器集合
	IsPackStart     bool                //是否开始分包
	IsSingle        bool                //是否只有一个分包算法
}

策略分包器

func NewDynamicReceiver

func NewDynamicReceiver() *DynamicReceiver

策略分包器

func (*DynamicReceiver) Receiver

func (d *DynamicReceiver) Receiver(conn netConn.IConnection, buffer []byte, offset int, count int) (err error)

分包处理

type SpliceSymbolReceiver

type SpliceSymbolReceiver struct {
	StartSymbol  byte
	FinishSymbol byte
}

/ 按照开始结束符来粘包(单字节版)

func NewSpliceSymbolReceiver

func NewSpliceSymbolReceiver(startSymbol byte, finishSymbol byte) *SpliceSymbolReceiver

按照开始结束符来粘包

func (*SpliceSymbolReceiver) Receiver

func (s *SpliceSymbolReceiver) Receiver(conn netConn.IConnection, buffer []byte) ([]byte, int, bool)

分包逻辑