Oracle发布开源的轻量级 Java 微服务框架 Helidon

分手后的思念是犯贱 2022-05-09 12:54 223阅读 0赞

近日，Oracle推出了一个新的开源框架Helidon，该项目是一个用于创建基于微服务的应用程序的Java库集合。和Payara Micro、Thorntail（之前的WildFly Swarm）、OpenLiberty、TomEE等项目一样，该项目也加入了MicroProfile家族。

Helidon最初被命名为J4C（Java for Cloud），其设计以简单、快速为目标，它包括两个版本：Helidon SE和Helidon MP。Helidon SE提供了创建微服务的三个核心API：Web服务器、配置和安全，用于构建基于微服务的应用程序，不需要应用服务器。Helidon MP支持用于构建基于微服务的应用程序的MicroProfile 1.1规范。

## Helidon的架构 ##

下面的架构图显示了Helidon SE和Helidon MP的关系。

![1.png][]

下图说明了Helidon SE和Helidon MP所属的微服务框架类别。

![2.png][]

## Web服务器 ##

受NodeJS和其他Java框架的启发，Helidon的Web服务器是一个异步、反应性API，运行在Netty之上。WebServer接口包括对配置、路由、错误处理以及构建度量和健康端点的支持。

## 快速入门示例 ##

Helidon提供了[快速入门示例][Link 1]来演示Helidon SE和Helidon MP之间的区别。

先借用官方示例，稍后我们手写一个示例。

在GitHub上可以找到整个官方Helidon项目。

[https://github.com/oracle/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>
    
    
    <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][http_localhost_8080_jersey_hello]

响应：

Hello World !

带参数访问

[http://localhost:8080/jersey/query?a=www.souyunku.com&b=www.ymq.io][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()

![3.png][]

官方文档：

[https://helidon.io/docs/latest][https_helidon.io_docs_latest]

Helidon 的 GitHub 项目地址：

[https://github.com/oracle/helidon][https_github.com_oracle_helidon]

**本文测试代码**

GitHub：  
[https://github.com/souyunku/DemoProjects/tree/master/helidon-examples][https_github.com_souyunku_DemoProjects_tree_master_helidon-examples]

[1.png]: http://www.ymq.io/images/2018/helidons/1.png
[2.png]: http://www.ymq.io/images/2018/helidons/2.png
[Link 1]: https://helidon.io/docs/latest/#/getting-started/02_base-example
[https_github.com_oracle_helidon]: https://github.com/oracle/helidon
[http_localhost_8080_jersey_hello]: http://localhost:8080/jersey/hello
[http_localhost_8080_jersey_query_a_www.souyunku.com_b_www.ymq.io]: http://localhost:8080/jersey/query?a=www.souyunku.com&b=www.ymq.io
[3.png]: http://www.ymq.io/images/2018/helidons/3.png
[https_helidon.io_docs_latest]: https://helidon.io/docs/latest/
[https_github.com_souyunku_DemoProjects_tree_master_helidon-examples]: https://github.com/souyunku/DemoProjects/tree/master/helidon-examples