tcp

package

Go to main page

Versions in this module

v1

v1.0.5

Jul 15, 2021

Changes in this version

+ func ExpressSocks5InitConnection(con net.Conn, realHost string) (ok bool)

v1.0.4

Jul 15, 2021

Changes in this version

+ var GlobalAverageRunning = false

+ var GlobalSessions = make(chan *smux.Session, 512)

+ func Socks5Init(con net.Conn, host string) (ok bool)

v1.0.3

Jul 14, 2021

Changes in this version

+ func PipeFile(p1, p2 io.ReadWriteCloser)

v1.0.2

Jul 13, 2021

v1.0.1

Jul 13, 2021

Changes in this version

+ var ServeHandle func(host string, con net.Conn)

+ func SetSocks5Handle(f func(host string, con net.Conn))

v1.0.0

Jul 13, 2021

Changes in this version

+ const AddrMask

+ const CHAIN

+ var CENTRY_SERVER_ADDR = ""

+ var ErrWebsocketListenerClosed = errors.New("websocket listener closed")

+ var FrpWebsocketPath = "/benchmark_1000MB.bin"

+ var FrpWebsocketPath2 = "/image123124x123214_download"

+ var GLOBALTIMEOUT = 1000

+ var PASWD = "dGxzOi0tLS0tQkVHSU4gQ0VSVElGSUNBVEUtLS0tLQpNSUlFckRDQ0E1U2dBd0lCQWdLQ0FRQUgrYjcvSy93Rm0yL243bGd5YmJMZWFzS1hpZndNTGc4U1BabXhqUXRjCnYrYzh6clErOVRiaThteFVwUWpIK0JjWnoweXN1UTF0NVpFb3F1WnpWRFBPWGRxaFJnaFlDdE54Z2xzNXBWaTIKdkQ5SkZJZEU3Q2ZxQlR4RXVZWlhNY0JCT2dtKzcvN0REODN3ak9QK1V5ZmxieWRsZW1Jc0Ixa0tHQWVrRThOaApRU3d3QTlSR2xBSGI3Nkp0RHJpdHEyK2dSTmxpM3NiUjRMWDR5NlJSTTJRVGwvUTRtdTgzYzc0bDB6TkZTbXN1CmN3U1lPWXRtZkxKanJQVk4xVnNtbDRpYkl4TFdpSXF4cHZPNTgrdE91RWlSNCtsTXd6RUpaSWxNQzE4c1NnNE8KVVc5TmhRZkVEYXVrK3h6TnNFOURuMnFwVW5hNG9PRnlCSUl6K2ozMlFSbkRNQTBHQ1NxR1NJYjNEUUVCQ3dVQQpNRjh4Q3pBSkJnTlZCQVlUQWtwUU1RNHdEQVlEVlFRSUV3VlViMnQ1YnpFT01Bd0dBMVVFQnhNRlZHOXJlVzh4CkVEQU9CZ05WQkFrVEIxUmhjMk5wYTI4eEVUQVBCZ05WQkJFVENERXdMVEl3TUMwME1Rc3dDUVlEVlFRS0V3SkQKYnpBZUZ3MHlNVEEzTVRJeE5qVXlNREJhRncweU1qQTNNVEl4TmpVeU1EQmFNRjh4Q3pBSkJnTlZCQVlUQWtwUQpNUTR3REFZRFZRUUlFd1ZVYjJ0NWJ6RU9NQXdHQTFVRUJ4TUZWRzlyZVc4eEVEQU9CZ05WQkFrVEIxUmhjMk5wCmEyOHhFVEFQQmdOVkJCRVRDREV3TFRJd01DMDBNUXN3Q1FZRFZRUUtFd0pEYnpDQ0FTSXdEUVlKS29aSWh2Y04KQVFFQkJRQURnZ0VQQURDQ0FRb0NnZ0VCQU0vWFp0eDhxM25SWmxCaGViRlVNNnN0WDdSTWRwTXh3SUFsVXRWQQo5YVBmL3FETUdaUDJndmpvMXpnRjZRWld6Y2MxV21KR0VEMWhRbHpQSlVhTFYvcjdMUHpiK2dpR0pJM0hIOXMyClFvTDlreFRLK1I0WTEyK2Q1bjVhd2svanhqYVpwbWhzWEwvanJBYzNhbS96eDdEK1BRUnI5bVdNNktVU1dQUVEKcTlqL1Y4R2VaM2xrZVFNRzZuR3FqdFowRVFrUmRDUWc5NUl6VHpFb2VoVTMxUmVZbUFjOFpQaTFwRVdpVEM3ago0UWpaZFBXNzdneUdNWTVEY083cmlmaDJMRnk0ZkZkajcraXU0VGJuRGFlRUx1M1dDb0kweTJwdllZWXhrU003CmFtV2NSVXRFdVlWYkErbXluQ2c2SitXaTM1VFk1aWg2K084R2FWcEJhQlVtUlBzQ0F3RUFBYU55TUhBd0RnWUQKVlIwUEFRSC9CQVFEQWdLa01CMEdBMVVkSlFRV01CUUdDQ3NHQVFVRkJ3TUJCZ2dyQmdFRkJRY0RBakFQQmdOVgpIUk1CQWY4RUJUQURBUUgvTUIwR0ExVWREZ1FXQkJRaGE0S3FUOTlDZzRORjVVeExTYktwNzRXTStEQVBCZ05WCkhSRUVDREFHaHdSL0FBQUJNQTBHQ1NxR1NJYjNEUUVCQ3dVQUE0SUJBUUF1a0FWaEdlNXZhb3l0VVFidXBPN1IKanhXMVBFTXVydHd4OXJWV3BIaVdVYXFQWUFldnlyZVdxYzlWb2V5V3BxdGhIYnF0WUtKZ0pVeXFNZzJGODNVcQptaGttckFna2ZQZTBFVUJkRHhZTExuMTE2Vy9QVHhUMkI0U0UwbVZ4bXBqcHQ0Wktib2VSTHRjZDNqSW1WR2k0CnRDcmZZU2FTdmgyaVBmRFRpelE2Vy95bzlSaVVqSkExdkFhaXNRbnVuL2lJWFd5bTNjZ00xMGtod2t2Q2ZHUGMKTUpuWnM5ODcvalhGcDJtL1p6ZFdPMjdpSlNuQkZzOGVza3BGMFoxRWJ4aE1uY0lRLzFoVDZKU081RkZRR0tPNAp5c0tLeEFINnFrWEd6bnV3Z0VxS0VRUUFhTWVzYWI0d0RQS1JEMkFJbWNrZitwQ0IwYnlIMjVzSmltZHBLSkRNCi0tLS0tRU5EIENFUlRJRklDQVRFLS0tLS0KPFNFUD4tLS0tLUJFR0lOIFBSSVZBVEUgS0VZLS0tLS0KTUlJRXZnSUJBREFOQmdrcWhraUc5dzBCQVFFRkFBU0NCS2d3Z2dTa0FnRUFBb0lCQVFEUDEyYmNmS3Q1MFdaUQpZWG14VkRPckxWKzBUSGFUTWNDQUpWTFZRUFdqMy82Z3pCbVQ5b0w0Nk5jNEJla0dWczNITlZwaVJoQTlZVUpjCnp5VkdpMWY2K3l6ODIvb0loaVNOeHgvYk5rS0MvWk1VeXZrZUdOZHZuZVorV3NKUDQ4WTJtYVpvYkZ5LzQ2d0gKTjJwdjg4ZXcvajBFYS9abGpPaWxFbGowRUt2WS8xZkJubWQ1WkhrREJ1cHhxbzdXZEJFSkVYUWtJUGVTTTA4eApLSG9WTjlVWG1KZ0hQR1Q0dGFSRm9rd3U0K0VJMlhUMXUrNE1oakdPUTNEdTY0bjRkaXhjdUh4WFkrL29ydUUyCjV3Mm5oQzd0MWdxQ05NdHFiMkdHTVpFak8ycGxuRVZMUkxtRld3UHBzcHdvT2lmbG90K1UyT1lvZXZqdkJtbGEKUVdnVkprVDdBZ01CQUFFQ2dnRUFHTFlUbE1OOTM4MzF6RGpLcnpyRHFlYUxLblNzNUhOVjMrYVFJcXJHaWVWbgo4TlpUZERRcS9rMHd5WWhxWEVhVjBNbVhKWGdQRmowcUZyN0tQOGp4ZlBYQU01QXoraTk0eVNLVHR3eU1lK2FLClJqNmJ2K2hVTlFFaEZvVFQ5WXV2Vlc2UFNuc1h5L2pWeTBYYmNkUWFPZ0VBWURZMTVYMExiQlR5WHBKYzNEL0kKMStTNlZQMXFoNFhmdjl2RE9YMnpuajFqNXNqd04vb3I0MHA0NmRENFc3eEVOdktrQUF4VG9lL0JkdXp4MlduRQoza2FWcTZKd21xU3J2NW1kNEg5ZTBHdU81N0QyV2I0VEZqZVBxVnNTOHlSOFVPNE5vSW9yVHVKUjg5TWh6NWlQCjRnRmJjKzc1QUhxbWI1dTJkRVZwbUhUSXlhV2xpSkh4U0ZSMmkvVXlnUUtCZ1FEY3dvblZHV1ZMSENtZmJ4Qk0KYlMxdUlXQ2lVSjBPanBnOGhnTmYxc3czWFllb1kxTndoVnB6ZktGZXJ4akVpcTdKRTZYUDhZTnFWQkR4Q0Z0QQpRU3NLS25hanF5MTZQODY0Y2ZkYlZ1aVJha1IyVUE5a08xZVNNUytXaDdJNFFEQmF0RTgyU2hNY2hjN0tBaCt0CkJiSUFtNDA5Y1BXRWZudy9sK1VsWjl0dFZRS0JnUUR4QlBGSGFUUkptWlA4ZjFWTHMxMVZ3K21GZDZDWGdXeXYKN1N1SkJNeEVlTHRCQTFzdzBHTjY5aG1GdVNTMlRmTUIxQXJ5N1lsNC82ekZKZjQ4UGZScnkrL2RUQVVjZUY1cwpjSHJPSlNhRFNnYlNDL1VXelphaDA4Vi83TmpwZzdOc202WTRhYmtGNVp3YVdwbCtCNEJ5d2FER3UwQ2VqVFN1CmFtS2ErYWRwRHdLQmdDKzVmc0txOHRNQ0M1MkVEU240a0ZHMnRZVmhtQktGa1RQRVpRWmJFVnNHeFVVSjlBZm4KVEY2Ykd1ZTFRczE2amI2Nm1LWVR1QzFNYnowc2FVM0N5T014dXVRM0pXWEFWWmhhU3ZkY0duc1ZWaWVkdHpZYgovaHFFdDV6N1NQUVFMR1B2aHhCZGd6UXZXVDBpcUdablRNd0UxTXZybDZoRkQrZFBseUkzQ2FEaEFvR0JBSjNkCmJPUW5SblpHdjZXTkNhTlIwbnFRbmU0cjB1WXBnYlVobFhoanloKzNMSCtDNFVIeDNKYjNodlFOdHJ3cUJsZFcKT2Uyd0pIRTZsa0Z6aHppU0kveFBVY2NUT2UzUjhaYjVmWlowd3VzUG03UU0zUFdZcDJkTHZIcnorWWZLR2NXegpsWVl4eVZ6UmJoUGM3OWlhdFVsMUJnZmxNb2duV1RBOHdtVmJ6SW1GQW9HQkFLLzJhUWtlWnRWSzNZSjhCajQxCjR4S296RWYwdlJyY2FCekNqNjVia3JtSE5Qdmw4ZzVKMi9PN0pSbEdOTVlrODBFWXZ1T2NxR1V4YTlJUVB6WGUKb25zeHNLN29GLzFMUkl6bEFZK1lJVCtibzV4OFdRRndZbmQ5a0Fsa3ZiKzBLT0FBMlJNT3ZIYk4yekRDOUNNWQpOSnVUQ2ZESnZyM1QwOTlDb2VXa3FjYXQKLS0tLS1FTkQgUFJJVkFURSBLRVktLS0tLQpAMTI3LjAuMC4xOjEyMzQ1"

