信息发布→ 登录 注册 退出

JUnit5/Mockito:优雅测试内部依赖与异常处理的实践

发布时间:2025-12-01

点击量:

JUnit5/Mockito:优雅测试内部依赖与异常处理的实践

本文旨在解决使用junit5和mockito测试j*a服务中内部依赖(如gu*a loadingcache)抛出并处理的异常(特别是catch块覆盖率)的挑战。核心策略是采用依赖注入模式,通过引入工厂接口或自定义包装器类来解耦服务与缓存的直接创建,从而使缓存实例在测试中可被模拟。文章将详细介绍两种实现方式及其对应的测试代码,确保`executionexception`的`catch`块能够被有效覆盖,提升代码测试的完整性。

在开发高健壮性的J*a应用时,我们经常会遇到需要处理内部组件抛出的异常场景。然而,当这些组件在服务类内部直接实例化时,对其异常处理逻辑进行单元测试,特别是覆盖catch块,会变得极具挑战。本教程将以一个具体的案例为例,探讨如何利用JUnit5和Mockito,通过引入依赖注入(Dependency Injection)模式,有效测试一个void方法中由LoadingCache引起的ExecutionException的catch块。

问题剖析:内部依赖的测试难题

考虑以下MyService类中的unlockFailed方法:

public class MyService {
    private LoadingCache<String, Integer> attemptsCache;

    public MyService() {
       super();
       // 缓存直接在构造函数中实例化
       attemptsCache = CacheBuilder.newBuilder()
           .expireAfterWrite(1, TimeUnits.HOURS)
           .build(new CacheLoader<String, Integer>() {
              @Override
              public Integer load(String key) throws Exception {
                  return 0;
              }
       });
    }

    public void unlockFailed(String key) {
        int attempts = 0;
        try {
            attempts = attemptsCache.get(key); // 这里的get方法可能抛出ExecutionException
        } catch (ExecutionException e) {
            attempts = 0; // 目标:覆盖这个catch块
        }
        attempts++;
        attemptsCache.put(key, attempts);
    }
}

在上述代码中,MyService内部直接创建并持有一个LoadingCache实例。unlockFailed方法尝试从缓存中获取值,并包含一个try-catch块来处理可能发生的ExecutionException。传统的单元测试尝试通过Mockito.doThrow().when(attemptsCache).get(USER);来模拟异常,但由于attemptsCache是在MyService内部创建的真实对象,而非注入的模拟对象,因此这种模拟无法生效,导致catch块始终无法被覆盖。

问题的核心在于MyService与LoadingCache的紧密耦合。为了实现可测试性,我们需要解耦它们,使得在测试时可以注入一个模拟的LoadingCache。

解决方案:依赖注入策略

依赖注入是解决此类问题的关键。通过将LoadingCache的创建或实例本身作为依赖项注入到MyService中,我们就可以在测试环境中提供一个由Mockito创建的模拟对象。下面介绍两种常用的依赖注入实现方式。

方法一:注入缓存工厂(Cache Factory)

这种方法通过引入一个工厂接口来抽象LoadingCache的创建过程。MyService不再直接创建缓存,而是通过工厂获取。

1. 定义缓存工厂接口和实现类

// CacheFactory.j*a
public interface CacheFactory {
  LoadingCache<String, Integer> createCache();
}

// ExpiringCacheFactory.j*a (生产环境实现)
public class ExpiringCacheFactory implements CacheFactory {
  @Override
  public LoadingCache<String, Integer> createCache() {
      return CacheBuilder.newBuilder()
           .expireAfterWrite(1, TimeUnit.HOURS)
           .build(new CacheLoader<String, Integer>() {
              @Override
              public Integer load(String key) throws Exception {
                  return 0;
              }
       });
  }
}

2. 修改 MyService 构造函数

MyService现在通过构造函数接收CacheFactory实例。

// MyService.j*a (修改后)
public class MyService {
    private LoadingCache<String, Integer> attemptsCache;

    public MyService(final CacheFactory cacheFactory) { // 注入CacheFactory
       super();
       this.attemptsCache = cacheFactory.createCache(); // 通过工厂创建缓存
    }

