本站首页 收藏本站
广告位联系

APP正在开发中...
返回顶部
您的位置： 主页 > 服务器 > Tomcat >

收藏
分享到

在Tomcat中启用虚拟线程特性的介绍

Tomcat 来源：互联网 作者：佚名 发布时间：2022-10-10 21:01:10 人浏览
摘要

前提 趁着国庆前后阅读了虚拟线程相关的源码，写了一篇《虚拟线程 - VirtualThread源码透视》，里面介绍了虚拟线程的实现原理和使用示例。需要准备做一下前期准备： 安装OpenJDK-19或者

前提

趁着国庆前后阅读了虚拟线程相关的源码，写了一篇《虚拟线程 - VirtualThread源码透视》，里面介绍了虚拟线程的实现原理和使用示例。需要准备做一下前期准备：

  • 安装OpenJDK-19或者Oracle JDK-19
  • 准备好嵌入式Tomcat的依赖，需要引入三个依赖包，分别是tomcat-embed-core、tomcat-embed-el和tomcat-embed-websocket，版本选用10.1.0+

查看Tomcat官方文档的CHANGELOG：

支持Loom项目的Tomcat最低版本为10.1.0-M16，对应的正式版是10.1.0（当前时间为2022-10-07前后），低于此版本因为大量API还没有适配虚拟线程，主要是没有改造监视器锁的引用导致虚拟线程pin到载体（平台）线程等问题，因此别无他选。另外，重要的提醒说三次：

  • 本文是实验性质，在未完全证实改造功能可以应用生产环境前需要谨慎评估，或者先别使用于生产环境
  • 本文是实验性质，在未完全证实改造功能可以应用生产环境前需要谨慎评估，或者先别使用于生产环境
  • 本文是实验性质，在未完全证实改造功能可以应用生产环境前需要谨慎评估，或者先别使用于生产环境

引入依赖

引入以下依赖：

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

<dependency>

    <groupId>org.apache.tomcat.embed</groupId>

    <artifactId>tomcat-embed-core</artifactId>

    <version>10.1.0</version>

</dependency>

<dependency>

    <groupId>org.apache.tomcat.embed</groupId>

    <artifactId>tomcat-embed-el</artifactId>

    <version>10.1.0</version>

</dependency>

<dependency>

    <groupId>org.apache.tomcat.embed</groupId>

    <artifactId>tomcat-embed-websocket</artifactId>

    <version>10.1.0</version>

</dependency>

编程式初始化Tomcat

为了使用反射调用一些java.base模块下没开放的依赖包和跟踪虚拟线程栈，程序运行时候加入下面的VM参数：

1

--add-opens java.base/java.lang=ALL-UNNAMED --add-opens java.base/java.lang.reflect=ALL-UNNAMED --add-opens java.base/java.util.concurrent=ALL-UNNAMED -Djdk.tracePinnedThreads=full

在IDEA的运行配置中是这个样子：

接着编写一个HttpServlet实现：

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

public class VirtualThreadHandleServlet extends HttpServlet {

 

    private static final DateTimeFormatter FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss.SSS");

 

    @Override

    protected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {

        Thread thread = Thread.currentThread();

        System.out.printf("service by thread ==> %s, is virtual ==> %s, carrier thread ==> %s\n",

                thread.getName(), thread.isVirtual(), getCurrentCarrierThreadName(thread));

        resp.setStatus(HttpServletResponse.SC_OK);

        resp.setHeader("Content-Type", "application/json");

        String content = "{\"time\":" + "\"" + LocalDateTime.now().format(FORMATTER) + "\"}";

        resp.getWriter().write(content);

    }

 

    private static String getCurrentCarrierThreadName(Thread currentThread) {

        if (currentThread.isVirtual()) {

            try {

                MethodHandle methodHandle = MethodHandles.privateLookupIn(Thread.class, MethodHandles.lookup())

                        .findStatic(Thread.class, "currentCarrierThread", MethodType.methodType(Thread.class));

                Thread carrierThread = (Thread) methodHandle.invoke();

                return carrierThread.getName();

            } catch (Throwable e) {

                e.printStackTrace();

            }

        }

        return "UNKNOWN";

    }

}

