SpringBoot 는 다 중 스 레 드 를 사용 하여 RESTful 서비스의 성능 을 향상 시킨다.

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

    @Autowired
    private WebApplicationContext wac;

    private MockMvc mockMvc;


    @Before
    public void setUp() throws Exception {
        mockMvc = MockMvcBuilders.webAppContextSetup(wac).build();
    }

    @Test
    public void order() throws Exception {
        mockMvc.perform(MockMvcRequestBuilders.get("/order").contentType(MediaType.APPLICATION_JSON_UTF8))
                .andExpect(MockMvcResultMatchers.status().isOk());
    }
}

@RestController
@RequestMapping("/order")
@Slf4j
public class AsyncController {

    @GetMapping
    public String order() throws InterruptedException {
        log.info("     ");
        Thread.sleep(1000);
        log.info("     ");
        return "success";
    }
}

@GetMapping
public Callable order() throws InterruptedException {
    log.info("     ");
    Callable result = new Callable() {
        @Override
        public String call() throws Exception {

            log.info("     ");
            Thread.sleep(1000);
            log.info("     ");
            return  "success";
        }
    };
    log.info("     ");
    return result;
}

@Component
public class MockQueue {

    /**
     *     
     */
    private String placeOrder;

    /**
     *        
     */
    private String completeOrder;


    public String getPlaceOrder() {
        return placeOrder;
    }

    public void setPlaceOrder(String placeOrder)  {
		
        new Thread(() -> {
            log.info("      , " + placeOrder);
            try {
                Thread.sleep(1000);
            } catch (Exception e) {
                e.printStackTrace();
            }
            this.completeOrder = placeOrder;
            log.info("        ," + placeOrder);
        }).start();

    }

    public String getCompleteOrder() {
        return completeOrder;
    }

    public void setCompleteOrder(String completeOrder) {
        this.completeOrder = completeOrder;
    }
}

@Component
@Getter
@Setter
public class DeferredResultHolder {
    private Map> map = new HashMap>();
}

@Slf4j
@Component
public class QueueListener implements ApplicationListener {

    @Autowired
    private MockQueue mockQueue;

    @Autowired
    private DeferredResultHolder deferredResultHolder;

    /**
     *   Spring  
     * @param contextRefreshedEvent
     */
    @Override
    public void onApplicationEvent(ContextRefreshedEvent contextRefreshedEvent) {
        new Thread(()->{
            while (true) {
                if (StringUtils.isNotBlank(mockQueue.getCompleteOrder())) {
                    String orderNumber = mockQueue.getCompleteOrder();
                    log.info("        :"+orderNumber);
                    deferredResultHolder.getMap().get(orderNumber).setResult("place order success");
                    mockQueue.setCompleteOrder(null);
                }else{
                    try {
                        Thread.sleep(100);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            }
        }).start();
    }
}