    // unlockFailed 方法保持不变
    public void unlockFailed(String key) {
        int attempts = 0;
        try {
            attempts = attemptsCache.get(key);
        } catch (ExecutionException e) {
            attempts = 0;
        }
        attempts++;
        attemptsCache.put(key, attempts);
    }
}

3. 生产环境中的使用

final MyService myService = new MyService(new ExpiringCacheFactory());

4. 单元测试代码

在测试中,我们可以提供一个匿名CacheFactory实现,它返回一个由Mockito模拟的LoadingCache。

网易人工智能 网易人工智能

网易数帆多媒体智能生产力平台

网易人工智能 233 查看详情 网易人工智能
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Test;
import org.mockito.Mockito;
import org.mockito.InjectMocks;
import org.mockito.Spy;

import com.google.common.cache.LoadingCache;
import com.google.common.util.concurrent.ExecutionError;

import j*a.util.concurrent.ExecutionException;
import j*a.util.concurrent.TimeUnit;

import static org.mockito.Mockito.*;

public class MyServiceTest {

    private final String USER = "fakeuser";

    @DisplayName("unlockFailed 应该在 LoadingCache.get 抛出 ExecutionException 时处理异常")
    @Test
    public void unlockFailed_should_handle_ExecutionException_with_factory() throws ExecutionException {
        // Arrange
        // 1. 模拟 LoadingCache
        LoadingCache<String, Integer> attemptsCacheMock = Mockito.mock(LoadingCache.class);
        // 2. 配置模拟缓存,使其在调用get方法时抛出ExecutionException
        doThrow(new ExecutionException("Dummy ExecutionException", null)).when(attemptsCacheMock).get(USER);

        // 3. 创建 MyService 实例,注入一个返回模拟缓存的工厂
        // 这里使用 lambda 表达式简化匿名内部类
        MyService sut = new MyService(() -> attemptsCacheMock);

        // Act
        sut.unlockFailed(USER);

        // Assert
        // 验证 attemptsCache.get(USER) 方法被调用了一次
        verify(attemptsCacheMock, times(1)).get(USER);
        // 验证 attemptsCache.put(USER, 0) 方法被调用了一次 (因为catch块将attempts重置为0)
        verify(attemptsCacheMock, times(1)).put(USER, 1); // attempts = 0 + 1 = 1
        // 注意:这里不需要断言抛出异常,因为方法内部已经捕获并处理了
    }
}

通过这种方式,MyService在测试时使用的是一个完全受控的模拟LoadingCache,我们可以轻松地模拟get()方法抛出ExecutionException,从而覆盖到catch块的逻辑。

方法二:注入自定义缓存包装器(Custom Cache Wrapper)

如果LoadingCache的接口过于复杂,或者我们只想暴露其一部分方法,可以创建一个自定义接口来包装LoadingCache,并将其注入到MyService中。

1. 定义自定义缓存接口和实现类

// MyLoadingCache.j*a
public interface MyLoadingCache {
  // 暴露 LoadingCache 中需要用到的方法
  Integer get(String key) throws ExecutionException;
  void put(String key, Integer value);
}

// MyLoadingCacheImpl.j*a (生产环境实现)
public class MyLoadingCacheImpl implements MyLoadingCache {
  private LoadingCache<String, Integer> attemptsCache;

  public MyLoadingCacheImpl() {
      this.attemptsCache = CacheBuilder.newBuilder()
           .expireAfterWrite(1, TimeUnit.HOURS)
           .build(new CacheLoader<String, Integer>() {
              @Override
              public Integer load(String key) throws Exception {
                  return 0;
              }
       });
  }

  @Override
  public Integer get(String key) throws ExecutionException {
      return attemptsCache.get(key);
  }

  @Override
  public void put(String key, Integer value) {
      attemptsCache.put(key, value);
  }
}

2. 修改 MyService 构造函数

MyService现在直接接收MyLoadingCache接口实例。

// MyService.j*a (修改后)
public class MyService {
    private MyLoadingCache attemptsCache; // 使用自定义接口类型

