x

src/main/java/com/egolm/shop/aliyunLog/AliyunLogProducer.java

@@ -37,8 +37,15 @@ public class AliyunLogProducer {
 	private static final ExecutorService EXECUTOR_SERVICE = Executors.newCachedThreadPool();
 	
 	public void sendLog(String logText) {
+		if(!isOpen) {
+			return;
+		}
 		try {
 			List<LogItem> logItems = new ArrayList<LogItem>();
+			LogItem logItem = new LogItem();
+		    logItem.PushBack("id", String.valueOf(System.currentTimeMillis()));
+		    logItem.PushBack("logText", logText);
+		    logItems.add(logItem);
 			ListenableFuture<Result> future = producer.send(project, logStore, logItems);
 			Futures.addCallback(future, new SampleFutureCallback(project, logStore, logText), EXECUTOR_SERVICE);
 		} catch (Exception e) {

src/main/java/com/egolm/shop/config/ExceptionHandler.java

@@ -5,19 +5,26 @@ import javax.servlet.http.HttpServletResponse;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.springframework.web.servlet.HandlerExceptionResolver;
 import org.springframework.web.servlet.ModelAndView;
 import org.springframework.web.servlet.view.json.MappingJackson2JsonView;
 
 import com.egolm.common.bean.Rjx;
+import com.egolm.shop.aliyunLog.AliyunLogProducer;
 import com.egolm.shop.util.I18NUtils;
 
+import io.netty.util.internal.ThrowableUtil;
+
 @Component
 public class ExceptionHandler implements HandlerExceptionResolver {
 
 	private static final Log logger = LogFactory.getLog(ExceptionHandler.class);
 	
+	@Autowired
+	private AliyunLogProducer logProducer;
+	
 	@Override
 	public ModelAndView resolveException(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) {
 		String langID = request.getParameter("langID");
@@ -33,6 +40,7 @@ public class ExceptionHandler implements HandlerExceptionResolver {
 			mav.addAllObjects(Rjx.jsonErr().setMessage(I18NUtils.getMessage(langID, "Msg_Exception_processFailure")));
 		} finally {
 			logger.error("", ex);
+			logProducer.sendLog(ThrowableUtil.stackTraceToString(ex));
 		}
 		return mav;
 	}