01_在NET中使用RabbitMQ

来源:https://www.cnblogs.com/MingQiu/p/18129505
-Advertisement-
Play Games

1.Linux上安裝Docken 伺服器系統版本以及內核版本:cat /etc/redhat-release 查看伺服器內核版本:uname -r 安裝依賴包:yum install -y yum-utils device-mapper-persistent-data lvm2 設置阿裡雲鏡像源:y ...


1.Linux上安裝Docken

伺服器系統版本以及內核版本:cat /etc/redhat-release
查看伺服器內核版本:uname -r
安裝依賴包:yum install -y yum-utils device-mapper-persistent-data lvm2
設置阿裡雲鏡像源:yum-config-manager --add-repo https://mirrors.aliyun.com/docker-ce/linux/centos/docker-ce.repo
安裝Docker:yum install -y docker-ce
    社區版(Community Edition,縮寫為 CE)
    企業版(Enterprise Edition,縮寫為 EE)  
啟動docker並設置開機自啟:
    啟動docker命令:systemctl start docker
    設置開機自啟命令:systemctl enable docker
    查看docker版本命令:docker version

  刪除docker-ce命令:yum remove docker-ce
  刪除鏡像、容器、配置文件等內容
  rm -rf /var/lib/containerd
  rm -rf /var/lib/docker



----------------------------------------通過docker help命令來查看更多的命令--------------------------------

  docker search --鏡像名 搜索倉庫鏡像

  docker pull --鏡像名 拉取鏡像

  docker ps 查看目前正在運行的所有容器 (-a 顯示包括已經停止的容器)

  docker rmi image_id/image_name 刪除鏡像

  docker build 使用Dockerfile創建鏡像

  docker run 運行容器

  docker exec 進入容器中執行命令 (例如:docker exec -it container_id/container_name /bin/bash)

  docker logs container_id/container_name 查看容器日誌(例如:docker logs -f -t --tail 10 container_id )

  docker start container_id/container_name 啟動容器

  docker restart container_id/container_name 重啟容器

  docker stop container_id/container_name 停止容器

  docker rm container_id/container_name 刪除容器(只能刪除已停止的容器)

 

2基於Docken安裝RabbitMq

  docker啟動:systemctl start docker
  docker重啟:ystemctl restart docker
  docker關閉:systemctl stop docker

查看正在運行容器:docker ps 

查詢Rabbitmq鏡像: docker search rabbitmq
安裝Rabbitmq鏡像:
指定版本:docker pull rabbitmq:3.7.7-management
最新版本:docker pull rabbitmq
創建和啟動容器:docker run -d --hostname myrabbitmq --name rabbitmq -p 5672:5672 -p 15673:15672 rabbitmq
-d 後臺運行容器;
--hostname  主機名;
--name 指定容器名;
-p 指定服務運行的埠
5672 控制台Web埠號(服務端)
15672 應用訪問埠(客戶端)
-v 映射目錄或文件
-e 指定環境變數(RABBITMQ_DEFAULT_VHOST:預設虛擬機名;RABBITMQ_DEFAULT_USER:預設的用戶名;RABBITMQ_DEFAULT_PASS:預設用戶名的密碼)
進入容器內部:docker exec -it 容器id /bin/bash
運行:rabbitmq-plugins enable rabbitmq_management
重啟rabbitmq:docker start rabbitmq
重啟容器:docker restart rabbitmq
停止容器:docker stop rabbitmq

訪問:http://ip:15672/
賬號密碼:guest/guest

其它命令:

  列出所有用戶:rabbitmqctl list_users
  添加用戶:rabbitmqctl add_user username password   如:新增一個用戶:rabbitmqctl add_user 名稱 密碼
  刪除用戶:rabbitmqctl delete_user username
  修改密碼:rabbitmqctl change_password username newpassword
  列出用戶許可權:rabbitmqctl list_user_permissions username
  列出虛擬主機上的所有許可權:rabbitmqctl list_permissions -p vhostpath
  設置用戶許可權:rabbitmqctl set_permissions -p vhostpath username “.” “.” “.*”    如:設置用戶許可權:rabbitmqctl set_permissions -p VHostPath User ConfP WriteP ReadP

 

3.添加用戶和設置許可權

 

 

 

 

4.NET中使用RabbitMQ

RabbitMq有7種模式:RabbitMQ Tutorials | RabbitMQ

