为Spring重试max atttemps编写Junit测试用例

Question

我想为SpringRetry编写一个junit测试用例，我像下面这样尝试过，但是junit没有按预期工作。我打电话给MaxAttemptRetryService。重试方法，如果失败，最多必须尝试3次。在这里，Dao正在调用一个rest服务，即停止，因此它最多应该尝试3次。因此道。sam方法必须调用3次。

服务类别：

@Service
@EnableRetry
public class MaxAttemptRetryService {   
    @Retryable(maxAttempts=3)
    public String retry(String username) throws Exception {
        System.out.println("retry???? am retrying...");
        int h = maxAttemptDao.sam();
        return "kkkk";
    }
}

Dao类：

@Component
public class MaxAttemptDao {
    public int sam() throws Exception{
        try{
            new RestTemplate()
            .getForObject("http://localhost:8080/greeting1/{userName}", 
                    String.class, "");
        }catch(Exception e){
            throw  e;
        }
        return 0;
    }
}

测试等级：

@RunWith(SpringRunner.class)
public class HystrixServiceTest {

    @InjectMocks
    private MaxAttemptRetryService maxAttemptRetryService = new MaxAttemptRetryService();

    @Mock
    private MaxAttemptDao maxAttemptDao;

    @Test
    public void ff() throws Exception{
        when(maxAttemptDao.sam()).thenThrow(Exception.class);
        maxAttemptRetryService.retry("ll");
        verify(maxAttemptDao, times(3)).sam();
    }
}

Answer 1

@EnableRetry和@Retryable注释应该由Spring处理，因为Spring应该在DAO的运行时动态生成代理。代理将添加重试功能。

现在，当您运行测试时，我看不出它是否运行spring。您提到您正在运行Spring Boot，但您没有使用@SpringBootTest。另一方面，您也没有指定要从中加载类的配置（HystrixServiceTestclass上的@ContextConfiguration注释）

因此，我的结论是，您没有正确初始化Spring，因此它不能正确处理@Retry注释。

在我看来其他错误的事情：

您应该使用@MockBean（如果您在测试中正确地启动了spring），这样它不仅会创建一个@Mock（您需要一个mockito运行程序），而且会创建一个mockspring bean，并在应用程序上下文中注册它，从而有效地覆盖标准bean声明。

我认为你应该这样做：

@RunWith(SpringRunner.class)
@SpringBootTest
public class HystrixServiceTest {

  @Autowired // if everything worked right, you should get a proxy here actually (you can check that in debugger)
  private MaxAttemptRetryService maxAttemptRetryService;

  @MockBean
  private MaxAttemptDao maxAttemptDao;


  @Test
  public void ff() throws Exception{
      when(maxAttemptDao.sam()).thenThrow(Exception.class);
      maxAttemptRetryService.retry("ll");
      verify(maxAttemptDao, times(3)).sam();
  }


}