建立个人博客网站的流程,大型网站建设招商,二级网站免费建,免费网站建站申请我们看一下如何在spring-boot中利用loom虚拟线程。
我们将做一些负载测试#xff0c;看看虚拟线程和普通线程的响应时间如何。
让我们快速设置我们的 Spring Boot 项目。
?xml version1.0 encodingUTF-8?
project xmlnshttp:/…我们看一下如何在spring-boot中利用loom虚拟线程。
我们将做一些负载测试看看虚拟线程和普通线程的响应时间如何。
让我们快速设置我们的 Spring Boot 项目。
?xml version1.0 encodingUTF-8?
project xmlnshttp://maven.apache.org/POM/4.0.0 xmlns:xsihttp://www.w3.org/2001/XMLSchema-instancexsi:schemaLocationhttp://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsdmodelVersion4.0.0/modelVersionparentgroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-parent/artifactIdversion3.1.0/versionrelativePath/ !-- lookup parent from repository --/parentgroupIdorg.anil/groupIdartifactIdvirtualthread/artifactIdversion0.0.1-SNAPSHOT/versionnamevirtualthread/namedescriptionvirtualthread/descriptionpropertiesjava.version20/java.versiontomcat.version11.0.0-M4/tomcat.version/propertiesdependenciesdependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-data-jpa/artifactId/dependency!-- https://mvnrepository.com/artifact/org.apache.commons/commons-lang3 --dependencygroupIdorg.apache.commons/groupIdartifactIdcommons-lang3/artifactIdversion3.12.0/version/dependency!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java --dependencygroupIdmysql/groupIdartifactIdmysql-connector-java/artifactIdscoperuntime/scopeversion8.0.33/version/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-web/artifactId/dependencydependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-test/artifactIdscopetest/scope/dependencydependencygroupIdorg.projectlombok/groupIdartifactIdlombok/artifactIdversion1.18.24/versionscopecompile/scope/dependency/dependenciesbuildpluginsplugingroupIdorg.springframework.boot/groupIdartifactIdspring-boot-maven-plugin/artifactId/pluginplugingroupIdorg.apache.maven.plugins/groupIdartifactIdmaven-compiler-plugin/artifactIdconfigurationcompilerArgsarg--enable-preview/arg/compilerArgssource20/sourcetarget20/target/configuration/plugin/plugins/build/project由于 Project Loom 处于预览阶段我们需要启用预览功能。
package org.anil.virtualthread;import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.embedded.tomcat.TomcatProtocolHandlerCustomizer;
import org.springframework.context.annotation.Bean;import java.util.concurrent.Executors;SpringBootApplication
Slf4j
public class VirtualthreadApplication {public static void main(String[] args) {SpringApplication.run(VirtualthreadApplication.class, args);}Beanpublic TomcatProtocolHandlerCustomizer? protocolHandlerVirtualThreadExecutorCustomizer() {return protocolHandler - {log.info(Configuring protocolHandler to use VirtualThreadPerTaskExecutor);protocolHandler.setExecutor(Executors.newVirtualThreadPerTaskExecutor());};}}到目前为止我们需要为 Tomcat 服务器配置虚拟线程设置。将来这可能会在自动配置本身中得到解决。
package org.anil.virtualthread;import org.apache.commons.lang3.RandomStringUtils;
import org.apache.commons.lang3.RandomUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;import java.util.List;RestController
public class HomeController {AutowiredProductRepository productRepository;GetMapping(/thread)public ListProduct checkThread() throws InterruptedException {Thread.sleep(1000);return productRepository.findAll();}PostMapping(/save)public String saveProduct() throws InterruptedException {for(int i0; i 1000; i){Product product new Product();product.setProductName(RandomStringUtils.randomAlphanumeric(5));product.setPrice(RandomUtils.nextLong(10,1000));product.setPrice(1L);productRepository.save(product);}return anil;}
}我们有一个GetMapping返回所有结果我们的数据库中有 1000 条数据。我们已经让线程休眠 1 秒。让我们看看我们的Product实体和ProductRepository。
package org.anil.virtualthread;import jakarta.persistence.Entity;
import jakarta.persistence.GeneratedValue;
import jakarta.persistence.GenerationType;
import jakarta.persistence.Id;
import lombok.Getter;
import lombok.Setter;Entity
Getter
Setter
public class Product {IdGeneratedValue(strategy GenerationType.IDENTITY)private Long id;private String productName;private Long price;
}package org.anil.virtualthread;import org.springframework.data.jpa.repository.JpaRepository;public interface ProductRepository extends JpaRepositoryProduct,Long {
}让我们看看我们的 application.yaml
spring:datasource:driver-class-name: com.mysql.cj.jdbc.DrivermaxIdle: 1timeBetweenEvictionRunsMillis: 60000hikari:connection-timeout: 60000maximum-pool-size: 10minimum-idle: 5url: jdbc:mysql://localhost:3306/todostestWhileIdle: trueusername: rootpassword: root1234validationQuery: SELECT 1flyway:baseline-version: 0enabled: truevalidate-on-migrate: falsejpa:database: mysqlgenerate-ddl: truehibernate:ddl-auto: noneformat_sql: trueshow-sql: true现在我们首先通过注释以下行来运行应用程序这将在普通线程上运行我们的应用程序。
package org.anil.virtualthread;import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.embedded.tomcat.TomcatProtocolHandlerCustomizer;
import org.springframework.context.annotation.Bean;import java.util.concurrent.Executors;SpringBootApplication
Slf4j
public class VirtualthreadApplication {public static void main(String[] args) {SpringApplication.run(VirtualthreadApplication.class, args);}// Bean
// public TomcatProtocolHandlerCustomizer? protocolHandlerVirtualThreadExecutorCustomizer() {
// return protocolHandler - {
// log.info(Configuring protocolHandler to use VirtualThreadPerTaskExecutor);
// protocolHandler.setExecutor(Executors.newVirtualThreadPerTaskExecutor());
// };
// }
}现在让我们设置JMeter。我们将有 1000 个请求该请求将在 3 秒内增加。并且这样的状态会持续200秒。每 3 秒将触发 1000 个 GET (“/thread”) 请求。我们还添加了响应时间图侦听器。 现在让我们运行测试并等待 200 秒。 从图中我们可以看到一旦Tomcat的整个线程池被利用响应时间从3600毫秒猛增到5200毫秒。
从那时起只有当以前的线程被释放时它才保持这种状态。 现在让我们在启用虚拟线程功能的情况下运行负载测试。
package org.anil.virtualthread;import lombok.extern.slf4j.Slf4j;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.web.embedded.tomcat.TomcatProtocolHandlerCustomizer;
import org.springframework.context.annotation.Bean;import java.util.concurrent.Executors;SpringBootApplication
Slf4j
public class VirtualthreadApplication {public static void main(String[] args) {SpringApplication.run(VirtualthreadApplication.class, args);}Beanpublic TomcatProtocolHandlerCustomizer? protocolHandlerVirtualThreadExecutorCustomizer() {return protocolHandler - {log.info(Configuring protocolHandler to use VirtualThreadPerTaskExecutor);protocolHandler.setExecutor(Executors.newVirtualThreadPerTaskExecutor());};}}现在让我们运行测试并等待 200 秒。 显然现在并发 1000 个请求的响应时间几乎略高于 1000 毫秒有时甚至会达到 1400 毫秒这比我们使用普通线程时要好得多。
显然当我们需要充分利用底层 CPU 时我们应该开始在应用程序中采用虚拟线程突然间我们可以看到对于相同的硬件应用程序的吞吐量增加了很多倍。
这比切换到反应式编程要好得多反应式编程意味着重写所有代码这很难先学习然后编写甚至更难调试和分析。
简而言之更多用户可以使用该应用程序并与第一个用户同时获得响应。
最后说一句(求关注!别白嫖)
如果这篇文章对您有所帮助或者有所启发的话求一键三连点赞、转发、在看。
关注公众号woniuxgg在公众号中回复笔记 就可以获得蜗牛为你精心准备的java实战语雀笔记回复面试、开发手册、有超赞的粉丝福利