安裝包:RabbitMQ.Client

 

定義隊列和交換機名稱

    /// <summary>
    /// 定義隊列和交換機名稱
    /// </summary>
    public class RabbitConstant
    {
        public const string QUEUE_HELLO_WORLD = "helloworld.queue";
        public const string QUEUE_SMS = "sms.queue";
        public const string EXCHANGE_WEATHER = "weather.exchange";
        public const string QUEUE_BAIDU = "baidu.queue";
        public const string QUEUE_SINA = "sina.queue";
        public const string EXCHANGE_WEATHER_ROUTING = "weather.routing.exchange";
        public const string EXCHANGE_WEATHER_TOPIC = "weather.topic.exchange";
    }

 

 

第一種模式:Hello World

消費者:

using RabbitMQ.Client;
using RabbitMQ.Client.Events;


 public class HelloConsumer
    {
        public static void HelloWorldShow()
        {
            var factory = new ConnectionFactory();
            factory.HostName = "127.0.0.1";
            factory.Port = 5672;//5672是RabbitMQ預設的埠號
            factory.UserName = "admin";
            factory.Password = "admin";
            factory.VirtualHost = "my_vhost";

            using (var connection = factory.CreateConnection())
            {
                using (var channel = connection.CreateModel())
                {
                    /*
                     * 創建隊列,聲明並創建一個隊列,如果隊列已存在,則使用這個隊列
                     * 第一個參數:隊列名稱ID
                     * 第二個參數:是否持久化,false對應不持久化數據,MQ停掉數據就會丟失
                     * 第三個參數:是否隊列私有化,false則代表所有的消費者都可以訪問,true代表只有第一次擁有它的消費者才能一直使用
                     * 第四個:是否自動刪除,false代表連接停掉後不自動刪除這個隊列
                     * 其他額外參數為null
                     */
                    channel.QueueDeclare(RabbitConstant.QUEUE_HELLO_WORLD, true, false, false, null);
                    Console.ForegroundColor = ConsoleColor.Cyan;
                    //事件消費者類
                    EventingBasicConsumer consumers = new EventingBasicConsumer(channel);
                    // 觸發事件
                    consumers.Received += (model, ea) =>
                    {
                        var body = ea.Body.ToArray();
                        var message = Encoding.UTF8.GetString(body);

                        // false只是確認簽收當前的消息,設置為true的時候則代表簽收該消費者所有未簽收的消息
                        channel.BasicAck(ea.DeliveryTag, false);
                        Console.WriteLine($"Consumer01接收消息:{message}");
                    };
                    /*
                     * 從MQ伺服器中獲取數據
                     * 創建一個消息消費者
                     * 第一個參數:隊列名
                     * 第二個參數:是否自動確認收到消息,false代表手動確認消息,這是MQ推薦的做法
                     * 第三個參數:要傳入的IBasicConsumer介面
                     */
                    channel.BasicConsume(RabbitConstant.QUEUE_HELLO_WORLD, false, consumers);
                    Console.WriteLine("Press [Enter] to exit");
                    Console.Read();
                }
            }
        }
    }

生產者:

using RabbitMQ.Client;
 

 public class HelloProducer
    {
        public static void HelloWorldShow()
        {
            var factory = new ConnectionFactory();
            factory.HostName = "127.0.0.1";//IP
            factory.Port = 5672;//
            factory.UserName = "admin";//用戶名
            factory.Password = "admin";//密碼
            factory.VirtualHost = "my_vhost";//虛擬主機

            // 獲取TCP 長連接
            using (var connection = factory.CreateConnection())
            {
                // 創建通信“通道”,相當於TCP中的虛擬連接
                using (var channel = connection.CreateModel())
                {
                    /*
                     * 創建隊列,聲明並創建一個隊列,如果隊列已存在,則使用這個隊列
                     * 第一個參數:隊列名稱ID
                     * 第二個參數:是否持久化,false對應不持久化數據,MQ停掉數據就會丟失
                     * 第三個參數:是否隊列私有化,false則代表所有的消費者都可以訪問,true代表只有第一次擁有它的消費者才能一直使用
                     * 第四個:是否自動刪除,false代表連接停掉後不自動刪除這個隊列
                     * 其他額外參數為null
                     */
                    channel.QueueDeclare(RabbitConstant.QUEUE_HELLO_WORLD, true, false, false, null);
                    Console.ForegroundColor = ConsoleColor.Red;
                    string message = "hello CodeMan 666";//要發送的數據
                    var body = Encoding.UTF8.GetBytes(message);

                    /*
                     * 第一個參數:exchange:交換機,暫時用不到,在進行發佈訂閱時才會用到
                     * 第二個參數:路由key
                     * 第三個參數:額外的設置屬性
                     * 第四個參數:最後一個參數是要傳遞的消息位元組數組
                     */
                    channel.BasicPublish("", RabbitConstant.QUEUE_HELLO_WORLD, null, body);
                    Console.WriteLine($"producer消息:{message}已發送");
                }
            }
        }
    }

 

