Spring framework Future와 AsyncResult 를 이용한 Async 서비스 호출

Spring framework Controller에서는 일반적으로 동기 방식으로 서비스를 호출한다.

그러나 요청된 파라미터의 값에 따라 동시에 여러 서비스를 호출하여 결과를 받을 때 순차적으로 서비스를 호출하지 않고  비동기로 서비스를 호출하여 결과를 Return 받으면 서비스의 수행 성능을 향상 시킬 수 있다.

Controller에서 비동기적으로 서비스를 호출하기 위해서는 Java 1.5에서부터 지원하는 Future 기능을 사용하고, 응답을 받을 경우 호출되는 서비스에서  AsyncResult를 이용하여 결과를 Return할 수 있다.

Funcure 기능과 AsyncResult를 이용하기 위해서는 task관련 Bean을 다음과 같이 정의한다.

■ context-baen.xml

<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"         xmlns:p="http://www.springframework.org/schema/p"         xmlns:context="http://www.springframework.org/schema/context"         xmlns:task="http://www.springframework.org/schema/task"         xmlns:mvc="http://www.springframework.org/schema/mvc"         xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd                 http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd                 http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd                 http://www.springframework.org/schema/task http://www.springframework.org/schema/task/spring-task-4.0.xsd"> <task:annotation-driven  executor="taskExecutor"/> <!-- mvc:annotation-driven> <mvc:async-support default-timeout="2500" task-executor="taskExecutor"> <mvc:callable-interceptors> <bean class="org.springframework.web.servlet.config.MvcNamespaceTests.TestCallableProcessingInterceptor" /> </mvc:callable-interceptors> <mvc:deferred-result-interceptors> <bean class="org.springframework.web.servlet.config.MvcNamespaceTests.TestDeferredResultProcessingInterceptor" /> </mvc:deferred-result-interceptors> </mvc:async-support> </mvc:annotation-driven--> <!-- Async Task --> <!-- task:annotation-driven scheduler="scheduler" executor="taskExecutor"/> <task:scheduler id="scheduler" pool-size="10"/--> <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">     <property name="corePoolSize" value="100"/>     <property name="maxPoolSize" value="100"/>     <property name="queueCapacity" value="2000000000"/>     <property name="keepAliveSeconds" value="120"/> </bean>   </beans>

비동기적으로 서비스를 호출하기 위해 <task:annotation-drive>을 설정하고, executor를 정의하여 Pool size와 Capacity를 정의한다.

다음은 비동기적으로 실행할 서비스를 생성한다.

■AsyncServiceImpl.java

import org.springframework.scheduling.annotation.Async; import org.springframework.scheduling.annotation.AsyncResult; import org.springframework.stereotype.Service; @Service("asyncService") public class AsyncServiceImpl extends BaseService implements AsyncService{ @Async @Override public Future<List<Map<String, Object>>> selectUserListAsync(NexacroMapDTO dto) throws Exception { LOGGER.info("selectUserListAsync Start"); Map<String, Object> searchMap = getDataSet(dto, "searchMap"); Thread.sleep(2000); List<Map<String, Object>> resultList = getMapper("sbMapper").selectList("user.selUser", searchMap); return new AsyncResult<List<Map<String, Object>>>(resultList); } @Async @Override public Future<List<Map<String, Object>>> selectUserListAsync1(NexacroMapDTO dto) throws Exception { LOGGER.info("selectUserListAsync1 Start"); Map<String, Object> searchMap = getDataSet(dto, "searchMap"); List<Map<String, Object>> resultList = getMapper("sbMapper").selectList("user.selUser", searchMap); LOGGER.info("selectUserListAsync1 End"); return new AsyncResult<List<Map<String, Object>>>(resultList); } }

Service 메소드에 @Async Annotation을 설정하여 해당 메소드가 비동기적 수행을 정의한다.

@Async는 public 메소드에만 정의되고, 동일한 Class에서는 @Async 메소드를 호출할 수 없다. 즉 외부의  Class에서 @Async 메소드를 호출한다.

@Async로 정의된 메소드는 Return Type이 Future<?>이고 결과는 AsyncResult를 생성하여 결과를 Return한다.

다음은 서비스를 호출하는 Controller를 생성한다.

■AsyncController

@RequestMapping(value = "/sample/selectUserAsync.do") public ModelAndView selectUserAsync(NexacroMapDTO dto) throws Exception { ModelAndView modelAndView = NexacroUtil.getModelAndView(dto); Future<List<Map<String,Object>>> future1 = asyncService.selectUserListAsync(dto); Future<List<Map<String,Object>>> future2 = asyncService.selectUserListAsync1(dto); // List<Map<String,Object>> resultList1 = future1.get(); // List<Map<String,Object>> resultList2 = future2.get();                modelAndView.addObject("list1", resultList1);                modelAndView.addObject("list2", resultList2); return modelAndView; }

Controller에서 Future에 서비스의 Async Method를 호출한 후 결과를 받기 위해 생성된 future의 get Method를 호출하여 결과를 받는다.

■ 수행결과

INFO | createCompositeTransaction ( 300000 ): created new ROOT transaction with id 192.168.0.59.tm0000100063  INFO | createCompositeTransaction ( 300000 ): created new ROOT transaction with id 192.168.0.59.tm0000200063  INFO | selectUserListAsync1 Start  INFO | selectUserListAsync Start  INFO | AtomikosDataSoureBean 'xaSBDataSource': getConnection ( null )...  INFO | AtomikosDataSoureBean 'xaSBDataSource': init...  INFO | atomikos connection proxy for oracle.jdbc.driver.LogicalConnection@1c182f16: calling getMetaData...  INFO | 1. Connection opened  INFO | 1. Connection.new Connection returned   INFO | atomikos connection proxy for oracle.jdbc.driver.LogicalConnection@1c182f16: calling getAutoCommit...  INFO | 1. Connection.getAutoCommit() returned true  INFO | addParticipant ( XAResourceTransaction: 3139322E3136382E302E35392E746D30303030313030303633:3139322E3136382E302E35392E746D31 ) for transaction 192.168.0.59.tm0000100063  INFO | XAResource.start ( 3139322E3136382E302E35392E746D30303030313030303633:3139322E3136382E302E35392E746D31 , XAResource.TMNOFLAGS ) on resource xaSBDataSource represented by XAResource instance oracle.jdbc.driver.T4CXAResource@5c7c0881  INFO | registerSynchronization ( com.atomikos.jdbc.AtomikosConnectionProxy$JdbcRequeueSynchronization@48d3cd82 ) for transaction 192.168.0.59.tm0000100063  INFO | atomikos connection proxy for oracle.jdbc.driver.LogicalConnection@1c182f16: calling prepareStatement(SELECT ID, NAME, PASSWORD, DESCRIPTION, USE_YN, REG_USER FROM TB_USER WHERE 1 = 1)...

결과를 확인하면 로그에 selectUserListAsync1,과 selectUserListAsync 출력됨을 확인할 수 있으며, 각각의 서비스가 순차적으로 호출되지 않고 병렬로 호출되었음을 확인할 수 있다.