Spring MockMvc и код состояния HTTP асинхронного контроллера

Как проверить/проверить внутреннюю ошибку сервера 500 в MockMvc, если мой контроллер имеет природу асинхронного сервлета?

Я пишу модульные тестовые примеры для своей конечной точки REST как часть тестовых случаев, мне нужно проверить, что сервер отправляет внутреннюю ошибку 500 в виде http-кода и с соответствующим сообщением об ошибке.

Вот мое приложение на основе весенней загрузки: (все импорты опущены для лучшей читабельности)

@RestController
@RequestMapping("/user")
@EnableAutoConfiguration
@SpringBootApplication
public class App 
{
    @RequestMapping(method = RequestMethod.GET, value = "/{name}", 
            produces = MediaType.APPLICATION_JSON_VALUE)
    private DeferredResult<String> greetByJson(@PathVariable("name") final String name){
        DeferredResult<String> dResult = new DeferredResult<String>();

        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    Thread.sleep(5000);
                    dResult.setErrorResult(new RuntimeException("Boom!!! time for Internal server error"));
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        }).start();

        return dResult;
    }

    public static void main( String[] args )
    {
        SpringApplication.run(App.class);
    }
}

Вот мои тестовые примеры MovkMvc JUnit:

@RunWith(SpringJUnit4ClassRunner.class)
@SpringApplicationConfiguration(classes = MockServletContext.class)
@WebAppConfiguration
public class AppTest {

    private final MockMvc mockMvc = MockMvcBuilders.standaloneSetup(new App())
            .build();

    @Test
    public void testAsyncInternalServerError() {
        try {
            MvcResult mvcResult = mockMvc.perform(
                    get("/user/naveen").accept(MediaType.APPLICATION_JSON_VALUE))
                    .andExpect(request().asyncStarted())
                    .andReturn();

            System.out.println("Http Response Content = " + mvcResult.getAsyncResult());
            System.out.println("Http Response Status Code = " + mvcResult.getResponse().getStatus());

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

Ниже приведены отпечатки консоли:

2015-08-08 18:11:51.494  INFO 10224 --- [           main] o.s.w.c.s.GenericWebApplicationContext   : Refreshing org.springframework.web.context.support.GenericWebApplicationContext@a82c5f1: startup date [Sat Aug 08 18:11:51 IST 2015]; root of context hierarchy
2015-08-08 18:11:51.526  INFO 10224 --- [           main] o.e.j.i.junit.runner.RemoteTestRunner    : Started RemoteTestRunner in 0.258 seconds (JVM running for 1.131)
Http Response Content = java.lang.RuntimeException: Boom!!! time for Internal server error
Http Response Status Code = 200
2015-08-08 18:11:56.584  INFO 10224 --- [       Thread-1] o.s.w.c.s.GenericWebApplicationContext   : Closing org.springframework.web.context.support.GenericWebApplicationContext@a82c5f1: startup date [Sat Aug 08 18:11:51 IST 2015]; root of context hierarchy

Из приведенного выше журнала видно, что MockMvc возвращает код состояния http как 200, а не 500. Сообщение об ошибке в порядке.

Где, например, когда я вызываю конечную точку с помощью почтальона Chrome, я вижу внутреннюю ошибку сервера 500, прикрепленную к изображению введите здесь описание изображения


spring-boot spring-mvc junit mockmvc spring-mvc-test
person Naveen Kumar    schedule 08.08.2015    source источник
comment
Вы действительно должны принять ответ @mzc. :)   -  person growlingchaos    schedule 24.08.2016

Ответы (3)


arrow_upward
13
arrow_downward

Вы должны выполнить асинхронную отправку и впоследствии проверить статус:

@Test
public void testMethod() throws Exception {

    MvcResult mvcResult = mockMvc.perform(get("/your/endpoint"))
            .andExpect(request().asyncStarted())
            .andExpect(request().asyncResult(notNullValue()))
            .andReturn();

    mockMvc.perform(asyncDispatch(mvcResult))
            .andExpect(status().isInternalServerError())
            .andReturn();

}
person mzc    schedule 08.08.2015
comment
Привет, Мне утверждение не подходит для этой строки: .andExpect(request().asyncStarted()) Есть идеи? - person VSZM; 18.07.2018

arrow_upward
2
arrow_downward

Пользовательский вспомогательный метод perform, который обрабатывает как синхронизирующий, так и асинхронный запрос:

ResultActions perform(MockHttpServletRequestBuilder builder) throws Exception {
    ResultActions resultActions = mockMvc.perform(builder);
    if (resultActions.andReturn().getRequest().isAsyncStarted()) {
      return mockMvc.perform(asyncDispatch(resultActions
          .andExpect(request().asyncResult(anything()))
          .andReturn()));
    } else {
      return resultActions;
    }
}

Длинный ответ с примером здесь

person jamonkko    schedule 28.02.2016

arrow_upward
0
arrow_downward

Ниже приведен рабочий пример (спецификация Groovy Spock) с методом asyncPerform(builder)

import static org.hamcrest.core.IsNull.notNullValue
import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.asyncDispatch
import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.post
import static org.springframework.test.web.servlet.result.MockMvcResultHandlers.print
import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.*

@ContextConfiguration(classes = [MyConfig])
@WebAppConfiguration
class MyControllerComponentSpec extends Specification {

    @Autowired
    WebApplicationContext webApplicationContext

    MockMvc endpoint

    def setup() {
        endpoint = MockMvcBuilders.webAppContextSetup(webApplicationContext).build()
    }

    ResultActions asyncPerform(MockHttpServletRequestBuilder builder) throws Exception {
         ResultActions resultActions = endpoint.perform(builder);
         asyncDispatch(resultActions.andExpect(request()
                        .asyncResult(notNullValue()))
                        .andReturn()));
     }

    def "accepts valid request and responds with 200 status code and response body"() {
        when:
        def response = asyncPerform(post("/my_async_endpoint")
            .content("""{"correlationID": "fe5d1699-20e3-4502-bf51-b947e6b9e51a"}""")
            .header("Content-Type", "application/json"))
            .andDo(print())

        then:
        response.andExpect(status().is(200))
            .andExpect(jsonPath("body.correlationID").value("fe5d1699-20e3-4502-bf51-b947e6b9e51a"))

    }
}
person prayagupd    schedule 21.09.2017