当前位置:首页 > 科技  > 软件

Spring Boot虚拟线程的性能还不如Webflux?

来源: 责编: 时间:2024-01-10 17:24:55 478观看
导读早上看到一篇关于Spring Boot虚拟线程和Webflux性能对比的文章,觉得还不错。内容较长,抓重点给大家介绍一下这篇文章的核心内容,方便大家快速阅读。测试场景作者采用了一个尽可能贴近现实操作的场景:从授权头信息中提取JW

早上看到一篇关于Spring Boot虚拟线程和Webflux性能对比的文章,觉得还不错。内容较长,抓重点给大家介绍一下这篇文章的核心内容,方便大家快速阅读。sHb28资讯网——每日最新资讯28at.com

测试场景

作者采用了一个尽可能贴近现实操作的场景:sHb28资讯网——每日最新资讯28at.com

  1. 从授权头信息中提取JWT
  2. 验证JWT并从中提取用户的Email
  3. 使用用户的Email去MySQL里执行查询
  4. 返回用户记录

测试技术

这里要对比的两个核心技术点是:sHb28资讯网——每日最新资讯28at.com

  1. 带有虚拟线程的Spring Boot:这不是一个跑在传统物理线程上的Spring Boot应用,而是跑在虚拟线程上的。这些轻量级线程简化了开发、维护和调试高吞吐量并发应用程序的复杂任务。虽然虚拟线程仍然在底层操作系统线程上运行,但它们带来了显著的效率改进。当虚拟线程遇到阻塞 I/O 操作时,Java 运行时会暂时挂起它,从而释放关联的操作系统线程来为其他虚拟线程提供服务。这个优雅的解决方案优化了资源分配并增强了整体应用程序响应能力。
  2. Spring Boot Webflux:Spring Boot WebFlux是Spring生态系统中的反应式编程框架,它利用Project Reactor库来实现非阻塞、事件驱动的编程。所以,它特别适合需要高并发和低延迟的应用程序。依靠反应式方法,它允许开发人员有效地处理大量并发请求,同时仍然提供与各种数据源和通信协议集成的灵活性。

不论是Webflux还是虚拟线程,这两个都是为了提供程序的高并发能力而生,那么谁更胜一筹呢?下面一起看看具体的测试。sHb28资讯网——每日最新资讯28at.com

测试环境

运行环境与工具sHb28资讯网——每日最新资讯28at.com

  • 一台16G内存的MacBook Pro M1
  • Java 20
  • Spring Boot 3.1.3
  • 启用预览模式,以获得虚拟线程的强大能力
  • 依赖的第三方库:jjwt、mysql-connector-java
  • 测试工具:Bombardier
  • 数据库:MySQL

数据准备sHb28资讯网——每日最新资讯28at.com

  • 在Bombardier中准备100000个JWT列表,用来从中随机选取JWT,并将其放入HTTP请求的授权信息中。
  • 在MySQL中创建一个users表,表结构如下:
mysql> desc users;+--------+--------------+------+-----+---------+-------+| Field  | Type         | Null | Key | Default | Extra |+--------+--------------+------+-----+---------+-------+| email  | varchar(255) | NO   | PRI | NULL    |       || first  | varchar(255) | YES  |     | NULL    |       || last   | varchar(255) | YES  |     | NULL    |       || city   | varchar(255) | YES  |     | NULL    |       || county | varchar(255) | YES  |     | NULL    |       || age    | int          | YES  |     | NULL    |       |+--------+--------------+------+-----+---------+-------+6 rows in set (0.00 sec)
  • 为users表准备100000条用户数据

测试代码

带虚拟线程的Spring Boot程序

application.properties配置文件:sHb28资讯网——每日最新资讯28at.com

server.port=3000spring.datasource.url= jdbc:mysql://localhost:3306/testdb?useSSL=falsespring.datasource.username= testuserspring.datasource.password= testpwdspring.jpa.hibernate.ddl-auto= updatespring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver

