NATS .NET C# Streaming 客户端官方源码下载

【实例简介】
NATS .NET C# Streaming Client是一个高性能、轻量级且可靠的流平台客户端，由NATS支持。
主要特性包括：基于日志的持久性、至少一次的交付模型确保消息可靠传递、按订阅匹配速率、重放/重启以及最后值语义。

var cf = new StanConnectionFactory();
using (var c = cf.CreateConnection("test-cluster", "appname"))
{
    using (c.Subscribe("foo", (obj, args) =>
    {
        Console.WriteLine(
            System.Text.Encoding.UTF8.GetString(args.Message.Data));
    }))
    {
        c.Publish("foo", System.Text.Encoding.UTF8.GetBytes("hello"));
    }
}

此外，NATS Streaming 订阅与NATS订阅类似，但客户端可以在消息流中更早的点开始其订阅，允许他们接收在此客户端注册感兴趣之前发布的消息。NATS Streaming还提供了持久订阅功能，允许客户端为订阅分配一个持久名称。这使得NATS Streaming服务器跟踪该clientID+持久名称的最后一个确认消息，以便仅将自上次确认的消息后的消息传递给客户端。
【实例截图】
【核心代码】
文件清单
└── stan.net-f5bb25e560bc9d2ee5d63194a4c9a08a995901f6
    ├── az-templates
    │   ├── stage-build.yml
    │   └── stage-deploy.yml
    ├── azure-pipelines-cd.yml
    ├── azure-pipelines-ci.yml
    ├── CODE-OF-CONDUCT.md
    ├── dependencies.md
    ├── doc
    │   ├── build_doc.bat
    │   ├── customdoxygen.css
    │   ├── DoxyFile.STAN.Client
    │   ├── footer.html
    │   └── header.html
    ├── GOVERNANCE.md
    ├── install_nss.sh
    ├── LICENSE
    ├── MAINTAINERS.md
    ├── README.md
    └── src
        ├── Directory.Build.props
        ├── Samples
        │   ├── RxSample
        │   │   ├── Program.cs
        │   │   └── RxSample.csproj
        │   ├── StanPub
        │   │   ├── Program.cs
        │   │   └── StanPub.csproj
        │   └── StanSub
        │       ├── Program.cs
        │       └── StanSub.csproj
        ├── STAN.Client
        │   ├── AsyncSubscription.cs
        │   ├── BlockingChannel.cs
        │   ├── Consts.cs
        │   ├── IStanConnection.cs
        │   ├── IStanSubscription.cs
        │   ├── Options.cs
        │   ├── package-icon.png
        │   ├── pb
        │   │   ├── genproto.bat
        │   │   └── protocol.proto
        │   ├── Protocol.cs
        │   ├── ProtocolSerializer.cs
        │   ├── Rx
        │   │   ├── RxExtensions.cs
        │   │   └── StanObservableSubscription.cs
        │   ├── StanAckHandlerArgs.cs
        │   ├── STAN.Client.csproj
        │   ├── StanConnection.cs
        │   ├── StanConnectionFactory.cs
        │   ├── StanConnLostHandlerArgs.cs
        │   ├── STANExceptions.cs
        │   ├── StanMsg.cs
        │   ├── StanMsgHandlerArgs.cs
        │   └── SubscriptionOptions.cs
        ├── STAN.Client.snk
        ├── STAN.sln
        └── Tests
            ├── IntegrationTests
            │   ├── BasicTests.cs
            │   ├── ClusterTests.cs
            │   ├── IntegrationTests.csproj
            │   ├── PingTests.cs
            │   ├── RxTests.cs
            │   ├── TestServerInfo.cs
            │   ├── TestSuite.cs
            │   └── TestUtilities.cs
            └── UnitTests
                ├── TestOptions.cs
                └── UnitTests.csproj

14 directories, 57 files