Oracle發佈開源的輕量級 Java 微服務框架 Helidon

時間 2019-12-04

標籤 oracle 發佈開源輕量級 java 微服框架 helidon 欄目 Oracle 简体版

原文原文鏈接

近日，Oracle推出了一個新的開源框架Helidon，該項目是一個用於建立基於微服務的應用程序的Java庫集合。和Payara Micro、Thorntail（以前的WildFly Swarm）、OpenLiberty、TomEE等項目同樣，該項目也加入了MicroProfile家族。java

Helidon最初被命名爲J4C（Java for Cloud），其設計以簡單、快速爲目標，它包括兩個版本：Helidon SE和Helidon MP。Helidon SE提供了建立微服務的三個核心API：Web服務器、配置和安全，用於構建基於微服務的應用程序，不須要應用服務器。Helidon MP支持用於構建基於微服務的應用程序的MicroProfile 1.1規範。git

Helidon的架構

下面的架構圖顯示了Helidon SE和Helidon MP的關係。github

下圖說明了Helidon SE和Helidon MP所屬的微服務框架類別。web

Web服務器

受NodeJS和其餘Java框架的啓發，Helidon的Web服務器是一個異步、反應性API，運行在Netty之上。WebServer接口包括對配置、路由、錯誤處理以及構建度量和健康端點的支持。docker

快速入門示例

Helidon提供了快速入門示例來演示Helidon SE和Helidon MP之間的區別。瀏覽器

先借用官方示例，稍後咱們手寫一個示例。安全

在GitHub上能夠找到整個官方Helidon項目。服務器

https://github.com/oracle/helidon架構

構建Docker鏡像

Helidon SE示例併發

docker build -t quickstart-se target

Helidon MP示例

docker build -t quickstart-mp target

運行Docker鏡像

Helidon SE示例

docker run --rm -p 8080:8080 quickstart-se:latest

Helidon MP示例

docker run --rm -p 8080:8080 quickstart-mp:latest

測試

這兩個示例都支持相同的REST接口

該示例是一個很是簡單的「Hello World」問候語服務。響應使用JSON編碼。例如：

curl -X GET http://localhost:8080/greet
{"message":"Hello World!"}

curl -X GET http://localhost:8080/greet/Joe
{"message":"Hello Joe!"}

curl -X PUT http://localhost:8080/greet/greeting/Hola
{"greeting":"Hola"}

curl -X GET http://localhost:8080/greet/Jose
{"message":"Hola Jose!"}

動手寫一個示例

環境

Helidon須要Java 8（或更高版本）和Maven。若是要構建和部署Docker容器，則須要Docker。若是要部署到Kubernetes，則須要kubectl和Kubernetes集羣

如下列表顯示了最低版本

Maven座標

將如下代碼段添加到pom.xml文件中

<dependency>
    <groupId>io.helidon.webserver</groupId>
    <artifactId>helidon-webserver</artifactId>
    <version>0.10.1</version>
</dependency>

<dependency>
    <groupId>io.helidon.webserver</groupId>
    <artifactId>helidon-webserver-netty</artifactId>
    <version>0.10.1</version>
</dependency>

<!--  WebServer Jersey依賴-->
<dependency>
    <groupId>io.helidon.webserver</groupId>
    <artifactId>helidon-webserver-jersey</artifactId>
    <version>0.10.1</version>
</dependency>

測試方法

package com.souyunku.helidon.webserver.examples.jersey;

import io.helidon.webserver.ServerRequest;
import io.helidon.webserver.ServerResponse;
import io.helidon.webserver.jersey.JerseySupport;
import io.opentracing.SpanContext;

import javax.inject.Inject;
import javax.inject.Named;
import javax.ws.rs.*;
import javax.ws.rs.core.Context;
import javax.ws.rs.core.HttpHeaders;
import javax.ws.rs.core.Response;
import javax.ws.rs.core.UriInfo;
import java.util.stream.Collectors;

@Path("/")
public class HelloWorld {

    @Inject
    private ServerRequest request;

    @Inject
    private ServerResponse response;


    @Inject
    @Named(JerseySupport.REQUEST_SPAN_CONTEXT)
    private SpanContext spanContext;


    @GET
    @Path("hello")
    public Response hello() {
        return Response.ok("Hello World !").build();
    }


    @POST
    @Path("hello")
    public Response hello(String content) {
        return Response.accepted("Hello: " + content + "!").build();
    }

