springboot实现定时任务,异步操作,统一结果返回,全局异常处理,拦截器及事务处理

本文是作者原创,版权归作者所有.若要转载,请注明出处.

本文都是springboot的常用和实用功能,话不多说开始吧

定时任务

1.启动类开启注解

@EnableScheduling //开启基于注解的定时任务
@MapperScan("com.pdzx.dao")
@SpringBootApplication
public class VideoApplication {

    public static void main(String[] args) {
        SpringApplication.run(VideoApplication.class);
    }

}

2.开启定时任务

@Component
public class ScheduledService {

    //每2秒 执行任务
    @Scheduled(cron = "0/2 * * * * ?")
    public void hello(){
        System.out.println("hello.....");
    }
}

看结果

注意cron表达式的用法.

6个参数,分别为:秒  分  时   日   月  周

通配符说明:

*:表示匹配该域的任意值。在minutes域使用 * 表示每分钟。在months里表示每个月。在daysOfWeek域表示一周的每一天。

?:只能用在daysofMonth和daysofWeek两个域,表示不指定值,当两个子表达式其中之一被指定了值以后,为了避免冲突,需要将另一个子表达式的值设为 ?。因为daysofMonth和daysofWeek会相互影响。例如想在每月的2号触发调度,不管2号是周几,则只能使用如下写法:0 0 0 2 * ?, 其中最后一位只能用?,而不能使用*,如果使用*表示不管周几都会触发。

-:表示范围。例如在minutes域使用5-20,表示从5分到20分钟每分钟触发一次

/:表示起始时间开始触发,然后每隔固定时间触发一次。例如在minutes域使用5/20,则意味着从当前小时的第5分钟开每20分钟触发一次。

,:表示列出枚举值。例如:在minutes域使用5,20,则意味着在5分和20分时各触发一次。

L:表示最后,是单词“last”的缩写,只能出现在daysofWeek和dayofMonth域。在daysofWeek域使用5L意思是在指定月的最后的一个星期四触发。在dayofMonth域使用5L或者FRIL意思是在指定月的倒数第5天触发。在使用L参数时,不要指定列表或范围。

W:表示有效工作日(周一到周五),只能出现在daysofMonth域,系统将在离指定日期的最近的有效工作日触发事件。例如:在daysofMonth使用5W,如果5号是周六,则将在最近的工作日周五,即4号触发。如果5号是周日,则在6日(周一)触发。如果5日在星期一到星期五中的一天,则就在5日触发。另外,W的最近寻找不会跨过月份 。

LW:这两个字符可以连用,表示指定月的最后一个工作日。

#:用于确定每个月第几个周几,只能出现在daysofMonth域。例如在4#2,表示某月的第二个周三。

常用表达式示例:

例如想在每月的2号触发调度,不管2号是周几,则只能使用如下写法: 0 0 0 2 * ? , 其中最后一位只能用 ? ,而不能使用 * ,如果使用 * 表示不管周几都会触发

 (1)0/2 * * * * ?   表示每2秒 执行任务
 (1)0 0/2 * * * ?   表示每2分钟 执行任务
 (1)0 0 2 1 * ?   表示在每月的1日的凌晨2点调整任务
 (2)0 15 10 ? * MON-FRI   表示周一到周五每天上午10:15执行作业
 (3)0 15 10 ? 6L 2002-2006   表示2002-2006年的每个月的最后一个星期五上午10:15执行作
 (4)0 0 10,14,16 * * ?   每天上午10点,下午2点,4点
 (5)0 0/30 9-17 * * ?   朝九晚五工作时间内每半小时
 (6)0 0 12 ? * WED   表示每个星期三中午12点
 (7)0 0 12 * * ?   每天中午12点触发
 (8)0 15 10 ? * *   每天上午10:15触发
 (9)0 15 10 * * ?     每天上午10:15触发
 (10)0 15 10 * * ?   每天上午10:15触发
 (11)0 15 10 * * ? 2005   2005年的每天上午10:15触发
 (12)0 * 14 * * ?     在每天下午2点到下午2:59期间的每1分钟触发
 (13)0 0/5 14 * * ?   在每天下午2点到下午2:55期间的每5分钟触发
 (14)0 0/5 14,18 * * ?     在每天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发
 (15)0 0-5 14 * * ?   在每天下午2点到下午2:05期间的每1分钟触发
 (16)0 10,44 14 ? 3 WED   每年三月的星期三的下午2:10和2:44触发
 (17)0 15 10 ? * MON-FRI   周一至周五的上午10:15触发
 (18)0 15 10 15 * ?   每月15日上午10:15触发
 (19)0 15 10 L * ?   每月最后一日的上午10:15触发
 (20)0 15 10 ? * 6L   每月的最后一个星期五上午10:15触发
 (21)0 15 10 ? * 6L 2002-2005   2002年至2005年的每月的最后一个星期五上午10:15触发
 (22)0 15 10 ? * 6#3   每月的第三个星期五上午10:15触发

