我的项目地址：https://github.com/fzdwx/burst
明天次要应用Go实现 echo client，并与server胜利连贯。
websocket框架选型
应用在Go语言中比拟风行的实现：https://github.com/gorilla/websocket
我的项目搭建
mkdri go && cd gogo mod init demogo 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)) }}()- 启动一个协程，读取从控制台输出的数据，而后发送到服务端。
成果
最终代码
package mainimport ( "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 }}明日指标
今天就正式进入具体的代码实现了。
- 定义交互协定（暂定为json,次要为了疾速开发）
3个阶段
- 服务端与客户端连贯初始化（确定客户端与服务端的端口映射关系）
- 客户连贯，告诉客户端，监听本地端口
- 数据转发。