zoukankan      html  css  js  c++  java
  • mongo 监听指定语句

    class Program
        {
            private static string conn = "mongodb://47.104.206.56:27017";
            //数据库名称
            private static string dbName = "Test1";
            //集合名称
            private static string colName = "Demo4";
            //连接服务端
            static MongoClient client = new MongoClient(conn);
            //获取指定数据库
            static IMongoDatabase db = client.GetDatabase(dbName);
           static  MongoClientSettings settings = new MongoClientSettings();
            static async Task Main(string[] args)
            {
                int i = 0;
                MongoClientSettings settings = new MongoClientSettings();
                settings.ConnectionMode = ConnectionMode.Automatic;
                settings.ClusterConfigurator = cb =>
                {
                    //      监听执行语句
                    cb.Subscribe<CommandStartedEvent>(hand =>
                    {
                        Console.WriteLine($"命令名称:{hand.CommandName};命令内容{hand.Command}");
                    });
                };
                settings.Server = new MongoServerAddress("47.104.206.56", 27017);
                MongoClient client = new MongoClient(settings);
                //获取指定数据库
                IMongoDatabase db = client.GetDatabase(dbName);
                IMongoCollection<BsonDocument> coll = db.GetCollection<BsonDocument>(colName);
    
                while (true)
                {
                    var data = coll.Find(Builders<BsonDocument>.Filter.Empty).ToList();
                    Thread.Sleep(1000);
                }
            }
    
  • 相关阅读:
    Redis 和 Memcached 的区别
    缓存详解
    HTTP常见状态码
    ORM的概念, ORM到底是什么
    remote: Unauthorized fatal: Authentication failed for...
    TR、FN、FP、FN
    <笔记>ue破解
    <笔记>bmp图片数据格式
    三轴加速度数据处理
    智能手环+三轴加速度传感器总结
  • 原文地址:https://www.cnblogs.com/yan7/p/9970934.html
Copyright © 2011-2022 走看看