資訊專欄INFORMATION COLUMN
摘要：零前期準(zhǔn)備版本版本核心依賴包支持包簡介是官方出品的微服務(wù)框架，底層基于驅(qū)動，大致的使用套路和相差不是很多筆者只是淺淺的了解過，可能存在理解不透的情況。一配置中的配置類有兩種，一種是用于讀取配置文件的，另一種是用于配置服務(wù)器對象的。
零 前期準(zhǔn)備 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 微服務(wù)框架，底層基于 Netty 驅(qū)動，大致的使用套路和 Vertx 相差不是很多(筆者只是淺淺的了解過 Vertx，可能存在理解不透的情況)。在 2019 年的年初，Helidon 迎來了 1.0.0 的版本更新，api 開始趨于穩(wěn)定。
就目前的版本來看，Oracle 應(yīng)該希望 Helidon 是一個小而美的輕巧型 java 框架，所以對其的封裝非常之薄，僅僅是對 Netty 做了一層定制化的處理，同時也深度整合了 jdk 的相關(guān)接口(畢竟是自家的東西，駕馭能力不一般)。就連 json 的處理都引用了 javax 中的 joup 去做，而不是使用第三方工具包。
Helidon 目前的網(wǎng)絡(luò)資料很少，所以本文主要通過其官方文檔進(jìn)行 Demo 的構(gòu)筑。
一 配置Helidon 中的配置類有兩種，一種是用于讀取配置文件的 Config，另一種是用于配置服務(wù)器對象的 ServerConfiguration。
先來看 Config：
//配置文件
Config conf = Config
//builder
.builder()
//載入配置文件，可以一次載入多張
.sources(
//根據(jù)絕對路徑去載入配置文件
ConfigSources.file("D://application.yaml"),
//到 resource 文件夾下去尋找
ConfigSources.classpath("application2.yaml")
)
//創(chuàng)建完成
.build();
再來看 ServerConfiguration：
//創(chuàng)建一個配置對象，用于注入一些配置信息
ServerConfiguration config = ServerConfiguration
//生成 builder
.builder()
//address
//getLoopbackAddress() 會獲取到 localhost
.bindAddress(InetAddress.getLoopbackAddress())
//getLocalHost() 會獲取到本機的 ip
//.bindAddress(InetAddress.getLocalHost())
//端口
.port(8080)
//工作線程的線程數(shù)
.workersCount(10)
//增加一個 ServerConfiguration 對象
//.addSocket("serverConfiguration",ServerConfiguration.builder().build())
//載入配置文件
//.config(conf)
//創(chuàng)建完成
.build();
二 路由
網(wǎng)絡(luò)博文最簡單的 Hello World 的路由對象：
//創(chuàng)建最簡單的路由邏輯
Routing rt = Routing
//builder
.builder()
//設(shè)置路由的請求方法和業(yè)務(wù)邏輯
//設(shè)置多種請求方法
.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"))
//創(chuàng)建完成
.build();
結(jié)合業(yè)務(wù)邏輯的路由對象：
//創(chuàng)建路由對象
Routing routing = Routing
//builder
.builder()
//注冊 json 解析器
.register(JsonSupport.create())
//添加 url 路由，一個路由對象可以添加多個
//可以添加業(yè)務(wù)邏輯的 service 類
.post("/hello", Handler.create(JsonObject.class,new HelloService()))
//hello world
.get("/hello1",(req, res) -> res.send("hello world"))
//創(chuàng)建完成
.build();
HelloService 中處理具體的業(yè)務(wù)邏輯：
//HelloService 必須實現(xiàn) Handler.EntityHandler
class HelloService implements Handler.EntityHandler{
//json 的解析門面對象
private static final JsonBuilderFactory jsonFactory = Json.createBuilderFactory(Collections.emptyMap());
//核心業(yè)務(wù)類，里面可以寫具體的業(yè)務(wù)邏輯，最后 send(...) 進(jìn) response 里就可以了
@Override
public void accept(ServerRequest req, ServerResponse res, Object entity) {
//entity 本質(zhì)上就是 JsonObject
JsonObject reqJson = (JsonObject)entity;
//獲取鍵值對并打印，這個操作和 Fastjson 很類似
String ret = reqJson.getString("hello");
System.out.println(ret);
//創(chuàng)建要返回的 json object
JsonObject msg = jsonFactory
//builder
.createObjectBuilder()
//添加一組 json 的 key - value 鍵值對
.add("message", "Hello")
//創(chuàng)建 json 對象完成
.build();
//json array 的創(chuàng)建方式
//JsonArray array = jsonFactory.createArrayBuilder().build();
//返回
res.send(msg);
}
}
三 服務(wù)器對象
服務(wù)器對象：
//啟動服務(wù)器
WebServer
//創(chuàng)建服務(wù)器對象
//具體依賴 ServerConfiguration 和 Routing 對象
.create(config,routing)
//開啟服務(wù)器
.start()
//獲取 future
.toCompletableFuture()
//設(shè)置超時時間為 10 秒
.get(10, TimeUnit.SECONDS);
四 服務(wù)實現(xiàn)
先來看 WebServer 的 create(...) 方法：
//step 1
//WebServer.class
static WebServer create(ServerConfiguration configuration, Routing routing) {
//有效性驗證
Objects.requireNonNull(routing, "Parameter "routing" is null!");
//builder(...) 方法會創(chuàng)建一個 WebServer.Builder 對象，最終在 build() 方法里創(chuàng)建 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 接口的實現(xiàn)類
//defaultRouting 是上方 create(...) 方法存入的路由對象
WebServer result = new NettyWebServer(configuration == null
? ServerBasicConfig.DEFAULT_CONFIGURATION
: configuration,
defaultRouting, routings);
//默認(rèn)的路由對象即為 RequestRouting 類型
//此處給路由對象添加回調(diào)方法
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();
//創(chuàng)建兩個線程
this.bossGroup = new NioEventLoopGroup(sockets.size());
this.workerGroup = config.workersCount() <= 0 ? new NioEventLoopGroup() : new NioEventLoopGroup(config.workersCount());
this.configuration = config;
//循環(huán)所有的配置對象，然后分別創(chuàng)建 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 是核心的業(yè)務(wù) handler，使用者寫的業(yè)務(wù)邏輯也都在里面
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 中的構(gòu)造器代碼其實本質(zhì)上就是半段 Netty 的啟動模板代碼。
主要是為了兼容多配置文件帶來的多啟動器需求，所以做了一個 for 循環(huán)。在多數(shù)時候其實就只有一個配置對象，也就只有一個啟動器。
而另外半段 Netty 模板代碼在 start(...) 方法中：