异步操作

1.启动类开启注解

@EnableAsync //开启异步注解功能
@EnableScheduling //开启基于注解的定时任务
@MapperScan("com.pdzx.dao")
@SpringBootApplication
public class VideoApplication {

    public static void main(String[] args) {
        SpringApplication.run(VideoApplication.class);
    }

}

2.注解标注异步方法

@Component
public class AsyncService {

    //告诉Spring这是一个异步方法,SpringBoot就会自己开一个线程池,进行调用!
    @Async
    public void hello(){
        try {
            Thread.sleep(10000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("业务进行中....");
    }

}

3.控制层测试

@RestController
public class AsyncController {

    @Autowired
    AsyncService asyncService;

    @GetMapping("/async/hello")
    public String hello(){
        long time1 = System.currentTimeMillis();
        asyncService.hello();//调用异步方法
        long time2 = System.currentTimeMillis();
        System.out.println("Controller  :"+(time2-time1));
        return "success";
    }

}

访问该url,看结果

异步生效了

统一结果返回

封装一个统一的返回类

public class Result<T> {
    //是否成功
    private Boolean success;
    //状态码
    private Integer code;
    //提示信息
    private String msg;
    //数据
    private T data;
    public Result() {

    }
    //自定义返回结果的构造方法
    public Result(Boolean success,Integer code, String msg,T data) {
        this.success = success;
        this.code = code;
        this.msg = msg;
        this.data = data;
    }
    //自定义异常返回的结果
    public static Result defineError(DefinitionException de){
        Result result = new Result();
        result.setSuccess(false);
        result.setCode(de.getErrorCode());
        result.setMsg(de.getErrorMsg());
        result.setData(null);
        return result;
    }
    //其他异常处理方法返回的结果
    public static Result otherError(ErrorEnum errorEnum){
        Result result = new Result();
        result.setMsg(errorEnum.getErrorMsg());
        result.setCode(errorEnum.getErrorCode());
        result.setSuccess(false);
        result.setData(null);
        return result;
    }

    public Boolean getSuccess() {
        return success;
    }

    public void setSuccess(Boolean success) {
        this.success = success;
    }

    public Integer getCode() {
        return code;
    }

    public void setCode(Integer code) {
        this.code = code;
    }

    public String getMsg() {
        return msg;
    }

    public void setMsg(String msg) {
        this.msg = msg;
    }

    public T getData() {
        return data;
    }

    public void setData(T data) {
        this.data = data;
    }
}

统一异常

public enum ErrorEnum {
    // 数据操作错误定义
    SUCCESS(200, "nice"),
    NO_PERMISSION(403,"你没得权限"),
    NO_AUTH(401,"你能不能先登录一下"),
    NOT_FOUND(404, "未找到该资源!"),
    INTERNAL_SERVER_ERROR(500, "服务器跑路了"),
    ;

    /** 错误码 */
    private Integer errorCode;

    /** 错误信息 */
    private String errorMsg;

    ErrorEnum(Integer errorCode, String errorMsg) {
        this.errorCode = errorCode;
        this.errorMsg = errorMsg;
    }

    public Integer getErrorCode() {
        return errorCode;
    }

    public String getErrorMsg() {
        return errorMsg;
    }
}

全局异常处理

Springboot对于异常的处理也做了不错的支持,

它提供了一个 @ControllerAdvice注解以及 @ExceptionHandler注解,前者是用来开启全局的异常捕获,后者则是说明捕获哪些异常,对那些异常进行处理。如下

1.自定义异常

public class DefinitionException extends RuntimeException {
    protected Integer errorCode;
    protected String errorMsg;

    public DefinitionException(){

    }
    public DefinitionException(Integer errorCode, String errorMsg) {
        this.errorCode = errorCode;
        this.errorMsg = errorMsg;
    }

    public Integer getErrorCode() {
        return errorCode;
    }

    public void setErrorCode(Integer errorCode) {
        this.errorCode = errorCode;
    }

    public String getErrorMsg() {
        return errorMsg;
    }

    public void setErrorMsg(String errorMsg) {
        this.errorMsg = errorMsg;
    }
}

2.全局异常处理

@ControllerAdvice
public class GlobalExceptionHandler {

    /**
     * 处理自定义异常
     */
    @ExceptionHandler(value = DefinitionException.class)
    @ResponseBody
    public Result bizExceptionHandler(DefinitionException e) {
        return Result.defineError(e);
    }

    /**
     * 处理其他异常
     */
    @ExceptionHandler(value = Exception.class)
    @ResponseBody
    public Result exceptionHandler( Exception e) {
        return Result.otherError(ErrorEnum.INTERNAL_SERVER_ERROR);
    }
}

测试

    @RequestMapping("/getDeException")
    public Result DeException(){
        throw new DefinitionException(400,"我出错了");
    }

    @RequestMapping("/getException")
    public Result Exception(){
        Result result = new Result();
        int a=1/0;
        return result;
    }

看结果

首先看自定义异常

看其他异常结果

拦截器

拦截器是在servlet执行之前执行的程序(这里就是controller代码执行之前),它主要是用于拦截用户请求并作相应的处理,比如说可以判断用户是否登录,做相关的日志记录,也可以做权限管理。

SpringBoot中的拦截器实现和spring mvc 中是一样的,

它的大致流程是,先自己定义一个拦截器类,并将这个类实现一个 HandlerInterceptor 类,或者是继承 HandlerInterceptorAdapter ,都可以实现拦截器的定义。

然后将自己定义的拦截器注入到适配器中,也有两种方式,一种是实现 WebMvcConfigurer 接口,一种是继承 WebMvcConfigurerAdapter 。下面我们来看看如何完成。

1.自定义拦截器

/**
 *
 * 自定义的拦截器可以实现HandlerInterceptor接口,也可以继承HandlerInterceptorAdapter类。
 重写三个方法,当然也可以只实现一个最重要的preHandle方法。
 preHandle方法:此方法会在进入controller之前执行,返回Boolean值决定是否执行后续操作。
 postHandle方法:此方法将在controller执行之后执行,但是视图还没有解析,可向ModelAndView中添加数据(前后端不分离的)。
 afterCompletion方法:该方法会在整个请求结束(请求结束,但是并未返回结果给客户端)之后执行, 可获取响应数据及异常信息。
 */
public class MyInterceptor implements HandlerInterceptor {
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) {
        System.out.println("进入拦截器了");
        //中间写逻辑代码,比如判断是否登录成功,失败则返回false
        return true;
    }

    @Override
    public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) {
        //
        System.out.println("controller 执行完了");
    }


    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) {
        System.out.println("我获取到了一个返回的结果:"+response);
        System.out.println("请求结束了");
    }
}

