消息隊列NetMQ 原理分析3-命令產生/處理和回收線程

来源:http://www.cnblogs.com/Jack-Blog/archive/2017/04/27/6774902.html
-Advertisement-
Play Games

NetMQ是ZeroMQ的C#移植版本,它是對標準socket介面的擴展。它提供了一種非同步消息隊列,多消息模式,消息過濾（訂閱）,對多種傳輸協議的無縫訪問。本文記錄了NetMQ的源碼進行學習並分析理解。 ...


前言

介紹

[NetMQ](https://github.com/zeromq/netmq.git)是ZeroMQ的C#移植版本,它是對標準socket介面的擴展。它提供了一種非同步消息隊列,多消息模式,消息過濾（訂閱）,對多種傳輸協議的無縫訪問。
當前有2個版本正在維護，版本3最新版為3.3.4，版本4最新版本為4.0.1。本文檔是對4.0.1分支代碼進行分析。

zeromq的英文文檔
NetMQ的英文文檔

目的

對NetMQ的源碼進行學習並分析理解,因此寫下該系列文章,本系列文章暫定編寫計劃如下：

  1. 消息隊列NetMQ 原理分析1-Context和ZObject
  2. 消息隊列NetMQ 原理分析2-IO線程和完成埠
  3. 消息隊列NetMQ 原理分析3-命令產生/處理、創建Socket和回收線程
  4. 消息隊列NetMQ 原理分析4-Session、Option和Pipe
  5. 消息隊列NetMQ 原理分析5-Engine
  6. 消息隊列NetMQ 原理分析6-TCP和Inpoc實現
  7. 消息隊列NetMQ 原理分析7-Device
  8. 消息隊列NetMQ 原理分析8-不同類型的Socket
  9. 消息隊列NetMQ 原理分析9-實戰

友情提示: 看本系列文章時最好獲取源碼,更有助於理解。

命令

命令結構

Command定義如下

internal struct Command
{
    public Command([CanBeNull] ZObject destination, CommandType type, [CanBeNull] object arg = null) : this()
    {
        Destination = destination;
        CommandType = type;
        Arg = arg;
    }
    [CanBeNull]
    public ZObject Destination { get; }
    public CommandType CommandType { get; }
    [CanBeNull]
    public object Arg { get; private set; }        
    public override string ToString()
    {
        return base.ToString() + "[" + CommandType + ", " + Destination + "]";
    }
}

其包含了3個信息：調用者,命令類型和命令參數。

命令產生

還記的《消息隊列NetMQ 原理分析1-Context和ZObject》中我們介紹過NetMQ中的命令類型嗎?待處理命令全部會存放著Socket的信箱中。當Socket有命令(連接完成、發送完成或接受完成等)需要處理時調用基類ZObject的SendCommand方法。

private void SendCommand([NotNull] Command cmd)
{
    m_ctx.SendCommand(cmd.Destination.ThreadId, cmd);
}

201726204151-1

ZObject實際調用Context的SendCommand方法

public void SendCommand(int threadId, [NotNull] Command command)
{
    m_slots[threadId].Send(command);
}

m_slots[threadId]保存的是當前IO線程的IO信箱IOThreadMailbox,在《消息隊列NetMQ 原理分析2-IO線程和完成埠》
我們簡單介紹了IOThreadMailbox的結構。

[NotNull] private readonly YPipe<Command> m_commandPipe = new YPipe<Command>(Config.CommandPipeGranularity, "mailbox");

IOThreadMailbox中維護這一個Command管道,該管道實際就是一個先進先出隊列，詳細解析會在第四章進行介紹。

public void Send(Command command)
{
    bool ok;
    lock (m_sync)
    {
        //向管道寫入命令
        m_commandPipe.Write(ref command, false);
        //成功寫入會返回false,表示有命令需要處理
        ok = m_commandPipe.Flush();
    }
    if (!ok)
    {
        //向完成埠傳遞信號
        m_proactor.SignalMailbox(this);
    }
}

public bool TryRecv(out Command command)
{
    return m_commandPipe.TryRead(out command);
}

public void RaiseEvent()
{
    if (!m_disposed)
    {
        m_mailboxEvent.Ready();
    }
}

IOThreadMailbox的主要就是這三個方法

  1. 當有命令來的時候調用Send方法向管道(隊列)寫入命令。寫完時,會向完成埠傳遞信號。
  2. 當有命令需要處理時調用TryRecv方法讀取
  3. 當完成埠接收到信號需要命令處理時,調用RaiseEvent(實際是信箱的IO線程的RaiseEvent方法)進行處理命令。
public void SignalMailbox(IOThreadMailbox mailbox)
{
    //該方法會向完成埠的隊列中插入一個信號狀態
    m_completionPort.Signal(mailbox);
}

有關於完成埠介紹請查看《消息隊列NetMQ 原理分析2-IO線程和完成埠》

命令處理

當有命令需要處理時,完成埠會接收到信號。

private void Loop()
{
    ...
    int timeout = ExecuteTimers();
    int removed;
    if (!m_completionPort.GetMultipleQueuedCompletionStatus(timeout != 0 ? timeout : -1, completionStatuses, out removed))
        continue;
    for (int i = 0; i < removed; i++)
    {
        try
        {
            if (completionStatuses[i].OperationType == OperationType.Signal)
            {
                var mailbox = (IOThreadMailbox)completionStatuses[i].State;
                mailbox.RaiseEvent();
            }
            ...
        }
        ...
    }
    ...
}

線上程輪詢方法Loop中,當接收到需要處理的數據時,首先會判斷是否是信號,若為信號,則將狀態(參數)轉化為IOThreadMailbox類型,同時調用RaiseEvent方法處理命令。

public void Ready()
{
    Command command;
    while (m_mailbox.TryRecv(out command))
        command.Destination.ProcessCommand(command);
}

當有命令需要處理時,會調用IOThreadMailbox的TryRecv方法從管道(隊列,先進先出)中獲取第一個命令進行處理。

創建Socket(SocketBase)

在介紹回收線程工作之前,我們先看下創建一個新的Socket做了哪些工作,這裡的Socket實際是NetMQ中的SocketBase。

RequestSocket socket = new RequestSocket();
socket.Connect("tcp://127.0.0.1:12345");

NetMQSocket是NetMQ的Socket的基類。

public RequestSocket(string connectionString = null) : base(ZmqSocketType.Req, connectionString, DefaultAction.Connect)
{

}
internal NetMQSocket(ZmqSocketType socketType, string connectionString, DefaultAction defaultAction)
{
    m_socketHandle = NetMQConfig.Context.CreateSocket(socketType);
    m_netMqSelector = new NetMQSelector();
    Options = new SocketOptions(this);
    m_socketEventArgs = new NetMQSocketEventArgs(this);

    Options.Linger = NetMQConfig.Linger;

    if (!string.IsNullOrEmpty(connectionString))
    {
        var endpoints =
            connectionString.Split(new[] {','}, StringSplitOptions.RemoveEmptyEntries)
                .Select(a => a.Trim()).Where(a=> !string.IsNullOrEmpty(a));

        foreach (string endpoint in endpoints)
        {
            if (endpoint[0] == '@')
            {
                Bind(endpoint.Substring(1));
            }
            else if (endpoint[0] == '>')
            {
                Connect(endpoint.Substring(1));
            }
            else if (defaultAction == DefaultAction.Connect)
            {
                Connect(endpoint);
            }
            else
            {
                Bind(endpoint);
            }
        }
    }
}

首先會根據Socket的類型創建對應的Socket,調用的是Context的CreateSocket方法。具體的請看創建SocketBase。最終創建方法是調用SocketBase的Create方法

public static SocketBase Create(ZmqSocketType type, [NotNull] Ctx parent, int threadId, int socketId)
{
    switch (type)
    {
        ...
        case ZmqSocketType.Req:
            return new Req(parent, threadId, socketId);
        ...
        default:
            throw new InvalidException("SocketBase.Create called with invalid type of " + type);
    }
}

創建完後,就對地址進行解析。若有多個地址,則可用,分隔。

var endpoints =
connectionString.Split(new[] {','}, StringSplitOptions.RemoveEmptyEntries)
    .Select(a => a.Trim()).Where(a=> !string.IsNullOrEmpty(a));

解析完成後則用預設的方式進行綁定或連接，如RequestSocket預設為連接,而ResponseSocket則為綁定。

創建連接

  1. 首先對地址進行解析,判斷當前是tcp還是其他協議。然後會根據協議類型創建對應的Socket,具體的協議類型分析請查看《消息隊列NetMQ 原理分析6-TCP和Inpoc實現》

    private static void DecodeAddress([NotNull] string addr, out string address, out string protocol)
{
    const string protocolDelimeter = "://";
    int protocolDelimeterIndex = addr.IndexOf(protocolDelimeter, StringComparison.Ordinal);

    protocol = addr.Substring(0, protocolDelimeterIndex);
    address = addr.Substring(protocolDelimeterIndex + protocolDelimeter.Length);
}
  2. 負載均衡選擇一個IO線程。
  3. 創建Session,Socket和Session的關係如圖所示
    201742710032-2

  4. 創建管道，創建管道會創建一對單向管道，形成“一個”雙向管道。頭尾分別連接Socket和Session，如上圖所示。創建管道完畢後需要設置管道的回調事件，管道1設置回調為Socket的回調方法，管道2設置為Session的回調方法。

具體關於Session和Pipe的內容請查看《消息隊列NetMQ 原理分析4-Session、Option和Pipe》。

  1. 處理Socket和Session的關係
protected void LaunchChild([NotNull] Own obj)
{
    // Specify the owner of the object.
    obj.SetOwner(this);
    // Plug the object into the I/O thread.
    SendPlug(obj);
    // Take ownership of the object.
    SendOwn(this, obj);
}

  • 將Session的宿主設置為該Socket

    private void SetOwner([NotNull] Own owner)
{
Debug.Assert(m_owner == null);
m_owner = owner;
}

  • 為IO對象設置Session,當管道有數據交互時，Session的回調方法就會觸發。

    protected void SendPlug([NotNull] Own destination, bool incSeqnum = true)
{
if (incSeqnum)
    destination.IncSeqnum();
SendCommand(new Command(destination, CommandType.Plug));
}

    SessionBase的ProcessPlug會被觸發

    protected override void ProcessPlug()
{
m_ioObject.SetHandler(this);
if (m_connect)
    StartConnecting(false);
}

  • 將當前Session加入到Socket的Session集合中，

    protected void SendOwn([NotNull] Own destination, [NotNull] Own obj)
{
destination.IncSeqnum();
SendCommand(new Command(destination, CommandType.Own, obj));
}

    SocketBase的父類方法SendOwn(Own方法)方法會被觸發，將Session加入到集合中

    protected override void ProcessOwn(Own obj)
{
...
// Store the reference to the owned object.
m_owned.Add(obj);
}

    創建綁定

  1. 首先對地址進行解析,判斷當前是tcp還是其他協議。然後會根據協議類型創建對應的Socket,具體的協議類型分析請查看《消息隊列NetMQ 原理分析6-TCP和Inpoc實現》

    private static void DecodeAddress([NotNull] string addr, out string address, out string protocol)
{
    const string protocolDelimeter = "://";
    int protocolDelimeterIndex = addr.IndexOf(protocolDelimeter, StringComparison.Ordinal);

    protocol = addr.Substring(0, protocolDelimeterIndex);
    address = addr.Substring(protocolDelimeterIndex + protocolDelimeter.Length);
}

  2. 負載均衡選擇一個IO線程。

  3. 處理Socket和Session的關係

protected void LaunchChild([NotNull] Own obj)
{
    // Specify the owner of the object.
    obj.SetOwner(this);
    // Plug the object into the I/O thread.
    SendPlug(obj);
    // Take ownership of the object.
    SendOwn(this, obj);
}

  • 將Listener的宿主設置為該Socket

    private void SetOwner([NotNull] Own owner)
{
Debug.Assert(m_owner == null);
m_owner = owner;
}

  • 為IO對象設置Listener,當管道有數據交互是，Listener的回調方法就會觸發。

    protected void SendPlug([NotNull] Own destination, bool incSeqnum = true)
{
if (incSeqnum)
    destination.IncSeqnum();
SendCommand(new Command(destination, CommandType.Plug));
}

    Listener的ProcessPlug會被觸發

    protected override void ProcessPlug()
{
m_ioObject.SetHandler(this);
m_ioObject.AddSocket(m_handle);
//接收非同步socket
Accept();
}

  • 將當前Listener加入到Socket的Listener集合中，

    protected void SendOwn([NotNull] Own destination, [NotNull] Own obj)
{
destination.IncSeqnum();
SendCommand(new Command(destination, CommandType.Own, obj));
}

    SocketBase的父類方法SendOwn(Own方法)方法會被觸發，將Listener加入到集合中

    protected override void ProcessOwn(Own obj)
{
...
// Store the reference to the owned object.
m_owned.Add(obj);
}

    SocketBase的創建處理就完成了

回收線程

(垃圾)回收線程是專門處理(清理)非同步關閉的Socket的線程,它在NetMQ中起到至關重要的作用。

internal class Reaper : ZObject, IPollEvents
{
   ... 
}

Reaper是一個ZObject對象,同時實現了IPollEvents介面,該介面的作用是當有信息接收或發送時進行處理。回收線程實現了InEvent方法。

internal interface IPollEvents : ITimerEvent
{
    void InEvent();
    void OutEvent();
}

InEvent方法實現和IO線程的Ready方法很像,都是遍歷需要處理的命令進行處理。

public void InEvent()
{
    while (true)
    {
        Command command;
        if (!m_mailbox.TryRecv(0, out command))
            break;
        command.Destination.ProcessCommand(command);
    }
}

釋放SocketBase

當有SocketBase需要釋放時,會向完成埠發送Reap信號。

public void Close()
{
    // Mark the socket as disposed
    m_disposed = true;
    //工作線程向Socket郵箱發送Reap信號
    //回收線程會做剩下的工作
    SendReap(this);
}

發送回收命令

向回收線程的郵箱發送當前SocketBase的回收命令

protected void SendReap([NotNull] SocketBase socket)
{
    SendCommand(new Command(m_ctx.GetReaper(), CommandType.Reap, socket));
}

處理回收命令

Reap接收到釋放信號進行處理

protected override void ProcessReap(SocketBase socket)
{
    // Add the socket to the poller.
    socket.StartReaping(m_poller);
    ++m_sockets;
}

SocketBase回收

  1. 將當前Socket的加入到回收線程的中，當Socket接收到數據時，由回收線程回調該Socket的處理事件進行處理。
  2. 當前Socket終止處理

  3. 最後確認釋放

    internal void StartReaping([NotNull] Poller poller)
{
m_poller = poller;
m_handle = m_mailbox.Handle;
m_poller.AddHandle(m_handle, this);
m_poller.SetPollIn(m_handle);
Terminate();
CheckDestroy();
}
終止處理
  1. 終止Socket時，直接終止即可

預設情況下NetMQ的Linger值被設置為-1，就是說如果網路讀寫沒有進行完是不能退出的。如果Linger被設置為0,那麼中斷時會丟棄一切未完成的網路操作。如果Linger被設置的大於0，那麼將等待Linger毫秒用來完成未完成的網路讀寫，在指定的時間里完成或者超時都會立即返回。

  1. 若終止的是Session,則需要發送請求清理關聯Socket的當前Session對象

    protected void Terminate()
{
...
if (m_owner == null)
{
    // 釋放的是Socket,Owner為空
    ProcessTerm(m_options.Linger);
}
else
{
    // 釋放的是Session則會關聯一個Socket
    SendTermReq(m_owner, this);
}
}
    終止SocketBase
  2. 終止SocketBase時，需要先中斷當前SocketBase關聯的SessionBase
  3. 然後增加需要終端請求響應的個數，當全部都響應了則處理第四步驟
  4. 清空當前關聯的Session集合

  5. 最後當Session全部終止後發送給當前Socket宿主終端響應(TermAck)

    protected override void ProcessTerm(int linger)
{
...
// 斷開所有session的連接
foreach (Own it in m_owned)
{
    SendTerm(it, linger);
}
RegisterTermAcks(m_owned.Count);
m_owned.Clear();
CheckTermAcks();
}
    終止當前Socket關聯的Session
  6. 如果終端管道命令在終止命令前處理了，則立即終止當前Session
  7. 標記當前準備終止
  8. 若Ligner大於0 則等到N毫秒後再終止終止Socket和Session之間的管道

  9. 檢查管道是否還有數據要讀取

    protected override void ProcessTerm(int linger)
{
if (m_pipe == null)
{
    ProceedWithTerm();
    return;
}

m_pending = true;

if (linger > 0)
{
    Debug.Assert(!m_hasLingerTimer);
    m_ioObject.AddTimer(linger, LingerTimerId);
    m_hasLingerTimer = true;
}
// 是否需要等待一定時間後消息處理完再終止管道.
m_pipe.Terminate(linger != 0);

// TODO: Should this go into pipe_t::terminate ?
// In case there's no engine and there's only delimiter in the
// pipe it wouldn't be ever read. Thus we check for it explicitly.
m_pipe.CheckRead();
}
    終止管道

    管道狀態如下所示

    private enum State
{
/// <summary> Active 表示在中斷命令開始前的狀態 </summary>
Active,
/// <summary> Delimited 表示在終端命令接收前從管道接收到分隔符</summary>
Delimited,
/// <summary> Pending 表示中斷命令已經從管道接收，但是仍有待定消息可讀</summary>
Pending,
/// <summary> Terminating 表示所有待定消息都已經讀取等待管道終止確認信號返回 </summary>
Terminating,
/// <summary> Terminated 表示終止命令是由用戶顯示調用 </summary>
Terminated,
/// <summary> Double_terminated 表示用戶調用了終止命令同時管道也調用了終止命令 </summary>
DoubleTerminated
}

  10. 終止當前管道
    若當前狀態為Terminated、DoubleTerminated和Terminating不再處理終止命令

    public void Terminate(bool delay)
{
    //判斷當前狀態是否可處理終止命令
    ...

    if (m_state == State.Active)
    {
        // 向另一個管道發送終止命令然後等待確認終止
        SendPipeTerm(m_peer);
        m_state = State.Terminated;
    }
    else if (m_state == State.Pending && !m_delay)
    {
        // 若有待處理數據，但是不等待直接終止,則向另一個管道發送確認終止.
        m_outboundPipe = null;
        SendPipeTermAck(m_peer);
        m_state = State.Terminating;
    }
    else if (m_state == State.Pending)
    {
        //若有待處理數據但是需要等到則不處理.
    }
    else if (m_state == State.Delimited)
    {
        //若已經獲取到限定符但是還沒有收到終止命令則忽略定界符，然後發送終止命令給另一個管道 
        SendPipeTerm(m_peer);
        m_state = State.Terminated;
    }
    else
    {
        // 沒有其他狀態
        Debug.Assert(false);
    }
    //停止向外發送的消息
    m_outActive = false;

    if (m_outboundPipe != null)
    {
        //拋棄未發送出的消息.
        Rollback();

        // 這裡不會再先查水位，所以即使管道滿了也可再寫入，向管道寫入定界符 .
        var msg = new Msg();
        msg.InitDelimiter();
        m_outboundPipe.Write(ref msg, false);
        Flush();
    }
}

  11. 終止另一個管道

    protected override void ProcessPipeTerm()
{
    // 這是一個簡單的例子有道管道終止 
    //若沒有更多待處理消息需要讀取，或者這個管道已經丟去待處理數據，我們直接將狀態設置為正在終止(terminating),否則我們擱置待處理狀態直到所有待處理消息被髮送
    if (m_state == State.Active)
    {
        if (!m_delay)
        {
            //不需要等到消息處理
            m_state = State.Terminating;
            m_outboundPipe = null;
            //發送終止確認
            SendPipeTermAck(m_peer);
        }
        else
            m_state = State.Pending;
        return;
    }
    // 若定界符碰巧在終止命令之前到達，將狀態改為正在終止
    if (m_state == State.Delimited)
    {
        m_state = State.Terminating;
        m_outboundPipe = null;
        SendPipeTermAck(m_peer);
        return;
    }
    // 當管道併發關閉，則狀態改為DoubleTerminated
    if (m_state == State.Terminated)
    {
        m_state = State.DoubleTerminated;
        m_outboundPipe = null;
        SendPipeTermAck(m_peer);
        return;
    }
    // pipe_term is invalid in other states.
    Debug.Assert(false);
}

  12. 確認終止

    protected override void ProcessPipeTermAck()
{
    // 通知Socket或Session中斷當前管道 .
    Debug.Assert(m_sink != null);
    m_sink.Terminated(this);

    // 若正則處理或double_terminated這裡不做任何事 
    // 簡化釋放管道，在已終止狀態，我們必須在釋放這個管道之前確認
    //其他狀態都是非法的 
    if (m_state == State.Terminated)
    {
        m_outboundPipe = null;
        SendPipeTermAck(m_peer);
    }
    else
        Debug.Assert(m_state == State.Terminating || m_state == State.DoubleTerminated);

    // 刪除所有管道中的未讀消息，然後釋放流入管道 
    var msg = new Msg();
    while (m_inboundPipe.TryRead(out msg))
    {
        msg.Close();
    }

    m_inboundPipe = null;
}

    整體回收Socket流程圖如下：

2017427171929-3

public virtual void InEvent()
{
    // 回收線程命令會調用此事件
    try
    {
        ProcessCommands(0, false);
    }
    catch
    {
        // ignored
    }
    finally
    {
        CheckDestroy();
    }
}
private void CheckDestroy()
{
    // socket釋放完則做最後的清除和釋放工作.
    if (m_destroyed)
    {
        // 從回收線程移除輪詢
        m_poller.RemoveHandle(m_handle);
        // 釋放socke.
        DestroySocket(this);
        // 通知已釋放.
        SendReaped();
        // Deallocate.
        base.ProcessDestroy();
    }
}

總結

該篇介紹命令處理方式和回收線程回收Socket，順便介紹了下創建SocketBase的細節性問題。以便對釋放Socket有更清晰的認識。


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

-Advertisement-
Play Games
更多相關文章
  • 基於.Net Framework 4.0 Web API開發（4）：ASP.NET Web APIs 基於
    概述： ASP.NET Web API 的好用使用過的都知道，沒有複雜的配置文件，一個簡單的ApiController加上需要的Action就能工作。但是在使用API的時候總會遇到跨域請求的問題， 特別各種APP萬花齊放的今天，對API使用者身份角色驗證是不能避免的（完全開發的API不需要對使用者身 ...
  • ASP.NET Core的配置（5）：配置的同步[設計篇]
    本節所謂的“配置同步”主要體現在兩個方面：其一，如何監控配置源併在其變化的時候自動載入其數據，其目的是讓應用中通過Configuration對象承載的配置與配置源的數據同步；其二、當Configuration對象承載的配置放生變換的時候如何嚮應用程式發送通知，最終讓應用程式使用最新的配置。 一、配置 ...
  • （翻譯）Entity Framework技巧系列之一 - Tip 1 - 5
    本系列英文原文出自。 提示1. 在Entity Framework中怎樣排序關係(Relationships) 問題： 在Entity Framework論壇中常會看到關於排序相關聯項目的問題。 例如，想象你要查詢客戶，並返回那些欠款超過30的賬戶，與此同時檢索這些賬戶的訂單。 並且你需要將那些訂單 ...
  • 用慣了Task，你應該也需要瞭解它的內部調度機制TaskScheduler
    平時我們在用多線程開發的時候少不了Task，確實task給我們帶來了巨大的編程效率，在Task底層有一個TaskScheduler，它決定了task該如何被調度，而 在.net framework中有兩種系統定義Scheduler，第一個是Task預設的ThreadPoolTaskScheduler ...
  • NPOI操作Excel文件
    首先，通過NuGet添加NPOI. NPOI依賴SharpZipLib，通過NuGet添加SharpZipLib. 然後添加NPOI. 添加後項目的引用列表如下： 把DataTable轉換成Excel文件。 代碼如下： public static MemoryStream RenderDataTab ...
  • AspNetCore-MVC實戰系列（二）之通過綁定郵箱找回密碼
    AspNetCore - MVC實戰系列目錄 . 愛留圖網站誕生 . AspNetCore - MVC實戰系列（一）之Sqlserver表映射實體模型 . AspNetCore-MVC實戰系列（二）之通過綁定郵箱找回密碼 開篇嘮嗑 本篇內容寫在5.1假期前夕，主要是讓大家能在節假日休息充點的時候能有 ...
  • [.NET] 《Effective C#》快速筆記（三）- 使用 C# 表達設計
    《Effective C#》快速筆記（三）- 使用 C# 表達設計 目錄 二十一、限制類型的可見性 二十二、通過定義並實現介面替代繼承 二十三、理解介面方法和虛方法的區別 二十四、用委托實現回調 二十五、用事件模式實現通知 二十六、避免返回對內部類對象的引用 二十七、讓類型支持序列化 二十八、提供組 ...
  • NPOI 生成 excel基本設置
    //設置頁眉頁腳 tempSheet.Header.Center = "2017-04-27"; tempSheet.Footer.Center = "√" + " 正常 " + "×" + " 故障 " + "○" + " 其他 "; //設置單元格邊線ICellStyle style = wb1 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類