User实体类(为了让文章让简洁一些,这里DD省略了getter和setter):sHb28资讯网——每日最新资讯28at.com

@Entity@Table(name = "users")public class User {  @Id  private String email;  private String first;  private String last;  private String city;  private String county;  private int age;}

应用主类:sHb28资讯网——每日最新资讯28at.com

@SpringBootApplicationpublic class UserApplication {    public static void main(String[] args) {        SpringApplication.run(UserApplication.class, args);    }    @Bean    public TomcatProtocolHandlerCustomizer<?> protocolHandlerVirtualThreadExecutorCustomizer() {        return protocolHandler -> {            protocolHandler.setExecutor(Executors.newVirtualThreadPerTaskExecutor());        };    }}

提供CRUD操作的UserRepository:sHb28资讯网——每日最新资讯28at.com

import org.springframework.data.repository.CrudRepository;import com.example.demo.User;public interface UserRepository extends CrudRepository<User, String> {}

提供API接口的UserController类:sHb28资讯网——每日最新资讯28at.com

@RestControllerpublic class UserController {    @Autowired    UserRepository userRepository;    private SignatureAlgorithm sa = SignatureAlgorithm.HS256;    private String jwtSecret = System.getenv("JWT_SECRET");    @GetMapping("/")    public User handleRequest(@RequestHeader(HttpHeaders.AUTHORIZATION) String authHdr) {        String jwtString = authHdr.replace("Bearer","");        Claims claims = Jwts.parser()            .setSigningKey(jwtSecret.getBytes())            .parseClaimsJws(jwtString).getBody();        Optional<User> user = userRepository.findById((String)claims.get("email"));        return user.get();    }}

Spring Boot Webflux程序

application.properties配置文件:sHb28资讯网——每日最新资讯28at.com

server.port=3000spring.r2dbc.url=r2dbc:mysql://localhost:3306/testdbspring.r2dbc.username=dbserspring.r2dbc.password=dbpwd

User实体(这里DD也省略了构造函数、getter和setter):sHb28资讯网——每日最新资讯28at.com

public class User {  @Id  private String email;  private String first;  private String last;  private String city;  private String county;  private int age;  // 省略了构造函数、getter、setter  }

应用主类:sHb28资讯网——每日最新资讯28at.com

@EnableWebFlux@SpringBootApplicationpublic class UserApplication {  public static void main(String[] args) {    SpringApplication.run(UserApplication.class, args);  }}

提供CRUD操作的UserRepository:sHb28资讯网——每日最新资讯28at.com

public interface UserRepository extends R2dbcRepository<User, String> {}

提供根据id查用户的业务类UserService:sHb28资讯网——每日最新资讯28at.com

@Servicepublic class UserService {  @Autowired  UserRepository userRepository;  public Mono<User> findById(String id) {    return userRepository.findById(id);  }}

提供API接口的UserController类:sHb28资讯网——每日最新资讯28at.com

@RestController@RequestMapping("/")public class UserController {  @Autowired  UserService userService;  private SignatureAlgorithm sa = SignatureAlgorithm.HS256;  private String jwtSecret = System.getenv("JWT_SECRET");  @GetMapping("/")  @ResponseStatus(HttpStatus.OK)  public Mono<User> getUserById(@RequestHeader(HttpHeaders.AUTHORIZATION) String authHdr) {    String jwtString = authHdr.replace("Bearer","");    Claims claims = Jwts.parser()        .setSigningKey(jwtSecret.getBytes())        .parseClaimsJws(jwtString).getBody();    return userService.findById((String)claims.get("email"));  }}

测试结果

接下来是重头戏了,作者对两个技术方案都做了500w个请求的测试,评估的不同并发连接级别包含:50、100、300。sHb28资讯网——每日最新资讯28at.com

具体结果如下三张图:sHb28资讯网——每日最新资讯28at.com

sHb28资讯网——每日最新资讯28at.com

50并发连接sHb28资讯网——每日最新资讯28at.com

sHb28资讯网——每日最新资讯28at.com

100并发连接sHb28资讯网——每日最新资讯28at.com

sHb28资讯网——每日最新资讯28at.com

300并发连接sHb28资讯网——每日最新资讯28at.com

最后,作者得出结论:Spring Boot Webflux要更优于带虚拟线程的Spring Boot。sHb28资讯网——每日最新资讯28at.com

sHb28资讯网——每日最新资讯28at.com

似乎引入了虚拟线程还不如已经在用的Webflux?不知道大家是否有做过相关调研呢?如果有的话,欢迎在留言区一起聊聊~我们创建了一个高质量的技术交流群,与优秀的人在一起,自己也会优秀起来,赶紧点击加群,享受一起成长的快乐。sHb28资讯网——每日最新资讯28at.com

本文链接:http://www.28at.com/showinfo-26-60396-0.htmlSpring Boot虚拟线程的性能还不如Webflux?

声明:本网页内容旨在传播知识,若有侵权等问题请及时与本网联系,我们将在第一时间删除处理。邮件:2376512515@qq.com

上一篇: C# 如何判断某个 TCP 端口是否被占用?

下一篇: Docker镜像与容器的交互及在容器内部执行代码的原理与实践

标签:
  • 热门焦点
  • 容量越大越不坏?24万块硬盘故障率报告公布 这些产品零故障

