tcp_protocol

package

v1.0.1 Latest Latest Go to latest Published: Oct 3, 2023 License: Apache-2.0 Imports: 5 Imported by: 0

Details

View Source

const TcpConnProtocol = "tcp"

This section is empty.

This section is empty.

type TcpConnection struct {
	Conn  net.Conn
	Mutex sync.Mutex
	// contains filtered or unexported fields
}

func NewTcpConnection(conn net.Conn) *TcpConnection

func (this *TcpConnection) Addr() string

func (this *TcpConnection) Close() error

func (this *TcpConnection) ConnProtocol() string

func (this *TcpConnection) ReadMsg() ([]byte, error)

func (this *TcpConnection) SetFlowProtocolHandler(flowProtocolHandler protocol.Proto)

func (this *TcpConnection) WriteMsg(data []byte) error

WriteMsg send byte array message

type TcpProtocol struct {
}

func (this *TcpProtocol) Dial(addr string) (protocol.Connection, error)

func (this *TcpProtocol) ListenAndServe(port int64, onConnect func(conn protocol.Connection)) error