test DeferredResult

Author: netbuffer

src/main/java/cn/com/ttblog/ssmbootstrap_table/controller/JsonpController.java

@@ -1,36 +1,27 @@
 package cn.com.ttblog.ssmbootstrap_table.controller;
 
-import java.io.IOException;
-import java.util.Arrays;
-import java.util.Map;
-import java.util.concurrent.Callable;
-import java.util.concurrent.TimeUnit;
-import javax.annotation.Resource;
-import javax.servlet.http.HttpServletRequest;
-import javax.servlet.http.HttpServletResponse;
-import javax.servlet.http.HttpSession;
-
-import org.apache.commons.io.IOUtils;
+import cn.com.ttblog.ssmbootstrap_table.model.User;
+import cn.com.ttblog.ssmbootstrap_table.service.IUserService;
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONObject;
+import com.google.common.collect.Maps;
 import org.apache.commons.lang3.builder.ToStringBuilder;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.stereotype.Controller;
 import org.springframework.ui.Model;
-import org.springframework.web.bind.annotation.ModelAttribute;
-import org.springframework.web.bind.annotation.PathVariable;
-import org.springframework.web.bind.annotation.RequestBody;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestMethod;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.ResponseBody;
-import org.springframework.web.bind.annotation.SessionAttributes;
+import org.springframework.web.bind.annotation.*;
 import org.springframework.web.context.request.async.DeferredResult;
 
-import com.alibaba.fastjson.JSON;
-import com.alibaba.fastjson.JSONObject;
-
-import cn.com.ttblog.ssmbootstrap_table.model.User;
-import cn.com.ttblog.ssmbootstrap_table.service.IUserService;
+import javax.annotation.Resource;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import javax.servlet.http.HttpSession;
+import java.io.IOException;
+import java.util.Arrays;
+import java.util.Map;
+import java.util.concurrent.Callable;
+import java.util.concurrent.TimeUnit;
 
 /**
  * jsonp测试
@@ -73,6 +64,7 @@ public void testModelAttr(HttpSession session, Model model) {
 	 * 通过一个TaskExecutor，Spring
 	 * MVC可以在另外的线程中调用Callable。当Callable返回时，请求再携带Callable返回的值
 	 * ，再次被分配到Servlet容器中恢复处理流程
+	 * <mvc:async-support default-timeout="5000"></mvc:async-support> spring mvc中配置默认的超时时间
 	 * @param str
 	 * @return
 	 */
@@ -91,19 +83,21 @@ public String call() throws Exception {
 
 	@RequestMapping(value = "/asyncd", method = RequestMethod.GET)
 	@ResponseBody
-	public DeferredResult<String> asyncd(final String str) {
-		DeferredResult<String> dr = new DeferredResult<String>();
-		dr.onCompletion(new Runnable() {
+	public DeferredResult<String> asyncd(final String str,@RequestParam(value = "sleep",required = false,defaultValue = "3")final Integer sleep) {
+		final DeferredResult<String> dr = new DeferredResult<String>();
+		new Thread(new Runnable() {
 			@Override
 			public void run() {
+				logger.info("asyncd task start");
 				try {
-					TimeUnit.SECONDS.sleep(3);
+					TimeUnit.SECONDS.sleep(sleep);
 				} catch (InterruptedException e) {
 					e.printStackTrace();
 				}
-				logger.debug("run with:{}",str);
+				logger.info("asyncd task end");
+				dr.setResult("hello:"+str);
 			}
-		});
+		},"deffered-execute-thread").start();
 		return dr;
 	}
 
@@ -282,4 +276,13 @@ Map receivejsonobj(@RequestBody Map user,HttpServletRequest request) {
 		logger.debug("name:{}", name);
 		return session.getAttribute("name").toString();
 	}
+
+	@ExceptionHandler
+	@ResponseBody
+	public Map handleAllException(Exception ex) {
+		Map result= Maps.newHashMap();
+		result.put("success",false);
+		result.put("msg",ex.getMessage());
+		return result;
+	}
 }

src/main/java/cn/com/ttblog/ssmbootstrap_table/interceptor/DefferedAsyncInterceptor.java

@@ -0,0 +1,38 @@
+package cn.com.ttblog.ssmbootstrap_table.interceptor;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.web.context.request.NativeWebRequest;
+import org.springframework.web.context.request.async.DeferredResult;
+import org.springframework.web.context.request.async.DeferredResultProcessingInterceptor;
+
+public class DefferedAsyncInterceptor implements DeferredResultProcessingInterceptor {
+
+	private static final Logger LOGGER=LoggerFactory.getLogger(DefferedAsyncInterceptor.class);
+
+	@Override
+	public <T> void beforeConcurrentHandling(NativeWebRequest nativeWebRequest, DeferredResult<T> deferredResult) throws Exception {
+		LOGGER.info("before deffered request :{},deferredResult:{}",nativeWebRequest,deferredResult);
+	}
+
+	@Override
+	public <T> void preProcess(NativeWebRequest nativeWebRequest, DeferredResult<T> deferredResult) throws Exception {
+		LOGGER.info("preProcess deffered request :{},deferredResult:{}",nativeWebRequest,deferredResult);
+	}
+
+	@Override
+	public <T> void postProcess(NativeWebRequest nativeWebRequest, DeferredResult<T> deferredResult, Object o) throws Exception {
+		LOGGER.info("postProcess deffered request :{},deferredResult:{}",nativeWebRequest,deferredResult);
+	}
+
+	@Override
+	public <T> boolean handleTimeout(NativeWebRequest nativeWebRequest, DeferredResult<T> deferredResult) throws Exception {
+		LOGGER.info("handleTimeout deffered request :{},deferredResult:{}",nativeWebRequest,deferredResult);
+		return true;
+	}
+
+	@Override
+	public <T> void afterCompletion(NativeWebRequest nativeWebRequest, DeferredResult<T> deferredResult) throws Exception {
+		LOGGER.info("after deffered request :{},deferredResult:{}",nativeWebRequest,deferredResult);
+	}
+}

src/main/resources/spring/spring-mvc.xml

@@ -122,6 +122,9 @@
 			<mvc:callable-interceptors>
 				<bean class="cn.com.ttblog.ssmbootstrap_table.interceptor.AsyncInterceptor"></bean>
 			</mvc:callable-interceptors>
+			<mvc:deferred-result-interceptors>
+				<bean class="cn.com.ttblog.ssmbootstrap_table.interceptor.DefferedAsyncInterceptor"></bean>
+			</mvc:deferred-result-interceptors>
 		</mvc:async-support>
 	</mvc:annotation-driven>