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

摘要：近日，推出了一个新的开源框架，该项目是一个用于创建基于微服务的应用程序的库集合。下图说明了和所属的微服务框架类别。启用后，会将其跟踪事件发送到。

近日，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 SE和Helidon MP的关系。

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

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

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

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

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

https://github.com/oracle/helidon

Helidon SE示例

docker build -t quickstart-se target

Helidon MP示例

docker build -t quickstart-mp target

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集群

以下列表显示了最低版本

| Java SE 8或Open JDK 8 |
| Maven 3.5 |
| Docker 18.02 | 使用Edge通道在桌面上运行Kubernetes |
| Kubectl 1.7.4 |

将以下代码段添加到pom.xml文件中

    io.helidon.webserver
    helidon-webserver
    0.10.1



    io.helidon.webserver
    helidon-webserver-netty
    0.10.1




    io.helidon.webserver
    helidon-webserver-jersey
    0.10.1

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()
                + "
response=" + response.getClass().getName()
                + "
spanContext=" + 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 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"

更多就不演示了

WebServer包括Zipkin对OpenTracing的支持。启用后，WebServer会将其跟踪事件发送到Zipkin。

WebServer Zipkin支持依赖

    io.helidon.webserver
    helidon-webserver-zipkin

要启用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

如何找到完美的以太坊区块链开发者

大数据推荐系统实时架构和离线架构

ElasticSearch优化会员列表搜索

Rabbitmq延迟队列实现定时任务

软件做异常测试？必知的22个测试点总结！

Java SQL注入危害这么大，该如何来防止呢?

还没用上 JDK 11吧，JDK 12 早期访问构建版使用

Dubbo 整合 Pinpoint 做分布式服务请求跟踪

Java并发：分布式应用限流实践

作者：鹏磊

出处：http://www.ymq.io/2018/10/15/Helidon

版权归作者所有，转载请注明出处

Wechat：关注公众号，搜云库，专注于开发技术的研究与知识分享