Oracle推出开源轻量级 Java 微服务框架 Helidon

From 鹏磊搜云库技术团队 2019-04-07

搜云库互联网/架构/开发/运维

近日，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的关系。

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

Web服务器

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

快速入门示例

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>

<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
}
}