2.拦截器注入适配器

@Configuration
public class InterceptorConfig implements WebMvcConfigurer {

    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        registry.addInterceptor(new MyInterceptor())
                .addPathPatterns("/**")//拦截所有的路径
                .excludePathPatterns("/LoginController/*")//配置不需要拦截的路径。
                .excludePathPatterns("/hello/login");//配置多个路径。
    }
}

3.先创建一个登陆的测试,这个接口是不会拦截的。

@RestController
@RequestMapping("LoginController")
public class Login {

    @RequestMapping("/login")
    public String login(){
        System.out.println("controller开始执行");
        return "login success";
    }

}

浏览器测试

http://localhost:5000/pdzx/LoginController/login

看结果

控制台只输出了未拦截接口内的代码,说明这个接口是未拦截的。浏览器的显示就不管了。其实一般是拦截登录接口,这里就将它放开了,以供测试。

4..创建一个拦截的controller

@RestController
@RequestMapping("/hello")
public class HelloController {
    @RequestMapping("/hello")
    public String hello(){
        System.out.println("经过拦截的controller代码执行完毕");
        return "hello";
    }

    @RequestMapping("/login")
    public String login(){
        System.out.println("不拦截的controller代码执行完毕");
        return "hello   login";
    }
}

测试

http://localhost:5000/pdzx/hello/hello

