继续造轮子-MongoDB写日志

女爷i 2023-02-21 11:47 3阅读 0赞

> 微信公众号：**Java患者**  
> **专注Java领域技术分享**

继上一篇文章

[我造了一个轮子去写系统日志][Link 1]

### MongoDB ###

MongoDB我们都知道是一个Nosql，其次MongoDB可以存储海量数据，正好满足我们的需求，日志本身就会很多，基本每一个操作可能都会保存一条日志记录，如果选用mysql或者oracle的话成本感觉相对较高，而MongoDB会存在少量数据丢失的情况，当然我们用来保存日志，少几条操作也没关系？是吧！

MongoDB是将数据存储为一个文档的格式，文档格式则类似于一个JSON对象。

{
        name: "Zero",
        date: "2020-05-20",
        detail: "客户支付了十元",
        type: "payment"
    }

### MondoDB简单搭建 ###

package com.zero.na;
    
    import com.mongodb.MongoClient;
    import com.mongodb.client.MongoDatabase;
    import org.bson.Document;
    
    /**
     * 芒狗DB 工具类
     */
    public class MongodbUtil {
    
        private String DEFAULT_DATABASE_NAME = "test";
    
        private MongoClient mongoClient;
    
        private static MongodbUtil instance = new MongodbUtil();
    
        private MongodbUtil() {
            mongoClient  = new MongoClient("152.136.**.**", 27017);
        }
    
        public static MongodbUtil getInstance() {
            return instance;
        }
    
        // 插入
        public void insert(String collectionName, Document doc, Object id) {
            if (id != null) {
                doc.put("_id", id);
            }
            insertOne(DEFAULT_DATABASE_NAME, collectionName, doc);
        }
    
        private void insertOne(String default_database_name, String collectionName, Document doc) {
            MongoDatabase mongoDatabase = getMondoDatabase(default_database_name);
            mongoDatabase.getCollection(collectionName).insertOne(doc);
    
        }
    
        private MongoDatabase getMondoDatabase(String default_database_name) {
            MongoDatabase database = mongoClient.getDatabase(default_database_name);
            return database;
        }
    
    }

在原有的写日志类中添加保存日志业务 WriteLogUtil.java

private void write(Map<String, String> item) {
            Document document = new Document();
            for (String key : item.keySet()) {
                document.put(key, item.get(key));
            }
            MongodbUtil.getInstance().insert("test", document, null);
        }

### 效果 ###

![format_png][]

### 读日志 ###

package com.zero.na;
    
    import org.bson.Document;
    
    import javax.print.Doc;
    import java.util.List;
    import java.util.Map;
    import java.util.concurrent.ArrayBlockingQueue;
    import java.util.concurrent.BlockingQueue;
    import java.util.concurrent.ExecutorService;
    import java.util.concurrent.Executors;
    
    public class WriteLogUtil {
    
        // 省略......
    
    
        private List<Document> query (String name) {
            return MongodbUtil.getInstance().query("test", name);
        }
    }

package com.zero.na;
    
    import com.mongodb.MongoClient;
    import com.mongodb.client.FindIterable;
    import com.mongodb.client.MongoCollection;
    import com.mongodb.client.MongoCursor;
    import com.mongodb.client.MongoDatabase;
    import com.mongodb.client.model.Filters;
    import org.bson.BsonDocument;
    import org.bson.Document;
    import org.bson.conversions.Bson;
    
    import javax.print.Doc;
    import java.util.ArrayList;
    import java.util.HashMap;
    import java.util.List;
    import java.util.function.Consumer;
    
    /**
     * 芒狗DB 工具类
     */
    public class MongodbUtil {
    
        // 省略.....
    
    
    
        // 查询
        public List<Document> query(String collectionName, String params) {
            return queryList(DEFAULT_DATABASE_NAME, collectionName, params);
        }
    
    
        private List<Document> queryList(String default_database_name, String collectionName, String params) {
            MongoDatabase mongoDatabase = getMondoDatabase(default_database_name);
            MongoCollection<Document> collection = mongoDatabase.getCollection(collectionName);
            Bson filter = Filters.and(Filters.eq("name", params));
    
            FindIterable<Document> list = collection.find(filter);
    
    
            MongoCursor<Document> iterator = list.iterator();
            List<Document> result = new ArrayList<>();
            while (iterator.hasNext()) {
                Document item = iterator.next();
                result.add(item);
            }
            return result;
        }
    
    
    
    
    }

![format_png 1][]

专注分享Java技术，跟我一起学习吧

长按识别二维码关注

![format_png 2][]

![format_png 3][]

[Link 1]: http://mp.weixin.qq.com/s?__biz=MzI1NzU3ODAwMg%3D%3D&chksm=ea140067dd638971a70e95ae5fa6454007897b549d63823c5b94e7405a7979c3906d2601b46a&idx=1&mid=2247484698&scene=21&sn=751526c4a97b185326570766c9f15dea#wechat_redirect
[format_png]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9PalpmWGtUTTYxNkk1WUtRN3Rya1NuaGJxekpjUFFVOXVvUzZXUzVzQk9wRTRLdlRqdktEVlA3a2Y3aFdxR1NVNVBKMWhNNzhoaWFpY2I0eDhMb2pJNXNRLzY0MA?x-oss-process=image/format,png
[format_png 1]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9PalpmWGtUTTYxNkk1WUtRN3Rya1NuaGJxekpjUFFVOVl0bVhHcTRtWVNRYm9yNU5RRWZWT3gwNUhVVnpJamt5SWJKcWI3dVBLOGw4Ym5zQXVPU1JDZy82NDA?x-oss-process=image/format,png
[format_png 2]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9PalpmWGtUTTYxNVZ1aE1sRWplSTBpYm9WamliT3NZZmpXQ3I5T0FmQzdTWEw2eTVVTENpY29JTk9WSWZ5STdmM05FUGxCQllhanc3S0dDb2xVMFpCQlZUUS82NDA?x-oss-process=image/format,png
[format_png 3]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X2pwZy9PalpmWGtUTTYxNVZ1aE1sRWplSTBpYm9WamliT3NZZmpXY0RrWFZtZ1RMVnFJNlhlSmlib0daY2VZS0lZMlZpYThESmU1V1paMWlhS2liMGtvaWJOYVVKblBXVFEvNjQw?x-oss-process=image/format,png