-------------------------------------------------------------------------------漂亮的分割線--------------------------------------------------------------------------------------------------

獲取ConnectionFactory 對象

/// <summary>
    /// RabbitMQ連接類
    /// </summary>
    public class RabbitUtils
    {
        /// <summary>
        /// 獲取ConnectionFactory對象
        /// </summary>
        /// <returns></returns>
        public static ConnectionFactory GetConnection()
        {
            var factory = new ConnectionFactory();
            factory.HostName = "127.0.0.1";//IP地址
            factory.Port = 5672;//5672是RabbitMQ預設的埠號
            factory.UserName = "admin";//用戶名
            factory.Password = "admin";//密碼
            factory.VirtualHost = "my_vhost";//虛擬主機
            return factory;
        }
    }

 

    /// <summary>
    /// 發送消息內容類
    /// </summary>
    public class Sms
    {
        public string Name { get; set; }
        public string Mobile { get; set; }
        public string Content { get; set; }

        public Sms()
        {

        }

        public Sms(string name, string mobile, string content)
        {
            Name = name;
            Mobile = mobile;
            Content = content;
        }
    }

 

 

第二種模式:Work Queues

消費者1

public class SmsReceive
    {
        public static void Sender()
        {
            var connection = RabbitUtils.GetConnection().CreateConnection();

            var channel = connection.CreateModel();
            /*
             * 創建隊列,聲明並創建一個隊列,如果隊列已存在,則使用這個隊列
             * 第一個參數:隊列名稱ID
             * 第二個參數:是否持久化,false對應不持久化數據,MQ停掉數據就會丟失
             * 第三個參數:是否隊列私有化,false則代表所有的消費者都可以訪問,true代表只有第一次擁有它的消費者才能一直使用
             * 第四個:是否自動刪除,false代表連接停掉後不自動刪除這個隊列
             * 其他額外參數為null
             */
            channel.QueueDeclare(RabbitConstant.QUEUE_SMS, true, false, false, null);
            // 如果不寫basicQos(1),則自動MQ會將所有請求平均發送給所有消費者
            // basicQos,MQ不再對消費者一次發送多個請求,而是消費者處理完一個消息後(確認後),在從隊列中獲取一個新的
            channel.BasicQos(0, 1, false);

            var consumer = new EventingBasicConsumer(channel);

            consumer.Received += (model, ea) =>
            {
                var body = ea.Body.ToArray();
                var message = Encoding.UTF8.GetString(body);
                Thread.Sleep(30);
                Console.WriteLine($"SmsSender-發送簡訊成功:{message}");
                channel.BasicAck(ea.DeliveryTag, false);
            };

            channel.BasicConsume(RabbitConstant.QUEUE_SMS, false, consumer);
            Console.WriteLine("Press [Enter] to exit");
            Console.Read();
        }
    }

消費者2

public class SmsReceive
    {
        public static void Sender()
        {
            var connection = RabbitUtils.GetConnection().CreateConnection();
            var channel = connection.CreateModel();

            channel.QueueDeclare(RabbitConstant.QUEUE_SMS, true, false, false, null);
            // 如果不寫basicQos(1),則自動MQ會將所有請求平均發送給所有消費者
            // basicQos,MQ不再對消費者一次發送多個請求,而是消費者處理完一個消息後(確認後),在從隊列中獲取一個新的
            channel.BasicQos(0, 1, false);//處理完一個取一個

            var consumer = new EventingBasicConsumer(channel);

            consumer.Received += (model, ea) =>
            {
                var body = ea.Body.ToArray();
                var message = Encoding.UTF8.GetString(body);
                Thread.Sleep(60);
                Console.WriteLine($"SmsSender-發送簡訊成功:{message}");
                channel.BasicAck(ea.DeliveryTag, false);
            };

            channel.BasicConsume(RabbitConstant.QUEUE_SMS, false, consumer);
            Console.WriteLine("Press [Enter] to exit");
            Console.Read();
        }
    }