看结果

可以看到,首先是进入了拦截器,

通过拦截器之后,进入了controller中的方法,执行完controller的代码之后就进入了自定义拦截器中的postHandle方法,最后进入afterCompletion方法,并获取到了一个response对象。

事务处理

1.开启事务支持

@EnableTransactionManagement//开启事务支持
@EnableAsync //开启异步注解功能
@EnableScheduling //开启基于注解的定时任务
@MapperScan("com.pdzx.dao")
@SpringBootApplication
public class VideoApplication {

    public static void main(String[] args) {
        SpringApplication.run(VideoApplication.class);
    }

}

2.@Transactional来修饰一个方法

@Service
public class UserInfoServiceImpl {

    @Autowired
    private UserInfoMapper userInfoMapper;


    public int insertSelective(UserInfo record) {
        return userInfoMapper.insertSelective(record);
    }
    
    public int updateByPrimaryKeySelective(UserInfo record) {
        return userInfoMapper.updateByPrimaryKeySelective(record);
    }

    @Transactional
    public void add1(UserInfo record){
        userInfoMapper.insertSelective(record);
        int i=1/0;
    }
    
}

3.controller

@RequestMapping("userInfo")
@RestController
public class UserInfoController {

    @Autowired
    private UserInfoServiceImpl userInfoService;

    @RequestMapping("/add1")
    public void add1(){
        UserInfo userInfo=new UserInfo();
        userInfo.setName("张三");
        userInfoService.add1(userInfo);
    }
}

请求该路径之前,看一下数据库

请求该接口

http://localhost:5000/pdzx/userInfo/add1

看结果

看控制台和数据库

数据没进入数据库

我们把那行错误注释掉

@Transactional
    public void add1(UserInfo record){
        userInfoMapper.insertSelective(record);
        //int i=1/0;
    }

再试一下,看结果

结果了,可以看出,事务处理生效了.

我们再看一个情况:

不带事务的方法调用该类中带事务的方法,不会回滚。

因为spring的回滚是用过代理模式生成的,如果是一个不带事务的方法调用该类的带事务的方法,直接通过 this.xxx() 调用,而不生成代理事务,所以事务不起作用

看代码,add2,调用带事务处理的updateByPrimaryKeySelective

@Transactional
    public int updateByPrimaryKeySelective(UserInfo userInfo) {
        int i=1/0;
        userInfo=new UserInfo();
        userInfo.setId((long)100);
        userInfo.setName("李四");
        return userInfoMapper.updateByPrimaryKeySelective(userInfo);
    }
    
    public void add2(UserInfo record){
        userInfoMapper.insertSelective(record);

        updateByPrimaryKeySelective(record);
    }

controller层

@RequestMapping("/add2")
    public void add2(){
        UserInfo userInfo=new UserInfo();
        userInfo.setId((long) 150);
        userInfo.setName("张三");
        userInfoService.add2(userInfo);
    }

测试

http://localhost:5000/pdzx/userInfo/add2

看控制台和数据库

可以看到数据存到数据库了,事物没有生效,这个情况还需注意

我来评几句
登录后评论

已发表评论数()

相关站点

热门文章