2024-09-02



import org.springframework.web.servlet.HandlerInterceptor;
 
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
 
public class CustomInterceptor implements HandlerInterceptor {
 
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) {
        // 在请求处理之前进行调用(Controller方法调用之前)
        System.out.println("CustomInterceptor preHandle");
        return true; // 如果返回false,则停止流程,api不会被调用
    }
 
    @Override
    public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) {
        // 请求处理之后进行调用,但是在视图被渲染之前(Controller方法调用之后)
        System.out.println("CustomInterceptor postHandle");
    }
 
    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) {
        // 在整个请求结束之后调用,也就是在DispatcherServlet渲染了视图执行
        System.out.println("CustomInterceptor afterCompletion");
    }
}

这个代码示例展示了如何实现一个简单的Spring Boot拦截器。通过实现HandlerInterceptor接口,并重写其preHandle、postHandle和afterCompletion方法,你可以在请求处理的不同阶段加入自己的逻辑。这个拦截器仅仅是打印了一些信息,实际应用中你可以在这些方法中加入认证、日志记录、处理属性等功能。

2024-09-02

Spring Boot中的拦截器(HandlerInterceptor)可以用于在控制器方法执行前后进行一些操作,比如权限校验、日志记录、参数校验等。

以下是一个简单的Spring Boot拦截器的示例:

  1. 创建一个拦截器类实现HandlerInterceptor接口:



import org.springframework.web.servlet.HandlerInterceptor;
import org.springframework.web.servlet.ModelAndView;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
 
public class CustomInterceptor implements HandlerInterceptor {
 
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        // 在请求处理之前进行调用(Controller方法调用之前)
        System.out.println("Pre Handle");
        return true; // 如果返回false,则停止流程,api不会被调用
    }
 
    @Override
    public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) throws Exception {
        // 请求处理之后进行调用,但是在视图被渲染之前(Controller方法调用之后)
        System.out.println("Post Handle");
    }
 
    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {
        // 在整个请求结束之后调用,也就是在DispatcherServlet渲染了视图执行
        System.out.println("After Completion");
    }
}
  1. 注册拦截器。在Spring Boot配置类中添加拦截器:



import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;
 
@Configuration
public class WebConfig implements WebMvcConfigurer {
 
    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        registry.addInterceptor(new CustomInterceptor())
                .addPathPatterns("/**"); // 这里可以配置拦截的路径
                //.excludePathPatterns("/login", "/error"); // 这里可以配置不拦截的路径
    }
}

在上述配置中,我们创建了一个拦截器CustomInterceptor并将其应用

2024-09-02



import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean;
import org.springframework.scheduling.quartz.SimpleTriggerFactoryBean;
 
@Configuration
public class QuartzConfig {
 
    @Bean
    public MethodInvokingJobDetailFactoryBean jobDetail() {
        MethodInvokingJobDetailFactoryBean jobDetail = new MethodInvokingJobDetailFactoryBean();
        jobDetail.setTargetBeanName("scheduledTaskService"); // 指定目标Bean名称
        jobDetail.setTargetMethod("execute"); // 指定目标方法
        jobDetail.setConcurrent(false); // 设置为false表示任务不并发执行
        jobDetail.setName("scheduledTaskJob"); // 设置任务名称
        return jobDetail;
    }
 
    @Bean
    public SimpleTriggerFactoryBean simpleTrigger(MethodInvokingJobDetailFactoryBean jobDetail) {
        SimpleTriggerFactoryBean trigger = new SimpleTriggerFactoryBean();
        trigger.setJobDetail(jobDetail.getObject());
        trigger.setStartTime(new Date()); // 设置开始时间
        trigger.setRepeatInterval(2000); // 设置重复间隔时间,单位为毫秒
        trigger.setRepeatCount(10); // 设置重复次数
        trigger.setName("simpleTrigger"); // 设置触发器名称
        return trigger;
    }
 
    // 注册SchedulerFactoryBean,Spring Boot会自动完成初始化
}

