3

我有一个需要测试异步方法的场景。我有基于 XML 的配置，如下所示

<task:annotation-driven executor="myExecutor"
        scheduler="myScheduler" />
    <task:executor id="myExecutor" pool-size="5" />
    <task:scheduler id="myScheduler" pool-size="10" />

控制器中的原始异步方法如下

@Async
    public Future<ResponseEntity<?>> saveData(@RequestParam("file") MultipartFile file) {
        byte[] gzipContents = null;
        try {
            gzipContents = file.getBytes();
        } catch (IOException ioEx) {
        }
        if (gzipContents != null) {
            FileDTO fileDTO = new FileDTO(gzipContents);
            boolean response = storingService.processData(fileDTO);
            return new AsyncResult(new ResponseEntity<>(new ApiResponse<Boolean>(response, true), HttpStatus.OK));
        }
        return new AsyncResult(new ResponseEntity<>(new ApiResponse<Boolean>(false, true), HttpStatus.OK));

    }

我的测试用例如下所示。

@RunWith(SpringJUnit4ClassRunner.class)
@Transactional
public class TestSave extends BaseIntegrationTest {

        @Test
        public void testTrackingDataSave() throws Exception {
            // setup
            MvcResult mvcResult = this.mockMvc
                    .perform(MockMvcRequestBuilders.fileUpload(API_TESTER_SAVETRACKINGDATA)
                            .file("file", readFileBytesFromClasspath("testdata/output_sample1.txt"))
                            .header("certificate", testerCertificate))
                    .andExpect(request().asyncStarted()).andReturn();

            this.mockMvc.perform(asyncDispatch(mvcResult)).andExpect(status().isOk())
                    .andExpect(content().contentType(MediaType.APPLICATION_JSON_UTF8_VALUE))
                    .andExpect(status().is(200));
    }}

当您运行此测试时，我收到异常，因为异步开始预期为 true 但为 false。

需要如何着手解决这个问题。我错过了什么..？

4

0 回答 0