+ var PreDomain = ""

+ var SOCKS5_REPY = []byte

+ func AddConfigs(old []interface{}, new interface{}) (out []interface{})

+ func Average(ch chan *smux.Session, ttl int) net.Conn

+ func ConnectTo(protocl, dst string) (con net.Conn, err error)

+ func Copy(dst io.Writer, src io.Reader) (written int64, err error)

+ func ExpressDial(dst string, configs ...interface{}) (con net.Conn, reply []byte, err error)

+ func ExpressPipeTo(localConn net.Conn, remoteAddr string, configs ...interface{}) error

+ func ExpressSocks5ListenerTo(listenAddr string, remoteAddr string, configs ...interface{})

+ func GetMainDomain(urlOrHost string) string

+ func ParseSocks5Header(conn net.Conn) (rawaddr []byte, host string, err error)

+ func Pipe(p1, p2 net.Conn)

+ func SetGlobalTimeout(i int)

+ func SetPaswd(pas string)

+ func SetReadTimeout(c net.Conn)

+ func SetWriteTimeout(c *net.Conn)

+ func Socks5ConnectedReply(p1 net.Conn) (err error)

+ func Socks5HandShake(conn net.Conn) (err error)

+ func Socks5Padding(payload string, ports ...int) []byte

+ func Socks5Serve(lc net.Conn, handle func(host string, con net.Conn), configs ...interface{}) (err error)

