DH.NMQ 2.0.2024.1008-beta0853

.NET Standard 2.0 This package targets .NET Standard 2.0. The package is compatible with this framework or higher. .NET Framework 4.5 This package targets .NET Framework 4.5. The package is compatible with this framework or higher.
This is a prerelease version of DH.NMQ. 
dotnet add package DH.NMQ --version 2.0.2024.1008-beta0853                

                    
                

            
NuGet\Install-Package DH.NMQ -Version 2.0.2024.1008-beta0853
This command is intended to be used within the Package Manager Console in Visual Studio, as it uses the NuGet module's version of Install-Package. 
<PackageReference Include="DH.NMQ" Version="2.0.2024.1008-beta0853" />
For projects that support PackageReference, copy this XML node into the project file to reference the package. 
paket add DH.NMQ --version 2.0.2024.1008-beta0853                

                    
                

            
#r "nuget: DH.NMQ, 2.0.2024.1008-beta0853"
#r directive can be used in F# Interactive and Polyglot Notebooks. Copy this into the interactive tool or source code of the script to reference the package. 
// Install DH.NMQ as a Cake Addin
#addin nuget:?package=DH.NMQ&version=2.0.2024.1008-beta0853&prerelease

// Install DH.NMQ as a Cake Tool
#tool nuget:?package=DH.NMQ&version=2.0.2024.1008-beta0853&prerelease

消息队列 DH.NMQ

DH.NMQ 是一个轻量级消息队列，无延迟分发，支持消费组和消息去重，不支持集群部署。

主要特点：

  • 轻量级。服务端和客户端都是通过nuget引用DH.NMQ即可，也可以在Windows上直接安装发行版DH.NMQServer。
  • 低延迟。默认不做持久化，发布消息后直接分发到目标队列，客户端长连接实时消费。（特别适用于跨系统异步通信）
  • 消费者。支持广播消息给多个消费者。
  • 消息延迟和去重。支持延迟消息，支持对重复发送的消息进行去重，降低消费成本。

2019-02-20 v2.0混合测试通过

1, 实现了基础的发送与消费
2, 每个Topic下有一个队列，目前使用并行字典实现，自增消息ID为key，便于查找和删除 3, 每个消费组（相同登录用户）记录消费偏移量

// 初始化客户端
var client = new MQClient
{
    Servers = new[] { "tcp://127.0.0.1:6789" },
    Log = XTrace.Log,

    Topic = "测试主题",
};

// 发布消息
var msgid = client.Public("发布测试").Result;
XTrace.WriteLine("msgid={0}", msgid);

// 消费消息
client.OnConsume = msgs =>
{
    foreach (var item in msgs)
    {
        XTrace.WriteLine("消费到 {0}", item);
    }
};
client.StartConsume();

主要术语：

  • MQHost 消息队列主机，管理多主题的订阅和发布
  • Topic 主题队列，每个主题有一个队列用于缓冲保存消息，同时记录多个消费者
  • Consumer 消费者，发布到主题的消息，会广播给各个消费者。多个订阅者构成消费者集群，消息只推送给其中一个订阅者。
  • Subscriber 订阅者，使用相同消费者标识的不同来源，视为不同订阅者，比如同一个消费者账号的不同网络连接。
Product Compatible and additional computed target framework versions.
.NET net5.0 was computed.  net5.0-windows was computed.  net6.0 was computed.  net6.0-android was computed.  net6.0-ios was computed.  net6.0-maccatalyst was computed.  net6.0-macos was computed.  net6.0-tvos was computed.  net6.0-windows was computed.  net7.0 was computed.  net7.0-android was computed.  net7.0-ios was computed.  net7.0-maccatalyst was computed.  net7.0-macos was computed.  net7.0-tvos was computed.  net7.0-windows was computed.  net8.0 was computed.  net8.0-android was computed.  net8.0-browser was computed.  net8.0-ios was computed.  net8.0-maccatalyst was computed.  net8.0-macos was computed.  net8.0-tvos was computed.  net8.0-windows was computed. 
.NET Core netcoreapp2.0 was computed.  netcoreapp2.1 was computed.  netcoreapp2.2 was computed.  netcoreapp3.0 was computed.  netcoreapp3.1 was computed. 
.NET Standard netstandard2.0 is compatible.  netstandard2.1 was computed. 
.NET Framework net45 is compatible.  net451 was computed.  net452 was computed.  net46 was computed.  net461 was computed.  net462 was computed.  net463 was computed.  net47 was computed.  net471 was computed.  net472 was computed.  net48 was computed.  net481 was computed. 
MonoAndroid monoandroid was computed. 
MonoMac monomac was computed. 
MonoTouch monotouch was computed. 
Tizen tizen40 was computed.  tizen60 was computed. 
Xamarin.iOS xamarinios was computed. 
Xamarin.Mac xamarinmac was computed. 
Xamarin.TVOS xamarintvos was computed. 
Xamarin.WatchOS xamarinwatchos was computed. 
Compatible target framework(s)
Included target framework(s) (in package)
Learn more about Target Frameworks and .NET Standard.

NuGet packages

This package is not used by any NuGet packages.

GitHub repositories

This package is not used by any popular GitHub repositories.