查看原文
其他

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

鹏磊 搜云库技术团队 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示例

  1. docker build -t quickstart-se target

Helidon MP示例

  1. docker build -t quickstart-mp target

运行Docker镜像

Helidon SE示例

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

Helidon MP示例

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

测试

这两个示例都支持相同的REST接口

该示例是一个非常简单的“Hello World”问候语服务。响应使用JSON编码。例如:

  1. curl -X GET http://localhost:8080/greet

  2. {"message":"Hello World!"}

  3. curl -X GET http://localhost:8080/greet/Joe

  4. {"message":"Hello Joe!"}

  5. curl -X PUT http://localhost:8080/greet/greeting/Hola

  6. {"greeting":"Hola"}

  7. curl -X GET http://localhost:8080/greet/Jose

  8. {"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 |

Maven坐标

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

  1. <dependency>

  2.    <groupId>io.helidon.webserver</groupId>

  3.    <artifactId>helidon-webserver</artifactId>

  4.    <version>0.10.1</version>

  5. </dependency>

  6. <dependency>

  7.    <groupId>io.helidon.webserver</groupId>

  8.    <artifactId>helidon-webserver-netty</artifactId>

  9.    <version>0.10.1</version>

  10. </dependency>

  11. <!--  WebServer Jersey依赖-->

  12. <dependency>

  13.    <groupId>io.helidon.webserver</groupId>

  14.    <artifactId>helidon-webserver-jersey</artifactId>

  15.    <version>0.10.1</version>

  16. </dependency>


测试方法

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

  2. import io.helidon.webserver.ServerRequest;

  3. import io.helidon.webserver.ServerResponse;

  4. import io.helidon.webserver.jersey.JerseySupport;

  5. import io.opentracing.SpanContext;

  6. import javax.inject.Inject;

  7. import javax.inject.Named;

  8. import javax.ws.rs.*;

  9. import javax.ws.rs.core.Context;

  10. import javax.ws.rs.core.HttpHeaders;

  11. import javax.ws.rs.core.Response;

  12. import javax.ws.rs.core.UriInfo;

  13. import java.util.stream.Collectors;

  14. @Path("/")

  15. public class HelloWorld {

  16.    @Inject

  17.    private ServerRequest request;

  18.    @Inject

  19.    private ServerResponse response;

  20.    @Inject

  21.    @Named(JerseySupport.REQUEST_SPAN_CONTEXT)

  22.    private SpanContext spanContext;

  23.    @GET

  24.    @Path("hello")

  25.    public Response hello() {

  26.        return Response.ok("Hello World !").build();

  27.    }

  28.    @POST

  29.    @Path("hello")

  30.    public Response hello(String content) {

  31.        return Response.accepted("Hello: " + content + "!").build();

  32.    }

  33.    @POST

  34.    @Path("content")

  35.    public Response content(String content) {

  36.        return Response.accepted(content).build();

  37.    }

  38.    @GET

  39.    @Path("injection")

  40.    public Response webServerInjection() {

  41.        return Response.ok("request=" + request.getClass().getName()

  42.                + "\nresponse=" + response.getClass().getName()

  43.                + "\nspanContext=" + spanContext.getClass().getName()).build();

  44.    }

  45.    @GET

  46.    @Path("headers")

  47.    public Response headers(@Context HttpHeaders headers, @QueryParam("header") String header) {

  48.        return Response.ok("headers=" + headers.getRequestHeader(header).stream().collect(Collectors.joining(",")))

  49.                .build();

  50.    }

  51.    @GET

  52.    @Path("query")

  53.    public Response query(@QueryParam("a") String a, @QueryParam("b") String b) {

  54.        return Response.accepted("a='" + a + "';b='" + b + "'").build();

  55.    }

  56.    @GET

  57.    @Path("path/{num}")

  58.    public Response path(@PathParam("num") String num) {

  59.        return Response.accepted("num=" + num).build();

  60.    }

  61.    @GET

  62.    @Path("requestUri")

  63.    public String getRequestUri(@Context UriInfo uriInfo) {

  64.        return uriInfo.getRequestUri().getPath();

  65.    }

  66. }


启动服务

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

  2. import io.helidon.webserver.Routing;

  3. import io.helidon.webserver.ServerConfiguration;

  4. import io.helidon.webserver.WebServer;

  5. import io.helidon.webserver.jersey.JerseySupport;

  6. import org.glassfish.jersey.server.ResourceConfig;

  7. import java.io.IOException;

  8. import java.util.concurrent.CompletionStage;

  9. import java.util.concurrent.ExecutionException;

  10. import java.util.concurrent.TimeoutException;

  11. import java.util.logging.LogManager;

  12. /**

  13. * WebServer Jersey

  14. */

  15. public final class WebServerJerseyMain {

  16.    private WebServerJerseyMain() {

  17.    }

  18.    /**

  19.     * 运行Jersey WebServer示例。

  20.     *

  21.     * @param args

  22.     * @throws IOException

  23.     */

  24.    public static void main(String[] args) throws IOException, InterruptedException, ExecutionException, TimeoutException {

  25.        // 配置日志记录,以避免标准的JVM默认设置

  26.        LogManager.getLogManager().readConfiguration(WebServerJerseyMain.class.getResourceAsStream("/logging.properties"));

  27.        // 最简单方法启动在8080端口

  28.        startServer(ServerConfiguration.builder()

  29.                .port(8080)

  30.                .build());

  31.    }

  32.    static CompletionStage<WebServer> startServer(ServerConfiguration serverConfiguration) {

  33.        WebServer webServer = WebServer.create(

  34.                serverConfiguration,

  35.                Routing.builder()

  36.                        //在/jersey上下文根目录注册Jersey应用程序

  37.                        .register("/jersey",

  38.                                JerseySupport.create(new ResourceConfig(HelloWorld.class)))

  39.                        .build());

  40.        return webServer.start()

  41.                .whenComplete((server, t) -> {

  42.                    System.out.println("Jersey WebServer started.");

  43.                    System.out.println("Try the hello world resource at: http://localhost:" + server.port() + "/jersey/hello");

  44.                });

  45.        // http://localhost:8080/jersey/hello

  46.    }

  47. }

响应:

  1. Jersey WebServer started.

  2. 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支持依赖

  1. <dependency>

  2.    <groupId>io.helidon.webserver</groupId>

  3.    <artifactId>helidon-webserver-zipkin</artifactId>

  4. </dependency>


配置跟踪支持

要启用Zipkin集成,请Tracer在上 配置ServerConfiguration.Builder。

zipkin是一个开放源代码分布式的跟踪系统,由Twitter公司开源,它致力于收集服务的定时数据,以解决微服务架构中的延迟问题,包括数据的收集、存储、查找和展现。它的理论模型来自于Google Dapper 论文。

配置OpenTracing Tracer

  1. ServerConfiguration.builder()

  2.                   .tracer(new ZipkinTracerBuilder.forService("my-application")

  3.                                 .zipkin("http://10.0.0.18:9411")  

  4.                                 .build())

  5.                   .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并发:分布式应用限流实践

长按:二维码关注

专注于开发技术研究与知识分享

公众号回复:”进群” 加微信群深入交流

回复 JavaDocker等关键字可获得学习资料

    您可能也对以下帖子感兴趣

    文章有问题?点此查看未经处理的缓存