Tùy chọn Network Callback

Không gian tên: Nalix.Network.Options
Assembly: Nalix.Network

NetworkCallbackOptions cấu hình hai lớp áp lực callback độc lập:

1. Lớp 1 (ngưỡng theo từng kết nối trong SocketConnection): Giới hạn số gói nhận đang chờ (MaxPerConnectionPendingPackets) và số luồng phân mảnh đang mở (MaxPerConnectionOpenFragmentStreams) cho mỗi kết nối, áp dụng OverflowPolicy (DropPacket hoặc Disconnect) khi vượt ngưỡng.
2. Lớp 2 (làn công bằng toàn cục và theo IP trong AsyncCallback): Áp dụng ngân sách riêng cho callback xử lý đầu vào (CallbackLane.Process) và callback hậu xử lý đầu ra (CallbackLane.Post), trên các bộ đếm toàn cục và mảng công bằng băm theo endpoint không dùng lock (FairnessMapSize).

Ánh xạ mã nguồn#

• src/Nalix.Network/Options/NetworkCallbackOptions.cs
• src/Nalix.Abstractions/Networking/NetworkOverflowPolicy.cs
• src/Nalix.Network/Internal/Transport/SocketConnection.cs
• src/Nalix.Network/Internal/Transport/AsyncCallback.cs
• src/Nalix.Network/Connections/Connection.cs
• src/Nalix.Network/Internal/Pooling/PooledConnectEventContext.cs

Giá trị mặc định và kiểm tra hợp lệ#

Quy tắc kiểm tra hợp lệ#

Validate() chạy kiểm tra DataAnnotations, sau đó kiểm tra ba ràng buộc liên trường:

• CallbackWarningThreshold < MaxPendingNormalCallbacks (khi CallbackWarningThreshold > 0)
• MaxPendingPerIp <= MaxPendingNormalCallbacks
• MaxPendingPostPerIp <= MaxPendingPostCallbacks

Lớp 1: Ngưỡng nhận dữ liệu theo từng kết nối (Connection.OnFrameReceived và SocketConnection)#

Khi một khung hoàn chỉnh được lắp ráp trong SocketConnection.PROCESS_FRAME_FROM_BUFFER, nó gọi _connectionOwner?.OnFrameReceived(lease) trên Connection sở hữu. Khi AsyncCallback.CanRunInline(backing.MessageProcessing) là false, Connection.OnFrameReceived tăng backing.PendingProcessCallbacks trước khi xếp hàng khung:

• Nếu bộ đếm vượt quá MaxPerConnectionPendingPackets:
  • Bộ đếm được giảm ngay lập tức, IncrementPacketsDropped() được gọi và lease của khung được giải phóng.
  • Nếu OverflowPolicy == NetworkOverflowPolicy.Disconnect, kết nối bị đóng ngay (Disconnect()) để bảo vệ máy chủ khỏi lạm dụng kiểu consumer chậm / flood.
  • Nếu OverflowPolicy == NetworkOverflowPolicy.DropPacket (mặc định), gói bị loại bỏ và kết nối vẫn mở.
• Ngược lại, khung được bọc trong ConnectionEventArgs và được điều phối qua:

  AsyncCallback.Invoke(
      s_messageProcessingBridge,
      this,
      args,
      CallbackLane.Process,
      releasePendingPacketOnCompletion: true);

  Khi callback thực thi xong, PooledConnectEventContext thông báo cho kết nối (ReleasePendingPacket()) để giảm backing.PendingProcessCallbacks.

Giới hạn luồng phân mảnh#

Khi một khung phân mảnh đến và mở một luồng mới trong FragmentAssembler, SocketConnection áp dụng MaxPerConnectionOpenFragmentStreams. Nếu số lượng vượt quá MaxPerConnectionOpenFragmentStreams, luồng bị từ chối và khung bị loại bỏ. Các luồng phân mảnh đã hết hạn được loại bỏ định kỳ qua FragmentAssembler.EvictExpired(...).

Lớp 2: Áp lực ngược hai làn của AsyncCallback#

AsyncCallback tách các callback thường thành hai làn độc lập (CallbackLane.Process cho MessageProcessing và CallbackLane.Post cho MessageProcessed), cùng một làn dọn dẹp ưu tiên cao (InvokeHighPriority cho ConnectionClosed):

flowchart TD
    I["AsyncCallback.Invoke(delegate, sender, args, lane)"] --> G{"Reserve Global Slot?<br/>(Process: MaxPendingNormalCallbacks<br/>Post: MaxPendingPostCallbacks)"}
    G -- No --> D1["Increment Dropped + Return false"]
    G -- Yes --> E{"Reserve Per-IP Fairness Bucket?<br/>(Process: MaxPendingPerIp<br/>Post: MaxPendingPostPerIp)"}
    E -- No --> R["Rollback Global Slot + Increment Dropped"]
    E -- Yes --> Q["Rent PooledConnectEventContext + UnsafeQueueUserWorkItem"]
    Q --> X["Execute Callback -> Measure Elapsed Ms -> Release Slots"]

Làn dọn dẹp ưu tiên cao#

AsyncCallback.InvokeHighPriority(...) được Connection dùng khi phát sinh ConnectionClosed. Làn này bỏ qua MaxPendingNormalCallbacks và MaxPendingPerIp, để việc dọn dẹp ngắt kết nối và giải phóng tài nguyên luôn được thực thi kể cả khi callback đang bão hòa nghiêm trọng.

Chẩn đoán (AsyncCallbackMetrics)#

AsyncCallback.GetStatistics() trả về một internal readonly struct AsyncCallbackMetrics:

Ví dụ cấu hình INI#

[NetworkCallback]
MaxPerConnectionPendingPackets = 16
MaxPerConnectionOpenFragmentStreams = 4
OverflowPolicy = DropPacket
MaxPendingNormalCallbacks = 10000
CallbackWarningThreshold = 5000
MaxPendingPerIp = 64
MaxPendingPostCallbacks = 5000
MaxPendingPostPerIp = 32
MaxCallbackExecutionMs = 50
MaxPooledCallbackStates = 1000
FairnessMapSize = 16384

API liên quan#

• Sự kiện kết nối
• Socket Connection
• Tùy chọn Connection Guard
• Tùy chọn Pooling
• Tùy chọn mạng