tcp

package

v0.0.0-...-9fb38be Latest Latest Go to latest Published: Apr 22, 2024 License: MIT Imports: 11 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var (
	ErrMaxPacket = errors.New("packet over size")
	ErrMinPacket = errors.New("packet short size")
)

func InitProc(order binary.ByteOrder, bodySize int)

InitProc 使用"tcp.lv"前需自行在init()中调用这个函数

func RecvLVPacket(reader io.Reader, maxPacketSize int, order binary.ByteOrder, bodySize int) (msg interface{}, err error)

RecvLVPacket 接收Length-Value格式的封包流程

func SendLVPacket(writer io.Writer, _ cellnet.ContextSet, data interface{}, order binary.ByteOrder, bodySize int) error

SendLVPacket 发送Length-Value格式的封包流程

func WriteFull(writer io.Writer, buf []byte) error

WriteFull 完整发送所有封包

type MsgHooker struct {
}

带有RPC和relay功能

func (self MsgHooker) OnInboundEvent(inputEvent cellnet.Event) (outputEvent cellnet.Event)

func (self MsgHooker) OnOutboundEvent(inputEvent cellnet.Event) (outputEvent cellnet.Event)

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

func (t *TCPMessageTransmitter) OnRecvMessage(ses cellnet.Session) (msg interface{}, err error)

func (t *TCPMessageTransmitter) OnSendMessage(ses cellnet.Session, msg interface{}) (err error)