Spring Boot 3 + Resilience4j 简单入门 + Redis Cache 整合

1. 项目结构

2. Maven依赖

 <parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>3.1.2</version><relativePath/> <!-- lookup parent from repository --></parent><dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-aop</artifactId></dependency><!-- https://mvnrepository.com/artifact/io.github.resilience4j/resilience4j-spring-boot3 --><dependency><groupId>io.github.resilience4j</groupId><artifactId>resilience4j-spring-boot3</artifactId><version>2.2.0</version></dependency><!-- Redis cache dependency --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency></dependencies>

注：Resilience4j 需要 AOP（面向切面编程）相关的依赖，因为它利用 AOP 来动态地拦截和处理方法调用。

3. application.yml

spring:application:name: spring_resilience4j # Spring Boot 应用程序名称cache:type: redis # 缓存类型，使用 Redisdata:redis:host: 192.168.186.77 # Redis 服务器主机地址port: 6379 # Redis 服务器端口号resilience4j:timelimiter:instances:timeoutService:timeoutDuration: 2s # 超时时间为2秒circuitbreaker:instances:circuitbreakerService:slidingWindowSize: 10 # 滑动窗口大小为10failureRateThreshold: 50 # 失败率阈值为50%waitDurationInOpenState: 10s # 打开状态等待时间为10秒ratelimiter:instances:ratelimiterService:limitForPeriod: 1 # 每个周期允许的最大请求数为1limitRefreshPeriod: 10s # 速率限制刷新周期为10秒timeoutDuration: 500ms # 等待许可的超时时间为500毫秒retry:instances:retryService:maxAttempts: 5 # 最大重试次数为5次waitDuration: 1000ms # 重试间隔为1000毫秒（1秒）enableExponentialBackoff: true # 启用指数回退exponentialBackoffMultiplier: 1.5 # 指数回退倍数为1.5retryExceptions:- java.lang.RuntimeException # 需要重试的异常类型bulkhead:instances:bulkheadService:maxConcurrentCalls: 5 # 批隔离允许的最大并发调用数为5maxWaitDuration: 1s # 等待许可的最大时间为1秒

4. SpringResilience4jApplication.java

package org.example;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cache.annotation.EnableCaching;
@SpringBootApplication
@EnableCaching //开启缓存
public class SpringResilience4jApplication {public static void main(String[] args) {SpringApplication.run(SpringResilience4jApplication.class, args);}
}

5. Common.java

package org.example.controller;import org.example.service.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;import java.util.concurrent.CompletableFuture;@RestController
public class Common {@AutowiredTimeoutService timeoutService;@AutowiredRateLimiterService rateLimiterService;@AutowiredCircuitBreakerService circuitBreakerService;@AutowiredRetryService retryService;@AutowiredBulkheadService bulkheadService;//模拟超时@GetMapping("/timeout")public CompletableFuture<String> timeout() {return timeoutService.timeoutExample();}//模拟限速@GetMapping("/rateLimiter")public CompletableFuture<String> rateLimiter() {return rateLimiterService.rateLimiterExample();}//模拟回退@GetMapping("/circuitBreaker")public ResponseEntity<String> circuitBreaker() {return ResponseEntity.ok(circuitBreakerService.CircuitBreaker());}//模拟重试@GetMapping("/retry/{id}")public String getItemById(@PathVariable String id) {return retryService.getItemById(id);}// 模拟批隔离@GetMapping("/process/{id}")public String processRequest(@PathVariable String id) {return bulkheadService.processRequest(id);}
}

6. BulkheadService.java（批隔离）

package org.example.service;import io.github.resilience4j.bulkhead.BulkheadFullException;
import io.github.resilience4j.bulkhead.annotation.Bulkhead;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Service;@Service
public class BulkheadService {private static final Logger logger = LoggerFactory.getLogger(BulkheadService.class);@Bulkhead(name = "bulkheadService", fallbackMethod = "fallback")public String processRequest(String id) {logger.info("Processing request: {}", id);try {// 模拟处理延迟Thread.sleep(10000);} catch (InterruptedException e) {Thread.currentThread().interrupt();}return "Processed: " + id;}// 回退方法public String fallback(String id, BulkheadFullException ex) {logger.error("Bulkhead is full. Falling back for request: {}",id,ex);return "Bulkhead is full. Please try again later.";}
}

application.yml对应的配置信息：