生產者

 public class SmsSender
    {
        public static void Sender()
        {
            using (var connection = RabbitUtils.GetConnection().CreateConnection())
            {
                using (var channel = connection.CreateModel())
                {
                    /*
                     * 創建隊列,聲明並創建一個隊列,如果隊列已存在,則使用這個隊列
                     * 第一個參數:隊列名稱ID
                     * 第二個參數:是否持久化,false對應不持久化數據,MQ停掉數據就會丟失
                     * 第三個參數:是否隊列私有化,false則代表所有的消費者都可以訪問,true代表只有第一次擁有它的消費者才能一直使用
                     * 第四個:是否自動刪除,false代表連接停掉後不自動刪除這個隊列
                     * 其他額外參數為null
                     */
                    channel.QueueDeclare(RabbitConstant.QUEUE_SMS, true, false, false, null);
                    for (int i = 0; i < 100; i++)
                    {
                        Sms sms = new Sms("乘客" + i, "139000000" + i, "您的車票已預定成功");
                        string jsonSms = JsonConvert.SerializeObject(sms);
                        var body = Encoding.UTF8.GetBytes(jsonSms);
                        /*
                         * 第一個參數:exchange:交換機,暫時用不到,在進行發佈訂閱時才會用到
                         * 第二個參數:路由key
                         * 第三個參數:額外的設置屬性
                         * 第四個參數:最後一個參數是要傳遞的消息位元組數組
                         */
                        channel.BasicPublish("", RabbitConstant.QUEUE_SMS, null, body);
                        Console.WriteLine($"正在發送內容:{jsonSms}");
                    }
                    Console.WriteLine("發送數據成功");
                }
            }
        }
    }

 

第三種模式:Publish/Subscribe

消費者1

public class WeatherFanout
    {
        public static void Weather()
        {
            using (var connection = RabbitUtils.GetConnection().CreateConnection())
            {
                using (var channel = connection.CreateModel())
                {
                    //交換機
                    channel.ExchangeDeclare(RabbitConstant.EXCHANGE_WEATHER, ExchangeType.Fanout);
                    // 聲明隊列信息
                    channel.QueueDeclare(RabbitConstant.QUEUE_BAIDU, true, false, false, null);
                    /*
                     * queueBind 用於將隊列與交換機綁定
                     * 參數1:隊列名
                     * 參數2:交換機名
                     * 參數3:路由Key(暫時用不到)
                     */
                    channel.QueueBind(RabbitConstant.QUEUE_BAIDU, RabbitConstant.EXCHANGE_WEATHER, "");

                    channel.BasicQos(0, 1, false);

                    var consumer = new EventingBasicConsumer(channel);

                    consumer.Received += ((model, ea) =>
                    {
                        var message = Encoding.UTF8.GetString(ea.Body.ToArray());
                        Console.WriteLine($"百度收到的氣象信息:{message}");
                        channel.BasicAck(ea.DeliveryTag, false);
                    });

                    channel.BasicConsume(RabbitConstant.QUEUE_BAIDU, false, consumer);
                    Console.WriteLine("Press [Enter] to exit");
                    Console.Read();
                }
            }
        }
    }

消費者2

public class WeatherFanout
    {
        public static void Weather()
        {
            using (var connection = RabbitUtils.GetConnection().CreateConnection())
            {
                using (var channel = connection.CreateModel())
                {
                    channel.ExchangeDeclare(RabbitConstant.EXCHANGE_WEATHER, ExchangeType.Fanout);
                    // 聲明隊列信息
                    channel.QueueDeclare(RabbitConstant.QUEUE_SINA, true, false, false, null);
                    /*
                     * queueBind 用於將隊列與交換機綁定
                     * 參數1:隊列名
                     * 參數2:交換機名
                     * 參數3:路由Key(暫時用不到)
                     */
                    channel.QueueBind(RabbitConstant.QUEUE_SINA, RabbitConstant.EXCHANGE_WEATHER, "");

                    channel.BasicQos(0, 1, false);

                    var consumer = new EventingBasicConsumer(channel);

                    consumer.Received += ((model, ea) =>
                    {
                        var message = Encoding.UTF8.GetString(ea.Body.ToArray());
                        Console.WriteLine($"百度收到的氣象信息:{message}");
                        channel.BasicAck(ea.DeliveryTag, false);
                    });

                    channel.BasicConsume(RabbitConstant.QUEUE_SINA, false, consumer);
                    Console.WriteLine("Press [Enter] to exit");
                    Console.Read();
                }
            }
        }
    }