    public MyService(final MyLoadingCache attemptsCache) { // 注入自定义缓存接口
       super();
       this.attemptsCache = attemptsCache;
    }

    // unlockFailed 方法保持不变
    public void unlockFailed(String key) {
        int attempts = 0;
        try {
            attempts = attemptsCache.get(key);
        } catch (ExecutionException e) {
            attempts = 0;
        }
        attempts++;
        attemptsCache.put(key, attempts);
    }
}

3. 生产环境中的使用

final MyService myService = new MyService(new MyLoadingCacheImpl());

4. 单元测试代码

测试时,我们可以直接模拟MyLoadingCache接口。

import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Test;
import org.mockito.Mockito;

import j*a.util.concurrent.ExecutionException;

import static org.mockito.Mockito.*;

public class MyServiceTest {

    private final String USER = "fakeuser";

    @DisplayName("unlockFailed 应该在 MyLoadingCache.get 抛出 ExecutionException 时处理异常")
    @Test
    public void unlockFailed_should_handle_ExecutionException_with_wrapper() throws ExecutionException {
        // Arrange
        // 1. 模拟 MyLoadingCache 接口
        MyLoadingCache cacheMock = Mockito.mock(MyLoadingCache.class);
        // 2. 配置模拟缓存,使其在调用get方法时抛出ExecutionException
        doThrow(new ExecutionException("Dummy ExecutionException", null)).when(cacheMock).get(USER);

        // 3. 创建 MyService 实例,注入模拟缓存
        MyService sut = new MyService(cacheMock);

        // Act
        sut.unlockFailed(USER);

        // Assert
        // 验证 cacheMock.get(USER) 方法被调用了一次
        verify(cacheMock, times(1)).get(USER);
        // 验证 cacheMock.put(USER, 0) 方法被调用了一次
        verify(cacheMock, times(1)).put(USER, 1);
    }
}

替代方案:直接注入 LoadingCache 接口

在某些情况下,如果LoadingCache的创建逻辑不复杂,或者我们接受直接注入Gu*a的LoadingCache接口,也可以选择直接将LoadingCache作为依赖注入。

// MyService.j*a (直接注入LoadingCache)
public class MyService(final LoadingCache<String, Integer> attemptsCache) {
   super();
   this.attemptsCache = attemptsCache;
}

这种方式最直接,但需要确保LoadingCache的实际创建逻辑(如CacheLoader的定义)可以被外部管理或在生产环境中通过其他方式(如Spring的@Bean)提供。

注意事项与最佳实践

  • 依赖注入的优势: 依赖注入是实现高内聚低耦合、提高代码可测试性和可维护性的基石。它使得组件可以独立开发和测试,易于替换和扩展。
  • 选择合适的注入方式:
    • 如果缓存的创建逻辑复杂,且需要多种配置(例如不同的过期策略),工厂模式是更好的选择。
    • 如果只想暴露缓存的一部分功能,或者需要对缓存的行为进行更细粒度的控制,自定义包装器会更合适。
    • 如果缓存的创建相对简单,且直接注入第三方接口没有问题,直接注入接口是最简洁的方式。
  • Mockito的doThrow().when(): 这是模拟void方法或在when()语句中无法直接调用方法时抛出异常的标准方式。对于有返回值的方法,也可以使用when().thenThrow()。
  • 测试覆盖率: 采用上述方法后,unlockFailed方法中的catch (ExecutionException e)块将能够被成功触发和覆盖,从而提高代码的测试完整性。

总结

通过引入依赖注入模式,无论是通过缓存工厂还是自定义缓存包装器,我们都成功地将MyService与LoadingCache的具体实现解耦。这不仅解决了在单元测试中模拟内部依赖并覆盖异常处理块的难题,更重要的是,它提升了代码的设计质量和可维护性。在未来的开发中,应优先考虑使用依赖注入来管理类之间的协作关系,以构建更健壮、更易于测试的应用程序。

以上就是JUnit5/Mockito:优雅测试内部依赖与异常处理的实践的详细内容,更多请关注其它相关文章!