  bulkhead:instances:bulkheadService:maxConcurrentCalls: 5maxWaitDuration: 1s

解释： 

  • maxConcurrentCalls：

    • 最大并发调用数。在此示例中，设置为 5，表示同一时间最多允许 5 个并发调用。如果超过这个数量，额外的调用将被阻塞，直到有空闲的调用资源。

  • maxWaitDuration：

    • 在被阻塞的调用被拒绝之前，最大等待时间。在此示例中，设置为 1 秒，表示如果一个调用在 1 秒内没有获取到许可，将会被拒绝并抛出BulkheadFullException。

 结果：

先启动（目录12BulkheadTest测试类）模拟并发。

出现该结果证明并发调用数已经满。

 

7. CircuitBreakerService.java（熔断）

package org.example.service;import io.github.resilience4j.circuitbreaker.annotation.CircuitBreaker;
import org.springframework.stereotype.Service;@Service
public class CircuitBreakerService {@CircuitBreaker(name = "circuitbreakerService", fallbackMethod = "fallback")public String CircuitBreaker() {if (Math.random() > 0.5) {throw new RuntimeException("It is Failure!");}return "It is Successfully!";}public String fallback(Throwable ex) {return "Fallback : " + ex.getMessage();}
}

application.yml对应的配置信息：

  circuitbreaker:instances:circuitbreakerService:slidingWindowSize: 10failureRateThreshold: 50waitDurationInOpenState: 10s

解释：

  • slidingWindowSize：

    • 滑动窗口大小。在此示例中，设置为10，表示 CircuitBreaker 将根据最近的10个调用的结果来计算失败率。

  • failureRateThreshold：

    • 失败率阈值。在此示例中，设置为 50，表示如果滑动窗口中的调用失败率超过 50%，CircuitBreaker 将打开（短路）。

  • waitDurationInOpenState：

    • CircuitBreaker打开状态的等待时间。在此示例中，设置为10秒，表示 CircuitBreaker在打开状态下会保持10秒，然后进入半开状态以重新测试服务的可用性。

  • 闭合状态（Closed）：

    • 默认状态，所有请求正常通过并进行监控。
    • 如果失败率超过阈值，进入打开状态。

  • 打开状态（Open）：

    • 在打开状态下，所有请求将立即失败，不会调用实际的方法。
    • 在等待时间结束后，进入半开状态。

  • 半开状态（Half-Open）：

    • 在半开状态下，会允许部分请求通过以测试服务是否恢复。
    • 如果请求成功率恢复正常，恢复到闭合状态；否则重新进入打开状态。

结果：

监听消息：

CircuitBreaker Event: 2024-07-29T23:12:41.621862900+08:00[Asia/Shanghai]: CircuitBreaker 'circuitbreakerService' recorded an error: 'java.lang.RuntimeException: It is Failure!'. Elapsed time: 0 ms

8. RateLimiterService.java（限速）

package org.example.service;import io.github.resilience4j.ratelimiter.annotation.RateLimiter;
import org.springframework.stereotype.Service;import java.util.concurrent.CompletableFuture;@Service
public class RateLimiterService {@RateLimiter(name = "ratelimiterService", fallbackMethod = "fallbackRateLimiter")public CompletableFuture<String> rateLimiterExample() {return CompletableFuture.supplyAsync(() -> "It is Success!");}public CompletableFuture<String> fallbackRateLimiter(Exception e) {return CompletableFuture.completedFuture("Too many requests");}
}

application.yml对应的配置信息 ：

  ratelimiter:instances:ratelimiterService:limitForPeriod: 1limitRefreshPeriod: 10stimeoutDuration: 500ms

解释：

