C#多线程异步连接MySQL与SQLserver数据库

一、前言

当编写代码连接多台设备上的数据库时，如果采用同步逐个连接的方式，在网络流通的环境下连接速度尚可，但当其中一台设备网络不佳特殊是处于关机状态时，等候数据库连接同时程序无法相应的时间会大幅度增长，即使设置Connect Timeout也无法缩短等候时间，由于此时是程序在等候TCP应答，等候时间通常是由 TCP 协议本身的机制控制。
思量到此类异常环境的处置惩罚，可以利用多线程连接技术，利用线程控制连接超时题目，而异步连接可以在进行连接的同时进行其他操作。
二、多线程异步连接数据库代码

2.1代码块

1. private async Task<(bool isSuccess, string message)> TryConnectWithTimeoutAsync(object conn, int timeout)
2. {
3.     Stopwatch sw = new Stopwatch();
4.     bool connectSuccess = false;
5.     string message = "";
7.     // 创建取消令牌源
8.     CancellationTokenSource cancellationTokenSource = new CancellationTokenSource();
9.     CancellationToken token = cancellationTokenSource.Token;
11.     // 创建连接任务
12.     Task connectTask = Task.Run(() =>
13.     {
14.         try
15.         {
16.             sw.Start();
17.             if(conn is SqlConnection)
18.             {
19.                 ((SqlConnection)conn).Open();
20.             }
21.             if (conn is MySqlConnection)
22.             {
23.                 ((MySqlConnection)conn).Open();
24.             }
25.             connectSuccess = true;
26.             message = "数据库连接成功";
27.         }
28.         catch (Exception ex)
29.         {
30.             message = $"数据库连接失败:{ex.Message}";
31.         }
32.     }, token);
34.     // 创建超时任务
35.     Task timeoutTask = Task.Delay(timeout, token);
37.     // 等待连接任务或超时任务哪个先完成
38.     Task completedTask = await Task.WhenAny(connectTask, timeoutTask);
40.     if (completedTask == timeoutTask)
41.     {
42.         // 如果超时先完成，取消连接任务
43.         cancellationTokenSource.Cancel();
44.         message = "数据库连接超时";
45.     }
46.         return (connectSuccess, message);
47. }
49. public async Task ConnectMultipleDatabasesAsync(int timeout, List<MySqlConnection> mySqlConnections)
50. {
51.     var tasks = new List<Task>();
53.     for (int i = 0; i < mySqlConnections.Count; i++)
54.     {
55.         tasks.Add(TryConnectWithTimeoutAsync(mySqlConnections[i], timeout));
56.     }
58.     var results = await Task.WhenAll(tasks); // 等待所有任务完成
59.     for (int i = 0; i < results.Length; i++)
60.     {
61.         var (isSuccess, message) = results[i];
62.         Console.WriteLine($"{message}");
63.     }
64. }

复制代码

2.2代码阐明

上面代码定义了两个异步执行的函数，TryConnectWithTimeoutAsync和ConnectMultipleDatabasesAsync。TryConnectWithTimeoutAsync支持MySQL数据库连接和SQLserver数据库连接，返回Tuple类型描述数据库连接环境，执行单个数据库连接任务。
ConnectMultipleDatabasesAsync接受多个数据库连接对象输入，内部调用TryConnectWithTimeoutAsync，进行多个数据库连接任务，timeout参数控制每个连接任务超时，单位为毫秒。
现实利用时，可通过如下代码进行ConnectMultipleDatabasesAsync调用：

1. public async void UserFunc(List<MySqlConnection> mySqlConnections)
2. {
3.     await Task.Run(async () =>
4.     {
5.         await ConnectMultipleDatabasesAsync(mySqlConnections, 5000);//超时等待5000毫秒
7.     });
8. }

复制代码

参考文档

C# 测试SqlServer连接及设置连接超时时间
C# 控制连接超时处置惩罚方法-连接数据库与连接网络路径超时环境

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。