这是实现内网穿透的第一天,今天主要是完成项目的搭建以及基于 websocket 实现一个 echo server。
源码地址:https://github.com/fzdwx/burst
技术选型
服务端使用 Java & Netty & Spring boot
客户端使用 Go
服务端
mavne 依赖
<dependency>
<groupId>io.github.fzdwx</groupId>
<artifactId>sky-http-springboot-starter</artifactId>
<version>0.10.6</version>
</dependency>
复制代码
sky-http-springboot-starter是基于 Netty 封装的一个工具包,可以快速构建 http 服务
Main
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 到客户端。
现在我们可以用一个在线测试 websocket 的网站进行测试,成功接收到了hello world
那什么是 echo server 呢?
顾名思义就是将客户端发送的消息原样返回给客户端。所以我们只需要增加下面这一段代码就完成了:
ws.mountText(s -> {
ws.send(s);
});
复制代码
上面的代码大概意思:
在当前 websocket 连接上挂在一个监听客户端发送过来的文本数据
然后原样返回给客户端。
最终效果
总结
实现一个 echo server 还是很简单的,明天我们将进行 Go 语言的 echo client 的实现。
评论