  • limitForPeriod：

    • 指定每个刷新周期内允许的最大请求数。在此示例中，设置为1，表示每个刷新周期只允许1个请求通过。

  • limitRefreshPeriod：

    • 指定速率限制器的刷新周期。在此示例中，设置为10秒，表示每10秒刷新一次，重置允许的请求数。

  • timeoutDuration：

    • 指定在速率限制器中等待许可的最大时间。如果请求在timeoutDuration内未获得许可，则会被拒绝。在此示例中，设置为 500 毫秒。

结果（10s内发送两次请求）：

 

监听消息：

 RateLimiter Event: RateLimiterEvent{type=SUCCESSFUL_ACQUIRE, rateLimiterName='ratelimiterService', creationTime=2024-07-29T23:03:37.189104500+08:00[Asia/Shanghai]}
 RateLimiter Event: RateLimiterEvent{type=SUCCESSFUL_ACQUIRE, rateLimiterName='ratelimiterService', creationTime=2024-07-29T23:03:38.995416700+08:00[Asia/Shanghai]}
RateLimiter Event: RateLimiterEvent{type=FAILED_ACQUIRE, rateLimiterName='ratelimiterService', creationTime=2024-07-29T23:03:40.927729300+08:00[Asia/Shanghai]}

9. Resilience4jEventListener.java（事件监听）

package org.example.service;import io.github.resilience4j.circuitbreaker.CircuitBreaker;
import io.github.resilience4j.circuitbreaker.CircuitBreakerRegistry;
import io.github.resilience4j.ratelimiter.RateLimiter;
import io.github.resilience4j.ratelimiter.RateLimiterRegistry;
import io.github.resilience4j.retry.Retry;
import io.github.resilience4j.retry.RetryRegistry;
import io.github.resilience4j.timelimiter.TimeLimiter;
import io.github.resilience4j.timelimiter.TimeLimiterRegistry;
import jakarta.annotation.PostConstruct;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;@Component
public class Resilience4jEventListener {private static final Logger logger = LoggerFactory.getLogger(Resilience4jEventListener.class);private final RetryRegistry retryRegistry;private final TimeLimiterRegistry timeLimiterRegistry;private final CircuitBreakerRegistry circuitBreakerRegistry;private final RateLimiterRegistry rateLimiterRegistry;@Autowiredpublic Resilience4jEventListener(CircuitBreakerRegistry circuitBreakerRegistry,RateLimiterRegistry rateLimiterRegistry,RetryRegistry retryRegistry,TimeLimiterRegistry timeLimiterRegistry) {this.circuitBreakerRegistry = circuitBreakerRegistry;this.rateLimiterRegistry = rateLimiterRegistry;this.retryRegistry = retryRegistry;this.timeLimiterRegistry = timeLimiterRegistry;}@PostConstructpublic void postConstruct() {//  注册 Retry 事件监听器Retry retry = retryRegistry.retry("retryService");retry.getEventPublisher().onEvent(event -> logger.info("Retry event: {}", event));// 注册 CircuitBreaker 事件监听器CircuitBreaker circuitBreaker = circuitBreakerRegistry.circuitBreaker("circuitbreakerService");circuitBreaker.getEventPublisher().onEvent(event -> logger.info("CircuitBreaker Event: {}", event));// 注册 RateLimiter 事件监听器RateLimiter rateLimiter = rateLimiterRegistry.rateLimiter("ratelimiterService");rateLimiter.getEventPublisher().onEvent(event -> logger.info("RateLimiter Event: {}", event));// 注册 TimeLimiter 事件监听器TimeLimiter timeLimiter = timeLimiterRegistry.timeLimiter("timeoutService");timeLimiter.getEventPublisher().onEvent(event -> logger.info("TimeLimiter Event: {}", event));}
}

调试运行的信息如下：

2024-07-29T23:02:39.073+08:00  INFO 27996 --- [pool-2-thread-1] o.e.service.Resilience4jEventListener    : TimeLimiter Event: 2024-07-29T23:02:39.073307500+08:00[Asia/Shanghai]: TimeLimiter 'timeoutService' recorded a timeout exception.
2024-07-29T23:03:37.189+08:00  INFO 27996 --- [nio-8080-exec-4] o.e.service.Resilience4jEventListener    : RateLimiter Event: RateLimiterEvent{type=SUCCESSFUL_ACQUIRE, rateLimiterName='ratelimiterService', creationTime=2024-07-29T23:03:37.189104500+08:00[Asia/Shanghai]}
2024-07-29T23:03:38.995+08:00  INFO 27996 --- [nio-8080-exec-5] o.e.service.Resilience4jEventListener    : RateLimiter Event: RateLimiterEvent{type=SUCCESSFUL_ACQUIRE, rateLimiterName='ratelimiterService', creationTime=2024-07-29T23:03:38.995416700+08:00[Asia/Shanghai]}
2024-07-29T23:03:40.927+08:00  INFO 27996 --- [nio-8080-exec-6] o.e.service.Resilience4jEventListener    : RateLimiter Event: RateLimiterEvent{type=FAILED_ACQUIRE, rateLimiterName='ratelimiterService', creationTime=2024-07-29T23:03:40.927729300+08:00[Asia/Shanghai]}
2024-07-29T23:12:41.623+08:00  INFO 27996 --- [nio-8080-exec-9] o.e.service.Resilience4jEventListener    : CircuitBreaker Event: 2024-07-29T23:12:41.621862900+08:00[Asia/Shanghai]: CircuitBreaker 'circuitbreakerService' recorded an error: 'java.lang.RuntimeException: It is Failure!'. Elapsed time: 0 ms
2024-07-29T23:23:15.612+08:00  INFO 27996 --- [nio-8080-exec-3] org.example.service.RetryService         : Fetching item with id 2
2024-07-29T23:27:22.607+08:00  INFO 27996 --- [nio-8080-exec-6] org.example.service.RetryService         : Fetching item with id 3
2024-07-29T23:34:40.837+08:00  INFO 27996 --- [nio-8080-exec-2] org.example.service.RetryService         : Fetching item with id 4
2024-07-29T23:34:42.973+08:00  INFO 27996 --- [nio-8080-exec-1] org.example.service.RetryService         : Fetching item with id 5
2024-07-29T23:34:44.777+08:00  INFO 27996 --- [nio-8080-exec-3] org.example.service.RetryService         : Fetching item with id 6
2024-07-29T23:34:44.793+08:00  INFO 27996 --- [nio-8080-exec-3] o.e.service.Resilience4jEventListener    : Retry event: 2024-07-29T23:34:44.793527800+08:00[Asia/Shanghai]: Retry 'retryService', waiting PT1S until attempt '1'. Last attempt failed with exception 'java.lang.RuntimeException: Simulated database error'.
2024-07-29T23:34:45.817+08:00  INFO 27996 --- [nio-8080-exec-3] org.example.service.RetryService         : Fetching item with id 6
2024-07-29T23:34:45.822+08:00  INFO 27996 --- [nio-8080-exec-3] o.e.service.Resilience4jEventListener    : Retry event: 2024-07-29T23:34:45.822567400+08:00[Asia/Shanghai]: Retry 'retryService' recorded a successful retry attempt. Number of retry attempts: '1', Last exception was: 'java.lang.RuntimeException: Simulated database error'.

