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

微信扫一扫,分享到朋友圈

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

看控制台和数据库

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

乐视网:退市整理期首日开盘参考价为 1.69 元

上一篇

Markdown编辑器说明

下一篇

你也可能喜欢

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

长按储存图像,分享给朋友