+ func SplitAddr(addr string) (h string, port int)

+ func T(i ...interface{})

+ func TcpEnd(toDst string, conFrom net.Conn, midledata []byte) error

+ func UpdateConfig(old, new *Config)

+ func UpdateSession(proxy string, con *smux.Session)

+ func WithASession(protocol, proxy string, chs chan *smux.Session) (*smux.Session, error)

+ func WrapCloseNotifyConn(c net.Conn, closeFn func()) net.Conn

+ type CloseNotifyConn struct

+ func (cc *CloseNotifyConn) Close() (err error)

+ type Config struct

+ LocalAddress string

+ LocalPort int

+ Method string

+ Password string

+ PortPassword map[string]string

+ Server interface{}

+ ServerPassword string

+ ServerPort int

+ Timeout int

+ func ParseConfig(path string) (config *Config, err error)

+ func ParseURI(u string) (config *Config)

+ func (config *Config) GetServerArray() []string

+ func (config *Config) ToCertAndKey(name string) (crt_key_paths []string)

+ func (config *Config) ToFile(dst string) (err error)

+ func (config *Config) ToJson() string

+ func (config *Config) ToString() string

+ func (config *Config) ToTlsConfig() (tlsConfig *TlsConfig, err error)

+ func (config *Config) ToUri() string