 注：该类进行事件监听，便于调试。

10. RetryService.java（缓存+重试）

package org.example.service;import io.github.resilience4j.retry.annotation.Retry;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;import org.springframework.cache.annotation.Cacheable;
import org.springframework.stereotype.Service;@Service
public class RetryService {private static final Logger logger = LoggerFactory.getLogger(RetryService.class);@Cacheable(value = "items", key = "#id")@Retry(name = "retryService", fallbackMethod = "fallback")public String getItemById(String id) {logger.info("Fetching item with id {}", id);// 模拟数据库调用，可能会引发异常if (Math.random() > 0.8) {throw new RuntimeException("Simulated database error");}return "Cache " + id;}// 回退方法public String fallback(String id, RuntimeException e) {return "Fallback : " + id;}
}

注：该类简单的使用redis缓存，重试机制可以自动重新执行失败的操作。通过配置重试次数和重试间隔，可以在遇到暂时性错误时增加操作成功的机会。

application.yml对应的配置信息：

  retry:instances:retryService:maxAttempts: 5waitDuration: 1000enableExponentialBackoff: trueexponentialBackoffMultiplier: 1.5retryExceptions:- java.lang.RuntimeException

 解释：

  • maxAttempts：

    • 最大重试次数。在此示例中，设置为 5，表示如果方法调用失败，将最多重试 5 次。

