當前位置：首頁 > 运维知识 > windows >内容正文

windows

.Net Core应用搭建的分布式邮件系统设计

發布時間：2023/12/4 windows 24 豆豆

生活随笔收集整理的這篇文章主要介紹了 .Net Core应用搭建的分布式邮件系统设计小編覺得挺不錯的,現在分享給大家,幫大家做個參考.

本篇分享的是由NetCore搭建的分布式郵件系統，主要采用NetCore的Api和控制臺應用程序，由于此系統屬于公司的所以這里只能分享設計圖和一些單純不設計業務的類或方法；

為什么要在公司中首例采用NetCore做開發

為什么要在公司中首例采用NetCore做開發，有些netcoreapi不是還不全面么，您都敢嘗試？恐怕會有人這樣問我，我只能告訴你NetCore現在出2.0版本了，很多Framwork的常用封裝都已經有了，況且她主打的是MVC模式，能夠高效的開發系統，也有很多Core的Nuget包支持了，已經到達了幾乎可以放心大膽使用的地步，退一萬不說有些東西不支持那這又如何，可以采用接口的方式從其他地方對接過來也是一種不錯的處理方案。為了讓C#這門優秀的語言被廣泛應用，默默努力著。

?

正片環節 -?分布式郵件系統設計圖

分布式郵件系統說明

其實由上圖可以知曉這里我主要采用了Api+服務的模式，這也是現在互聯網公司經常采用的一種搭配默認；利用api接受請求插入待發送郵件隊列和入庫，然后通過部署多個NetCore跨平臺服務(這里服務指的是：控制臺應用)來做分布式處理操作，跨平臺服務主要操作有：

. 郵件發送

. 郵件發送狀態的通知（如果需要通知子業務，那么需要通知業務方郵件發送的狀態）

. 通知失敗處理(自動往綁定的責任人發送一封郵件)

. 填充隊列(如果待發郵件隊列或者通知隊列數據不完整，需要修復隊列數據)

Api接口的統一驗證入口

這里我用最簡單的方式，繼承Controller封裝了一個父級的BaseController，來讓各個api的Controller基礎統一來做身份驗證;來看看重寫?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 = "發送者Id無效"; return; }

? ? ? ? ? ? ? ? else if (string.IsNullOrWhiteSpace(baseRq.FuncName)) { moResponse.Msg = "業務方法名不正確"; return; }

? ? ? ? ? ? ? ? //token驗證

? ? ? ? ? ? ? ? var strToken = PublicClass._Md5($"{baseRq.UserName}{baseRq.AccId}", "");

? ? ? ? ? ? ? ? if (!strToken.Equals(baseRq.Token, StringComparison.OrdinalIgnoreCase)) { moResponse.Msg = "Token驗證失敗"; return; }

? ? ? ? ? ? ? ? //驗證發送者Id

? ? ? ? ? ? ? ? if (string.IsNullOrWhiteSpace(baseRq.Ip))

? ? ? ? ? ? ? ? {

? ? ? ? ? ? ? ? ? ? var account = _db.EmailAccount.SingleOrDefault(b => b.Id == baseRq.AccId);

? ? ? ? ? ? ? ? ? ? if (account == null) { moResponse.Msg = "發送者Id無效。"; return; }

? ? ? ? ? ? ? ? ? ? else

? ? ? ? ? ? ? ? ? ? {

? ? ? ? ? ? ? ? ? ? ? ? if (account.Status != (int)EnumHelper.EmStatus.啟用)

? ? ? ? ? ? ? ? ? ? ? ? {

? ? ? ? ? ? ? ? ? ? ? ? ? ? moResponse.Msg = "發送者Id已禁用"; return;

? ? ? ? ? ? ? ? ? ? ? ? }

? ? ? ? ? ? ? ? ? ? ? ? //驗證ip

? ? ? ? ? ? ? ? ? ? ? ? var ipArr = account.AllowIps.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries);

? ? ? ? ? ? ? ? ? ? ? ? //當前請求的Ip

? ? ? ? ? ? ? ? ? ? ? ? var nowIp = this.GetUserIp();

? ? ? ? ? ? ? ? ? ? ? ? baseRq.Ip = nowIp;

? ? ? ? ? ? ? ? ? ? ? ? //默認*為所有ip , 匹配ip

? ? ? ? ? ? ? ? ? ? ? ? if (!ipArr.Any(b => b.Equals("*")) && !ipArr.Any(b => b.Equals(nowIp)))

? ? ? ? ? ? ? ? ? ? ? ? {

? ? ? ? ? ? ? ? ? ? ? ? ? ? moResponse.Msg = "請求IP為授權"; 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 = "發送者未授權"; return; }

? ? ? ? ? ? ? ? ? ? else if (account.Status != (int)EnumHelper.EmStatus.啟用)

? ? ? ? ? ? ? ? ? ? {

? ? ? ? ? ? ? ? ? ? ? ? moResponse.Msg = "發送者Id已禁用"; return;

? ? ? ? ? ? ? ? ? ? }

? ? ? ? ? ? ? ? }

? ? ? ? ? ? ? ? //內容非空，格式驗證

? ? ? ? ? ? ? ? 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(賬號+配置發送者賬號信息的Id+Ip)） ? 必填

? ? ? ? /// </summary>

? ? ? ? public string Token { get; set; }

? ? ? ? /// <summary>

? ? ? ? /// 配置發送者賬號信息的Id ?必填

? ? ? ? /// </summary>

? ? ? ? public int AccId { get; set; }

? ? ? ? /// <summary>

? ? ? ? /// 業務方法名稱

? ? ? ? /// </summary>

? ? ? ? public string FuncName { get; set; }

? ? ? ? /// <summary>