生產者

public class WeatherFanout
    {
        public static void Weather()
        {
            using (var connection = RabbitUtils.GetConnection().CreateConnection())
            {
                using (var channel = connection.CreateModel())
                {
                    string message = "20度";
                    var body = Encoding.UTF8.GetBytes(message);
                    /*
                     * 第一個參數:exchange:交換機,暫時用不到,在進行發佈訂閱時才會用到
                     * 第二個參數:路由key
                     * 第三個參數:額外的設置屬性
                     * 第四個參數:最後一個參數是要傳遞的消息位元組數組
                     */
                    channel.BasicPublish(RabbitConstant.EXCHANGE_WEATHER, "", null, body);
                    Console.WriteLine("天氣信息發送成功!");
                }
            }
        }
    }

 

第三種模式:Routing

消費者1

public class WeatherDirect
    {
        public static void Weather()
        {
            using (var connection = RabbitUtils.GetConnection().CreateConnection())
            {
                using (var channel = connection.CreateModel())
                {
                    //交換機
                    channel.ExchangeDeclare(RabbitConstant.EXCHANGE_WEATHER_ROUTING, ExchangeType.Direct);
                    //隊列
                    channel.QueueDeclare(RabbitConstant.QUEUE_BAIDU, true, false, false, null);
                    /*
                    * queueBind 用於將隊列與交換機綁定
                    * 參數1:隊列名
                    * 參數2:交換機名
                    * 參數3:路由Key(暫時用不到)
                    */
                    channel.QueueBind(RabbitConstant.QUEUE_BAIDU, RabbitConstant.EXCHANGE_WEATHER_ROUTING, "china.hunan.changsha.20210525");
                    channel.QueueBind(RabbitConstant.QUEUE_BAIDU, RabbitConstant.EXCHANGE_WEATHER_ROUTING, "china.hubei.wuhan.20210525");

                    channel.BasicQos(0, 1, false);

                    var consumer = new EventingBasicConsumer(channel);

                    consumer.Received += ((model, ea) =>
                    {
                        var message = Encoding.UTF8.GetString(ea.Body.ToArray());
                        Console.WriteLine($"百度收到的氣象信息:{message}");
                        channel.BasicAck(ea.DeliveryTag, false);
                    });

                    channel.BasicConsume(RabbitConstant.QUEUE_BAIDU, false, consumer);
                    Console.WriteLine("Press [Enter] to exit");
                    Console.Read();
                }
            }
        }
    }

消費者2

public class WeatherDirect
    {
        public static void Weather()
        {
            using (var connection = RabbitUtils.GetConnection().CreateConnection())
            {
                using (var channel = connection.CreateModel())
                {
                    //交換機
                    channel.ExchangeDeclare(RabbitConstant.EXCHANGE_WEATHER_ROUTING, ExchangeType.Direct);
                    // 聲明隊列信息
                    channel.QueueDeclare(RabbitConstant.QUEUE_SINA, true, false, false, null);
                    /*
                     * queueBind 用於將隊列與交換機綁定
                     * 參數1:隊列名
                     * 參數2:交換機名
                     * 參數3:路由Key
                     */
                    channel.QueueBind(RabbitConstant.QUEUE_SINA, RabbitConstant.EXCHANGE_WEATHER_ROUTING, "china.hubei.xiangyang.20210525");
                    channel.QueueBind(RabbitConstant.QUEUE_SINA, RabbitConstant.EXCHANGE_WEATHER_ROUTING, "us.cal.lsj.20210525");
                    channel.QueueBind(RabbitConstant.QUEUE_SINA, RabbitConstant.EXCHANGE_WEATHER_ROUTING, "china.hubei.wuhan.20210525");

                    channel.BasicQos(0, 1, false);

                    var consumer = new EventingBasicConsumer(channel);

                    consumer.Received += ((model, ea) =>
                    {
                        var message = Encoding.UTF8.GetString(ea.Body.ToArray());
                        Console.WriteLine($"新浪收到的氣象信息:{message}");
                        channel.BasicAck(ea.DeliveryTag, false);
                    });

                    channel.BasicConsume(RabbitConstant.QUEUE_SINA, false, consumer);
                    Console.WriteLine("Press [Enter] to exit");
                    Console.Read();
                }
            }
        }
    }