该Servlet实现比较简单，就是在控制台打印一些虚拟线程和载体线程的一些信息，然后返回HTTP状态码为200和一个JSON字符展示当前精确到毫秒的时间。接着编写一个main方法初始化Tomcat：

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

34

35

36

37

38

39

public class EmbedTomcatVirtualThreadDemo {

 

    private static final String SERVLET_NAME = "VirtualThreadHandleServlet";

 

    private static final String SERVLET_PATH = "/*";

 

    /**

     * 设置VM参数:

     * --add-opens java.base/java.lang=ALL-UNNAMED

     * --add-opens java.base/java.lang.reflect=ALL-UNNAMED

     * --add-opens java.base/java.util.concurrent=ALL-UNNAMED

     * -Djdk.tracePinnedThreads=full

     *

     * @param args args

     * @throws Exception e

     */

    public static void main(String[] args) throws Throwable {

        String pinMode = System.getProperty("jdk.tracePinnedThreads");

        System.out.println("pin mode = " + pinMode);

        Tomcat tomcat = new Tomcat();

        Context context = tomcat.addContext("", (new File(".")).getAbsolutePath());

        Tomcat.addServlet(context, SERVLET_NAME, new VirtualThreadHandleServlet());

        context.addServletMappingDecoded(SERVLET_PATH, SERVLET_NAME);

        Connector connector = new Connector();

        ProtocolHandler protocolHandler = connector.getProtocolHandler();

        if (protocolHandler instanceof AbstractProtocol<?> protocol) {

            protocol.setAddress(InetAddress.getByName("127.0.0.1"));

            protocol.setPort(9091);

            ThreadFactory factory = Thread.ofVirtual().name("embed-tomcat-virtualWorker-", 0).factory();

            Class<?> klass = Class.forName("java.util.concurrent.ThreadPerTaskExecutor");

            MethodHandle methodHandle = MethodHandles.privateLookupIn(klass, MethodHandles.lookup())

                    .findStatic(klass, "create", MethodType.methodType(klass, new Class[]{ThreadFactory.class}));

            ExecutorService executor = (ExecutorService) methodHandle.invoke(factory);

            protocol.setExecutor(executor);

        }

        tomcat.getService().addConnector(connector);

        tomcat.start();

    }

}

这里VirtualThreadHandleServlet匹配所有格式的请求路径并且处理所有请求方法类型的请求。默认的虚拟线程调度器没有为虚拟线程设置名称，也就是如果使用Executors.newVirtualThreadPerTaskExecutor()作为Tomcat的线程池是最终调用看到的控制台输出的虚拟线程名称是一个空字符串。所以笔者这里用MethodHandle直接实例化了默认修饰符没有开放访问权限的ThreadPerTaskExecutor类，基于一个自定义的ThreadFactory强制构造了一个自定义ThreadPerTaskExecutor实例。调用main方法启动后见控制台输出：

这里确认了Tomcat启动完成侦听127.0.0.1:9091，通过浏览器或者POSTMAN发送任意请求例如http://127.0.0.1:9091/foo就能看到响应结果和控制台输出：

这里的Tomcat线程池甚至可以设计为一个完全自定义的虚拟线程调度器，可以参考前面一篇文章，这里不再赘述。

暂时无法在SpringBoot体系中使用

由于Servlet规范问题，Tomcat的升级导致一些接口迁移到jakarta.servlet包中，例如jakarta.servlet.Servlet，此时SpringBoot体系即使是最新版本（当前时间为2022-10-07前后，此时最新版本为2.7.4）使用的是还是旧的规范，对应的类是javax.servlet.Servlet，这只是其中一个接口，大部分和HTTP协议或者Servlet规范相关的接口都存在这个包升级不兼容的问题，需要等待SpringBoot升级为embed-tomcat-*-10.1.0+才能适配虚拟线程。

