这是实现内网穿透的第一天,今天主要是完成项目的搭建以及基于websocket实现一个echo server。
源码地址:https://github.com/fzdwx/burst
【实现内网穿透(一)】技术选型
- 服务端使用Java & Netty & Spring boot
- 客户端使用Go
io.github.fzdwx
sky-http-springboot-starter
0.10.6
sky-http-springboot-starterMain
是基于Netty封装的一个工具包,可以快速构建http服务
package org.example;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
public class Main {public static void main(String[] args) {
final var context = SpringApplication.run(Main.class, args);
}
}
接收websocket请求
package org.example.controller;
import http.HttpServerRequest;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class ConnectController {@GetMapping("/connect")
public void connect(HttpServerRequest request) {
request.upgradeToWebSocket(ws -> {ws.mountOpen(h -> {
ws.send("hello world");
});
});
}
}
上面的代码大概意思:
- 在12行将当前请求升级为websocket请求
- 在14行挂在一个方法,表示当与客户端成功建立连接时,发送hello world到客户端。
文章图片
那什么是echo server呢?
顾名思义就是将客户端发送的消息原样返回给客户端。所以我们只需要增加下面这一段代码就完成了:
ws.mountText(s -> {
ws.send(s);
});
上面的代码大概意思:
- 在当前websocket连接上挂在一个监听客户端发送过来的文本数据
- 然后原样返回给客户端。
文章图片
总结 实现一个echo server还是很简单的,明天我们将进行Go语言的echo client的实现。