• go io.Copy 实现 端口转发 SSH 代理


    借助io.Copy非常简单

    type Endpoint struct {
    	Host string
    	Port int
    }
    
    func (endpoint *Endpoint) String() string {
    	return fmt.Sprintf("%s:%d", endpoint.Host, endpoint.Port)
    }
    
    type SSHtunnel struct {
    	Local  *Endpoint
    	Server *Endpoint
    	Remote *Endpoint
    
    	Config *ssh.ClientConfig
    }
    
    func (tunnel *SSHtunnel) Start() error {
    	listener, err := net.Listen("tcp", tunnel.Local.String())
    	if err != nil {
    		return err
    	}
    	defer listener.Close()
    
    	for {
    		conn, err := listener.Accept()
    		if err != nil {
    			return err
    		}
    		go tunnel.forward(conn)
    	}
    }
    
    func (tunnel *SSHtunnel) forward(localConn net.Conn) {
    	serverConn, err := ssh.Dial("tcp", tunnel.Server.String(), tunnel.Config)
    	if err != nil {
    		fmt.Printf("Server dial error: %s\n", err)
    		return
    	}
    
    	remoteConn, err := serverConn.Dial("tcp", tunnel.Remote.String())
    	if err != nil {
    		fmt.Printf("Remote dial error: %s\n", err)
    		return
    	}
    
    	copyConn := func(writer, reader net.Conn) {
    		defer writer.Close()
    		defer reader.Close()
    
    		_, err := io.Copy(writer, reader)
    		if err != nil {
    			fmt.Printf("io.Copy error: %s", err)
    		}
    	}
    
    	go copyConn(localConn, remoteConn)
    	go copyConn(remoteConn, localConn)
    }
    
    func main() {
    	localEndpoint := &Endpoint{
    		Host: "localhost",
    		Port: 9000,
    	}
    
    	serverEndpoint := &Endpoint{
    		Host: "some-real-ssh-listening-port",
    		Port: 22,
    	}
    
    	remoteEndpoint := &Endpoint{
    		Host: "www.baidu.com",
    		Port: 80,
    	}
    
    	sshConfig := &ssh.ClientConfig{
    		User: "root",
    		Auth: []ssh.AuthMethod{
    			ssh.Password("real-password"),
    		},
    		HostKeyCallback: func(hostname string, remote net.Addr, key ssh.PublicKey) error {
    			// Always accept key.
    			return nil
    		},
    	}
    
    	tunnel := &SSHtunnel{
    		Config: sshConfig,
    		Local:  localEndpoint,
    		Server: serverEndpoint,
    		Remote: remoteEndpoint,
    	}
    
    	tunnel.Start()
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22
    • 23
    • 24
    • 25
    • 26
    • 27
    • 28
    • 29
    • 30
    • 31
    • 32
    • 33
    • 34
    • 35
    • 36
    • 37
    • 38
    • 39
    • 40
    • 41
    • 42
    • 43
    • 44
    • 45
    • 46
    • 47
    • 48
    • 49
    • 50
    • 51
    • 52
    • 53
    • 54
    • 55
    • 56
    • 57
    • 58
    • 59
    • 60
    • 61
    • 62
    • 63
    • 64
    • 65
    • 66
    • 67
    • 68
    • 69
    • 70
    • 71
    • 72
    • 73
    • 74
    • 75
    • 76
    • 77
    • 78
    • 79
    • 80
    • 81
    • 82
    • 83
    • 84
    • 85
    • 86
    • 87
    • 88
    • 89
    • 90
    • 91
    • 92
    • 93
    • 94
    • 95
    • 96
  • 相关阅读:
    Java数组理解与应用,看完就懂。数组的定义、初始化及特点详解,一篇博文全部理解。
    C++左值右值完美转发转移
    个人深度学习环境配置
    孪生神经网络
    LeetCode·899.有序队列·最小表示法
    CentOS7服务器用U盘装centos7系统报错解决方案
    抖音小店和商品橱窗一样吗?有什么区别?新手适合做哪个?
    Gitblit自建仓库及多人使用
    3分钟,快速上手Postman接口测试!
    flume使用实例
  • 原文地址:https://blog.csdn.net/shelutai/article/details/126545161