    8月5日消息,云存储服务商Backblaze发布了最新的硬盘故障率报告,年故障率有所上升。Backblaze发布的硬盘季度统计数据,其中包括故障率等重要方面。这些结
  • JavaScript 混淆及反混淆代码工具

    介绍在我们开始学习反混淆之前,我们首先要了解一下代码混淆。如果不了解代码是如何混淆的,我们可能无法成功对代码进行反混淆,尤其是使用自定义混淆器对其进行混淆时。什么是混
  • 共享单车的故事讲到哪了?

    来源丨海克财经与共享充电宝相差不多,共享单车已很久没有被国内热点新闻关照到了。除了一再涨价和用户直呼用不起了。近日多家媒体再发报道称,成都、天津、郑州等地多个共享单
  • 当家的盒马,加速谋生

    来源 | 价值星球Planet作者 | 归去来自己&ldquo;当家&rdquo;的盒马,开始加速谋生了。据盒马官微消息,盒马计划今年开放生鲜供应链,将其生鲜商品送往食堂。目前,盒马在上海已经与
  • iQOO Neo8 Pro抢先上架:首发天玑9200+ 安卓性能之王

    经过了一段时间的密集爆料,昨日iQOO官方如期对外宣布:将于5月23日推出全新的iQOO Neo8系列新品,官方称这是一款拥有旗舰级性能调校的作品。随着发布时
  • 回归OPPO两年,一加赢了销量,输了品牌

    成为OPPO旗下主打性能的先锋品牌后,一加屡创佳绩。今年618期间,一加手机全渠道销量同比增长362%,凭借一加 11、一加 Ace 2、一加 Ace 2V三款爆品,一加
  • 质感不错!OPPO K11渲染图曝光:旗舰IMX890传感器首次下放

    一直以来,OPPO K系列机型都保持着较为均衡的产品体验,历来都是2K价位的明星机型,去年推出的OPPO K10和OPPO K10 Pro两款机型凭借各自的出色配置,堪称有
  • 英特尔Xe-HP项目终止,将专注Xe-HPC/HPG系列显卡

    据10 月 31 日消息报道,英特尔高级副总裁兼加速计算系统和图形事业部总经理 表示,Xe-HP“ Arctic Sound” 系列服务器 GPU 已经应用于 oneAPI devcloud 云服
  • 电博会与软博会实现"线下+云端"的双线融合

    在本次“电博会”与“软博会”双展会利好条件的加持下,既可以发挥展会拉动人流、信息流、资金流实现快速交互流动的作用,继而推动区域经济良性发展;又可以聚
Top