相关文章: BetterDiscord插件中安全更新用户简介的实践指南  Win11蓝牙耳机断连怎么解决 Win11蓝牙设置重新配对与驱动更新【技巧】  探索高级语言到C/C++的转译路径:以Go为例及内存管理策略  如何在J*a中实现统一对象行为接口_项目大型化时的接口规范化  Pyrogram与g4f集成:异步编程实践与常见错误解决  zookeeper 都有哪些功能?  支付宝解绑银行卡步骤_支付宝如何解除绑定银行卡  解决macOS上安装pyhdf时‘hdf.h’文件缺失的编译错误  Lar*el如何正确地在控制器和模型之间分配逻辑_Lar*el代码职责分离与架构建议  2025-2030年全球乘用车销量预测:新能源成增长主力  腾讯QQ邮箱官方网站_QQ邮箱网页版在线登录  C#如何安全地从用户上传的XML文件中读取数据? 验证与清理策略  Go与Ruby之间实现AES加密互通:CFB模式下的密钥长度匹配策略  Yandex搜索引擎一键访问入口_俄罗斯Yandex官网免登录  《马克思佩恩3》早期版本曝光 UI设计曾多次调整!  CSS自定义字体样式被系统字体替换怎么办_font-face方式指定font-display控制渲染策略  FullCalendar 自定义按钮样式定制指南  c++如何使用Catch2编写单元测试_c++简洁易用的BDD风格测试框架  J*aScript中正确使用querySelectorAll与复杂CSS选择器  html两个JS只运行一个怎么办_让双JS在html中都运行方法【技巧】  Golang如何实现微服务鉴权与权限控制_Golang微服务鉴权与权限管理实践  Win11怎么安装Linux子系统 Win11 WSL2安装Ubuntu及环境配置指南  Yandex官网搜索引擎免登录_俄罗斯Yandex一键直达入口  Lar*el Eloquent:高效统计带条件关联模型的数量  C#使用XPath查询节点时出错? 常见语法错误与调试技巧  windows10怎么关闭系统提示音_windows10彻底静音设置方法  天眼查企业查询官网入口 天眼查官方网页版查询  Highcharts 雷达图径向轴标签定制指南:利用多Y轴实现数值标注  sublime怎么进行远程开发编辑_配置rsub/rmate实现sublime编辑服务器文件  Fabric Mod开发:在1.19.3+版本中正确添加自定义物品并管理物品组  C++如何检测键盘输入_C++ _kbhit与_getch函数非阻塞输入  微信网页版扫码登录入口 微信网页版二维码登录入口  在J*a中如何开发在线活动报名与管理系统_活动报名管理项目实战解析  解决PHP会话Cookie在跨域请求中不保留的问题  AWS EC2实例间SQL Server连接超时:安全组配置与故障排除指南  文心一言怎样用插件调度API数据_文心一言用插件调度API数据【API调用】  2025年云电脑操作系统体验 | 无需本地硬件,随时随地使用高性能PC  在J*a中如何实现对象克隆避免共享数据_对象克隆安全实践指南  随机参数递归函数的基准调用次数与时间复杂度探究  PPT平滑切换怎么做 PPT炫酷“平滑”切换动画制作教程【必学】  钉钉视频会议画面卡顿如何解决 钉钉会议画面优化方法  汽水音乐车机版8.9下载 汽水音乐车机版8.9版本安装入口  PHP中SSG-WSG API的AES加密实践:正确使用初始化向量  MAC怎么让Dock栏只显示当前运行的应用_MAC终端命令实现极简Dock栏  Lar*el 8 多关键词数据库搜索优化实践  快手官方唯一登录入口 谨防山寨钓鱼网站  Linux如何排查内存不足OOME问题_LinuxOOM分析教程  优化 Python 函数中的条件逻辑:解决 if-else 嵌套与参数选择问题  Pandas DataFrame 高效批量赋值:告别循环与笛卡尔积误区  处理Kafka消息时会话超时与实现幂等性消费者 

在线客服
服务热线

服务热线

4008988990

微信咨询
二维码
返回顶部
×二维码

截屏,微信识别二维码

打开微信

微信号已复制,请打开微信添加咨询详情!