我造了一个轮子去写系统日志

た入场券 2023-02-21 11:47 17阅读 0赞

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

### 前言 ###

在我们工作的项目中，每个项目都会涉及到操作日志，每个公司当然也有自己的想法自己做操作日志的保存。我今天造了一个简单的轮子来写日志。采用的技术是**Executors**跟**BlockingQueue**。

### Executors ###

![image-20200425222018584][]

一个线程池接口，定义了一个可以接收Runnable对象的方法executor，该方法接收要给Runnable实例后，可以用来执行一个任务，一般使用execute（new RunnableTask()）方法异步执行。

为什么要开另外一个线程？

为什么要异步执行？因为这里考虑到操作日志不应该影响到我们的性能，我们在操作之后，无需等到日志写完才response。

### BlockingQueue ###

**Blocking** 即为阻塞,**Queue**即为队列，BlockingQueue阻塞队列类。

其实就是一个队列的数据结构，线程一直以队列的数据结构从BlockingQueue里面拿数据，如果没数据了，那么线程就一直阻塞进入等待状态，一直等一直等，直到有其他线程在BlockingQueue中添加了数据，被阻塞的线程被唤醒。同样，如果BlockingQueue是满的，有线程从队列中存放数据，线程也会被阻塞，一直等一直等，等到不满的时候，线程唤醒，继续存放数据。

### 实例 ###

操作内容

package com.zero.na;
    
    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 ExecutorService executorService;
        private BlockingQueue<Map<String, String>> bqBuff;
    
        public WriteLogUtil() {
            executorService = Executors.newSingleThreadExecutor();
            bqBuff = new ArrayBlockingQueue<>(1024);
    
            executorService.execute(new Runnable() {
                @Override
                public void run() {
                    while (true) {
                        Map<String, String> item = null;
                        try {
                            item = bqBuff.take();
                        } catch (InterruptedException e) {
                            e.printStackTrace();
                        }
                        if (item != null) {
                            write(item);
                        }
    
                    }
                }
            });
        }
    
        private final static WriteLogUtil instance = new WriteLogUtil();
    
        public static WriteLogUtil getInstance() {
            return instance;
        }
    
        public void appLog(Map<String, String> log) {
            saveLog(log);
        }
    
        private void saveLog(Map<String, String> log) {
            bqBuff.add(log);
        }
    
        private void write(Map<String, String> item) {
            System.out.println(item);
        }
    }

测试1

package com.zero.na;
    
    import java.util.HashMap;
    import java.util.Map;
    
    public class Test1 {
    
        public static void main(String[] args) {
            WriteLogUtil instance = WriteLogUtil.getInstance();
            Map<String, String> map = new HashMap<>();
            map.put("name", "zero");
            map.put("detail", "第一个客户支付了十块钱");
    
            instance.appLog(map);
    
        }
    }

测试2

package com.zero.na;
    
    import java.util.HashMap;
    import java.util.Map;
    
    public class Test2 {
    
        public static void main(String[] args) {
            WriteLogUtil instance = WriteLogUtil.getInstance();
            Map<String, String> map = new HashMap<>();
            map.put("name", "zero");
            map.put("detail", "第二个客户支付了二十块钱");
    
            instance.appLog(map);
    
        }
    }

![image-20200425230014318][]

我们可以看到这个线程永远都不会停止，因为我们会有一个线程一直在while（true），一直在执行，永远都在等待。这个时候我们的用例写好了。这个时候我们的日志可以选择写在MongoDB数据库中。

这个我们下篇讲。。。。。。

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

长按识别二维码关注

![format_png][]

![format_png 1][]

[image-20200425222018584]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9PalpmWGtUTTYxNUZWYm90bWg4T2ZpY1gzNEVlcnl4aFhDZngyNDJkQlIySjRwNk9nekdQRXpNZjJmaWJod1FkSXlpYjhWaWNhVHE4V050SG1YQ0NyVE5lRXcvNjQw?x-oss-process=image/format,png
[image-20200425230014318]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9PalpmWGtUTTYxNUZWYm90bWg4T2ZpY1gzNEVlcnl4aFhSNktGZDFUWmlha1RvNzB2eVZacTdlbllRSzl0bXZYSFp1T3FzTmtTUDNjZGs1d1dKYzVUaWFWZy82NDA?x-oss-process=image/format,png
[format_png]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X3BuZy9PalpmWGtUTTYxNVZ1aE1sRWplSTBpYm9WamliT3NZZmpXQ3I5T0FmQzdTWEw2eTVVTENpY29JTk9WSWZ5STdmM05FUGxCQllhanc3S0dDb2xVMFpCQlZUUS82NDA?x-oss-process=image/format,png
[format_png 1]: https://imgconvert.csdnimg.cn/aHR0cHM6Ly9tbWJpei5xcGljLmNuL21tYml6X2pwZy9PalpmWGtUTTYxNVZ1aE1sRWplSTBpYm9WamliT3NZZmpXY0RrWFZtZ1RMVnFJNlhlSmlib0daY2VZS0lZMlZpYThESmU1V1paMWlhS2liMGtvaWJOYVVKblBXVFEvNjQw?x-oss-process=image/format,png