Receivers

Documentation

Index

• func NewDynamicJT1078Receiver(startBf []byte) netInterface.IReceiver
• func NewDynamicSpliceSymbol(startSymbol byte, finishSymbol byte) netInterface.IReceiver
• type DynamicJT1078Receiver
  • func (d *DynamicJT1078Receiver) IsMeHandle(conn netInterface.IConnection, buffer []byte) bool
  • func (d *DynamicJT1078Receiver) Receiver(conn netInterface.IConnection, buffer []byte) ([]byte, int)
• type DynamicReceiver
  • func NewDynamicReceiver() *DynamicReceiver
  • func (d *DynamicReceiver) Receiver(conn netInterface.IConnection, buffer []byte) (err error)
• type DynamicSpliceSymbol
  • func (d *DynamicSpliceSymbol) IsMeHandle(conn netInterface.IConnection, buffer []byte) bool
  • func (d *DynamicSpliceSymbol) Receiver(conn netInterface.IConnection, buffer []byte) ([]byte, int)
• type JT1078Receiver
  • func NewJT1078Receiver(startBf []byte) *JT1078Receiver
  • func (j *JT1078Receiver) Receiver(conn netInterface.IConnection, buffer []byte) ([]byte, int)
• type SpliceSymbolReceiver
  • func NewSpliceSymbolReceiver(startSymbol byte, finishSymbol byte) *SpliceSymbolReceiver
  • func (s *SpliceSymbolReceiver) Receiver(conn netInterface.IConnection, buffer []byte) ([]byte, int)

Functions

func NewDynamicJT1078Receiver

func NewDynamicJT1078Receiver(startBf []byte) netInterface.IReceiver

实例化

func NewDynamicSpliceSymbol

func NewDynamicSpliceSymbol(startSymbol byte, finishSymbol byte) netInterface.IReceiver

实例化

Types

type DynamicJT1078Receiver

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

单字节策略

func (*DynamicJT1078Receiver) IsMeHandle

func (d *DynamicJT1078Receiver) IsMeHandle(conn netInterface.IConnection, buffer []byte) bool

是否我处理

func (*DynamicJT1078Receiver) Receiver

func (d *DynamicJT1078Receiver) Receiver(conn netInterface.IConnection, buffer []byte) ([]byte, int)

分包处理[处理一包后跳出]

type DynamicReceiver

type DynamicReceiver struct {
	Receivers   []netInterface.IReceiver //分包器集合
	ReceiverLen int                      //分包器个数
	IsPackStart bool                     //是否开始分包
	IsSingle    bool                     //是否只有一个分包算法
	// contains filtered or unexported fields
}

策略分包器

func NewDynamicReceiver

func NewDynamicReceiver() *DynamicReceiver

策略分包器

func (*DynamicReceiver) Receiver

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

分包处理

type DynamicSpliceSymbol

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

单字节策略

func (*DynamicSpliceSymbol) IsMeHandle

func (d *DynamicSpliceSymbol) IsMeHandle(conn netInterface.IConnection, buffer []byte) bool

是否我处理

func (*DynamicSpliceSymbol) Receiver

func (d *DynamicSpliceSymbol) Receiver(conn netInterface.IConnection, buffer []byte) ([]byte, int)

分包处理[处理一包后跳出]

type JT1078Receiver

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

JT1078分包器

func NewJT1078Receiver

func NewJT1078Receiver(startBf []byte) *JT1078Receiver

按照开始结束符来粘包

func (*JT1078Receiver) Receiver

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

分包逻辑

type SpliceSymbolReceiver

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

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

func NewSpliceSymbolReceiver

func NewSpliceSymbolReceiver(startSymbol byte, finishSymbol byte) *SpliceSymbolReceiver

按照开始结束符来粘包

func (*SpliceSymbolReceiver) Receiver

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

分包逻辑