.Net Core应用搭建的分布式邮件系统设计
本篇分享的是由NetCore搭建的分布式郵件系統(tǒng)，主要采用NetCore的Api和控制臺應(yīng)用程序，由于此系統(tǒng)屬于公司的所以這里只能分享設(shè)計圖和一些單純不設(shè)計業(yè)務(wù)的類或方法；
為什么要在公司中首例采用NetCore做開發(fā)
為什么要在公司中首例采用NetCore做開發(fā)，有些netcoreapi不是還不全面么，您都敢嘗試？恐怕會有人這樣問我，我只能告訴你NetCore現(xiàn)在出2.0版本了，很多Framwork的常用封裝都已經(jīng)有了，況且她主打的是MVC模式，能夠高效的開發(fā)系統(tǒng)，也有很多Core的Nuget包支持了，已經(jīng)到達(dá)了幾乎可以放心大膽使用的地步，退一萬不說有些東西不支持那這又如何，可以采用接口的方式從其他地方對接過來也是一種不錯的處理方案。為了讓C#這門優(yōu)秀的語言被廣泛應(yīng)用，默默努力著。
?
正片環(huán)節(jié) -?分布式郵件系統(tǒng)設(shè)計圖
分布式郵件系統(tǒng)說明
其實由上圖可以知曉這里我主要采用了Api+服務(wù)的模式，這也是現(xiàn)在互聯(lián)網(wǎng)公司經(jīng)常采用的一種搭配默認(rèn)；利用api接受請求插入待發(fā)送郵件隊列和入庫，然后通過部署多個NetCore跨平臺服務(wù)(這里服務(wù)指的是：控制臺應(yīng)用)來做分布式處理操作，跨平臺服務(wù)主要操作有：
. 郵件發(fā)送
. 郵件發(fā)送狀態(tài)的通知（如果需要通知子業(yè)務(wù)，那么需要通知業(yè)務(wù)方郵件發(fā)送的狀態(tài)）
. 通知失敗處理(自動往綁定的責(zé)任人發(fā)送一封郵件)
. 填充隊列(如果待發(fā)郵件隊列或者通知隊列數(shù)據(jù)不完整，需要修復(fù)隊列數(shù)據(jù))
Api接口的統(tǒng)一驗證入口
這里我用最簡單的方式，繼承Controller封裝了一個父級的BaseController，來讓各個api的Controller基礎(chǔ)統(tǒng)一來做身份驗證;來看看重寫?public override void OnActionExecuting(ActionExecutingContext context)?的驗證代碼：
public override void OnActionExecuting(ActionExecutingContext context)
? ? ? ? {
? ? ? ? ? ? base.OnActionExecuting(context);
? ? ? ? ? ? var moResponse = new MoBaseRp();
? ? ? ? ? ? try
? ? ? ? ? ? {
? ? ? ? ? ? ? ? #region 安全性驗證
? ? ? ? ? ? ? ? var key = "request";
? ? ? ? ? ? ? ? if (!context.ActionArguments.ContainsKey(key)) { moResponse.Msg = "請求方式不正確"; return; }
? ? ? ? ? ? ? ? var request = context.ActionArguments[key];
? ? ? ? ? ? ? ? var baseRq = request as MoBaseRq;
? ? ? ? ? ? ? ? //暫時不驗證登錄賬號密碼
? ? ? ? ? ? ? ? if (string.IsNullOrWhiteSpace(baseRq.UserName) || string.IsNullOrWhiteSpace(baseRq.UserPwd)) { moResponse.Msg = "登錄賬號或密碼不能為空"; return; }
? ? ? ? ? ? ? ? else if (baseRq.AccId <= 0) { moResponse.Msg = "發(fā)送者Id無效"; return; }
? ? ? ? ? ? ? ? else if (string.IsNullOrWhiteSpace(baseRq.FuncName)) { moResponse.Msg = "業(yè)務(wù)方法名不正確"; return; }
? ? ? ? ? ? ? ? //token驗證
? ? ? ? ? ? ? ? var strToken = PublicClass._Md5($"{baseRq.UserName}{baseRq.AccId}", "");
? ? ? ? ? ? ? ? if (!strToken.Equals(baseRq.Token, StringComparison.OrdinalIgnoreCase)) { moResponse.Msg = "Token驗證失敗"; return; }
? ? ? ? ? ? ? ? //驗證發(fā)送者Id
? ? ? ? ? ? ? ? if (string.IsNullOrWhiteSpace(baseRq.Ip))
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? var account = _db.EmailAccount.SingleOrDefault(b => b.Id == baseRq.AccId);
? ? ? ? ? ? ? ? ? ? if (account == null) { moResponse.Msg = "發(fā)送者Id無效。"; return; }
? ? ? ? ? ? ? ? ? ? else
? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? if (account.Status != (int)EnumHelper.EmStatus.啟用)
? ? ? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? ? ? moResponse.Msg = "發(fā)送者Id已禁用"; return;
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? ? ? //驗證ip
? ? ? ? ? ? ? ? ? ? ? ? var ipArr = account.AllowIps.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries);
? ? ? ? ? ? ? ? ? ? ? ? //當(dāng)前請求的Ip
? ? ? ? ? ? ? ? ? ? ? ? var nowIp = this.GetUserIp();
? ? ? ? ? ? ? ? ? ? ? ? baseRq.Ip = nowIp;
? ? ? ? ? ? ? ? ? ? ? ? //默認(rèn)*為所有ip , 匹配ip
? ? ? ? ? ? ? ? ? ? ? ? if (!ipArr.Any(b => b.Equals("*")) && !ipArr.Any(b => b.Equals(nowIp)))
? ? ? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? ? ? moResponse.Msg = "請求IP為授權(quán)"; return;
? ? ? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? else
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? var account = _db.EmailAccount.SingleOrDefault(b => b.Id == baseRq.AccId && b.AllowIps.Any(bb => bb.Equals(baseRq.Ip)));
? ? ? ? ? ? ? ? ? ? if (account == null) { moResponse.Msg = "發(fā)送者未授權(quán)"; return; }
? ? ? ? ? ? ? ? ? ? else if (account.Status != (int)EnumHelper.EmStatus.啟用)
? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? moResponse.Msg = "發(fā)送者Id已禁用"; return;
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? //內(nèi)容非空，格式驗證
? ? ? ? ? ? ? ? if (!context.ModelState.IsValid)
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? var values = context.ModelState.Values.Where(b => b.Errors.Count > 0);
? ? ? ? ? ? ? ? ? ? if (values.Count() > 0)
? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? moResponse.Msg = values.First().Errors.First().ErrorMessage;
? ? ? ? ? ? ? ? ? ? ? ? return;
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? #endregion
? ? ? ? ? ? ? ? moResponse.Status = 1;
? ? ? ? ? ? }
? ? ? ? ? ? catch (Exception ex)
? ? ? ? ? ? {
? ? ? ? ? ? ? ? moResponse.Msg = "O No請求信息錯誤";
? ? ? ? ? ? }
? ? ? ? ? ? finally
? ? ? ? ? ? {
? ? ? ? ? ? ? ? if (moResponse.Status == 0) { context.Result = Json(moResponse); ? ? ? ? ? ? }
? ? ? ? ? ? }
? ? ? ? }
郵件請求父類實體：
/// <summary>
? ? /// 郵件請求父類
? ? /// </summary>
? ? public class MoBaseRq
? ? {
? ? ? ? public string UserName { get; set; }
? ? ? ? public string UserPwd { get; set; }
? ? ? ? /// <summary>
? ? ? ? /// 驗證token（Md5(賬號+配置發(fā)送者賬號信息的Id+Ip)） ? 必填
? ? ? ? /// </summary>
? ? ? ? public string Token { get; set; }
? ? ? ? /// <summary>
? ? ? ? /// 配置發(fā)送者賬號信息的Id ?必填
? ? ? ? /// </summary>
? ? ? ? public int AccId { get; set; }
? ? ? ? /// <summary>
? ? ? ? /// 業(yè)務(wù)方法名稱
? ? ? ? /// </summary>
? ? ? ? public string FuncName { get; set; }
? ? ? ? /// <summary>
? ? ? ? /// 請求者Ip，如果客戶端沒賦值，默認(rèn)服務(wù)端獲取
? ? ? ? /// </summary>
? ? ? ? public string Ip { get; set; }
? ? }
第三方Nuget包的便利
此郵件系統(tǒng)使用到了第三方包，這也能夠看出有很多朋友正為開源，便利，NetCore的推廣努力著；
首先看看MailKit(郵件發(fā)送)包，通過安裝下載命令：?Install-Package MailKit?能夠下載最新包，然后你不需要做太花哨的分裝，只需要正對于郵件發(fā)送的服務(wù)器，端口，賬號，密碼做一些設(shè)置基本就行了，如果可以您可以直接使用我的代碼：
/// <summary>
? ? ? ? /// 發(fā)送郵件
? ? ? ? /// </summary>
? ? ? ? /// <param name="dicToEmail"></param>
? ? ? ? /// <param name="title"></param>
? ? ? ? /// <param name="content"></param>
? ? ? ? /// <param name="name"></param>
? ? ? ? /// <param name="fromEmail"></param>
? ? ? ? /// <returns></returns>
? ? ? ? public static bool _SendEmail(
? ? ? ? ? ? Dictionary<string, string> dicToEmail,
? ? ? ? ? ? string title, string content,
? ? ? ? ? ? string name = "愛留圖網(wǎng)", string fromEmail = "841202396@qq.com",
? ? ? ? ? ? string host = "smtp.qq.com", int port = 587,
? ? ? ? ? ? string userName = "841202396@qq.com", string userPwd = "123123")
? ? ? ? {
? ? ? ? ? ? var isOk = false;
? ? ? ? ? ? try
? ? ? ? ? ? {
? ? ? ? ? ? ? ? if (string.IsNullOrWhiteSpace(title) || string.IsNullOrWhiteSpace(content)) { return isOk; }
? ? ? ? ? ? ? ? //設(shè)置基本信息
? ? ? ? ? ? ? ? var message = new MimeMessage();
? ? ? ? ? ? ? ? message.From.Add(new MailboxAddress(name, fromEmail));
? ? ? ? ? ? ? ? foreach (var item in dicToEmail.Keys)
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? message.To.Add(new MailboxAddress(item, dicToEmail[item]));
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? message.Subject = title;
? ? ? ? ? ? ? ? message.Body = new TextPart("html")
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? Text = content
? ? ? ? ? ? ? ? };
? ? ? ? ? ? ? ? //鏈接發(fā)送
? ? ? ? ? ? ? ? using (var client = new SmtpClient())
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? // For demo-purposes, accept all SSL certificates (in case the server supports STARTTLS)
? ? ? ? ? ? ? ? ? ? client.ServerCertificateValidationCallback = (s, c, h, e) => true;
? ? ? ? ? ? ? ? ? ? //采用qq郵箱服務(wù)器發(fā)送郵件
? ? ? ? ? ? ? ? ? ? client.Connect(host, port, false);
? ? ? ? ? ? ? ? ? ? // Note: since we don't have an OAuth2 token, disable
? ? ? ? ? ? ? ? ? ? // the XOAUTH2 authentication mechanism.
? ? ? ? ? ? ? ? ? ? client.AuthenticationMechanisms.Remove("XOAUTH2");
? ? ? ? ? ? ? ? ? ? //qq郵箱，密碼(安全設(shè)置短信獲取后的密碼) ?ufiaszkkulbabejh
? ? ? ? ? ? ? ? ? ? client.Authenticate(userName, userPwd);
? ? ? ? ? ? ? ? ? ? client.Send(message);
? ? ? ? ? ? ? ? ? ? client.Disconnect(true);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? isOk = true;
? ? ? ? ? ? }
? ? ? ? ? ? catch (Exception ex)
? ? ? ? ? ? {
? ? ? ? ? ? }
? ? ? ? ? ? return isOk;
? ? ? ? }
Redis方面的操作包StackExchange.Redis，現(xiàn)在NetCore支持很多數(shù)據(jù)庫驅(qū)動（例如：Sqlserver，mysql，postgressql，db2等）這么用可以參考下這篇文章AspNetCore - MVC實戰(zhàn)系列（一）之Sqlserver表映射實體模型，不僅如此還支持很多緩存服務(wù)（如：Memorycach，Redis），這里講到的就是Redis，我利用Redis的list的隊列特性來做分布式任務(wù)存儲，盡管目前我用到的只有一個主Redis服務(wù)還沒有業(yè)務(wù)場景需要用到主從復(fù)制等功能；這里分享的代碼是基于StackExchange.Redis基礎(chǔ)上封裝對于string，list的操作：
public class StackRedis : IDisposable
? ? {
? ? ? ? #region 配置屬性 ? 基于 StackExchange.Redis 封裝
? ? ? ? //連接串 （注：IP:端口,屬性=,屬性=)
? ? ? ? public string _ConnectionString = "127.0.0.1:6377,password=shenniubuxing3";
? ? ? ? //操作的庫（注：默認(rèn)0庫）
? ? ? ? public int _Db = 0;
? ? ? ? #endregion
? ? ? ? #region 管理器對象
? ? ? ? /// <summary>
? ? ? ? /// 獲取redis操作類對象
? ? ? ? /// </summary>
? ? ? ? private static StackRedis _StackRedis;
? ? ? ? private static object _locker_StackRedis = new object();
? ? ? ? public static StackRedis Current
? ? ? ? {
? ? ? ? ? ? get
? ? ? ? ? ? {
? ? ? ? ? ? ? ? if (_StackRedis == null)
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? lock (_locker_StackRedis)
? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? _StackRedis = _StackRedis ?? new StackRedis();
? ? ? ? ? ? ? ? ? ? ? ? return _StackRedis;
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? return _StackRedis;
? ? ? ? ? ? }
? ? ? ? }
? ? ? ? /// <summary>
? ? ? ? /// 獲取并發(fā)鏈接管理器對象
? ? ? ? /// </summary>
? ? ? ? private static ConnectionMultiplexer _redis;
? ? ? ? private static object _locker = new object();
? ? ? ? public ConnectionMultiplexer Manager
? ? ? ? {
? ? ? ? ? ? get
? ? ? ? ? ? {
? ? ? ? ? ? ? ? if (_redis == null)
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? lock (_locker)
? ? ? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ? ? _redis = _redis ?? GetManager(this._ConnectionString);
? ? ? ? ? ? ? ? ? ? ? ? return _redis;
? ? ? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? return _redis;
? ? ? ? ? ? }
? ? ? ? }
? ? ? ? /// <summary>
? ? ? ? /// 獲取鏈接管理器
? ? ? ? /// </summary>
? ? ? ? /// <param name="connectionString"></param>
? ? ? ? /// <returns></returns>
? ? ? ? public ConnectionMultiplexer GetManager(string connectionString)
? ? ? ? {
? ? ? ? ? ? return ConnectionMultiplexer.Connect(connectionString);
? ? ? ? }
? ? ? ? /// <summary>
? ? ? ? /// 獲取操作數(shù)據(jù)庫對象
? ? ? ? /// </summary>
? ? ? ? /// <returns></returns>
? ? ? ? public IDatabase GetDb()
? ? ? ? {
? ? ? ? ? ? return Manager.GetDatabase(_Db);
? ? ? ? }
? ? ? ? #endregion
? ? ? ? #region 操作方法
? ? ? ? #region string 操作
? ? ? ? /// <summary>
? ? ? ? /// 根據(jù)Key移除
? ? ? ? /// </summary>
? ? ? ? /// <param name="key"></param>
? ? ? ? /// <returns></returns>
? ? ? ? public async Task<bool> Remove(string key)
? ? ? ? {
? ? ? ? ? ? var db = this.GetDb();
? ? ? ? ? ? return await db.KeyDeleteAsync(key);
? ? ? ? }
? ? ? ? /// <summary>
? ? ? ? /// 根據(jù)key獲取string結(jié)果
? ? ? ? /// </summary>
? ? ? ? /// <param name="key"></param>
? ? ? ? /// <returns></returns>
? ? ? ? public async Task<string> Get(string key)
? ? ? ? {
? ? ? ? ? ? var db = this.GetDb();
? ? ? ? ? ? return await db.StringGetAsync(key);
? ? ? ? }
? ? ? ? /// <summary>
? ? ? ? /// 根據(jù)key獲取string中的對象
? ? ? ? /// </summary>
? ? ? ? /// <typeparam name="T"></typeparam>
? ? ? ? /// <param name="key"></param>
? ? ? ? /// <returns></returns>
? ? ? ? public async Task<T> Get<T>(string key)
? ? ? ? {
? ? ? ? ? ? var t = default(T);
? ? ? ? ? ? try
? ? ? ? ? ? {
? ? ? ? ? ? ? ? var _str = await this.Get(key);
? ? ? ? ? ? ? ? if (string.IsNullOrWhiteSpace(_str)) { return t; }
? ? ? ? ? ? ? ? t = JsonConvert.DeserializeObject<T>(_str);
? ? ? ? ? ? }
? ? ? ? ? ? catch (Exception ex) { }
? ? ? ? ? ? return t;
? ? ? ? }
? ? ? ? /// <summary>
? ? ? ? /// 存儲string數(shù)據(jù)
? ? ? ? /// </summary>
? ? ? ? /// <param name="key"></param>
? ? ? ? /// <param name="value"></param>
? ? ? ? /// <param name="expireMinutes"></param>
? ? ? ? /// <returns></returns>
? ? ? ? public async Task<bool> Set(string key, string value, int expireMinutes = 0)
? ? ? ? {
? ? ? ? ? ? var db = this.GetDb();
? ? ? ? ? ? if (expireMinutes > 0)
? ? ? ? ? ? {
? ? ? ? ? ? ? ? return db.StringSet(key, value, TimeSpan.FromMinutes(expireMinutes));
? ? ? ? ? ? }
? ? ? ? ? ? return await db.StringSetAsync(key, value);
? ? ? ? }
? ? ? ? /// <summary>
? ? ? ? /// 存儲對象數(shù)據(jù)到string
? ? ? ? /// </summary>
? ? ? ? /// <typeparam name="T"></typeparam>
? ? ? ? /// <param name="key"></param>
? ? ? ? /// <param name="value"></param>
? ? ? ? /// <param name="expireMinutes"></param>
? ? ? ? /// <returns></returns>
? ? ? ? public async Task<bool> Set<T>(string key, T value, int expireMinutes = 0)
? ? ? ? {
? ? ? ? ? ? try
? ? ? ? ? ? {
? ? ? ? ? ? ? ? var jsonOption = new JsonSerializerSettings()
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ReferenceLoopHandling = ReferenceLoopHandling.Ignore
? ? ? ? ? ? ? ? };
? ? ? ? ? ? ? ? var _str = JsonConvert.SerializeObject(value, jsonOption);
? ? ? ? ? ? ? ? if (string.IsNullOrWhiteSpace(_str)) { return false; }
? ? ? ? ? ? ? ? return await this.Set(key, _str, expireMinutes);
? ? ? ? ? ? }
? ? ? ? ? ? catch (Exception ex) { }
? ? ? ? ? ? return false;
? ? ? ? }
? ? ? ? #endregion
? ? ? ? #region List操作（注：可以當(dāng)做隊列使用）
? ? ? ? /// <summary>
? ? ? ? /// list長度
? ? ? ? /// </summary>
? ? ? ? /// <typeparam name="T"></typeparam>
? ? ? ? /// <param name="key"></param>
? ? ? ? /// <returns></returns>
? ? ? ? public async Task<long> GetListLen<T>(string key)
? ? ? ? {
? ? ? ? ? ? try
? ? ? ? ? ? {
? ? ? ? ? ? ? ? var db = this.GetDb();
? ? ? ? ? ? ? ? return await db.ListLengthAsync(key);
? ? ? ? ? ? }
? ? ? ? ? ? catch (Exception ex) { }
? ? ? ? ? ? return 0;
? ? ? ? }
? ? ? ? /// <summary>
? ? ? ? /// 獲取隊列出口數(shù)據(jù)并移除
? ? ? ? /// </summary>
? ? ? ? /// <typeparam name="T"></typeparam>
? ? ? ? /// <param name="key"></param>
? ? ? ? /// <returns></returns>
? ? ? ? public async Task<T> GetListAndPop<T>(string key)
? ? ? ? {
? ? ? ? ? ? var t = default(T);
? ? ? ? ? ? try
? ? ? ? ? ? {
? ? ? ? ? ? ? ? var db = this.GetDb();
? ? ? ? ? ? ? ? var _str = await db.ListRightPopAsync(key);
? ? ? ? ? ? ? ? if (string.IsNullOrWhiteSpace(_str)) { return t; }
? ? ? ? ? ? ? ? t = JsonConvert.DeserializeObject<T>(_str);
? ? ? ? ? ? }
? ? ? ? ? ? catch (Exception ex) { }
? ? ? ? ? ? return t;
? ? ? ? }
? ? ? ? /// <summary>
? ? ? ? /// 集合對象添加到list左邊
? ? ? ? /// </summary>
? ? ? ? /// <typeparam name="T"></typeparam>
? ? ? ? /// <param name="key"></param>
? ? ? ? /// <param name="values"></param>
? ? ? ? /// <returns></returns>
? ? ? ? public async Task<long> SetLists<T>(string key, List<T> values)
? ? ? ? {
? ? ? ? ? ? var result = 0L;
? ? ? ? ? ? try
? ? ? ? ? ? {
? ? ? ? ? ? ? ? var jsonOption = new JsonSerializerSettings()
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? ReferenceLoopHandling = ReferenceLoopHandling.Ignore
? ? ? ? ? ? ? ? };
? ? ? ? ? ? ? ? var db = this.GetDb();
? ? ? ? ? ? ? ? foreach (var item in values)
? ? ? ? ? ? ? ? {
? ? ? ? ? ? ? ? ? ? var _str = JsonConvert.SerializeObject(item, jsonOption);
? ? ? ? ? ? ? ? ? ? result += await db.ListLeftPushAsync(key, _str);
? ? ? ? ? ? ? ? }
? ? ? ? ? ? ? ? return result;
? ? ? ? ? ? }
? ? ? ? ? ? catch (Exception ex) { }
? ? ? ? ? ? return result;
? ? ? ? }
? ? ? ? /// <summary>
? ? ? ? /// 單個對象添加到list左邊
? ? ? ? /// </summary>
? ? ? ? /// <typeparam name="T"></typeparam>
? ? ? ? /// <param name="key"></param>
? ? ? ? /// <param name="value"></param>
? ? ? ? /// <returns></returns>
? ? ? ? public async Task<long> SetList<T>(string key, T value)
? ? ? ? {
? ? ? ? ? ? var result = 0L;
? ? ? ? ? ? try
? ? ? ? ? ? {
? ? ? ? ? ? ? ? result = await this.SetLists(key, new List<T> { value });
? ? ? ? ? ? }
? ? ? ? ? ? catch (Exception ex) { }
? ? ? ? ? ? return result;
? ? ? ? }
? ? ? ? #endregion
? ? ? ? #region 額外擴(kuò)展
? ? ? ? /// <summary>
? ? ? ? /// 手動回收管理器對象
? ? ? ? /// </summary>
? ? ? ? public void Dispose()
? ? ? ? {
? ? ? ? ? ? this.Dispose(_redis);
? ? ? ? }
? ? ? ? public void Dispose(ConnectionMultiplexer con)
? ? ? ? {
? ? ? ? ? ? if (con != null)
? ? ? ? ? ? {
? ? ? ? ? ? ? ? con.Close();
? ? ? ? ? ? ? ? con.Dispose();
? ? ? ? ? ? }
? ? ? ? }
? ? ? ? #endregion
? ? ? ? #endregion
? ? }
用到Redis的那些操作就添加哪些就行了，也不用太花哨能用就行；
如何生成跨平臺的api服務(wù)和應(yīng)用程序服務(wù)
這小節(jié)的內(nèi)容最重要，由于之前有相關(guān)的文章，這里就不用再贅述了，來這里看看：Asp.NetCore1.1版本沒了project.json，這樣來生成跨平臺包
原文地址：http://www.cnblogs.com/wangrudong003/p/6898386.html
.NET社區(qū)新聞，深度好文，微信中搜索dotNET跨平臺或掃描二維碼關(guān)注
總結(jié)
以上是生活随笔為你收集整理的.Net Core应用搭建的分布式邮件系统设计的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： asp.net core中负载均衡场景下
- 下一篇： 互联网级监控系统必备-时序数据库之Inf