使用log4j实现http请求日志入mongodb

2016-05-25 14:02:43 +08:00
parent 8ac97ac2f4
commit b46a27d8e6
8 changed files with 319 additions and 0 deletions
@@ -0,0 +1,84 @@
+package com.didispace.log;
+
+import com.mongodb.BasicDBObject;
+import com.mongodb.DBObject;
+import com.mongodb.MongoClient;
+import com.mongodb.MongoClientURI;
+import com.mongodb.client.MongoCollection;
+import com.mongodb.client.MongoDatabase;
+import org.apache.log4j.AppenderSkeleton;
+import org.apache.log4j.spi.LoggingEvent;
+import org.bson.Document;
+
+import java.io.ByteArrayOutputStream;
+import java.io.IOException;
+import java.io.ObjectOutputStream;
+
+/**
+ * 日志插入MongoDB
+ *
+ * @author 程序猿DD
+ * @version 1.0.0
+ * @date 16/5/23 下午4:53.
+ * @blog http://blog.didispace.com
+ */
+public class MongoAppender  extends AppenderSkeleton {
+
+    private MongoClient mongoClient;
+    private MongoDatabase mongoDatabase;
+    private MongoCollection<BasicDBObject> logsCollection;
+
+    private String connectionUrl;
+    private String databaseName;
+    private String collectionName;
+
+    @Override
+    protected void append(LoggingEvent loggingEvent) {
+
+        if(mongoDatabase == null) {
+            MongoClientURI connectionString = new MongoClientURI(connectionUrl);
+            mongoClient = new MongoClient(connectionString);
+            mongoDatabase = mongoClient.getDatabase(databaseName);
+            logsCollection = mongoDatabase.getCollection(collectionName, BasicDBObject.class);
+        }
+        logsCollection.insertOne((BasicDBObject) loggingEvent.getMessage());
+
+    }
+
+    @Override
+    public void close() {
+        if(mongoClient != null) {
+            mongoClient.close();
+        }
+    }
+
+    @Override
+    public boolean requiresLayout() {
+        return false;
+    }
+
+    public String getConnectionUrl() {
+        return connectionUrl;
+    }
+
+    public void setConnectionUrl(String connectionUrl) {
+        this.connectionUrl = connectionUrl;
+    }
+
+    public String getDatabaseName() {
+        return databaseName;
+    }
+
+    public void setDatabaseName(String databaseName) {
+        this.databaseName = databaseName;
+    }
+
+    public String getCollectionName() {
+        return collectionName;
+    }
+
+    public void setCollectionName(String collectionName) {
+        this.collectionName = collectionName;
+    }
+
+}