資訊專欄INFORMATION COLUMN
摘要：零前期準備版本版本核心依賴包支持包簡介是官方出品的微服務框架，底層基于驅動，大致的使用套路和相差不是很多筆者只是淺淺的了解過，可能存在理解不透的情況。一配置中的配置類有兩種，一種是用于讀取配置文件的，另一種是用于配置服務器對象的。
零 前期準備 0 版本
JDK 版本 : OpenJDK 11.0.1
IDE : idea 2018.3
Helidon Webserver : helidon-webserver 1.0.0 (核心依賴包)
Helidon Json : helidon-media-jsonp-server 1.0.0 (json 支持包)
1 Helidon 簡介Helidon 是 Oracle 官方出品的 java 微服務框架，底層基于 Netty 驅動，大致的使用套路和 Vertx 相差不是很多(筆者只是淺淺的了解過 Vertx，可能存在理解不透的情況)。在 2019 年的年初，Helidon 迎來了 1.0.0 的版本更新，api 開始趨于穩定。
就目前的版本來看，Oracle 應該希望 Helidon 是一個小而美的輕巧型 java 框架，所以對其的封裝非常之薄，僅僅是對 Netty 做了一層定制化的處理，同時也深度整合了 jdk 的相關接口(畢竟是自家的東西，駕馭能力不一般)。就連 json 的處理都引用了 javax 中的 joup 去做，而不是使用第三方工具包。
Helidon 目前的網絡資料很少，所以本文主要通過其官方文檔進行 Demo 的構筑。
一 配置Helidon 中的配置類有兩種，一種是用于讀取配置文件的 Config，另一種是用于配置服務器對象的 ServerConfiguration。
先來看 Config：
//配置文件
Config conf = Config
//builder
.builder()
//載入配置文件，可以一次載入多張
.sources(
//根據絕對路徑去載入配置文件
ConfigSources.file("D://application.yaml"),
//到 resource 文件夾下去尋找
ConfigSources.classpath("application2.yaml")
)
//創建完成
.build();
再來看 ServerConfiguration：
//創建一個配置對象，用于注入一些配置信息
ServerConfiguration config = ServerConfiguration
//生成 builder
.builder()
//address
//getLoopbackAddress() 會獲取到 localhost
.bindAddress(InetAddress.getLoopbackAddress())
//getLocalHost() 會獲取到本機的 ip
//.bindAddress(InetAddress.getLocalHost())
//端口
.port(8080)
//工作線程的線程數
.workersCount(10)
//增加一個 ServerConfiguration 對象
//.addSocket("serverConfiguration",ServerConfiguration.builder().build())
//載入配置文件
//.config(conf)
//創建完成
.build();
二 路由
網絡博文最簡單的 Hello World 的路由對象：
//創建最簡單的路由邏輯
Routing rt = Routing
//builder
.builder()
//設置路由的請求方法和業務邏輯
//設置多種請求方法
.anyOf(List.of(Http.Method.GET, Http.Method.POST,Http.Method.DELETE),"/hello",(req, res) -> res.send("hello world"))
//單一請求方法
//.post("/hello",(req, res) -> res.send("hello world"))
//.get("/hello",(req, res) -> res.send("hello world"))
//創建完成
.build();
結合業務邏輯的路由對象：
//創建路由對象
Routing routing = Routing
//builder
.builder()
//注冊 json 解析器
.register(JsonSupport.create())
//添加 url 路由，一個路由對象可以添加多個
//可以添加業務邏輯的 service 類
.post("/hello", Handler.create(JsonObject.class,new HelloService()))
//hello world
.get("/hello1",(req, res) -> res.send("hello world"))
//創建完成
.build();
HelloService 中處理具體的業務邏輯：
//HelloService 必須實現 Handler.EntityHandler
class HelloService implements Handler.EntityHandler{
//json 的解析門面對象
private static final JsonBuilderFactory jsonFactory = Json.createBuilderFactory(Collections.emptyMap());
//核心業務類，里面可以寫具體的業務邏輯，最后 send(...) 進 response 里就可以了
@Override
public void accept(ServerRequest req, ServerResponse res, Object entity) {
//entity 本質上就是 JsonObject
JsonObject reqJson = (JsonObject)entity;
//獲取鍵值對并打印，這個操作和 Fastjson 很類似
String ret = reqJson.getString("hello");
System.out.println(ret);
//創建要返回的 json object
JsonObject msg = jsonFactory
//builder
.createObjectBuilder()
//添加一組 json 的 key - value 鍵值對
.add("message", "Hello")
//創建 json 對象完成
.build();
//json array 的創建方式
//JsonArray array = jsonFactory.createArrayBuilder().build();
//返回
res.send(msg);
}
}
三 服務器對象
服務器對象：
//啟動服務器
WebServer
//創建服務器對象
//具體依賴 ServerConfiguration 和 Routing 對象
.create(config,routing)
//開啟服務器
.start()
//獲取 future
.toCompletableFuture()
//設置超時時間為 10 秒
.get(10, TimeUnit.SECONDS);
四 服務實現
先來看 WebServer 的 create(...) 方法：
//step 1
//WebServer.class
static WebServer create(ServerConfiguration configuration, Routing routing) {
//有效性驗證
Objects.requireNonNull(routing, "Parameter "routing" is null!");
//builder(...) 方法會創建一個 WebServer.Builder 對象，最終在 build() 方法里創建 WebServer
return builder(routing).config(configuration)
.build();
}
//step 2
//WebServer.Builder.class
public WebServer build() {
//routings 是一個 Map 對象，用來儲存更多的路由對象
String unpairedRoutings = routings
.keySet()
.stream()
.filter(routingName -> configuration == null || configuration.socket(routingName) == null)
.collect(Collectors.joining(", "));
//有效性驗證
if (!unpairedRoutings.isEmpty()) {
throw new IllegalStateException("No server socket configuration found for named routings: " + unpairedRoutings);
}
//NettyWebServer 是 WebServer 接口的實現類
//defaultRouting 是上方 create(...) 方法存入的路由對象
WebServer result = new NettyWebServer(configuration == null
? ServerBasicConfig.DEFAULT_CONFIGURATION
: configuration,
defaultRouting, routings);
//默認的路由對象即為 RequestRouting 類型
//此處給路由對象添加回調方法
if (defaultRouting instanceof RequestRouting) {
((RequestRouting) defaultRouting).fireNewWebServer(result);
}
//返回
return result;
}
//step 3
//NettyWebServer.class
NettyWebServer(ServerConfiguration config,
Routing routing,
Map namedRoutings) {
//獲取所有的 SocketConfiguration 對象
//即為之前 addSocket(...) 方法存入的對象，也包括主配置對象自身
Set> sockets = config.sockets().entrySet();
//創建兩個線程
this.bossGroup = new NioEventLoopGroup(sockets.size());
this.workerGroup = config.workersCount() <= 0 ? new NioEventLoopGroup() : new NioEventLoopGroup(config.workersCount());
this.configuration = config;
//循環所有的配置對象，然后分別創建 ServerBootstrap 對象并保存
for (Map.Entry entry : sockets) {
String name = entry.getKey();
SocketConfiguration soConfig = entry.getValue();
ServerBootstrap bootstrap = new ServerBootstrap();
JdkSslContext sslContext = null;
if (soConfig.ssl() != null) {
sslContext = new JdkSslContext(soConfig.ssl(), false, ClientAuth.NONE);
}
if (soConfig.backlog() > 0) {
bootstrap.option(ChannelOption.SO_BACKLOG, soConfig.backlog());
}
if (soConfig.timeoutMillis() > 0) {
bootstrap.option(ChannelOption.SO_TIMEOUT, soConfig.timeoutMillis());
}
if (soConfig.receiveBufferSize() > 0) {
bootstrap.option(ChannelOption.SO_RCVBUF, soConfig.receiveBufferSize());
}
//childHandler 是核心的業務 handler，使用者寫的業務邏輯也都在里面
HttpInitializer childHandler = new HttpInitializer(sslContext, namedRoutings.getOrDefault(name, routing), this);
//儲存 handler
initializers.add(childHandler);
//配置 Netty 的啟動器對象
bootstrap.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.handler(new LoggingHandler(LogLevel.DEBUG))
.childHandler(childHandler);
//儲存啟動器
bootstraps.put(name, bootstrap);
}
}
NettyWebServer 中的構造器代碼其實本質上就是半段 Netty 的啟動模板代碼。
主要是為了兼容多配置文件帶來的多啟動器需求，所以做了一個 for 循環。在多數時候其實就只有一個配置對象，也就只有一個啟動器。
而另外半段 Netty 模板代碼在 start(...) 方法中：