? ? ? ? /// 請求者Ip，如果客戶端沒賦值，默認服務端獲取

? ? ? ? /// </summary>

? ? ? ? public string Ip { get; set; }

? ? }

第三方Nuget包的便利

此郵件系統使用到了第三方包，這也能夠看出有很多朋友正為開源，便利，NetCore的推廣努力著；

首先看看MailKit(郵件發送)包，通過安裝下載命令：?Install-Package MailKit?能夠下載最新包，然后你不需要做太花哨的分裝，只需要正對于郵件發送的服務器，端口，賬號，密碼做一些設置基本就行了，如果可以您可以直接使用我的代碼：

/// <summary>

? ? ? ? /// 發送郵件

? ? ? ? /// </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 = "愛留圖網", 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; }

? ? ? ? ? ? ? ? //設置基本信息

? ? ? ? ? ? ? ? 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

? ? ? ? ? ? ? ? };

? ? ? ? ? ? ? ? //鏈接發送

? ? ? ? ? ? ? ? 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郵箱服務器發送郵件

? ? ? ? ? ? ? ? ? ? client.Connect(host, port, false);

? ? ? ? ? ? ? ? ? ? // Note: since we don't have an OAuth2 token, disable

? ? ? ? ? ? ? ? ? ? // the XOAUTH2 authentication mechanism.

? ? ? ? ? ? ? ? ? ? client.AuthenticationMechanisms.Remove("XOAUTH2");

? ? ? ? ? ? ? ? ? ? //qq郵箱，密碼(安全設置短信獲取后的密碼) ?ufiaszkkulbabejh

? ? ? ? ? ? ? ? ? ? client.Authenticate(userName, userPwd);

? ? ? ? ? ? ? ? ? ? client.Send(message);

? ? ? ? ? ? ? ? ? ? client.Disconnect(true);

? ? ? ? ? ? ? ? }

? ? ? ? ? ? ? ? isOk = true;

? ? ? ? ? ? }

? ? ? ? ? ? catch (Exception ex)

? ? ? ? ? ? {

? ? ? ? ? ? }

? ? ? ? ? ? return isOk;

? ? ? ? }

Redis方面的操作包StackExchange.Redis，現在NetCore支持很多數據庫驅動（例如：Sqlserver，mysql，postgressql，db2等）這么用可以參考下這篇文章AspNetCore - MVC實戰系列（一）之Sqlserver表映射實體模型，不僅如此還支持很多緩存服務（如：Memorycach，Redis），這里講到的就是Redis，我利用Redis的list的隊列特性來做分布式任務存儲，盡管目前我用到的只有一個主Redis服務還沒有業務場景需要用到主從復制等功能；這里分享的代碼是基于StackExchange.Redis基礎上封裝對于string，list的操作：

public class StackRedis : IDisposable

? ? {

? ? ? ? #region 配置屬性 ? 基于 StackExchange.Redis 封裝

? ? ? ? //連接串（注：IP:端口,屬性=,屬性=)

? ? ? ? public string _ConnectionString = "127.0.0.1:6377,password=shenniubuxing3";

? ? ? ? //操作的庫（注：默認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>

? ? ? ? /// 獲取并發鏈接管理器對象

? ? ? ? /// </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>

? ? ? ? /// 獲取操作數據庫對象

? ? ? ? /// </summary>

? ? ? ? /// <returns></returns>

? ? ? ? public IDatabase GetDb()

? ? ? ? {

? ? ? ? ? ? return Manager.GetDatabase(_Db);

? ? ? ? }

? ? ? ? #endregion

? ? ? ? #region 操作方法

? ? ? ? #region string 操作

? ? ? ? /// <summary>

? ? ? ? /// 根據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>

? ? ? ? /// 根據key獲取string結果

? ? ? ? /// </summary>

? ? ? ? /// <param name="key"></param>

? ? ? ? /// <returns></returns>

? ? ? ? public async Task<string> Get(string key)

? ? ? ? {

? ? ? ? ? ? var db = this.GetDb();

? ? ? ? ? ? return await db.StringGetAsync(key);

? ? ? ? }

? ? ? ? /// <summary>

? ? ? ? /// 根據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數據

? ? ? ? /// </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>

? ? ? ? /// 存儲對象數據到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操作（注：可以當做隊列使用）

? ? ? ? /// <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>

? ? ? ? /// 獲取隊列出口數據并移除

? ? ? ? /// </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 額外擴展

? ? ? ? /// <summary>

? ? ? ? /// 手動回收管理器對象

? ? ? ? /// </summary>

? ? ? ? public void Dispose()

? ? ? ? {

? ? ? ? ? ? this.Dispose(_redis);

? ? ? ? }

? ? ? ? public void Dispose(ConnectionMultiplexer con)

? ? ? ? {

? ? ? ? ? ? if (con != null)

? ? ? ? ? ? {

? ? ? ? ? ? ? ? con.Close();

? ? ? ? ? ? ? ? con.Dispose();

? ? ? ? ? ? }

? ? ? ? }

? ? ? ? #endregion

? ? }

用到Redis的那些操作就添加哪些就行了，也不用太花哨能用就行；

如何生成跨平臺的api服務和應用程序服務

這小節的內容最重要，由于之前有相關的文章，這里就不用再贅述了，來這里看看：Asp.NetCore1.1版本沒了project.json，這樣來生成跨平臺包

原文地址：http://www.cnblogs.com/wangrudong003/p/6898386.html

.NET社區新聞，深度好文，微信中搜索dotNET跨平臺或掃描二維碼關注

總結

以上是生活随笔為你收集整理的.Net Core应用搭建的分布式邮件系统设计的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。

上一篇： asp.net core中负载均衡场景下
下一篇： .NET开源MSSQL、Redis监控产