#填写服务器域名和连接端口
server_addr: ngrok.domain.com:4444
trust_host_root_certs: false
tunnels:adb:#这里的remote_port是指从ngrok.domain.com:5555->被代理端的5555端口remote_port: 5555proto:#使用tcp协议tcp: 5555

func Join(c Conn, c2 Conn) (int64, int64) {var wait sync.WaitGrouppipe := func(to Conn, from Conn, bytesCopied *int64) {defer to.Close()defer from.Close()defer wait.Done()var err error*bytesCopied, err = io.Copy(to, from)if err != nil {from.Warn("Copied %d bytes to %s before failing with error %v", *bytesCopied, to.Id(), err)} else {from.Debug("Copied %d bytes to %s", *bytesCopied, to.Id())}}wait.Add(2)var fromBytes, toBytes int64go pipe(c, c2, &fromBytes)go pipe(c2, c, &toBytes)c.Info("Joined with connection %s", c2.Id())wait.Wait()return fromBytes, toBytes
}

func Listen(addr, typ string, tlsCfg *tls.Config) (l *Listener, err error) {// listen for incoming connectionslistener, err := net.Listen("tcp", addr)if err != nil {return}l = &Listener{Addr:  listener.Addr(),Conns: make(chan *loggedConn),}go func() {for {rawConn, err := listener.Accept()if err != nil {log.Error("Failed to accept new TCP connection of type %s: %v", typ, err)continue}c := wrapConn(rawConn, typ)if tlsCfg != nil {c.Conn = tls.Server(c.Conn, tlsCfg)}c.Info("New connection from %v", c.RemoteAddr())l.Conns <- c

if rawConn, ok := rawConn.(*net.TCPConn); ok {err := rawConn.SetKeepAlive(true)if err != nil {fmt.Println(err.Error())}err = rawConn.SetKeepAlivePeriod(time.Minute)if err != nil {fmt.Println(err.Error())}}

/ Listens for new public tcp connections from the internet.
func (t *Tunnel) listenTcp(listener *net.TCPListener) {for {defer func() {if r := recover(); r != nil {log.Warn("listenTcp failed with error %v", r)}}()// accept public connectionstcpConn, err := listener.AcceptTCP()if err != nil {// not an error, we're shutting down this tunnelif atomic.LoadInt32(&t.closing) == 1 {return}t.Error("Failed to accept new TCP connection: %v", err)continue}conn := conn.Wrap(tcpConn, "pub")conn.AddLogPrefix(t.Id())conn.Info("New connection from %v", conn.RemoteAddr())go t.HandlePublicConnection(conn)

err1 := tcpConn.SetKeepAlive(true)if err1 != nil {fmt.Println(err1.Error())}err2 := tcpConn.SetKeepAlivePeriod(time.Minute)if err2 != nil {fmt.Println(err2.Error())}