分析Dictionary实现日志数据批量插入
副问题[/!--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)) (编辑:湖南网) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |