Nalix.Network

Nalix.Network là tầng transport máy chủ cấp 3. Nó cung cấp các listener TCP, UDP và WebSocket hiệu năng cao, vòng lặp nhận/gửi frame trên socket, kiểm soát chấp nhận kết nối (ConnectionGuard), theo dõi kết nối đang hoạt động (ConnectionHub), phân tích proxy-protocol/forwarded-header, và loại bỏ kết nối nhàn rỗi bằng timing wheel.

Vị trí trong kiến trúc#

flowchart LR
    A["TcpListenerBase / UdpListenerBase / WebSocketListenerBase"] --> B["ConnectionGuard & ConnectionHub"]
    B --> C["Protocol (IProtocol)"]
    C --> D["IPacketDispatch (Nalix.Runtime)"]

Thành phần cốt lõi#

1. Listener transport (Nalix.Network.Listeners)#

Mọi listener đều triển khai IListener, IActivatable và IReportable:

• Activate(CancellationToken) / Deactivate(CancellationToken)
• GenerateReport() / WriteReportData(Utf8JsonWriter) để chẩn đoán trực tiếp

2. Cầu nối giao thức (Protocol)#

Lớp trừu tượng Protocol (Nalix.Network.Protocols.Protocol) nối các kết nối transport thô với bộ điều phối gói tin:

• Bộ xử lý frame & bộ trích xuất opcode — Cung cấp abstract IFrameProcessor FrameProcessor { get; } và abstract IOpCodeExtractor OpCodeExtractor { get; } (được ApplicationProtocol / DefaultProtocol trong Nalix.Hosting triển khai tự động).
• Chấp nhận kết nối — ValidateConnection(IConnection) kiểm soát các kết nối mới trước khi đăng ký.
• Vòng đời sau chấp nhận — OnAccept(IConnection, CancellationToken) chạy sau khi đã qua kiểm soát và đăng ký vào hub.
• Xử lý thông điệp — ProcessMessage(object? sender, IConnectionEventArgs args) chuyển các payload IBufferLease đã đóng khung tới IPacketDispatch.HandlePacket(...).
• Bật/tắt chấp nhận động — IsAccepting và SetConnectionAcceptance(bool) bật hoặc tạm dừng chấp nhận kết nối mới một cách nguyên tử, mà không đóng các socket đang hoạt động.

using Nalix.Abstractions.Networking;
using Nalix.Hosting.Protocols;

public sealed class GameProtocol : ApplicationProtocol
{
    public override void ProcessMessage(object? sender, IConnectionEventArgs args)
        => this.Dispatch.HandlePacket(args.Lease, args.Connection);

    protected override bool ValidateConnection(IConnection connection)
        => true;
}

3. Kết nối, hub & bảo vệ chấp nhận#

• SocketConnection & WebSocketConnection — Các triển khai IConnection cụ thể, quản lý việc truyền frame TCP/UDP/WebSocket (IConnectionTransmission), trạng thái số thứ tự và lease bộ đệm có pool.
• ConnectionHub — Registry kết nối đang hoạt động trong bộ nhớ, được phân mảnh (sharded), hỗ trợ tra cứu theo ID ISnowflake, các hàm phát tin và ảnh chụp chẩn đoán.
• ConnectionGuard — Bộ bảo vệ chấp nhận và chống lạm dụng nhiều tầng, thực thi trần kết nối toàn cục, hạn ngạch kết nối đồng thời theo IP, ngưỡng slowloris/lỗi, và cấm vĩnh viễn (FileBanStore, FileBlacklistStore).
• TimingWheel — Timer wheel phân cấp với độ phức tạp O(1), loại bỏ các kết nối nhàn rỗi mà không cấp phát timer riêng cho từng kết nối.

Tùy chọn cấu hình (Nalix.Network.Options)#

Trang API chính#

• Protocol
• TCP Listener
• UDP Listener
• WebSocket Listener
• Connection
• Connection Guard
• Connection Hub
• WebSocket Connection
• Tùy chọn Network