文件名称：NSQCore:.net NSQ核心客户端
文件大小：30KB
文件格式：ZIP
更新时间：2024-05-22 01:00:37
webjet webjetota team-bcs team-flights C#
NSQCore 面向netstandard 1.4的 .NET Core 1.0客户端库 仅与nsqio 1.0.0版兼容 该项目最初是从分支出来的，然后转换为.Net Standard 1.4 用法 Nuget来源： PM> Install-Package NSQCore 产生讯息 var prod = new NsqProducer("localhost", 4151); await prod.PublishAsync("topic1", "hello world" ); await prod.SetMaxInFlightAsync(1); 连接字符串如下所示： nsqd=localhost:4151; 消费信息 var cons = NsqConsumer.Create("lookupd=localhost:4161; topic=topic1; channel=abc");
【文件预览】：
NSQCore-master
----NSQCore()
--------CommunicationException.cs(206B)
--------BackoffStrategies.cs(3KB)
--------HttpClientWrapper.cs(2KB)
--------NsqConsumer.cs(917B)
--------Addresses.cs(3KB)
--------NsqTcpConnection.cs(13KB)
--------MessageBody.cs(2KB)
--------System()
--------DiscoveryEventArgs.cs(309B)
--------ConsumerOptions.cs(7KB)
--------InternalMessageEventArgs.cs(437B)
--------NsqLookupConsumer.cs(9KB)
--------TopicAndChannel.cs(2KB)
--------NsqLookup.cs(5KB)
--------Properties()
--------Frame.cs(557B)
--------NsqProducer.cs(6KB)
--------Message.cs(3KB)
--------Commands()
--------FrameReader.cs(3KB)
--------NsqStatistics.cs(5KB)
--------NSQCore.csproj(1KB)
----NSQCoreClient()
--------Program.cs(1KB)
--------NSQCoreClient.csproj(261B)
----LICENSE.md(1KB)
----README.md(2KB)
----NSQCore.sln(1KB)
----.gitignore(178B)