这个配置类定义了一个任务详情和一个简单触发器,它们将会触发ScheduledTaskServiceexecute方法。这个例子展示了如何在Spring Boot中配置Quartz来执行定时任务。

2024-09-02



import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.data.redis.core.script.DefaultRedisScript;
import org.springframework.stereotype.Component;
 
import java.util.Collections;
import java.util.UUID;
import java.util.concurrent.TimeUnit;
 
@Component
public class RedisLock {
 
    @Autowired
    private StringRedisTemplate redisTemplate;
 
    @Autowired
    private DefaultRedisScript<Long> lockScript;
 
    @Autowired
    private DefaultRedisScript<String> unlockScript;
 
    public boolean lock(String key, long expireTime) {
        String value = UUID.randomUUID().toString();
        Long result = redisTemplate.execute(lockScript, Collections.singletonList(key), value, String.valueOf(expireTime));
        return result != null && result.equals(1L);
    }
 
    public boolean unlock(String key, String value) {
        String result = redisTemplate.execute(unlockScript, Collections.singletonList(key), value);
        return "OK".equals(result);
    }
}
 
// Lua 脚本用于加锁
String lockScript = "if redis.call('exists', KEYS[1]) == 0 then redis.call('hset', KEYS[1], ARGV[1], 1) redis.call('pexpire', KEYS[1], ARGV[2]) return 1 elseif redis.call('hexists', KEYS[1], ARGV[1]) == 1 then return 0 else return -1 end";
 
// Lua 脚本用于解锁
String unlockScript = "if redis.call('hexists', KEYS[1], ARGV[1]) == 1 then redis.call('hdel', KEYS[1], ARGV[1]) return 'OK' else return 'INVALID_REQUEST' end";

在这个代码实例中,我们使用了Lua脚本来实现Redis分布式锁。这样做的好处是可以保证加锁和解锁的操作是原子的,避免了在解锁之前有其他线程获得锁的情况发生。同时,我们使用了UUID来生成唯一的客户端标识,避免了因为客户端重复请求导致的问题。这个实现是简化版的,但是它展示了如何在Spring Boot应用程序中使用Redis实现分布式锁的基本概念。

2024-09-02



import org.springframework.cloud.gateway.filter.GatewayFilterChain;
import org.springframework.cloud.gateway.filter.GlobalFilter;
import org.springframework.core.io.buffer.DataBufferUtils;
import org.springframework.http.HttpStatus;
import org.springframework.http.server.reactive.ServerHttpResponse;
import org.springframework.web.server.ServerWebExchange;
import reactor.core.publisher.Mono;
 
import java.nio.charset.StandardCharsets;
 
public class RequestRateLimiterFilter implements GlobalFilter {
 
    private final RequestRateLimiter requestRateLimiter;
 
    public RequestRateLimiterFilter(RequestRateLimiter requestRateLimiter) {
        this.requestRateLimiter = requestRateLimiter;
    }
 
    @Override
    public Mono<Void> filter(ServerWebExchange exchange, GatewayFilterChain chain) {
        return requestRateLimiter.isAllowed(exchange)
                .flatMap(response -> {
                    if (response.isCommitted()) {
                        return Mono.error(new RuntimeException("Request rejected"));
                    }
 
                    ServerHttpResponse response = exchange.getResponse();
                    response.setStatusCode(HttpStatus.TOO_MANY_REQUESTS);
                    String result = "Requests too many";
                    response.getHeaders().setContentType(MediaType.APPLICATION_JSON);
                    DataBufferUtils.write(response.bufferFactory().wrap(result.getBytes(StandardCharsets.UTF_8)), response);
                    return response.setComplete();
                });
    }
}

这段代码实现了一个全局过滤器,用于Spring Cloud Gateway中的限流处理。它通过RequestRateLimiter组件的isAllowed方法检查请求是否超出了限制,并返回合适的响应。如果请求被拒绝,它将返回一个429 Too Many Requests响应,并显示一个错误信息。这是一个简洁且有教育意义的实现,对于需要在自己的项目中实现类似功能的开发者来说,值得借鉴。

