x

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

@@ -4,10 +4,10 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
-import java.util.concurrent.atomic.AtomicLong;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
 
 import com.aliyun.openservices.aliyun.log.producer.Producer;
 import com.aliyun.openservices.aliyun.log.producer.Result;
@@ -17,6 +17,7 @@ import com.google.common.util.concurrent.FutureCallback;
 import com.google.common.util.concurrent.Futures;
 import com.google.common.util.concurrent.ListenableFuture;
 
+@Component
 public class AliyunLogProducer {
 
 	private static final ExecutorService EXECUTOR_SERVICE = Executors.newCachedThreadPool();
@@ -24,12 +25,11 @@ public class AliyunLogProducer {
 	private static final String project = System.getenv("PROJECT");
 	private static final String logStore = System.getenv("LOG_STORE");
 
-	public static void sendLog(String logText) {
+	public void sendLog(String logText) {
 		try {
-			final AtomicLong completed = new AtomicLong(0);
 			List<LogItem> logItems = new ArrayList<LogItem>();
 			ListenableFuture<Result> future = producer.send(project, logStore, logItems);
-			Futures.addCallback(future, new SampleFutureCallback(project, logStore, completed), EXECUTOR_SERVICE);
+			Futures.addCallback(future, new SampleFutureCallback(project, logStore, logText), EXECUTOR_SERVICE);
 		} catch (Exception e) {
 			e.printStackTrace();
 		}
@@ -43,29 +43,27 @@ public class AliyunLogProducer {
 
 		private final String logStore;
 
-		private final AtomicLong completed;
+		private final String logText;
 
-		SampleFutureCallback(String project, String logStore, AtomicLong completed) {
+		SampleFutureCallback(String project, String logStore, String logText) {
 			this.project = project;
 			this.logStore = logStore;
-			this.completed = completed;
+			this.logText = logText;
 		}
 
 		@Override
 		public void onSuccess(Result result) {
 			LOGGER.info("Send logs successfully.");
-			completed.getAndIncrement();
 		}
 
 		@Override
-		public void onFailure(Throwable t) {
-			if (t instanceof ResultFailedException) {
-				Result result = ((ResultFailedException) t).getResult();
-				LOGGER.error("Failed to send logs, project={}, logStore={}, result={}", project, logStore, result);
+		public void onFailure(Throwable errors) {
+			if (errors instanceof ResultFailedException) {
+				Result result = ((ResultFailedException) errors).getResult();
+				LOGGER.error("Failed to send logs, project={}, logStore={}, result={}, log={}", project, logStore, result, logText);
 			} else {
-				LOGGER.error("Failed to send log, e=", t);
+				LOGGER.error("Failed to send logs, project={}, logStore={}, errors={}, log={}", project, logStore, errors, logText);
 			}
-			completed.getAndIncrement();
 		}
 	}
 }