生產者

public class WeatherDirect
    {
        public static void Weather()
        {
            Dictionary<string, string> area = new Dictionary<string, string>();
            area.Add("china.hunan.changsha.20210525", "中國湖南長沙20210525天氣數據");
            area.Add("china.hubei.wuhan.20210525", "中國湖北武漢20210525天氣數據");
            area.Add("china.hubei.xiangyang.20210525", "中國湖北襄陽20210525天氣數據");
            area.Add("us.cal.lsj.20210525", "美國加州洛杉磯20210525天氣數據");

            using (var connection = RabbitUtils.GetConnection().CreateConnection())
            {
                using (var channel = connection.CreateModel())
                {
                    foreach (var item in area)
                    {
                        /*
                         * 第一個參數:exchange:交換機,暫時用不到,在進行發佈訂閱時才會用到
                         * 第二個參數:路由key
                         * 第三個參數:額外的設置屬性
                         * 第四個參數:最後一個參數是要傳遞的消息位元組數組
                         */
                        channel.BasicPublish(RabbitConstant.EXCHANGE_WEATHER_ROUTING, item.Key,
                            null, Encoding.UTF8.GetBytes(item.Value));
                    }

                    Console.WriteLine("氣象信息發送成功!");
                }
            }
        }
    }

 

第五章模式:Topics

消費者1

