Spring Boot@Async annotation和MockRestServiceServer

Question

我使用Spring Boot 2.0.6和Java10。我做了以下服务，仅使用RestTemboard访问外部Restapi。

@Service
@Slf4j
public class DbApiClientImpl implements DbApiClient {

  private final String URL_DELIMITER = "/";
  private RestTemplate restTemplate;
  private String url;

  public DbApiClientImpl(
      RestTemplateBuilder restTemplate,
      @Value("${dbapi.namespace}") String namespace,
      @Value("${dbapi.url}") String uri,
      @Value("${dbapi.username}") String username,
      @Value("${dbapi.password}") String password) {

  this.restTemplate = restTemplate.basicAuthorization(username, 
                      password).build();
  this.url = namespace.concat(uri);
}

   @Override
   @Async("asyncExecutor")
   public Merchant fetchMerchant(String id) {
       ResponseEntity<Merchant> response = 
        restTemplate.getForEntity(url.concat(URL_DELIMITER).concat(id), 
        Merchant.class);
   return response.getBody();
   }
}

使用MockeRestServiceServer进行以下测试：

@RunWith(SpringRunner.class)
@RestClientTest(value = {DbApiClient.class})
public class DbApiClientTest {

   private static final String TEST_NAME = "test";
   private static final String TEST_NAME_BAD_REQUEST = "test- 
   1";
   private static final String TEST_NAME_SERVER_ERROR = 
  "test-2";

   @Autowired DbApiClient dbApiClient;

   @Value("${dbapi.namespace}")
   private String namespace;

   @Value("${dbapi.url}")
   private String dbApiUrl;

   @Autowired private MockRestServiceServer mockServer;

   @Autowired private ObjectMapper objectMapper;

   @Test
   public void test() throws 
   JsonProcessingException, IOException {
      Merchant mockMerchantSpec = populateFakeMerchant();
      String jsonResponse = 
          objectMapper.writeValueAsString(mockMerchantSpec);
      mockServer
         .expect(manyTimes(), 
           requestTo(dbApiUrl.concat("/").concat(TEST_NAME)))
         .andExpect(method(HttpMethod.GET))
         .andRespond(withSuccess(jsonResponse, 
                       MediaType.APPLICATION_JSON));

       assertNotNull(dbApiClient.fetchMerchant(TEST_NAME));
  }

问题是，当我运行测试时，我得到了以下异常“无需进一步请求HTTP GET”http://localthost...“过度”

所以@Async似乎是在模仿MockerServerService响应...此外，如果我评论了@Async注释，一切都很好，我得到了所有测试绿色。

提前感谢您的意见。

更新：

根据@M.Deinum的评论。我从服务中删除了CompletableFuture，但我仍然得到同样的例外。

Answer 1

问题在于你的代码，而不是你的测试。

如果您阅读AsyncExecutionInterceptor的文档（JavaDoc），您将看到只有void或Future支持作为返回类型。您返回的是一个普通对象，该对象在内部被视为void。

对该方法的调用将始终以null响应。由于您的测试运行得非常快，所有内容都已被删除（或正在被删除），因此预计不会再进行调用。

要修复，请修复方法签名并返回Future

@Override
@Async("asyncExecutor")
public Future<Merchant> fetchMerchant(String id) {
   ResponseEntity<Merchant> response = 
    restTemplate.getForEntity(url.concat(URL_DELIMITER).concat(id), 
    Merchant.class);
   return CompletableFuture.completedFuture(response.getBody());
}

现在，调用代码知道返回的未来以及Spring异步代码。现在，在测试中，您可以对返回的值调用get（如果出现故障，可能会超时以接收错误）。检查结果。