Receivers

Documentation

Index

• type DynamicReceiver
  • func NewDynamicReceiver(receivers []netInterface.IReceiver, size int, onReceive func(data []byte), ...) *DynamicReceiver
  • func (d *DynamicReceiver) Receiver(conn netInterface.IConnection, buffer []byte) (err error)
• type JT1078Receiver
  • func NewJT1078Receiver(startBf []byte) *JT1078Receiver
  • func (j *JT1078Receiver) CanHandle(conn netInterface.IConnection, buffer []byte) bool
  • func (j *JT1078Receiver) GetHeadLen() int
  • func (j *JT1078Receiver) Receiver(conn netInterface.IConnection, buffer []byte) ([]byte, int)
  • func (j *JT1078Receiver) Reset()
• type SpliceSymbolReceiver
  • func NewSpliceSymbolReceiver(startSymbol byte, finishSymbol byte) *SpliceSymbolReceiver
  • func (s *SpliceSymbolReceiver) CanHandle(conn netInterface.IConnection, buffer []byte) bool
  • func (s *SpliceSymbolReceiver) GetHeadLen() int
  • func (s *SpliceSymbolReceiver) Receiver(conn netInterface.IConnection, buffer []byte) ([]byte, int)
  • func (s *SpliceSymbolReceiver) Reset()

Types

type DynamicReceiver

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

DynamicReceiver 策略分包器

func NewDynamicReceiver

func NewDynamicReceiver(receivers []netInterface.IReceiver, size int, onReceive func(data []byte), errorCallback func(errStr string)) *DynamicReceiver

NewDynamicReceiver 实例化策略分包器

func (*DynamicReceiver) Receiver

func (d *DynamicReceiver) Receiver(conn netInterface.IConnection, buffer []byte) (err error)

Receiver 分包处理

type JT1078Receiver

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

JT1078Receiver JT1078分包器

func NewJT1078Receiver

func NewJT1078Receiver(startBf []byte) *JT1078Receiver

NewJT1078Receiver 按照开始结束符来粘包

func (*JT1078Receiver) CanHandle

func (j *JT1078Receiver) CanHandle(conn netInterface.IConnection, buffer []byte) bool

CanHandle 是否我处理

func (*JT1078Receiver) GetHeadLen

func (j *JT1078Receiver) GetHeadLen() int

GetHeadLen 包头必须要够长度

func (*JT1078Receiver) Receiver

func (j *JT1078Receiver) Receiver(conn netInterface.IConnection, buffer []byte) ([]byte, int)

Receiver 分包逻辑

func (*JT1078Receiver) Reset

func (j *JT1078Receiver) Reset()

Reset 重置分包状态为初始状态

type SpliceSymbolReceiver

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

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

func NewSpliceSymbolReceiver

func NewSpliceSymbolReceiver(startSymbol byte, finishSymbol byte) *SpliceSymbolReceiver

NewSpliceSymbolReceiver 按照开始结束符来粘包

func (*SpliceSymbolReceiver) CanHandle

func (s *SpliceSymbolReceiver) CanHandle(conn netInterface.IConnection, buffer []byte) bool

CanHandle 是否能处理

func (*SpliceSymbolReceiver) GetHeadLen

func (s *SpliceSymbolReceiver) GetHeadLen() int

GetHeadLen 包头必须要的长度

func (*SpliceSymbolReceiver) Receiver

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

Receiver 分包逻辑

func (*SpliceSymbolReceiver) Reset

func (s *SpliceSymbolReceiver) Reset()

Reset 重置分包状态为初始状态