直屏旗艦來(lái)了 iQOO 12和K70 Pro同臺(tái)競(jìng)技
旗艦機(jī)基本上使用的都是雙曲面屏幕，這就讓很多喜歡直屏的愛(ài)好者在苦等一款直屏旗艦，這次，你們等到了。據(jù)博主數(shù)碼閑聊站帶來(lái)的最新爆料稱，Redmi下代旗艦K70 Pro和iQOO 12兩款手
我們將看到如何在spring-boot中利用loom虛擬線程。我們還將在JMeter的幫助下做一些負(fù)載測(cè)試，看看虛擬線程和普通線程的響應(yīng)時(shí)間如何。
首先，虛擬線程是 Project Loom 的一部分。
此外，Loom 不會(huì)加速內(nèi)存計(jì)算，例如并行流，這不是 Loom 的目標(biāo)。
我們正在研究如何使用可用的相同硬件來(lái)提高應(yīng)用程序吞吐量，即充分利用 CPU 的潛力，為此我們花費(fèi)了大量精力。截至目前，我們能夠利用 2% 到 3% 的 CPU。我在這篇博客中詳細(xì)討論了這一點(diǎn)：
https://medium.com/@anil.java.story/project-loom-virtual-threads-part-1-b17e327c8ba7
“我認(rèn)為 Loom 項(xiàng)目將會(huì)消滅響應(yīng)式編程”——Brian Goetz（Java 語(yǔ)言架構(gòu)師）
讓我們快速設(shè)置我們的 Spring Boot 項(xiàng)目。
<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>3.1.0</version> <relativePath/> <!-- lookup parent from repository --> </parent> <groupId>org.anil</groupId> <artifactId>virtualthread</artifactId> <version>0.0.1-SNAPSHOT</version> <name>virtualthread</name> <description>virtualthread</description> <properties> <java.version>20</java.version> <tomcat.version>11.0.0-M4</tomcat.version> </properties> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-jpa</artifactId> </dependency> <!-- https://mvnrepository.com/artifact/org.apache.commons/commons-lang3 --> <dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-lang3</artifactId> <version>3.12.0</version> </dependency> <!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java --> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <scope>runtime</scope> <version>8.0.33</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <dependency> <groupId>org.projectlombok</groupId> <artifactId>lombok</artifactId> <version>1.18.24</version> <scope>compile</scope> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId> <configuration> <compilerArgs> <arg>--enable-preview</arg> </compilerArgs> <source>20</source> <target>20</target> </configuration> </plugin> </plugins> </build></project>由于 Project Loom 處于預(yù)覽階段，我們需要啟用預(yù)覽功能。
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@Slf4jpublic 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()); }; }}到目前為止，我們需要為 Tomcat 服務(wù)器配置虛擬線程設(shè)置。將來(lái)，這可能會(huì)在自動(dòng)配置本身中得到解決。
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;@RestControllerpublic class HomeController { @Autowired ProductRepository productRepository; @GetMapping("/thread") public List<Product> checkThread() throws InterruptedException { Thread.sleep(1000); return productRepository.findAll(); } @PostMapping("/save") public String saveProduct() throws InterruptedException { for(int i=0; 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"; }}我們有一個(gè)GetMapping返回所有結(jié)果，我們的數(shù)據(jù)庫(kù)中有 1000 條數(shù)據(jù)。我們已經(jīng)讓線程休眠 1 秒。讓我們看看我們的Product實(shí)體和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@Setterpublic class Product { @Id @GeneratedValue(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 JpaRepository<Product,Long> {}讓我們看看我們的 application.yaml
spring: datasource: driver-class-name: com.mysql.cj.jdbc.Driver maxIdle: 1 timeBetweenEvictionRunsMillis: 60000 hikari: connection-timeout: 60000 maximum-pool-size: 10 minimum-idle: 5 url: jdbc:mysql://localhost:3306/todos testWhileIdle: true username: root password: root1234 validationQuery: SELECT 1 flyway: baseline-version: 0 enabled: true validate-on-migrate: false jpa: database: mysql generate-ddl: true hibernate: ddl-auto: none format_sql: true show-sql: true現(xiàn)在，我們首先通過(guò)注釋以下行來(lái)運(yùn)行應(yīng)用程序，這將在普通線程上運(yùn)行我們的應(yīng)用程序。
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@Slf4jpublic 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());// };// }}現(xiàn)在讓我們?cè)O(shè)置JMeter。我們將有 1000 個(gè)請(qǐng)求，該請(qǐng)求將在 3 秒內(nèi)增加。并且這樣的狀態(tài)會(huì)持續(xù)200秒。每 3 秒，將觸發(fā) 1000 個(gè) GET (“/thread”) 請(qǐng)求。我們還添加了響應(yīng)時(shí)間圖偵聽(tīng)器。
現(xiàn)在讓我們運(yùn)行測(cè)試并等待 200 秒。
從圖中我們可以看到，一旦Tomcat的整個(gè)線程池被利用，響應(yīng)時(shí)間從3600毫秒猛增到5200毫秒。從那時(shí)起，只有當(dāng)以前的線程被釋放時(shí)，它才保持這種狀態(tài)。
現(xiàn)在讓我們?cè)趩⒂锰摂M線程功能的情況下運(yùn)行負(fù)載測(cè)試。
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@Slf4jpublic 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()); }; }}現(xiàn)在讓我們運(yùn)行測(cè)試并等待 200 秒。
顯然，現(xiàn)在并發(fā) 1000 個(gè)請(qǐng)求的響應(yīng)時(shí)間幾乎略高于 1000 毫秒，有時(shí)甚至?xí)_(dá)到 1400 毫秒，這比我們使用普通線程時(shí)要好得多。
顯然，當(dāng)我們需要充分利用底層 CPU 時(shí)，我們應(yīng)該開(kāi)始在應(yīng)用程序中采用虛擬線程，突然間我們可以看到，對(duì)于相同的硬件，應(yīng)用程序的吞吐量增加了很多倍。
這比切換到反應(yīng)式編程要好得多，反應(yīng)式編程意味著重寫(xiě)所有代碼，這很難先學(xué)習(xí)，然后編寫(xiě)，甚至更難調(diào)試和分析。
簡(jiǎn)而言之，更多用戶可以使用該應(yīng)用程序并與第一個(gè)用戶同時(shí)獲得響應(yīng)。
本文鏈接：http://www.www897cc.com/showinfo-26-48731-0.htmlSpringBoot+虛擬線程，接口吞吐量成倍增加，太爽了！
聲明：本網(wǎng)頁(yè)內(nèi)容旨在傳播知識(shí)，若有侵權(quán)等問(wèn)題請(qǐng)及時(shí)與本網(wǎng)聯(lián)系，我們將在第一時(shí)間刪除處理。郵件：2376512515@qq.com
Copyright ? 2016-2023 天津谷騏科技有限公司 版權(quán)所有 sitemap.xml
違法及侵權(quán)請(qǐng)聯(lián)系：2376512515@qq.com 津ICP備18001702號(hào)
津公網(wǎng)安備 12010102000574號(hào)