加入收藏 | 设为首页 | 会员中心 | 我要投稿 湖南网 (https://www.hunanwang.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 编程 > 正文

分析Dictionary实现日志数据批量插入

发布时间:2021-06-03 18:48:34 所属栏目:编程 来源:互联网
导读:最近再做一个需求,就是对站点的一些变乱举办埋点,说白了就是记任命户的会见举动。那么这些数据怎么生涯呢,人家点一下生涯一下?显然不吻合,必定是必要批量保
副问题[/!--empirenews.page--]

最近再做一个需求,就是对站点的一些变乱举办埋点,说白了就是记任命户的会见举动。那么这些数据怎么生涯呢,人家点一下生涯一下?显然不吻合,必定是必要批量生涯,进步服从。

题目窥伺

起首,我想到的是Dictionary,对付C#中的Dictionary类信托各人都不生疏,这是一个Collection(荟萃)范例,可以通过Key/Value(键值对的情势来存放数据;该类最大的利益就是它查找元素的时刻伟大度靠近O(1),现实项目中常被用来做一些数据的当地缓存,晋升整体服从。Dictionary长短线程安详的范例,可以实现先添加到内存傍边,在批量生涯进去数据库。

首要代码实现

1、界说一个Dictionary。

private readonly Dictionary<string, Tuple<ObjectInfo, object>> _storage = new Dictionary<string, Tuple<ObjectInfo, object>>(StringComparer.OrdinalIgnoreCase); 

2、添加元素,操纵的时辰必要对其举办线程安详处理赏罚,最简朴的方法就是加锁(lock)。

public bool SaveObject<T>(string path, T value) where T : class { 

            if (String.IsNullOrWhiteSpace(path)) 

                throw new ArgumentNullException("path"); 

 

            lock (_lock) { 

                _storage[path] = Tuple.Create(new ObjectInfo { 

                    Created = DateTime.Now, 

                    Modified = DateTime.Now, 

                    Path = path 

                }, (object)value); 

 

                if (_storage.Count > MaxObjects) 

                    _storage.Remove(_storage.OrderByDescending(kvp => kvp.Value.Item1.Created).First().Key); 

            } 

 

            return true; 

        } 

3、界说一个行列,按时斲丧日记。

public DefaultEventQueue(ExceptionlessConfiguration config, IExceptionlessLog log, ISubmissionClient client, IObjectStorage objectStorage, IJsonSerializer serializer, TimeSpan? processQueueInterval, TimeSpan? queueStartDelay) { 

            _log = log; 

            _config = config; 

            _client = client; 

            _storage = objectStorage; 

            _serializer = serializer; 

            if (processQueueInterval.HasValue) 

                _processQueueInterval = processQueueInterval.Value; 

 

            _queueTimer = new Timer(OnProcessQueue, null, queueStartDelay ?? TimeSpan.FromSeconds(2), _processQueueInterval); 

        } 

这里删除的时辰也必要lock 操纵。

public bool DeleteObject(string path) { 

            if (String.IsNullOrWhiteSpace(path)) 

(编辑:湖南网)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

热点阅读