关于java:实现内网穿透二

我的项目地址：https://github.com/fzdwx/burst

明天次要应用 Go 实现 echo client，并与 server 胜利连贯。

websocket 框架选型

应用在 Go 语言中比拟风行的实现：https://github.com/gorilla/websocket

我的项目搭建

mkdri go && cd go
go mod init demo
go get github.com/gorilla/websocket

与客户端建设连贯

func main() {

    // 定义客户端的地址
    u := url.URL{Scheme: "ws", Host: "locaalhost:999", Path: "/connect"}

    // 与客户端建设连贯
    c, _, err := websocket.DefaultDialer.Dial(u.String(), nil)
    if err != nil {log.Fatal("dial:", err)
    }
    defer c.Close()

    // 启动一个协程，读取从服务端发送过去的数据
    go func() {
        for {_, message, _ := c.ReadMessage()
            fmt.Println(string(message))
        }
    }()


    // 阻塞主线程
    down := make(chan byte)
    for {<-down}
}

启动客户端

胜利接管到来自服务端的音讯。

实现 echo handle

只须要咱们从客户端发送音讯就 ok 了，而后服务端就会把咱们发送的数据返回给咱们。

go func() {
    for {
        var input string
        fmt.Scanln(&input)
        c.WriteMessage(websocket.TextMessage, []byte(input))
    }
}()

1. 启动一个协程，读取从控制台输出的数据，而后发送到服务端。

成果

最终代码

package main

import (
    "flag"
    "fmt"
    "github.com/gorilla/websocket"
    "log"
    "net/url"
)

var addr = flag.String("addr", "localhost:9999", "proxy server addr")

func main() {u := url.URL{Scheme: "ws", Host: *addr, Path: "/connect"}

    c, _, err := websocket.DefaultDialer.Dial(u.String(), nil)
    if err != nil {log.Fatal("dial:", err)
    }
    defer c.Close()

    down := make(chan byte)
    go func() {
        for {_, message, _ := c.ReadMessage()
            fmt.Println("服务端发送:" + string(message))
        }
    }()

    go func() {
        for {
            var input string
            fmt.Scanln(&input)
            c.WriteMessage(websocket.TextMessage, []byte(input))
        }
    }()

    for {<-down}
}

明日指标

今天就正式进入具体的代码实现了。

1. 定义交互协定（暂定为 json, 次要为了疾速开发）

2. 3 个阶段

   1. 服务端与客户端连贯初始化（确定客户端与服务端的端口映射关系）
   2. 客户连贯，告诉客户端，监听本地端口
   3. 数据转发。