2024-09-02

在Spring Boot中实现短信验证码功能,你可以使用第三方服务如Twilio或阿里云短信服务,也可以自己实现发送短信的功能。以下是一个简单的例子,演示如何使用Spring Boot和Mockito模拟发送短信。

  1. 添加依赖到pom.xml



<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
</dependency>
<!-- 如果要使用Twilio,需要添加以下依赖 -->
<!-- <dependency>
    <groupId>com.twilio.sdk</groupId>
    <artifactId>twilio</artifactId>
    <version>7.17.0</version>
</dependency> -->
  1. 创建Controller:



import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.http.ResponseEntity;
 
@RestController
public class SmsController {
 
    // 模拟发送短信的方法
    public void sendSmsMock(String mobile, String code) {
        // 实际项目中,这里会调用第三方短信服务API发送短信
        System.out.println("短信验证码已发送至手机号:" + mobile + ",验证码:" + code);
    }
 
    @PostMapping("/sendSms")
    public ResponseEntity<String> sendSms(@RequestParam String mobile, @RequestParam String code) {
        // 调用模拟的发送短信方法
        sendSmsMock(mobile, code);
        return ResponseEntity.ok("短信发送成功");
    }
}
  1. 创建Service:



public interface SmsService {
    void sendSms(String mobile, String code);
}



import org.springframework.stereotype.Service;
 
@Service
public class SmsServiceImpl implements SmsService {
    @Override
    public void sendSms(String mobile, String code) {
        // 调用第三方服务API发送短信
        // 例如使用Twilio:
        // Twilio.init(ACCOUNT_SID, AUTH_TOKEN);
        // Verification verification = Verification.creator(
        //         Servlet.getServletContext(), 
        //         "sms", 
        //         new PhoneNumber(mobile)
        // ).setChannel("sms")
        //  .setLocale("en")
        //  .addPayload("code", code)
        //  .create();
        
        System.out.println("短信验证码已发送至手机号:" + mobile + ",验证码:" + code);
    }
}
  1. 配置发送短信的逻辑,例如在Controller中注入SmsService:



import org.springframework.beans.factory.annotation.Autowired;
 
@RestController
public class SmsController {
 
    private final SmsService smsService;
 
    @Autowired
    public SmsController(SmsService smsService) {
        this.smsService = smsService;
    }
 