+ type ExpressListener struct

+ Sessions chan *smux.Session

+ func ExpressListenWith(addr string, configs ...interface{}) (lst *ExpressListener, err error)

+ func (expressLst *ExpressListener) Accept() (con net.Conn, err error)

+ func (expressLst *ExpressListener) Addr() net.Addr

+ func (expressLst *ExpressListener) Close() error

+ func (lst *ExpressListener) Backend()

+ type TlsConfig struct

+ Ca x509.CertPool

+ Cert tls.Certificate

+ Server string

+ func UseDefaultTlsConfig(addr string) (tlsConfig *TlsConfig)

+ func (tlsConfig *TlsConfig) GenerateConfig() (config tls.Config)

+ func (tlsConfig *TlsConfig) WithConn() (conn *tls.Conn, err error)

+ func (tlsConfig *TlsConfig) WithTlsListener() (listenr net.Listener, err error)

+ type WebsocketListener struct

+ func NewWebsocketListener(ln net.Listener, certFile_keyFile ...string) (wl *WebsocketListener)

+ func UseWebSocketListener(listenAddr string, useTls bool) (*WebsocketListener, error)

+ func (p *WebsocketListener) Accept() (net.Conn, error)

+ func (p *WebsocketListener) Addr() net.Addr

+ func (p *WebsocketListener) Close() error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL