你的位置:首页 > 数据库

[数据库]MongoDB 3.2.9 关于安全认证后使用C#调用碰上的相关问题


由于项目需要MongoDB做为存储数据库,在学习过程碰上疑难杂症,心痛如海,故此终于开始书写博客之路。

 

操作MongoDB类库版本:

----------------------------------------------

MongoDB.Driver 2.3 
MongoDB.Driver.Core 2.3
MongoDB.Bson 2.3

MongoDB 版本 3.2.9

参考相关学习链接(转载):
---------------------------------------------
https://izk.cloud/437/ 安全认证,权限管理
http://www.cnblogs.com/huangxincheng/archive/2015/10/12/4870557.html 主从热备集群

http://blog.csdn.net/luonanqin/article/details/8497860 集群搭建

连接字符串的相关变化:

-----------------------------------------------

没有安全认证的URL:mongodb://127.0.0.1:27017

加上安全认证的URL:mongodb://[userName]:[userPwd]@127.0.0.1:27017/[DataBaseName]

重点变化是最后一个指定数据库,如果不指定,将为默认数据库

所以想当然测试的时候一般使用的是mongodb://[userName]:[userPwd]@127.0.0.1:27017

并没有加上自定义数据库名称,导致初始化报错。

网上参考文章带安全验证的连接都是:mongodb://[userName]:[userPwd]@127.0.0.1:27017

都没有在最后补上/[DataBaseName]  导致自定义数据库的创建失败。

 

主副热备集群相关代码处理上的问题:

-------------------------------------------------

 感谢国庆,感谢国家,感谢这二篇博文,一直在操作主副集群C#代码碰上未知报错,通过下面链接

深度学习了一下:

双十一来了,别让你的mongodb宕机了

MongoDB副本集学习(二):基本测试与应用

虽然依然没有解决我的问题,但是从中学习到经验,值得回报。

按照上面代码(转载):

MongoClientSettings set = new MongoClientSettings();List<MongoServerAddress> servers = new List<MongoServerAddress>();servers.Add(new MongoServerAddress("192.168.129.129", 37017));servers.Add(new MongoServerAddress("192.168.129.129", 37018));servers.Add(new MongoServerAddress("192.168.129.129", 37019));set.Servers = servers;//设置副本集名称set.ReplicaSetName = "rs0";//设置超时时间为3秒set.ConnectTimeout = new TimeSpan(0, 0, 0, 3, 0);MongoClient client = new MongoClient(set);MongoServer server = client.GetServer();MongoDatabase db = server.GetDatabase("test");MongoCollection coll = db.GetCollection("test");//插入BsonDocument bd = new BsonDocument();bd.Add("name", "zhanjindong");bd.Add("age", 23);bd.Add("sex", "男D");coll.Insert(bd);//读取QueryDocument qd = new QueryDocument();qd.Add("name", "zhanjindong");qd.Add("age", 23);qd.Add("sex", "男D");BsonDocument rd = coll.FindOneAs<BsonDocument>(qd);Console.WriteLine(rd.ToString()); 默认的C#驱动的ReadPreference是Primary,也就是说读写操作都是在主节点上的,那么当集群中只剩下一个节点的时候,按照前面所说该节点一定是secondary节点,这样读取操作也是没法进行的(通过mongo shell当然是可以的)。解决方法就是设置驱动的ReadPreferenceMode:set.ReadPreference = new ReadPreference(ReadPreferenceMode.PrimaryPreferred);状态说明:primary主节点,默认模式,读操作只在主节点,如果主节点不可用,报错或者抛出异常。primaryPreferred首选主节点,大多情况下读操作在主节点,如果主节点不可用,如故障转移,读操作在从节点。secondary从节点,读操作只在从节点, 如果从节点不可用,报错或者抛出异常。secondaryPreferred首选从节点,大多情况下读操作在从节点,特殊情况(如单主节点架构)读操作在主节点。nearest最邻近节点,读操作在最邻近的成员,可能是主节点或者从节点

 

你以为上面就复制粘贴一下就解决了?No,实际调用跟参考代码是二回事,呃?绕回正题,通过上面代码以为可以轻松一步了,结果又挖了一个大坑,在招待我。

 

报错详情:

System.TimeoutException”类型的异常在 MongoDB.Driver.Core.dll中发生,但未在用户代码中进行处理其他信息: A timeout occured after 3000ms selecting a server using CompositeServerSelector {  Selectors = ReadPreferenceServerSelector {    ReadPreference = {      Mode = Secondary, TagSets = []    }  }, LatencyLimitingServerSelector {    AllowedLatencyRange = 00: 00: 00.0150000  }}.Client view of cluster state is {  ClusterId: "1",  ConnectionMode: "ReplicaSet",  Type: "ReplicaSet",  State: "Disconnected",  Servers: [{    ServerId: "{ ClusterId : 1, EndPoint : "    Unspecified / mongodb - 10.localdomain: 27017 " }",    EndPoint: "Unspecified/mongodb-10.localdomain:27017",    State: "Disconnected",    Type: "Unknown",    HeartbeatException: "MongoDB.Driver.MongoConnectionException: An exception occurred while opening a connection to the server. ---> System.Net.Sockets.SocketException: 不知道这样的主机。

 

我当时就#¥#@¥@#¥,你懂的,一波三折,要命,经过大量时间排查我锁定问题位置:

 EndPoint: "Unspecified/mongodb-10.localdomain:27017",

底气何来?原因如下:

如果你也是本地测试并且副集群IP地址使用是域名绑定,那么你在HOSTS没有配置域名的情况下,就会出现上面的超时30秒错误(一想起无数个F5等30秒就。。。。)

 

接下来配置HOSTS文件:

然后烧香拜佛,果然不出所料,调用成功,为此付出不少冤枉路,如果有人碰上相同的问题,可以参与一下。

最后放上测试单元代码:

using System;using System.Collections.Generic;using System.Linq;using MongoDB.Driver;using MongoDB.Driver.Linq;using System.Linq.Expressions;public class MongoUnitily{  /// <summary>  /// MongoDB调用类  /// </summary>  private MongoUnitily()  {    dataBase = new MongoClient(new MongoClientSettings    {      Credentials = new List<MongoCredential>() {        MongoCredential.CreateCredential("avatar","*******","*********") // 数据库名称,用户名,用户密码      },      Servers = new string[] { "10.199.*.1", "10.199.*.2", "10.199.*.3" }.Select(x => { return new MongoServerAddress(x); }), // 集群IP地址      ConnectionMode = ConnectionMode.ReplicaSet,                     // Replica 模式      ReplicaSetName = "RS01",                            // Replica名称      ReadPreference = new ReadPreference(ReadPreferenceMode.SecondaryPreferred),     // 读写配置,副IP不起作用的情况下使用主IP      ConnectTimeout = new TimeSpan(0, 0, 0, 3, 0),                    // 3秒报错测试,当初30秒我是等闲人。。。。      MaxConnectionIdleTime = new TimeSpan(0, 0, 0, 3, 0),                // 3秒报错测试,当初30秒我是等闲人。。。。      MaxConnectionLifeTime = new TimeSpan(0, 0, 0, 3, 0),                // 3秒报错测试,当初30秒我是等闲人。。。。      ServerSelectionTimeout = new TimeSpan(0, 0, 0, 3, 0)                // 3秒报错测试,当初30秒我是等闲人。。。。    }).GetDatabase(database);                                // 通过数据库名称获取 DbBase  }  static MongoUnitily()  {    //初始化单例对象    Instance = new MongoUnitily();  }  /// <summary>  /// 数据库名称  /// </summary>  private string database = "avatar";//数据库名   /// <summary>   /// dataBase上下文对象   /// </summary>  private IMongoDatabase dataBase = null;  public static MongoUnitily Instance { get; private set; }  /// <summary>  /// 验证读取  /// </summary>  /// <returns></returns>  public bool IsGet()  {    bool result = true;    var coll = dataBase.GetCollection<SysCodes>(nameof(SysCodes));    Expression<Func<SysCodes, bool>> predicate = x => true;    try    {      var count = coll.Find(predicate).Count();    }    catch    {      result = false;    }    return result;  }  /// <summary>  /// 验证写  /// </summary>  /// <returns></returns>  public bool IsPost()  {    var result = true;    var coll = dataBase.GetCollection<Demo>(nameof(Demo));    try    {      coll.InsertOne(new Demo { Id = Guid.NewGuid(), Name = "三" });    }    catch    {      result = false;    }    return result;  }  /// <summary>  /// 测试类  /// </summary>  public class Demo  {    public Guid Id { get; set; }    public string Name { get; set; }  }}

 

 

 验证结果:

 

 本篇文章旨在解决使用新版本MongoDB碰上的集群、连接字符串、安全验证的相关问题,文章深度不高,提供新手对象相互学习互挽。