标签：return 定义 专车 003 method Bean public SpringBoot
【原创】003 | 搭上基于SpringBoot事务思想实战专车
发车啦，发车啦，上车要求：
点击左上方的“java进阶架构师”进入页面
选择右上角的“置顶公众号”上车！
专车介绍
该趟专车是开往基于Spring Boot事务思想实战的专车，在上一篇 搭上SpringBoot事务源码分析专车[1]中我们详细介绍了Spring Boot事务实现的原理，这一篇是基于上一篇的实战。
在实战之前，我们再次回顾下上篇文章讲解的重点：
- 后置处理器：对Bean进行拦截并处理
- 切面：由切点和通知组成
- 切点：用于匹配符合的类和方法
- 通知：用于代理处理
专车问题 - 如何利用后置处理器对Bean进行拦截并处理？
- 如何定义切面？
- 如何定义切点？
- 如何定义通知？
- 如何实现自动配置？
专车分析
实现是以Spring Boot为基础，需要添加如下依赖
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
</dependency>
</dependencies>按照如上提到的问题依次定义
定义bean后置处理器，特别注意，如果项目中使用到了事务特性，就不需要重复定义
/**
* 一定要声明InfrastructureAdvisorAutoProxyCreator，用于实现bean的后置处理
*
* @return
*/
@Bean
public InfrastructureAdvisorAutoProxyCreator infrastructureAdvisorAutoProxyCreator() {
return new InfrastructureAdvisorAutoProxyCreator();
}定义切面
public class BeanFactorySystemLogAdvisor extends AbstractBeanFactoryPointcutAdvisor {
/**
* 定义切点
*/
private final SystemLogPointcut point = new SystemLogPointcut();
@Override
public Pointcut getPointcut() {
return this.point;
}
}定义切点
public class SystemLogPointcut extends StaticMethodMatcherPointcut {
@Override
public boolean matches(Method method, Class<?> targetClass) {
// 查找类上@SystemLog注解属性
AnnotationAttributes attributes = AnnotatedElementUtils.findMergedAnnotationAttributes(
targetClass, SystemLog.class, false, false);
if (Objects.nonNull(attributes)) {
return true;
}
// 查找方法上@SystemLog注解属性
attributes = AnnotatedElementUtils.findMergedAnnotationAttributes(
method, SystemLog.class, false, false);
return Objects.nonNull(attributes);
}
}定义通知
@Slf4j
public class SystemLogInterceptor implements MethodInterceptor, Serializable {
@Override
public Object invoke(MethodInvocation invocation) throws Throwable {
Method method = invocation.getMethod();
String className = method.getDeclaringClass().getSimpleName();
String methodName = method.getName();
log.info("======[" + className + "#" + methodName + " method begin execute]======");
Arrays.stream(invocation.getArguments()).forEach(argument -> log.info("======[execute method argument：" + argument + "]======"));
Long time1 = Clock.systemDefaultZone().millis();
Object result = invocation.proceed();
Long time2 = Clock.systemDefaultZone().millis();
log.info("======[method execute time：" + (time2 - time1) + "]======");
return result;
}
}自动配置
@Configuration
public class ProxySystemLogConfiguration {
/**
* 定义切面
* 此处一定要指定@Role注解
*
* @return
*/
@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
@Bean
public BeanFactorySystemLogAdvisor beanFactorySystemLogAdvisor() {
BeanFactorySystemLogAdvisor advisor = new BeanFactorySystemLogAdvisor();
advisor.setAdvice(systemLogInterceptor());
return advisor;
}
/**
* 定义通知
*
* @return
*/
@Bean
public SystemLogInterceptor systemLogInterceptor() {
return new SystemLogInterceptor();
}
/**
* 一定要声明InfrastructureAdvisorAutoProxyCreator，用于实现bean的后置处理
*
* @return
*/
@Bean
public InfrastructureAdvisorAutoProxyCreator infrastructureAdvisorAutoProxyCreator() {
return new InfrastructureAdvisorAutoProxyCreator();
}
}定义注解
@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface SystemLog {
}专车集成业务
定义控制器
@RestController
public class SystemLogController {
@Autowired
private SystemLogService systemLogService;
@GetMapping("/log")
public String hello(@RequestParam("name") String name) throws InterruptedException {
return systemLogService.log(name);
}
}定义业务方法
@Slf4j
@Service
public class SystemLogService {
@SystemLog
public String log(String name) throws InterruptedException {
log.info("执行业务方法");
TimeUnit.SECONDS.sleep(1);
return "hello " + name;
}
}定义启动类
@SpringBootApplication
public class TransactionImitateApplication {
public static void main(String[] args) {
SpringApplication.run(TransactionImitateApplication.class, args);
}
}访问http://localhost:8080/log?name=advisor
查看控制台
2019-08-23 11:13:36.029 INFO 23227 --- [nio-8080-exec-1] c.b.example.config.SystemLogInterceptor : ======[SystemLogService#log method begin execute]======
2019-08-23 11:13:36.030 INFO 23227 --- [nio-8080-exec-1] c.b.example.config.SystemLogInterceptor : ======[execute method argument：advisor]======
2019-08-23 11:13:36.038 INFO 23227 --- [nio-8080-exec-1] c.boot.example.service.SystemLogService : 执行业务方法
2019-08-23 11:13:37.038 INFO 23227 --- [nio-8080-exec-1] c.b.example.config.SystemLogInterceptor : ======[method execute time：1004]======可以看到通过模拟@Transaction注解的实现方式，完成了日志切面功能。
专车总结
- 首先我们需要定义一个Bean后置处理器，用于拦截处理Bean
- 然后定义切面，在切面中定义切点
- 切点中实现切入的逻辑，比如此处我们的实现逻辑就是查找类或方法上是否含有@SystemLog注解
- 定义通知，完成代理工作
- 自动装配，将我们的切面、通知、Bean后置处理器声明在配置类中
- 集成业务
专车回顾
回顾下开头的五个问题：
如何利用后置处理器对Bean进行拦截并处理？直接在配置类中声明后置处理器
如何定义切面？继承AbstractBeanFactoryPointcutAdvisor，并在配置类中中声明
如何定义切点？继承StaticMethodMatcherPointcut，实现matches方法
如何定义通知？实现MethodInterceptor接口，实现invoke方法
如何实现自动配置？自定义配置类，声明所有需要加入容器的Bean
参考资料
1]搭上SpringBoot事务源码分析专车: https://github.com/a601942905git/learning-notes/blob/master/springboot/搭上SpringBoot事务源码分析专车.md
———— e n d ————
微服务、高并发、JVM调优、面试专栏等20大进阶架构师专题请关注公众号【Java进阶架构师】后在菜单栏查看。
看到这里，说明你喜欢本文
你的转发，是对我最大的鼓励！在看亦是支持↓
标签：return,定义,专车,003,method,Bean,public,SpringBoot 来源： https://blog.51cto.com/15009303/2552977
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。