Ứng dụng mạng

Không gian tên: Nalix.Hosting, Nalix.Hosting.Protocols
Assembly: Nalix.Hosting

Nalix.Hosting cung cấp một builder fluent theo phong cách Microsoft (INetworkApplicationBuilder / NetworkApplicationBuilder) và host máy chủ (NetworkApplication), điều phối việc nạp cấu hình, đăng ký phụ thuộc, nối handler packet lúc biên dịch, và vòng đời listener đa transport (TCP, UDP và WebSocket).

Ánh xạ mã nguồn#

• src/Nalix.Hosting/NetworkApplication.cs
• src/Nalix.Hosting/INetworkApplicationBuilder.cs
• src/Nalix.Hosting/NetworkApplicationBuilder.cs
• src/Nalix.Hosting/NetworkApplicationBuilder.Extensions.cs
• src/Nalix.Hosting/IProtocolBindingBuilder.cs
• src/Nalix.Hosting/IWebSocketBindingBuilder.cs
• src/Nalix.Hosting/Protocols/DefaultProtocol.cs
• src/Nalix.Hosting/Protocols/DefaultFrameProcessor.cs
• src/Nalix.Hosting/Protocols/DefaultOpCodeExtractor.cs

Luồng khởi động & vòng đời#

flowchart LR
    subgraph Phase1["1. Fluent Configuration"]
        CB["NetworkApplication.CreateBuilder()"] --> Opts["Configure<TOptions>() / UseLogger()"]
        Opts --> Feat["UseSecureConnections() / UseSessions() / UseGroups()"]
        Feat --> Map["MapHandlers<THandler>() / RegisterScoped<T>()"]
        Map --> Bind["MapTcp<T>() / MapUdp<T>() / MapWebSocket<T>().Bind()"]
    end

    subgraph Phase2["2. Build()"]
        Bind --> Bld["Build()"]
        Bld --> RegPkt["RegisterPacketRegistry() + ApplyOptions()"]
        RegPkt --> Factories["Capture Dispatch & Listener Factories"]
    end

    subgraph Phase3["3. ActivateAsync() / RunAsync()"]
        Factories --> Prep["Register Logger, Hub, Guard, BufferPool, ObjectPool"]
        Prep --> Disp["Create & Activate IPacketDispatch"]
        Disp --> Listen["Construct & Activate TCP / UDP / WebSocket Listeners"]
    end

Tham chiếu NetworkApplication#

public sealed class NetworkApplication : IActivatableAsync, IAsyncDisposable
{
    public static NetworkApplicationBuilder CreateBuilder();
    public static NetworkApplication CreateMinimal(ushort? port = null);

    public Task RunAsync(CancellationToken cancellationToken = default);
    public Task ActivateAsync(CancellationToken cancellationToken = default);
    public Task DeactivateAsync(CancellationToken cancellationToken = default);
    public ValueTask DisposeAsync();
    public void Dispose();
}

Chi tiết phương thức#

Tham chiếu INetworkApplicationBuilder#

Các phương thức builder cốt lõi#

Phương thức mở rộng tính năng (NetworkApplicationBuilderExtensions)#

Nalix.Hosting cung cấp các phương thức mở rộng tùy chọn (opt-in) trên INetworkApplicationBuilder cho các hệ thống con runtime tích hợp sẵn:

Tham chiếu IProtocolBindingBuilder (TCP & UDP)#

MapTcp<TProtocol>() và MapUdp<TProtocol>() trả về một IProtocolBindingBuilder:

public interface IProtocolBindingBuilder
{
    IProtocolBindingBuilder OnPort(ushort port);
    IProtocolBindingBuilder WithMode(OperatingMode mode);
    IProtocolBindingBuilder WithFactory(Func<IPacketDispatch, IProtocol> factory);
    IProtocolBindingBuilder WithAuthentication(Func<IConnection, EndPoint, ReadOnlySpan<byte>, bool> authen);
    INetworkApplicationBuilder Bind();
}

Tham chiếu DefaultProtocol#

Với các ứng dụng đẩy mọi khung trực tiếp vào IPacketDispatch mà không cần máy trạng thái ở tầng protocol riêng, Nalix.Hosting.Protocols.DefaultProtocol giúp bạn không cần tự viết một lớp con Protocol:

[Injectable]
public sealed class DefaultProtocol : Protocol
{
    public DefaultProtocol(ILogger logger, IPacketDispatch dispatch);
    public override IFrameProcessor FrameProcessor { get; }
    public override IOpCodeExtractor OpCodeExtractor { get; }
    public override void ProcessMessage(object? sender, IConnectionEventArgs args);
}

• Đặt IsAccepting = true và KeepConnectionOpen = true khi khởi tạo.
• Dùng DefaultFrameProcessor và DefaultOpCodeExtractor (đọc payload.AsHeaderRef().OpCode từ PacketHeader).
• Chuyển trực tiếp args.Lease và args.Connection cho _dispatch.HandlePacket(args.Lease, args.Connection).

Ví dụ sử dụng thực tế#

using System.Threading;
using System.Threading.Tasks;
using Microsoft.Extensions.Logging;
using Nalix.Hosting;
using Nalix.Hosting.Protocols;
using Nalix.Network.Options;
using Nalix.Runtime.Middleware;

public static class Program
{
    public static async Task Main(string[] args)
    {
        using ILoggerFactory loggerFactory = LoggerFactory.Create(b => b.AddConsole());
        ILogger logger = loggerFactory.CreateLogger("GameServer");

        await using NetworkApplication app = NetworkApplication.CreateBuilder()
            .UseLogger(logger)
            .Configure<NetworkSocketOptions>(opt =>
            {
                opt.Port = 57206;
                opt.EnableDualStack = true;
            })
            .UseSecureConnections()
            .UseSessions()
            .UseGroups()
            .UseTimeSync()
            .ConfigureDispatchOptions(dispatch =>
            {
                dispatch.WithMiddleware(new TokenBucketMiddleware());
            })
            .MapHandlers<PlayerController>()
            .MapTcp<DefaultProtocol>().OnPort(57206).Bind()
            .MapUdp<DefaultProtocol>().OnPort(57206).Bind()
            .Build();

        using CancellationTokenSource cts = new();
        Console.CancelKeyPress += (_, e) =>
        {
            e.Cancel = true;
            cts.Cancel();
        };

        await app.RunAsync(cts.Token);
    }
}

API liên quan#

• Ràng buộc WebSocket Hosting
• Tùy chọn Hosting
• Protocol
• TCP Listener
• UDP Listener
• Packet Dispatch Channel & Router
• Tùy chọn Packet Dispatch