[fix] NameServerAddress地址可能没有使用域名，而是使用IP。fix: #85

NewLifeX · Dec 10, 2024 · ae97b0d · ae97b0d
1 parent 40fe924
commit ae97b0d
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/NewLife.RocketMQ/MqBase.cs b/NewLife.RocketMQ/MqBase.cs
@@ -285,14 +285,17 @@ protected BrokerClient GetBroker(String name)
 
             // broker可能在内网，转为公网地址
             var uri = new NetUri(NameServerAddress.Split(";").FirstOrDefault());
+            var ext = uri.Host;
+            if (ext.IsNullOrEmpty()) ext = uri.Address.ToString();
+
             var addrs = bk.Addresses.ToArray();
             for (var i = 0; i < addrs.Length; i++)
             {
                 var addr = addrs[i];
-                if (addr.StartsWithIgnoreCase("10.", "192.", "172."))
+                if (addr.StartsWithIgnoreCase("10.", "192.", "172.") && !ext.IsNullOrEmpty())
                 {
                     var p = addr.IndexOf(':');
-                    addrs[i] = p > 0 ? uri.Host + addr[p..] : uri.Host;
+                    addrs[i] = p > 0 ? ext + addr[p..] : ext;
                 }
             }
 

diff --git a/NewLife.RocketMQ/NewLife.RocketMQ.csproj b/NewLife.RocketMQ/NewLife.RocketMQ.csproj
@@ -61,7 +61,7 @@
   </ItemGroup>
 
   <ItemGroup>
-    <PackageReference Include="NewLife.Core" Version="11.0.2024.1201" />
+    <PackageReference Include="NewLife.Core" Version="11.1.2024.1206" />
   </ItemGroup>
 
 </Project>