    // 使用Service发送短信
    @PostMapping("/sendSms")
    public ResponseEntity<String> sendSms(@RequestParam String mobile, @RequestPar
2024-09-02



import org.redisson.Redisson;
import org.redisson.api.RLock;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
 
import java.util.concurrent.TimeUnit;
 
public class RedissonLockExample {
 
    // 配置Redisson客户端
    private static RedissonClient redissonClient = Redisson.create(new Config());
 
    public static void main(String[] args) {
        RLock lock = redissonClient.getLock("anyLock");
 
        try {
            // 尝试获取锁,最多等待100秒,锁定之后最多持有锁10秒
            if (lock.tryLock(100, 10, TimeUnit.SECONDS)) {
                try {
                    // 处理业务逻辑
                    System.out.println("Locked and processing...");
 
                    // 模拟长时间操作
                    Thread.sleep(2000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } finally {
                    // 释放锁
                    System.out.println("Releasing lock...");
                    lock.unlock();
                }
            }
        } finally {
            // 关闭Redisson客户端
            redissonClient.shutdown();
        }
    }
}

这段代码展示了如何在Spring Boot应用中使用Redisson实现分布式锁。首先,我们创建了一个Redisson客户端实例,然后在主方法中获取了一个锁对象。使用tryLock方法尝试获取锁,并在获取锁之后执行业务逻辑。最后,确保释放锁资源并关闭Redisson客户端。

2024-09-02

在Spring Boot项目中,使用Baomidou的Dynamic-Datasource组件可以轻松实现多数据源的配置和动态切换。以下是一个简单的示例:

  1. 添加依赖到pom.xml



<dependency>
    <groupId>com.baomidou</groupId>
    <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
    <version>3.x.x</version>
</dependency>
  1. application.yml中配置多个数据源:



spring:
  datasource:
    dynamic:
      primary: db1 # 设置默认数据源
      strict: false # 开启严格模式, 默认false不启用, 启用则在没有配置主键时会抛出异常, 不启用则自动生成
      datasource:
        db1:
          url: jdbc:mysql://localhost:3306/db1
          username: root
          password: 
          driver-class-name: com.mysql.cj.jdbc.Driver
        db2:
          url: jdbc:mysql://localhost:3306/db2
          username: root
          password: 
          driver-class-name: com.mysql.cj.jdbc.Driver
  1. 使用@DS注解动态切换数据源:



@Service
public class DataSourceService {
 
    @Autowired
    private DynamicDataSourceProvider dynamicDataSourceProvider;
 
    @Transactional
    public void switchDataSource(String dataSourceName) {
        // 切换数据源
        dynamicDataSourceProvider.setDataSource(dataSourceName);
    }
}
  1. 在业务代码中使用注解指定数据源:



@Service
public class SomeService {
 
    @DS("db1")
    public void someMethod1() {
        // 使用db1数据源执行操作
    }
 
    @DS("db2")
    public void someMethod2() {
        // 使用db2数据源执行操作
    }
}

以上代码展示了如何配置多数据源,如何动态切换数据源,以及如何在服务层方法上指定使用特定的数据源。这样,你就可以根据业务需要灵活地在不同的数据源之间切换了。

2024-09-02

在Spring Boot项目中引入其他Spring Boot项目的jar文件,你可以将该jar文件安装到本地Maven仓库中,然后像引入其他依赖一样在项目的pom.xml文件中添加。

步骤如下:

  1. 使用mvn install命令将Spring Boot项目打包成jar并安装到本地Maven仓库。



cd path_to_spring_boot_project
mvn install
  1. 在你的Spring Boot项目的pom.xml文件中添加依赖。



<dependencies>
    <!-- 其他依赖 -->
 
    <!-- 添加你的Spring Boot项目依赖 -->
    <dependency>
        <groupId>your.groupId</groupId>
        <artifactId>your-artifactId</artifactId>
        <version>your-version</version>
    </dependency>
</dependencies>

替换your.groupIdyour-artifactIdyour-version为你的Spring Boot项目的实际groupId、artifactId和版本号。

完成以上步骤后,Maven会自动处理依赖并将其包含在你的项目中。

2024-09-02

Spring Boot是一个用于简化Spring应用程序初始搭建以及开发过程的开源框架。它使用特定的方式来进行配置,从而使开发者不再需要定义样板化的配置。

以下是一个简单的Spring Boot应用程序的例子,它使用Spring Boot的Web模块创建了一个RESTful API:




import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
 
@SpringBootApplication // 标注这是一个Spring Boot应用
public class DemoApplication {
 
    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args); // 启动应用
    }
}
 
@RestController // 标注这是一个控制器,返回的数据将直接作为HTTP响应体
class HelloController {
 
    @GetMapping("/hello") // 映射GET请求到hello方法
    public String hello() {
        return "Hello, Spring Boot!"; // 返回字符串作为响应
    }
}

在这个例子中,我们定义了一个DemoApplication类,使用@SpringBootApplication注解标注它是一个Spring Boot应用程序的入口点。在HelloController类中,我们定义了一个方法hello(),它映射了一个GET请求到/hello路径,并返回一个简单的字符串。

当你运行main方法时,Spring Boot会启动一个内嵌的Tomcat服务器,监听8080端口(除非你在application.propertiesapplication.yml中指定了其他端口)。你可以通过访问http://localhost:8080/hello来测试你的API。

这只是一个非常基础的示例,Spring Boot还有许多其他特性,例如自动配置的安全性、缓存、消息传递、数据访问层集成等。