小结

Demo项目仓库：

Github：https://github.com/zjcscut/framework-mesh/tree/master/tomcat-virtual-thread
版权声明 : 本文内容来源于互联网或用户自行发布贡献，该文观点仅代表原作者本人。本站仅提供信息存储空间服务和不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权， 违法违规的内容， 请发送邮件至2530232025#qq.cn(#换@)举报，一经查实，本站将立刻删除。

您可能感兴趣的文章 :

原文链接 : https://www.cnblogs.com/throwable/p/16767573.html
相关文章

  • IDEA中的Tomcat中文乱码问题

    IDEA中的Tomcat中文乱码问题
    写在前面：此方法亲测有效！！！ 1、IDEA 2、VM options 加上这两行： 1 2 -Dfile.encoding=UTF-8 -Dconsole.encoding=UTF-8 3、IDEA启动程序的存放目录 找到这

  • 在Tomcat中启用虚拟线程特性的介绍

    在Tomcat中启用虚拟线程特性的介绍
    前提 趁着国庆前后阅读了虚拟线程相关的源码，写了一篇《虚拟线程 - VirtualThread源码透视》，里面介绍了虚拟线程的实现原理和使用示例。
  • 删除Tomcat webapps目录自带项目方式介绍
    1.webapps目录中的项目 本文将 %CATALINA_HOME% 目录称为tomcat目录。 在 Tomcat 8.0 的 tomcat/webapps 目录中，含有 5 个 Tomcat 自带的 Web 项目，如下所示
  • tomcat的webapps目录下的应用删除部署介绍
    1.tomcat9的webapps下应用的访问 tomcat9的server.xml文件中 Host下需要加一段： 1 Context docBase=/xxx/tomcat9/webapps/xxx path=/ reloadable=true/Context 改完后大致

  • 关于Tomcat虚拟路径访问本地图片失败的问题

    关于Tomcat虚拟路径访问本地图片失败的问题
    开发过程中，把图片放在本地一个磁盘的路径下。网上搜了下，可以使用tomcat虚拟路径访问本地图片。 这样就不用把图片放在整个项目的

  • tomcat8中startup可以启动tomcat8w无法启动的问题分析

    tomcat8中startup可以启动tomcat8w无法启动的问题分析
    今天，更改了一下tomcat的端口，将8080改为8090 结果在tomcat8/bin下电极startup可以启动tomcat，http://localhost:8090/可以打开 但是不用startup，而是点

  • Tomcat Catalina为什么不new出来原理解析

    Tomcat Catalina为什么不new出来原理解析
    一、Catalina为什么不new出来? 掌握了Java的类加载器和双亲委派机制，现在我们就可以回答正题上来了，Tomcat的类加载器是怎么设计的？ 1.We

  • Tomcat启动核心流程介绍

    Tomcat启动核心流程介绍
    一、Tomcat的启动核心流程 前面给大家介绍了Tomcat中的生命周期的设计，掌握了这块对于我们分析Tomcat的核心流程是非常有帮助的，也就是我

  • Tomcat生命周期的介绍

    Tomcat生命周期的介绍
    在上篇文章中我们看到了Tomcat架构中的核心组件，而且各个组件都有各自的作用，各司其职，而且相互之间也有对应的父子关系，那么这些

  • Tomcat架构设计及Servlet作用规范介绍

    Tomcat架构设计及Servlet作用规范介绍
    1.Servlet规范 1.1 Servlet作用讲解 Servlet是JavaEE规范中的一种，主要是为了扩展Java作为Web服务的功能，统一定义了对应的接口，比如Servlet接口，
推荐阅读
最新更新
友情链接
  • 本站所有内容来源于互联网或用户自行发布，本站仅提供信息存储空间服务，不拥有版权，不承担法律责任。如有侵犯您的权益，请您联系站长处理！
  • Copyright © 2017-2022 F11.CN All Rights Reserved. F11站长开发者网 版权所有 | 苏ICP备2022031554号-1 | 51LA统计