容量越大越不壞？24萬塊硬盤故障率報告公布 這些產(chǎn)品零故障
8月5日消息，云存儲服務(wù)商Backblaze發(fā)布了最新的硬盤故障率報告，年故障率有所上升。Backblaze發(fā)布的硬盤季度統(tǒng)計數(shù)據(jù)，其中包括故障率等重要方面。這些結(jié)
我們將看到如何在spring-boot中利用loom虛擬線程。我們還將在JMeter的幫助下做一些負(fù)載測試，看看虛擬線程和普通線程的響應(yīng)時間如何。
首先，虛擬線程是 Project Loom 的一部分。
此外，Loom 不會加速內(nèi)存計算，例如并行流，這不是 Loom 的目標(biāo)。
我們正在研究如何使用可用的相同硬件來提高應(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 項目將會消滅響應(yīng)式編程”——Brian Goetz（Java 語言架構(gòu)師）
讓我們快速設(shè)置我們的 Spring Boot 項目。
<?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è)置。將來，這可能會在自動配置本身中得到解決。
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"; }}我們有一個GetMapping返回所有結(jié)果，我們的數(shù)據(jù)庫中有 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)在，我們首先通過注釋以下行來運(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)在讓我們設(shè)置JMeter。我們將有 1000 個請求，該請求將在 3 秒內(nèi)增加。并且這樣的狀態(tài)會持續(xù)200秒。每 3 秒，將觸發(fā) 1000 個 GET (“/thread”) 請求。我們還添加了響應(yīng)時間圖偵聽器。
現(xiàn)在讓我們運(yùn)行測試并等待 200 秒。
從圖中我們可以看到，一旦Tomcat的整個線程池被利用，響應(yīng)時間從3600毫秒猛增到5200毫秒。從那時起，只有當(dāng)以前的線程被釋放時，它才保持這種狀態(tài)。
現(xiàn)在讓我們在啟用虛擬線程功能的情況下運(yùn)行負(fù)載測試。
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)行測試并等待 200 秒。
顯然，現(xiàn)在并發(fā) 1000 個請求的響應(yīng)時間幾乎略高于 1000 毫秒，有時甚至?xí)_(dá)到 1400 毫秒，這比我們使用普通線程時要好得多。
顯然，當(dāng)我們需要充分利用底層 CPU 時，我們應(yīng)該開始在應(yīng)用程序中采用虛擬線程，突然間我們可以看到，對于相同的硬件，應(yīng)用程序的吞吐量增加了很多倍。
這比切換到反應(yīng)式編程要好得多，反應(yīng)式編程意味著重寫所有代碼，這很難先學(xué)習(xí)，然后編寫，甚至更難調(diào)試和分析。
簡而言之，更多用戶可以使用該應(yīng)用程序并與第一個用戶同時獲得響應(yīng)。
本文鏈接：http://www.tebozhan.com/showinfo-26-48731-0.htmlSpringBoot+虛擬線程，接口吞吐量成倍增加，太爽了！
聲明：本網(wǎng)頁內(nèi)容旨在傳播知識，若有侵權(quán)等問題請及時與本網(wǎng)聯(lián)系，我們將在第一時間刪除處理。郵件：2376512515@qq.com
Copyright ? 2016-2023 天津谷騏科技有限公司 版權(quán)所有 sitemap.xml
違法及侵權(quán)請聯(lián)系：2376512515@qq.com 津ICP備18001702號
津公網(wǎng)安備 12010102000574號