189 8069 5689

Dictionary中怎么批量插入日志数据

本篇文章为大家展示了Dictionary中怎么批量插入日志数据,内容简明扼要并且容易理解,绝对能使你眼前一亮,通过这篇文章的详细介绍希望你能有所收获。

我们是于2013年成立的成都网站建设公司,提供网站建设,电商网站设计开发,成都外贸网站制作,响应式网页设计,微信小程序、等服务。为客户创造有价值的品牌营销体验,让互联网提升企业的竞争力!

问题窥探

首先,我想到的是Dictionary,对于C#中的Dictionary类相信大家都不陌生,这是一个Collection(集合)类型,可以通过Key/Value(键值对的形式来存放数据;该类最大的优点就是它查找元素的时间复杂度接近O(1),实际项目中常被用来做一些数据的本地缓存,提升整体效率。Dictionary是非线程安全的类型,可以实现先添加到内存当中,在批量保存进去数据库。

主要代码实现

1、定义一个Dictionary。

private readonly Dictionary> _storage = new Dictionary>(StringComparer.OrdinalIgnoreCase);

2、添加元素,操作的时候需要对其进行线程安全处理,最简单的方式就是加锁(lock)。

public bool SaveObject(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))                 throw new ArgumentNullException("path");              lock (_lock) {                 if (!_storage.ContainsKey(path))                     return false;                  _storage.Remove(path);             }              return true;         }
public IEnumerable GetObjectList(string searchPattern = null, int? limit = null, DateTime? maxCreatedDate = null) {             if (searchPattern == null)                 searchPattern = "*";             if (!maxCreatedDate.HasValue)                 maxCreatedDate = DateTime.MaxValue;              var regex = new Regex("^" + Regex.Escape(searchPattern).Replace("\\*", ".*?") + "$");             lock (_lock)                 return _storage.Keys.Where(k => regex.IsMatch(k)).Select(k => _storage[k].Item1).Where(f => f.Created <= maxCreatedDate).Take(limit ?? Int32.MaxValue).ToList();         }

上述内容就是Dictionary中怎么批量插入日志数据,你们学到知识或技能了吗?如果还想学到更多技能或者丰富自己的知识储备,欢迎关注创新互联行业资讯频道。


网站栏目:Dictionary中怎么批量插入日志数据
转载来于:http://cdxtjz.cn/article/ighgoi.html

其他资讯