获取用于数据库连接的底层 IP

Question

我正在尝试查看池化数据库连接如何影响一组只读 MySQL 数据库副本之间的命令负载平衡。连接字符串中的数据源是一个 DNS 条目，其中有多个条目以循环方式提供给客户端。

是否可以获取数据库连接对象并提取连接用于连接的 IP 地址？

更新

在此代码示例中：

MySql.Data.MySqlClient.MySqlConnection _mySQL = new MySql.Data.MySqlClient.MySqlConnection(_AuroraClusterEndPoint);

更新 #2

我的问题更多是关于如何确定活动连接使用的 IP，而不是真正如何平均分配流量。

伪代码：

MySql.Data.MySqlClient.MySqlConnection _mySQL = new MySql.Data.MySqlClient.MySqlConnection(_AuroraClusterEndPoint);

_mySQL.Open();
Console.WriteLine(_mySQL.ConnectionInfo.IPAddress); //This is the unknown part
_mySQL.Close();

我将如何获取_mySQL 并提取它正在使用的 IP 地址？

Answer 1

是与否，

不要将 dns 主机名存储在连接字符串中。即时构建连接字符串（无论如何您可以或想要存储信息）。

在代码查找中构建连接字符串时，请查找 dns 别名/主机名以获取其 ip 地址（应仅返回 1 个 ipv4 地址）

IPAddress[] ipv4Addresses = Array.FindAll(
    Dns.GetHostEntry("hostnamehere").AddressList,
    a => a.AddressFamily == AddressFamily.InterNetwork);

如果您获得多个地址，请对其进行测试和调试。

获得 IP 后，您现在就知道轮询提供了请求的 IP 地址，您可以记录它，然后使用 IP 地址而不是主机名构建连接字符串。

这是我在 5 分钟内写的一个粗略而肮脏的例子：

using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading.Tasks;

namespace ConsoleApp3
{
    class Program
    {
        static void Main(string[] args)
        {
            string ipAddress;
            var newConnectionString = SwapConnectionStringDNSWithIP("Server=google.com;Database=myDataBase;Uid=myUsername;Pwd=myPassword;", out ipAddress);
            Console.WriteLine(ipAddress);
            Console.WriteLine(newConnectionString);
            Console.ReadKey(true);
        }

        public static string SwapConnectionStringDNSWithIP(string connectionString, out string ipAddress)
        {
            ipAddress = null;
            if (string.IsNullOrEmpty(connectionString))
                return null;
            var dict = new Dictionary<string, string>();
            var pParts = connectionString.Split(';');
            foreach (var part in pParts)
            {
                if (part.IndexOf('=') == -1)
                    break;
                var sParts = part.Split('=');
                if (sParts.Length != 2)
                    break;
                string key = sParts[0].ToLower().Trim();
                string value = sParts[1];
                if (!dict.ContainsKey(key))
                {
                    dict.Add(key, value);
                }
            }
            var server = dict.ContainsKey("server") ? dict["server"] : null;
            if (server == null)
                return null;

            var ret = Dns.GetHostEntry(server);
            var addresses = ret.AddressList.Select(a => a.GetAddressBytes()).ToArray();
            if (addresses != null && addresses.Length > 0)
            {
                ipAddress = string.Join(".", addresses[0]);
                dict["server"] = ipAddress;
                var newConnectionString = string.Join(string.Empty, dict.Keys.Select(k => k + "=" + dict[k] + ";").ToArray());
                return newConnectionString;
            }                      
            return null;
        }
    }
}