Linkduck 1.0.0

Linkduck

Linkduck 是一个连接管理框架，提供统一的连接生命周期管理、状态事件和自动重连。

目前内置的传输层实现：SignalR。框架预留了扩展点，可自行实现 WebSocket、MQTT 等其他协议。

Packages

Package	NuGet	Description
Linkduck.Abstractions		Interfaces, base classes, and enums for building custom connection types
Linkduck		Core implementation: Manager, InMemoryStore, HostService, DI integration
Linkduck.SignalR		SignalR transport — client-side and server-side

Quick Start — SignalR

dotnet add package Linkduck.SignalR

Client Side（主动连接）

需要自行继承的类：

public class MyConnection : SignalRLinkduckBase
{
    public MyConnection(string name, string type, SignalRLinkduckOptions opts, IServiceProvider sp)
        : base(name, type, LinkduckMode.Active, opts, sp) { }

    protected override async Task ConfigureHubAsync(HubConnection hub)
    {
        // 注册消息处理器，断线重连后自动重新注册
        hub.On<string>("ReceiveHello", message =>
        {
            Console.WriteLine($"收到: {message}");
        });
    }
}

public class MyFactory : LinkduckFactoryBase
{
    readonly IServiceProvider _sp;
    public MyFactory(string type, IServiceProvider sp) : base(type) => _sp = sp;
    public override ILinkduck Create(LinkduckInfo info)
    {
        var opts = new SignalRLinkduckOptions { HubUri = new Uri(info.Options["HubUri"]) };
        return new MyConnection(info.Name, info.Type, opts, _sp);
    }
}

// 注册到 DI（种子配置 → 自动创建连接 → 自动重连）
var builder = WebApplication.CreateBuilder(args);
builder.Services.AddInMemoryLinkduckStore(new[]
{
    new LinkduckInfo
    {
        Name = "client1", Type = "myType",
        Options = new() { { "HubUri", "http://localhost:5000/hub" }, { "UseToken", "true" } }
    }
});
builder.Services.AddLinkduckFactory<MyFactory>("myType");
builder.Services.AddSignalRTokenProvider<MyTokenProvider>("myType");
await builder.Build().RunAsync();

Server Side（被动监听）

需要自行继承的类：

public class MyHub : SignalRLinkduckHubBase<MyListener>
{
    public MyHub(MyListener listener) : base(listener) { }

    // 客户端可通过 connection.InvokeAsync("SayHello", "world") 调用
    public Task<string> SayHello(string name)
        => Task.FromResult($"Hello, {name}!");
}

public class MyListener : SignalRLinkduckListenerBase
{
    public MyListener(string type) : base(type) { }
    protected override Task OnStartingAsync(CancellationToken ct) => Task.CompletedTask;
    protected override Task OnStoppingAsync(CancellationToken ct) => Task.CompletedTask;
}

// 注册到 DI
var builder = WebApplication.CreateBuilder(args);
builder.Services.AddSignalRListenerWithHub<MyListener, MyHub>("myType", "/hub");

var app = builder.Build();
app.UseLinkduckSignalR();
await app.RunAsync();

自动重连：客户端连接断开后，SignalR 内置自动重连 + LinkduckBase 后台重试循环双重保障。服务端 Hub 方法定义不变，客户端 .On() 注册的处理器在重连后自动恢复。

See docs/guide.md for detailed usage and docs/design.md for architecture.

License

MIT License — see LICENSE.