使用dotnetcore连接到mongo数据库
使用dotnetcore连接到mongo数据库
提问于 2016-08-05 00:11:04
我正在测试与dotnet内核兼容的c#版新MongoDB.Driver的测试版，但连接无法正常工作。我有一个mongo服务器v3.3，运行在27017端口下的docker容器上，我可以通过控制台通过docker exec -it和图形用户界面(Robomongo)成功地访问它。
我在我的project.json中使用"MongoDB.Driver": "2.3.0-beta1"，我运行的代码如下：
public class Program
{
public static void Main(string[] args)
{
var client = new MongoClient("mongodb://localhost:27017");
var db = client.GetDatabase("newdatabase");
var collection = db.GetCollection<Person>("mycollection");
collection.InsertOne(new Person{Id = "1", Age = 32});
}
public class Person
{
public string Id{ get; set;}
public int Age{ get; set;}
}
}我得到的例外是：
A timeout occured after 30000ms selecting a server using CompositeServerSelector{ Selectors = WritableServerSelector, LatencyLimitingServerSelector{ AllowedLatencyRange = 00:00:00.0150000 } }. Client view of cluster state is { ClusterId : "1", ConnectionMode : "Automatic", Type : "Unknown", State : "Disconnected", Servers : [{ ServerId: "{ ClusterId : 1, EndPoint : "Unspecified/localhost:27017" }", EndPoint: "Unspecified/localhost:27017", State: "Disconnected", Type: "Unknown", HeartbeatException: "MongoDB.Driver.MongoConnectionException: An exception occurred while opening a connection to the server. ---> System.PlatformNotSupportedException: This platform does not support connecting sockets to DNS endpoints via the instance Connect and ConnectAsync methods, due to the potential for a host name to map to multiple IP addresses and sockets becoming invalid for use after a failed connect attempt. Use the static ConnectAsync method, or provide to the instance methods the specific IPAddress desired.
at System.Net.Sockets.Socket.Connect(IPAddress[] addresses, Int32 port)
at System.Net.Sockets.Socket.Connect(String host, Int32 port)
at System.Net.Sockets.Socket.Connect(EndPoint remoteEP)
at System.Threading.Tasks.Task.Execute()
--- End of stack trace from previous location where exception was thrown ---
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
at MongoDB.Driver.Core.Connections.TcpStreamFactory.<ConnectAsync>d__7.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
at MongoDB.Driver.Core.Connections.TcpStreamFactory.<CreateStreamAsync>d__4.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
at MongoDB.Driver.Core.Connections.BinaryConnection.<OpenHelperAsync>d__48.MoveNext()
--- End of inner exception stack trace ---
at MongoDB.Driver.Core.Connections.BinaryConnection.<OpenHelperAsync>d__48.MoveNext()
--- End of stack trace from previous location where exception was thrown ---
at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
at MongoDB.Driver.Core.Servers.ServerMonitor.<HeartbeatAsync>d__27.MoveNext()" }] }.有没有明显的遗漏或配置错误的地方，或者这个驱动程序使用起来还为时过早？
回答 2
Stack Overflow用户
回答已采纳
发布于 2016-08-05 00:12:34
实际上，如果我将localhost更改为127.0.0.1，它就可以工作。由于某种原因，它不喜欢它的名字(注意，我使用的是Docker版本1.12.0-beta21 (build: 11019) 5a44e81a0513f32f5c49f7d2966570893451f32f，如果有帮助的话)。
Stack Overflow用户
发布于 2020-04-23 17:19:18
在Windows上Docker-Desktop中托管的Kubernetes集群中运行dotnet核心应用程序时也遇到了同样的问题。我已经尝试了Debian和基于阿尔卑斯山的图像，但没有运气。此外，这似乎不是Docker的问题，因为来自pod的任何nslookup hostname都可以解析正确的IP地址。
我发现的唯一解决方法是在初始化Mongo连接之前将主机名解析为IP地址，因此我最终使用实用程序方法：
private string GetMongoConnectionStringWithIps(string connectionString) {
var builder = new MongoUrlBuilder(connectionString);
var servers = new List<MongoServerAddress>();
foreach (var server in builder.Servers)
{
var address = Dns.GetHostAddresses(server.Host).FirstOrDefault(ip => ip.AddressFamily == AddressFamily.InterNetwork);
servers.Add(new MongoServerAddress(address.ToString(), server.Port));
}
builder.Servers = servers;
return builder.ToMongoUrl().ToString();
}页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/38772459
复制相关文章
相似问题
腾讯云开发者