  • waitDuration：

    • 重试之间的等待时间（以毫秒为单位）。在此示例中，设置为 1000 毫秒（1 秒），表示每次重试之间等待 1 秒。

  • enableExponentialBackoff：

    • 启用指数回退策略。设置为true 表示启用指数回退。

  • exponentialBackoffMultiplier：

    • 指数回退的倍数。在此示例中，设置为1.5，表示每次重试之间的等待时间将乘以 1.5。

  • retryExceptions：

    • 需要重试的异常类型列表。在此示例中，指定了 java.lang.RuntimeException，表示当方法抛出RuntimeException时会进行重试。

结果：

直接访问（保证redis正常运行），然后不断的尝试把路径1依次累加，然后发送请求，直到出现监听消息的内容即可看到重试，当方法上使用了 @Cacheable 注解时，如果请求的缓存存在且未过期，那么该方法不会实际执行，而是直接返回缓存中的数据。这意味着在这种情况下，@Retry 注解可能不会生效，因为方法调用不会实际发生，导致没有机会触发重试机制。

监听消息： 

2024-07-29T23:23:15.612+08:00  INFO 27996 --- [nio-8080-exec-3] org.example.service.RetryService         : Fetching item with id 2
2024-07-29T23:27:22.607+08:00  INFO 27996 --- [nio-8080-exec-6] org.example.service.RetryService         : Fetching item with id 3
2024-07-29T23:34:40.837+08:00  INFO 27996 --- [nio-8080-exec-2] org.example.service.RetryService         : Fetching item with id 4
2024-07-29T23:34:42.973+08:00  INFO 27996 --- [nio-8080-exec-1] org.example.service.RetryService         : Fetching item with id 5
2024-07-29T23:34:44.777+08:00  INFO 27996 --- [nio-8080-exec-3] org.example.service.RetryService         : Fetching item with id 6
2024-07-29T23:34:44.793+08:00  INFO 27996 --- [nio-8080-exec-3] o.e.service.Resilience4jEventListener    : Retry event: 2024-07-29T23:34:44.793527800+08:00[Asia/Shanghai]: Retry 'retryService', waiting PT1S until attempt '1'. Last attempt failed with exception 'java.lang.RuntimeException: Simulated database error'.
2024-07-29T23:34:45.817+08:00  INFO 27996 --- [nio-8080-exec-3] org.example.service.RetryService         : Fetching item with id 6
2024-07-29T23:34:45.822+08:00  INFO 27996 --- [nio-8080-exec-3] o.e.service.Resilience4jEventListener    : Retry event: 2024-07-29T23:34:45.822567400+08:00[Asia/Shanghai]: Retry 'retryService' recorded a successful retry attempt. Number of retry attempts: '1', Last exception was: 'java.lang.RuntimeException: Simulated database error'.
 

11. TimeoutService.java（超时）

package org.example.service;import io.github.resilience4j.timelimiter.annotation.TimeLimiter;
import org.springframework.stereotype.Service;
import java.util.concurrent.CompletableFuture;@Service
public class TimeoutService {@TimeLimiter(name = "timeoutService", fallbackMethod = "fallback")public CompletableFuture<String> timeoutExample() {return CompletableFuture.supplyAsync(() -> {try {Thread.sleep(5000); // 模拟长时间处理，这里设置为5秒} catch (InterruptedException e) {Thread.currentThread().interrupt();}return "Success";});}public CompletableFuture<String> fallback(Throwable t) {return CompletableFuture.completedFuture("fallback: timeout!");}
}

application.yml对应的配置信息：

  timelimiter:instances:timeoutService:timeoutDuration: 2s

解释：设置为 2 秒。如果方法调用在 2 秒内未完成，TimeLimiter 会中断调用并执行回退方法。

结果：

监听消息：

TimeLimiter Event: 2024-07-29T23:02:39.073307500+08:00[Asia/Shanghai]: TimeLimiter 'timeoutService' recorded a timeout exception. 

12. BulkheadTest.java（批隔离测试）

package org.example.test;import java.net.HttpURLConnection;
import java.net.URL;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class BulkheadTest {public static void main(String[] args) {// 创建一个固定大小的线程池，线程数为6ExecutorService executor = Executors.newFixedThreadPool(6);// 初始化一个 CountDownLatch，用于控制所有任务的开始CountDownLatch latch = new CountDownLatch(1);// 提交6个任务到线程池for (int i = 1; i <= 6; i++) {final int id = i;executor.submit(() -> {try {// 等待 latch 释放，确保所有任务同时开始latch.await();// 创建 URL 对象，指定请求路径URL url = new URL("http://localhost:8080/process/" + id);// 打开连接HttpURLConnection conn = (HttpURLConnection) url.openConnection();// 设置请求方法为 GETconn.setRequestMethod("GET");// 获取响应代码int responseCode = conn.getResponseCode();// 打印响应代码System.out.println("Response Code for request " + id + ": " + responseCode);} catch (Exception e) {// 打印异常信息e.printStackTrace();}});}// 释放 latch，启动所有任务latch.countDown();// 关闭线程池executor.shutdown();}
}

注：该类用于模拟批隔离，策略限制了同时处理的并发调用数量，确保系统部分组件的问题不会导致整个系统的瘫痪。

13. 总结

      通过Resilience4j+Redis实现超时检测，限速访问，以及重试，还有熔断回退和批隔离等简单的案例模拟，仅供学习交流使用。

 

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/pingmian/51727.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

如何学习ClickHouse：糙快猛的大数据之路（技术要点概览）

如何学习ClickHouse：糙快猛的大数据之路（技术要点概览）

这个系列文章用"粗快猛大模型问答讲故事"的创新学习方法&#xff0c;让你轻松理解复杂知识&#xff01;涵盖Hadoop、Spark、MySQL、Flink、Clickhouse、Hive、Presto等大数据所有热门技术栈&#xff0c;每篇万字长文。时间紧&#xff1f;只看开头20%就能有收获&#…
阅读更多...
如何智能便捷、自动化地进行文件数据采集？

如何智能便捷、自动化地进行文件数据采集？

文件数据采集是指从各种源头和渠道收集、整理、清洗、分析和挖掘数据的过程。它是大数据应用的基础&#xff0c;为企业提供全面的决策支持和业务价值。文件数据采集对于不同行业都至关重要&#xff0c;通过有效的文件数据采集&#xff0c;企业可以更好地了解市场动态、优化服务…
阅读更多...
数据驱动未来：构建下一代湖仓一体电商数据分析平台，引领实时商业智能革命

数据驱动未来：构建下一代湖仓一体电商数据分析平台，引领实时商业智能革命

1.1 项目背景 本项目是一个创新的湖仓一体实时电商数据分析平台&#xff0c;旨在为电商平台提供深度的数据洞察和业务分析。技术层面&#xff0c;项目涵盖了从基础架构搭建到大数据技术组件的集成&#xff0c;采用了湖仓一体的设计理念&#xff0c;实现了数据仓库与数据湖的有…
阅读更多...
pytorch3d的安装

pytorch3d的安装

在这个网址中&#xff0c;下载对应的pytorch3d安装包 https://anaconda.org/pytorch3d/pytorch3d/files下载完成后使用下面命令进行安装 conda install ./pytorch3d-0.7.7-py39_cu118_pyt201.tar.bz2
阅读更多...
web基础及http协议、

web基础及http协议、

⼀、web基本概念和常识 Web&#xff1a;为⽤户提供的⼀种在互联⽹上浏览信息的服务&#xff0c;Web 服 务是动态的、可交 互的、跨平台的和图形化的。Web 服务为⽤户提供各种互联⽹服务&#xff0c;这些服务包括信息浏览 服务&#xff0c;以及各种交互式服务&#xff0c;包括聊…
阅读更多...
芋道微服务全栈开发日记（商品sku数据归类为规格属性）

芋道微服务全栈开发日记（商品sku数据归类为规格属性）

商品的每一条规格和属性在数据库里都是单一的一条数据&#xff0c;从数据库里查出来后&#xff0c;该怎么归类为对应的规格和属性值&#xff1f;如下图&#xff1a; 在商城模块&#xff0c;商品的单规格、多规格、单属性、多属性功能可以说是非常完整&#xff0c;如下图&#x…
阅读更多...
web、http协议、apache服务、nginx服务

web、http协议、apache服务、nginx服务

web基本概念和常识 概念 web&#xff1a;为用户提供的一种在互联网上浏览信息的服务&#xff0c;是动态的、可交互的、跨平台的和图形化的&#xff1b; 为用户提供各种互联网服务&#xff0c;这些服务包括浏览服务以及各种交互式服务&#xff0c;包括聊天、购物等&#xff1…
阅读更多...
shp格式数据详解

shp格式数据详解

还是大剑师兰特&#xff1a;曾是美国某知名大学计算机专业研究生&#xff0c;现为航空航海领域高级前端工程师&#xff1b;CSDN知名博主&#xff0c;GIS领域优质创作者&#xff0c;深耕openlayers、leaflet、mapbox、cesium&#xff0c;canvas&#xff0c;webgl&#xff0c;ech…
阅读更多...
MATLAB中“varargin”的作用

MATLAB中“varargin”的作用

varargin是什么&#xff1f; 在MATLAB中&#xff0c;varargin是一个特殊的变量&#xff0c;用于接收函数输入参数中的可变数量的参数。它允许用户在调用函数时传递不确定数量的参数。 varargin的本质是一个包含了所有可变参数的cell数组。在函数内部&#xff0c;可以使用cell…
阅读更多...
鸿蒙HarmonyOS开发：@Observed装饰器和@ObjectLink装饰器：嵌套类对象属性变化

鸿蒙HarmonyOS开发：@Observed装饰器和@ObjectLink装饰器：嵌套类对象属性变化

文章目录 一、装饰器二、概述三、限制条件四、装饰器说明五、Toggle组件1、子组件2、接口3、ToggleType枚举4、事件 六、示例演示1、代码2、效果 一、装饰器 State装饰器&#xff1a;组件内状态Prop装饰器&#xff1a;父子单向同步Link装饰器&#xff1a;父子双向同步Provide装…
阅读更多...
.NET周刊【7月第4期 2024-07-28】

.NET周刊【7月第4期 2024-07-28】

国内文章 .NET 高性能缓冲队列实现 BufferQueue https://mp.weixin.qq.com/s/fUhJpyPqwcmb3whuV3CDyg BufferQueue 是一个用 .NET 编写的高性能的缓冲队列实现&#xff0c;支持多线程并发操作。 项目地址&#xff1a;https://github.com/eventhorizon-cli/BufferQueue 项目…
阅读更多...
【Python】基础学习技能提升代码样例6：日志logging

【Python】基础学习技能提升代码样例6：日志logging

logging 模块实现了python的日志能力。本文通过几个示例展示一些重点概念与用法。 一、线程安全介绍 logging 模块的目标是使客户端不必执行任何特殊操作即可确保线程安全。 它通过使用线程锁来达成这个目标&#xff1b;用一个锁来序列化对模块共享数据的访问&#xff0c;并且…
阅读更多...
upload-labs靶场练习

upload-labs靶场练习

文件上传函数的常见函数&#xff1a; 在PHP中&#xff0c;‌文件上传涉及的主要函数包括move_uploaded_file(), is_uploaded_file(), get_file_extension(), 和 mkdir()。‌这些函数共同协作&#xff0c;‌使得用户可以通过HTTP POST方法上传文件&#xff0c;‌并在服务器上保存…
阅读更多...
实战：安装ElasticSearch 和常用操作命令

实战：安装ElasticSearch 和常用操作命令

概叙 科普文&#xff1a;深入理解ElasticSearch体系结构-CSDN博客 Elasticsearch各版本比较 ElasticSearch 单点安装 1 创建普通用户 #1 创建普通用户名&#xff0c;密码 [roothlink1 lyz]# useradd lyz [roothlink1 lyz]# passwd lyz#2 然后 关闭xshell 重新登录 ip 地址…
阅读更多...
kaggle使用api下载数据集

kaggle使用api下载数据集

背景 kaggle通过api并配置代理下载数据集datasets 步骤 获取api key 登录kaggle&#xff0c;点个人资料&#xff0c;获取到自己的api key 创建好的key会自动下载 将key放至家目录下的kaggle.json文件中 我这里是windows的administrator用户。 装包 我用了虚拟环境 pip …
阅读更多...
Vite + Vue3 + TS项目配置前置路由守卫

Vite + Vue3 + TS项目配置前置路由守卫

在现代前端开发中&#xff0c;使用 Vue 3 和 TypeScript 的组合是一种流行且高效的开发方式。Vite 是一个极速的构建工具&#xff0c;可以显著提升开发体验。本文博主将指导你如何在 Vite Vue 3 TypeScript 项目中配置前置路由守卫&#xff08;Navigation Guards&#xff09;…
阅读更多...
【YashanDB知识库】如何远程连接、使用YashanDB？

【YashanDB知识库】如何远程连接、使用YashanDB？

问题现象 在各个项目实施中&#xff0c;我们经常遇到客户、开发人员需要连接和使用YashanDB但不知如何操作的问题&#xff0c;本文旨在介绍远程连接、使用YashanDB的几种方式。 问题的风险及影响 无风险 问题影响的版本 历史版本~23.2 问题发生原因 无 解决方法及规避方…
阅读更多...
前端web开发HTML+CSS3+移动web（0基础,超详细）——第1天

前端web开发HTML+CSS3+移动web（0基础,超详细）——第1天

一、开发坏境的准备 1&#xff0c;在微软商店下载并安装VS Code 以及谷歌浏览器或者其他浏览器&#xff08;我这里使用的是Microsoft Edge&#xff09; 2&#xff0c;打开vs code &#xff0c;在电脑桌面新建一个文件夹命名为code&#xff0c;将文件夹拖拽到vs code 中的右边…
阅读更多...
Windows10安装CMake图文教程

Windows10安装CMake图文教程

CMake是一个跨平台的开源构建工具&#xff0c;用于管理软件构建过程。CMake允许开发人员使用简单的语法来描述项目的构建过程&#xff0c;而无需直接处理特定于操作系统或编译器的细节。开发人员可以编写CMakeLists.txt文件来指定项目的源文件、依赖项和构建规则&#xff0c;然…
阅读更多...
Ubuntu 20.04.6 安装 Elasticsearch

Ubuntu 20.04.6 安装 Elasticsearch

1.准备 -- 系统更新 sudo apt update sudo apt upgrade -- 安装vim 文本编辑器 sudo apt install vim-- jdk 版本确认 java -versionjdk 安装可以参照&#xff1a;https://blog.csdn.net/CsethCRM/article/details/140768670 2.官方下载Elasticsearch 官方地址&#xff1a;h…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023