    @POST
    @Path("content")
    public Response content(String content) {
        return Response.accepted(content).build();
    }

    @GET
    @Path("injection")
    public Response webServerInjection() {
        return Response.ok("request=" + request.getClass().getName()
                + "\nresponse=" + response.getClass().getName()
                + "\nspanContext=" + spanContext.getClass().getName()).build();
    }

    @GET
    @Path("headers")
    public Response headers(@Context HttpHeaders headers, @QueryParam("header") String header) {
        return Response.ok("headers=" + headers.getRequestHeader(header).stream().collect(Collectors.joining(",")))
                .build();
    }

    @GET
    @Path("query")
    public Response query(@QueryParam("a") String a, @QueryParam("b") String b) {
        return Response.accepted("a='" + a + "';b='" + b + "'").build();
    }

    @GET
    @Path("path/{num}")
    public Response path(@PathParam("num") String num) {
        return Response.accepted("num=" + num).build();
    }

    @GET
    @Path("requestUri")
    public String getRequestUri(@Context UriInfo uriInfo) {
        return uriInfo.getRequestUri().getPath();
    }
}

啓動服務

package com.souyunku.helidon.webserver.examples.jersey;

import io.helidon.webserver.Routing;
import io.helidon.webserver.ServerConfiguration;
import io.helidon.webserver.WebServer;
import io.helidon.webserver.jersey.JerseySupport;
import org.glassfish.jersey.server.ResourceConfig;

import java.io.IOException;
import java.util.concurrent.CompletionStage;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeoutException;
import java.util.logging.LogManager;

/**
 * WebServer Jersey
 */
public final class WebServerJerseyMain {

    private WebServerJerseyMain() {
    }

    /**
     * 運行Jersey WebServer示例。
     *
     * @param args
     * @throws IOException
     */
    public static void main(String[] args) throws IOException, InterruptedException, ExecutionException, TimeoutException {
        // 配置日誌記錄，以免標準的JVM默認設置
        LogManager.getLogManager().readConfiguration(WebServerJerseyMain.class.getResourceAsStream("/logging.properties"));

        // 最簡單方法啓動在8080端口
        startServer(ServerConfiguration.builder()
                .port(8080)
                .build());

    }

    static CompletionStage<WebServer> startServer(ServerConfiguration serverConfiguration) {

        WebServer webServer = WebServer.create(
                serverConfiguration,
                Routing.builder()
                        //在/jersey上下文根目錄註冊Jersey應用程序
                        .register("/jersey",
                                JerseySupport.create(new ResourceConfig(HelloWorld.class)))
                        .build());

        return webServer.start()
                .whenComplete((server, t) -> {
                    System.out.println("Jersey WebServer started.");
                    System.out.println("Try the hello world resource at: http://localhost:" + server.port() + "/jersey/hello");
                });
        // http://localhost:8080/jersey/hello
    }
}

響應：

Jersey WebServer started.
Try the hello world resource at: http://localhost:8080/jersey/hello

測試

瀏覽器訪問

http://localhost:8080/jersey/hello

響應：

Hello World !

帶參數訪問

http://localhost:8080/jersey/query?a=www.souyunku.com&b=www.ymq.io

響應：

a='www.souyunku.com';b='www.ymq.io'

更多就不演示了

調用鏈監控 Zipkin

WebServer包括Zipkin對OpenTracing的支持。啓用後，WebServer會將其跟蹤事件發送到Zipkin。

Maven座標

WebServer Zipkin支持依賴

<dependency>
    <groupId>io.helidon.webserver</groupId>
    <artifactId>helidon-webserver-zipkin</artifactId>
</dependency>

配置跟蹤支持

要啓用Zipkin集成，請Tracer在上配置ServerConfiguration.Builder。

zipkin是一個開放源代碼分佈式的跟蹤系統，由Twitter公司開源，它致力於收集服務的定時數據，以解決微服務架構中的延遲問題，包括數據的收集、存儲、查找和展示。它的理論模型來自於Google Dapper 論文。

配置OpenTracing Tracer

ServerConfiguration.builder()
                   .tracer(new ZipkinTracerBuilder.forService("my-application") 
                                 .zipkin("http://10.0.0.18:9411")  
                                 .build())
                   .build()

官方文檔：

https://helidon.io/docs/latest

Helidon 的 GitHub 項目地址：

https://github.com/oracle/helidon

本文測試代碼

GitHub： https://github.com/souyunku/DemoProjects/tree/master/helidon-examples