Java——AOP 案例之测量业务层接口执行效率
作者：王小凡
- 2022 年 7 月 27 日
本文字数：4204 字
阅读完需：约 14 分钟
一、需求分析
这个需求比较简单
需求:任意业务层接口执行均可显示其执行效率（执行时长）
这个的目的是查看每个业务层执行的时间，这样就可以监控出哪个业务比较耗时，将其查找出来方便优化。
具体实现的思路:
(1) 开始执行方法之前记录一个时间
(2) 执行方法
(3) 执行完方法之后记录一个时间
(4) 用后一个时间减去前一个时间的差值，就是我们需要的结果。
所以要在方法执行的前后添加业务，经过分析我们将采用环绕通知。
说明:原始方法如果只执行一次，时间太快，两个时间差可能为 0，所以我们要执行万次来计算时间差。
二、环境准备
创建一个 Maven 项目
pom.xml 添加 Spring 依赖
<dependencies> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context</artifactId> <version>5.2.10.RELEASE</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-jdbc</artifactId> <version>5.2.10.RELEASE</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-test</artifactId> <version>5.2.10.RELEASE</version> </dependency> <dependency> <groupId>org.aspectj</groupId> <artifactId>aspectjweaver</artifactId> <version>1.9.4</version> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>5.1.47</version> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid</artifactId> <version>1.1.16</version> </dependency> <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis</artifactId> <version>3.5.6</version> </dependency> <dependency> <groupId>org.mybatis</groupId> <artifactId>mybatis-spring</artifactId> <version>1.3.0</version> </dependency> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>4.12</version> <scope>test</scope> </dependency> </dependencies>复制代码
添加 AccountService、AccountServiceImpl、AccountDao 与 Account 类
public interface AccountService { void save(Account account); void delete(Integer id); void update(Account account); List<Account> findAll(); Account findById(Integer id);}@Servicepublic class AccountServiceImpl implements AccountService { @Autowired private AccountDao accountDao; public void save(Account account) { accountDao.save(account); } public void update(Account account){ accountDao.update(account); } public void delete(Integer id) { accountDao.delete(id); } public Account findById(Integer id) { return accountDao.findById(id); } public List<Account> findAll() { return accountDao.findAll(); }}public interface AccountDao { @Insert("insert into tbl_account(name,money)values(#{name},#{money})") void save(Account account); @Delete("delete from tbl_account where id = #{id} ") void delete(Integer id); @Update("update tbl_account set name = #{name} , money = #{money} where id = #{id} ") void update(Account account); @Select("select * from tbl_account") List<Account> findAll(); @Select("select * from tbl_account where id = #{id} ") Account findById(Integer id);}public class Account implements Serializable { private Integer id; private String name; private Double money; //setter..getter..toString方法省略}复制代码
resources 下提供一个 jdbc.properties，并有如下数据
jdbc.driver=com.mysql.jdbc.Driverjdbc.url=jdbc:mysql://localhost:3306/spring_db?useSSL=falsejdbc.username=rootjdbc.password=root复制代码
创建相关配置类
//Spring配置类:SpringConfig@Configuration@ComponentScan("com.itheima")@PropertySource("classpath:jdbc.properties")@Import({JdbcConfig.class,MybatisConfig.class})public class SpringConfig {}//JdbcConfig配置类public class JdbcConfig { @Value("${jdbc.driver}") private String driver; @Value("${jdbc.url}") private String url; @Value("${jdbc.username}") private String userName; @Value("${jdbc.password}") private String password; @Bean public DataSource dataSource(){ DruidDataSource ds = new DruidDataSource(); ds.setDriverClassName(driver); ds.setUrl(url); ds.setUsername(userName); ds.setPassword(password); return ds; }}//MybatisConfig配置类public class MybatisConfig { @Bean public SqlSessionFactoryBean sqlSessionFactory(DataSource dataSource){ SqlSessionFactoryBean ssfb = new SqlSessionFactoryBean(); ssfb.setTypeAliasesPackage("com.itheima.domain"); ssfb.setDataSource(dataSource); return ssfb; } @Bean public MapperScannerConfigurer mapperScannerConfigurer(){ MapperScannerConfigurer msc = new MapperScannerConfigurer(); msc.setBasePackage("com.itheima.dao"); return msc; }}复制代码
编写 Spring 整合 Junit 的测试类
@RunWith(SpringJUnit4ClassRunner.class)@ContextConfiguration(classes = SpringConfig.class)public class AccountServiceTestCase { @Autowired private AccountService accountService; @Test public void testFindById(){ Account ac = accountService.findById(2); } @Test public void testFindAll(){ List<Account> all = accountService.findAll(); }}复制代码
最终创建好的项目结构如下:
三、功能开发
步骤 1:开启 SpringAOP 的注解功能
在 Spring 的主配置文件 SpringConfig 类中添加注解
@EnableAspectJAutoProxy复制代码
步骤 2:创建 AOP 的通知类
该类要被 Spring 管理，需要添加 @Component
要标识该类是一个 AOP 的切面类，需要添加 @Aspect
配置切入点表达式，需要添加一个方法，并添加 @Pointcut
@Component@Aspectpublic class ProjectAdvice { //配置业务层的所有方法 @Pointcut("execution(* com.itheima.service.*Service.*(..))") private void servicePt(){} public void runSpeed(){ } }复制代码
步骤 3:添加环绕通知
在 runSpeed()方法上添加 @Around
@Component@Aspectpublic class ProjectAdvice { //配置业务层的所有方法 @Pointcut("execution(* com.itheima.service.*Service.*(..))") private void servicePt(){} //@Around("ProjectAdvice.servicePt()") 可以简写为下面的方式 @Around("servicePt()") public Object runSpeed(ProceedingJoinPoint pjp){ Object ret = pjp.proceed(); return ret; } }复制代码
注意:目前并没有做任何增强步骤 4:完成核心业务，记录万次执行的时间
Component@Aspectpublic class ProjectAdvice { //配置业务层的所有方法 @Pointcut("execution(* com.itheima.service.*Service.*(..))") private void servicePt(){} //@Around("ProjectAdvice.servicePt()") 可以简写为下面的方式 @Around("servicePt()") public void runSpeed(ProceedingJoinPoint pjp){ long start = System.currentTimeMillis(); for (int i = 0; i < 10000; i++) { pjp.proceed(); } long end = System.currentTimeMillis(); System.out.println("业务层接口万次执行时间: "+(end-start)+"ms"); } }复制代码
步骤 5:运行单元测试类
注意:因为程序每次执行的时长是不一样的，所以运行多次最终的结果是不一样的。
步骤 6:程序优化
目前程序所面临的问题是，多个方法一起执行测试的时候，控制台都打印的是:
业务层接口万次执行时间:xxxms
我们没有办法区分到底是哪个接口的哪个方法执行的具体时间，具体如何优化?
@Component@Aspectpublic class ProjectAdvice { //配置业务层的所有方法 @Pointcut("execution(* com.itheima.service.*Service.*(..))") private void servicePt(){} //@Around("ProjectAdvice.servicePt()") 可以简写为下面的方式 @Around("servicePt()") public void runSpeed(ProceedingJoinPoint pjp){ //获取执行签名信息 Signature signature = pjp.getSignature(); //通过签名获取执行操作名称(接口名) String className = signature.getDeclaringTypeName(); //通过签名获取执行操作名称(方法名) String methodName = signature.getName(); long start = System.currentTimeMillis(); for (int i = 0; i < 10000; i++) { pjp.proceed(); } long end = System.currentTimeMillis(); System.out.println("万次执行："+ className+"."+methodName+"---->" +(end-start) + "ms"); } }复制代码
步骤 7:运行单元测试类
划线
评论
复制
发布于: 刚刚阅读数: 4
王小凡
关注
还未添加个人签名 2022.07.26 加入
还未添加个人简介
评论