public class WeatherTopic
    {
        public static void Weather()
        {
            using (var connection = RabbitUtils.GetConnection().CreateConnection())
            {
                using (var channel = connection.CreateModel())
                {
                    //交換機
                    channel.ExchangeDeclare(RabbitConstant.EXCHANGE_WEATHER_TOPIC, ExchangeType.Topic);
                    // 聲明隊列信息
                    channel.QueueDeclare(RabbitConstant.QUEUE_BAIDU, true, false, false, null);
                    /*
                     * queueBind 用於將隊列與交換機綁定
                     * 參數1:隊列名
                     * 參數2:交換機名
                     * 參數3:路由Key(暫時用不到)
                     */
                    channel.QueueBind(RabbitConstant.QUEUE_BAIDU, RabbitConstant.EXCHANGE_WEATHER_TOPIC, "china.#");//有關china的所有信息

                    channel.BasicQos(0, 1, false	   

您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 寫在前面 一款好的插件往往能提高我們的開發效率。今天就給大家安利一款maven 依賴搜索插件。 插件是自己一直關註的魯班大叔開發的,用了幾天真的好用 廢話不多說,我們就來看看這是一款什麼插件 一、maven 依賴搜索 平常我們需要找一個maven依賴,一般都會去 https://mvnreposit ...
  • OOM是什麼?英文全稱為 OutOfMemoryError(記憶體溢出錯誤)。當程式發生OOM時,如何去定位導致異常的代碼還是挺麻煩的。 要檢查OOM發生的原因,首先需要瞭解各種OOM情況下會報的異常信息。這樣能縮小排查範圍,再結合異常堆棧、heapDump文件、JVM分析工具和業務代碼來判斷具體是哪 ...
  • 1 開源解析和拆分文檔 第三方的工具去對文件解析拆分,去將我們的文件內容給提取出來,並將我們的文檔內容去拆分成一個小的chunk。常見的PDF word mark down, JSON、HTML。都可以有很好的一些模塊去把這些文件去進行一個東西去提取。 優勢 支持豐富的文檔類型 每種文檔多樣化選擇 ...
  • LiteDB 是一個輕量級的嵌入式 NoSQL 資料庫,其設計理念與 MongoDB 類似,但它是完全使用 C# 開發的,因此與 C# 應用程式的集成非常順暢。與 SQLite 相比,LiteDB 提供了 NoSQL(即鍵值對)的數據存儲方式,並且是一個開源且免費的項目。它適用於桌面、移動以及 We ...
  • 經過前面幾篇的學習,我們瞭解到指令的大概分類,如:參數載入指令,該載入指令以 Ld 開頭,將參數載入到棧中,以便於後續執行操作命令。參數存儲指令,其指令以 St 開頭,將棧中的數據,存儲到指定的變數中,以方便後續使用。創建實例指令,其指令以 New 開頭,用於在運行時動態生成並初始化對象。方法調用指... ...
  • 為.net6在CentOS7上面做準備,先在vmware虛擬機安裝CentOS 7.9 新建CentOS764位的系統 因為CentOS8不更新了,所以安裝7;簡單就一筆帶過了 選擇下載好的操作系統的iso文件,下載地址https://mirrors.aliyun.com/centos/7.9.20 ...
  • 引言 上一章節介紹了 TDD 的三大法則,今天我們講一下在單元測試中模擬對象的使用。 Fake Fake - Fake 是一個通用術語,可用於描述 stub或 mock 對象。 它是 stub 還是 mock 取決於使用它的上下文。 也就是說,Fake 可以是 stub 或 mock Mock - ...
  • 概述:WPF界面綁定和渲染大量數據可能導致性能問題。通過啟用UI虛擬化、非同步載入和數據分頁,可以有效提高界面響應性能。以下是簡單示例演示這些優化方法。 在WPF中,當你嘗試綁定和渲染大量的數據項時,性能問題可能出現。以下是一些可能導致性能慢的原因以及優化方法: UI 虛擬化: WPF提供了虛擬化技術 ...
一周排行
    -Advertisement-
    Play Games
  • C#.Net的BCL提供了豐富的類型,最基礎的是值類型、引用類型,而他們的共同(隱私)祖先是 System.Object(萬物之源),所以任何類型都可以轉換為Object。 ...
  • 最近有群友咨詢C#如何調用Python?小編嘗試Python.NET過程中遭遇的版本相容性和環境配置難題,小編決定尋找一個更為簡單、穩定且對初學者友好的解決方案。小編搜索一番,除了Python.NET之外,還有其他途徑能夠幫助我們輕鬆地在C#項目調用Python腳本,那就是通過命令行調用,使用 Sy ...
  • .NET中特性+反射 實現數據校驗 在.NET中,我們可以使用特性+反射來實現數據校驗。特性是一種用於為程式中的代碼添加元數據的機制。元數據是與程式中的代碼相關聯的數據,但不直接成為代碼的一部分。通過特性,我們可以為類、方法、屬性等添加額外的信息,這些信息可以在運行時通過反射獲取和使用。 對反射不太 ...
  • Biwen.Settings 是一個簡易的配置項管理模塊,主要的作用就是可以校驗並持久化配置項,比如將自己的配置存儲到資料庫中,JSON文件中等 使用上也是很簡單,只需要在服務中註入配置, 比如我們有一個GithubSetting的配置項,我們只需要定義好對象然後註入到Service中即可: [De ...
  • EDP是一套集組織架構,許可權框架【功能許可權,操作許可權,數據訪問許可權,WebApi許可權】,自動化日誌,動態Interface,WebApi管理等基礎功能於一體的,基於.net的企業應用開發框架。通過友好的編碼方式實現數據行、列許可權的管控。 ...
  • 前言 VB.NET,全名Visual Basic .NET,是Microsoft .NET框架的一部分,是一種面向對象的編程語言。它繼承了Visual Basic的易用性,同時增加了對面向對象編程的支持。VB.NET提供了大量的內置函數,使得開發者可以更容易地處理字元串、數學計算、文件和目錄訪問等任 ...
  • 自定義可移動點二維坐標軸控制項 目錄 路由參數 坐標軸控制項定義 Demo 路由參數 X_YResultCollection為當前X軸對應Y軸值存儲字典 public class ResultCollectionChangedEventArgs(RoutedEvent routedEvent, obje ...
  • 自定義分頁控制項 tip: 該控制項的樣式用的是materialDesign庫,需要下載Nuget包 Code Xaml <UserControl x:Class="TestTool.CustomControls.PagingControl" xmlns="http://schemas.microsof ...
  • 最近群里有個小伙伴把Dapper遷移SqlSugar幾個不能解決的問題進行一個彙總,我正好寫一篇文章來講解一下 一、sql where in傳參問題: SELECT * FROM users where id IN @ids 答: SqlSugar中應該是 var sql="SELECT * FRO ...
  • 安裝nuget包 Wesky.Net.OpenTools 1.0.8或以上版本。支持.net framework 4.6以上版本,以及所有.net core以及以上版本引用。 開發一個簡單的Winform界面,用來測試使用。如需該winform的demo,可以在公眾號【Dotnet Dancer】後 ...