这是实现内网穿透的第一天,明天次要是实现我的项目的搭建以及基于 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 的实现。