tcpx

Aug 20, 2023

Changes in this version

type TCPServer

+ func (s *TCPServer) FindConnection(address string) (conn netx.IServerConn, ok bool)

+ func (s *TCPServer) SetMaxConn(max int)

+ type TcpSockConn struct

+ Address string

+ Conn *net.TCPConn

+ SRProxy netx.IPackSendReceiver

+ func (o *TcpSockConn) ClientAddress() string

+ func (o *TcpSockConn) CloseConn() error

+ func (o *TcpSockConn) SendBytes(bytes []byte) error

+ func (o *TcpSockConn) SendPack(data []byte) error

Apr 17, 2022

Changes in this version

+ var TcpDataBlockHandler = bytex.NewDefaultDataBlockHandler()

+ func GetTCPAddr(network string, address string) (*net.TCPAddr, error)

+ func TCPAddrEqual(addr1 *net.TCPAddr, addr2 *net.TCPAddr) bool

+ type ITCPClient interface

+ func NewTCP4Client() ITCPClient

+ func NewTCP6Client() ITCPClient

+ func NewTCPClient() ITCPClient

+ type ITCPServer interface

+ func NewTCP4Server() ITCPServer

+ func NewTCP6Server() ITCPServer

+ func NewTCPServer() ITCPServer

+ type TCPClient struct

+ func (c *TCPClient) CloseClient() error

+ func (c *TCPClient) OpenClient(params netx.SockParams) error

+ type TCPServer struct

+ func (s *TCPServer) CloseConnection(address string) (err error, ok bool)

+ func (s *TCPServer) Connections() int

+ func (s *TCPServer) SendBytesTo(data []byte, rAddress ...string) error

+ func (s *TCPServer) SendPackTo(pack []byte, rAddress ...string) error

+ func (s *TCPServer) StartServer(params netx.SockParams) error

+ func (s *TCPServer) StopServer() error