event

Author: netbuffer

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

@@ -73,11 +73,12 @@ public String login(HttpSession session, HttpServletRequest request,
 			Cookie c = new Cookie(ConfigConstant.USERNAME, username);
 			c.setMaxAge(86400);
 			response.addCookie(c);
-			Map<String, String> param=new HashMap<String,String>();
+			Map<String, String> param=new HashMap<>();
 			param.put("loginname", username);
 			param.put("logintime", new DateTime().toString("yyyy-MM-dd HH:mm:ss"));
 			param.put("loginip", request.getRemoteAddr());
-			applicationContext.publishEvent(new LoginEvent(param));  
+			//publishEvent会依次调用所有的监听器，同步调用，所有监听器执行完毕继续向下执行
+			applicationContext.publishEvent(new LoginEvent(this,param));
 			if(requri!=null&&requri.length()>0){
 				String uri=new String(Base64.decodeBase64(requri));
 				String touri=uri.substring(request.getContextPath().length()+1);

src/main/java/cn/com/ttblog/ssmbootstrap_table/event/LoginEvent.java

@@ -1,11 +1,27 @@
 package cn.com.ttblog.ssmbootstrap_table.event;
 
+import org.apache.commons.lang3.builder.ToStringBuilder;
 import org.springframework.context.ApplicationEvent;
+import java.util.Map;
 
 public class LoginEvent extends ApplicationEvent {
-	
-	public LoginEvent(Object source) {
+
+	private Map data;
+
+	public LoginEvent(Object source, Map<String, String> data) {
 		super(source);
+		this.data=data;
+	}
+
+	public Map getData() {
+		return data;
+	}
+
+	public void setData(Map data) {
+		this.data = data;
+	}
+
+	public String toString(){
+		return ToStringBuilder.reflectionToString(this);
 	}
-	
 }

src/main/java/cn/com/ttblog/ssmbootstrap_table/util/Config.java

@@ -1,15 +1,48 @@
 package cn.com.ttblog.ssmbootstrap_table.util;
 
+import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.AsyncConfigurer;
 import org.springframework.scheduling.annotation.EnableAsync;
+import java.lang.reflect.Method;
+import java.util.concurrent.Executor;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.ThreadFactory;
 
 /**
  * 启用异步方法
  * 发现在xml中配置<task:annotation-driven></task:annotation-driven>不生效,
  * 基于java config是生效的
  * http://docs.spring.io/spring/docs/current/javadoc-api/org/springframework/scheduling/annotation/EnableAsync.html
+ * http://docs.spring.io/spring/docs/4.2.9.RELEASE/spring-framework-reference/htmlsingle/#scheduling-annotation-support-async
  */
 @Configuration
 @EnableAsync
-public class Config {
+public class Config implements AsyncConfigurer {
+
+    /**
+     * 自定义实现Executor
+     * @return
+     */
+    @Override
+    public Executor getAsyncExecutor() {
+        ExecutorService executorService=Executors.newSingleThreadExecutor(new ThreadFactory() {
+            @Override
+            public Thread newThread(Runnable r) {
+                return new Thread(r,"task");
+            }
+        });
+        return executorService;
+    }
+
+    @Override
+    public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
+        return new AsyncUncaughtExceptionHandler() {
+            @Override
+            public void handleUncaughtException(Throwable throwable, Method method, Object... objects) {
+                System.out.printf("throwable:%s,method:%s,objects:%s",throwable,method,objects);
+            }
+        };
+    }
 }

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

@@ -3,7 +3,11 @@
 	   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 	   xmlns:context="http://www.springframework.org/schema/context"
 	   xmlns:aop="http://www.springframework.org/schema/aop"
-	   xsi:schemaLocation="http://www.springframework.org/schema/beans
+	   xmlns:task="http://www.springframework.org/schema/task"
+	   xsi:schemaLocation="
+	   					http://www.springframework.org/schema/task
+						http://www.springframework.org/schema/task/spring-task-4.0.xsd
+	   					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
@@ -18,6 +22,17 @@
         <context:exclude-filter type="annotation" expression="org.springframework.web.bind.annotation.ControllerAdvice" />
     </context:component-scan>
 
+	<!--<bean id="threadPoolTaskExecutor"-->
+		  <!--class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">-->
+		<!--<property name="corePoolSize" value="1" />-->
+		<!--<property name="maxPoolSize" value="10" />-->
+		<!--<property name="queueCapacity" value="50" />-->
+		<!--<property name="threadNamePrefix" value="task-" />-->
+		<!--<property name="keepAliveSeconds" value="30" />-->
+	<!--</bean>-->
+
+	<!--<task:annotation-driven executor="threadPoolTaskExecutor"></task:annotation-driven>-->
+
 	<bean id="configProperties"
 		class="org.springframework.beans.factory.config.PropertiesFactoryBean">
 		<property name="locations">