EasilyNET.RabbitBus.AspNetCore 4.25.609.181

There is a newer version of this package available.
See the version list below for details.
dotnet add package EasilyNET.RabbitBus.AspNetCore --version 4.25.609.181
                    
NuGet\Install-Package EasilyNET.RabbitBus.AspNetCore -Version 4.25.609.181
                    
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="EasilyNET.RabbitBus.AspNetCore" Version="4.25.609.181" />
                    
For projects that support PackageReference, copy this XML node into the project file to reference the package.
<PackageVersion Include="EasilyNET.RabbitBus.AspNetCore" Version="4.25.609.181" />
                    
Directory.Packages.props
<PackageReference Include="EasilyNET.RabbitBus.AspNetCore" />
                    
Project file
For projects that support Central Package Management (CPM), copy this XML node into the solution Directory.Packages.props file to version the package.
paket add EasilyNET.RabbitBus.AspNetCore --version 4.25.609.181
                    
#r "nuget: EasilyNET.RabbitBus.AspNetCore, 4.25.609.181"
                    
#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.
#:package EasilyNET.RabbitBus.AspNetCore@4.25.609.181
                    
#:package directive can be used in C# file-based apps starting in .NET 10 preview 4. Copy this into a .cs file before any lines of code to reference the package.
#addin nuget:?package=EasilyNET.RabbitBus.AspNetCore&version=4.25.609.181
                    
Install as a Cake Addin
#tool nuget:?package=EasilyNET.RabbitBus.AspNetCore&version=4.25.609.181
                    
Install as a Cake Tool
EasilyNET.RabbitBus.AspNetCore

支持延时队列,服务端需要启用 rabbitmq-delayed-message-exchange 插件

  • 支持同一个消息被多个 Handler 消费
  • 若是就是想写多个 Handler 但是又希望某些 Handler 不执行,可以在不需要的 Handler 上标记 [IgnoreHandler] 特性
如何使用
  • 首先使用 Nuget 包管理工具添加依赖 EasilyNET.RabbitBus.AspNetCore
  • 等待下载完成和同意开源协议后,即可使用本库.
  • Step1.在 Program.cs 中配置消息总线
// 配置服务(亦可使用集群模式或者使用配置文件,或者环境变量.)
builder.Services.AddRabbitBus(c =>
{
    c.Host = "192.168.2.110";
    c.Port = 5672;
    c.UserName = "username";
    c.PassWord = "password";
    c.PoolCount = (uint)Environment.ProcessorCount;
    c.RetryCount = 5;
    ...
});
  • Step2.接下来配置事件和事件处理器
/// <summary>
/// 测试消息类型,消息继承自 IEvent 或者 Event
/// </summary>
[Exchange("hoyo.test", EModel.Routing, "test", "orderqueue2")]
public class TestEvent : Event
{
    /// <summary>
    /// 消息
    /// </summary>
    public string Message { get; set; } = default!;
}

/// <summary>
/// 消息处理Handler
/// </summary>
public class TestEventHandler(ILogger<TestEventHandler> logger) : IEventHandler<TestEvent>
{
    /// <summary>
    /// 当消息到达的时候执行的Action
    /// </summary>
    /// <param name="event"></param>
    /// <returns></returns>
    public Task HandleAsync(TestEvent @event)
    {
        logger.LogInformation("TestEvent_{event}-----{date}", @event.Message, DateTime.Now);
        return Task.CompletedTask;
    }
}

/// <summary>
/// 若是存在同一个消息多个 Handler 实现,比如这里我们写了两个 Handler,那么发送一次消息这两个 Handler 均会执行.
/// </summary>
/// 若是不希望这个 Handler 执行可以标记
[IgnoreHandler]
public class TestEventHandlerSecond(ILogger<TestEventHandlerSecond> logger) : IEventHandler<TestEvent>
{
    /// <summary>
    /// 当消息到达的时候执行的Action
    /// </summary>
    /// <param name="event"></param>
    /// <returns></returns>
    public Task HandleAsync(TestEvent @event)
    {
        logger.LogInformation("TestEvent_{event}-----{date}", @event.Message, DateTime.Now);
        return Task.CompletedTask;
    }
}
  • Step3.使用消息队列发送消息
private readonly IBus _ibus;
// 控制器构造函数伪代码
construct(IBus ibus){
   _ibus = ibus;
}
/// <summary>
/// 创建一个延时消息,同时发送一个普通消息做对比
/// </summary>
[HttpPost("TTLTest")]
public async Task TTLTest()
{
    var rand = new Random();
    var ttl = rand.Next(1000, 10000);
    var ttlobj = new DelayedMessageEvent() { Message = $"延迟{ttl}毫秒,当前时间{DateTime.Now:yyyy-MM-dd HH:mm:ss}" };
    // 延时队列需要服务端安装延时队列插件.
    await _ibus.Publish(ttlobj, (uint)ttl);
    await _ibus.Publish(ttlobj);
}
使用自定义序列化器
  • 默认序列化器是 System.Text.Json,若是需要使用其他序列化器,可以实现 IBusSerializer 接口,然后在配置中指定序列化器.
  • 若是单独开启一个项目用于该实现,推荐使用基础 Nuget 包 EasilyNET.RabbitBus.Core 然后实现 IBusSerializer 接口即可.这里以 MessagePack 为例.
/// <summary>
/// MessagePackSerializer
/// </summary>
public sealed class MsgPackSerializer : IBusSerializer
{
    private static readonly MessagePackSerializerOptions standardOptions =
        MessagePackSerializerOptions.Standard
                                    .WithResolver(CompositeResolver.Create(NativeDateTimeResolver.Instance, // 使用本地日期时间解析器
                                        ContractlessStandardResolver.Instance))                             // 使用无合约标准解析器
                                    .WithSecurity(MessagePackSecurity.UntrustedData);                       // 设置安全选项以处理不受信任的数据

    /// <summary>
    /// 使用 LZ4 算法对整个数组进行压缩.这种方式适用于需要对大量数据进行压缩的场景,压缩效率较高
    /// </summary>
    private static readonly MessagePackSerializerOptions lz4BlockArrayOptions =
        standardOptions.WithCompression(MessagePackCompression.Lz4BlockArray);

    /// <summary>
    /// 使用 LZ4 算法对每个数据块进行压缩.这种方式适用于需要对单个数据块进行压缩的场景,压缩速度较快
    /// </summary>
    private static readonly MessagePackSerializerOptions lz4BlockOptions =
        standardOptions.WithCompression(MessagePackCompression.Lz4Block);

    /// <inheritdoc />
    public byte[] Serialize(object? obj, Type type)
    {
        var data = MessagePackSerializer.Serialize(type, obj, standardOptions);
        var options = data.Length > 8192 ? lz4BlockArrayOptions : lz4BlockOptions;
        return MessagePackSerializer.Serialize(type, obj, options);
    }

    /// <inheritdoc />
    public object? Deserialize(byte[] data, Type type)
    {
        var options = data.Length > 8192 ? lz4BlockArrayOptions : lz4BlockOptions;
        return MessagePackSerializer.Deserialize(type, data, options);
    }
}
  • 然后调整服务注册代码添加如下内容
// 配置服务(亦可使用集群模式或者使用配置文件,或者环境变量.)
builder.Services.AddRabbitBus(c =>
{
    ...
    c.BusSerializer = new MsgPackSerializer();
    ...
});
Product Compatible and additional computed target framework versions.
.NET net8.0 is compatible.  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.  net9.0 is compatible.  net9.0-android was computed.  net9.0-browser was computed.  net9.0-ios was computed.  net9.0-maccatalyst was computed.  net9.0-macos was computed.  net9.0-tvos was computed.  net9.0-windows was computed.  net10.0 is compatible.  net10.0-android was computed.  net10.0-browser was computed.  net10.0-ios was computed.  net10.0-maccatalyst was computed.  net10.0-macos was computed.  net10.0-tvos was computed.  net10.0-windows 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.

Version Downloads Last Updated
4.25.720.80 16 7/20/2025
4.25.716.42 109 7/15/2025
4.25.617.153 124 6/17/2025
4.25.616.190 118 6/16/2025
4.25.616.182 114 6/16/2025
4.25.613.111 260 6/13/2025
4.25.609.190 214 6/9/2025
4.25.609.181 203 6/9/2025
4.25.609.163 205 6/9/2025
4.25.609.140 190 6/9/2025
4.25.605.171 121 6/5/2025
4.25.605.104 127 6/5/2025
4.25.602.41 128 6/1/2025
4.25.526.140 128 5/26/2025
4.25.513.101 218 5/13/2025
4.25.506.150 129 5/6/2025
4.25.429.162 136 4/29/2025
4.25.429.103 161 4/29/2025
4.25.411.142 126 4/11/2025
4.25.409.92 144 4/9/2025
4.25.403.133 146 4/3/2025
4.25.319.113 157 3/19/2025
4.25.312.103 158 3/12/2025
4.25.227.135 93 2/27/2025
4.25.212.95 240 2/12/2025
4.25.211.140 96 2/11/2025
4.25.124.223 79 1/24/2025
3.24.1206.100 88 12/6/2024
3.24.1205.171 92 12/5/2024
3.24.1202.150 89 12/2/2024
3.24.1126.231 93 11/26/2024
3.24.1126.172 86 11/26/2024
3.24.1126.114 88 11/26/2024
3.24.1126.104 87 11/26/2024
3.24.1125.181 80 11/25/2024
3.24.1125.104 90 11/25/2024
3.24.1121.183 82 11/21/2024
3.24.1120.183 84 11/20/2024
3.24.1119.31 89 11/18/2024
3.24.1115.143 72 11/15/2024
3.24.1113.100 91 11/13/2024
3.24.1112.125 577 11/12/2024
3.24.1107.140 84 11/7/2024
3.24.1107.54 82 11/7/2024
3.24.1107.34 85 11/7/2024
3.24.1105.111 87 11/5/2024
3.24.1103.31 92 11/2/2024
3.24.1103 86 11/2/2024
3.24.1031.135 84 10/31/2024
3.24.1031.112 82 10/31/2024
3.24.1031.104 84 10/31/2024
3.24.1029.142 85 10/29/2024
3.24.1025.30 182 10/24/2024
3.24.1022.142 74 10/22/2024
3.24.1018.204 137 10/18/2024
3.24.1018.175 131 10/18/2024
3.24.1018.166 132 10/18/2024
3.24.1018.93 133 10/18/2024
3.24.1017.42 84 10/16/2024
3.24.1016.161 84 10/16/2024
3.24.1015.231 84 10/15/2024
3.24.1015.14 89 10/14/2024
3.24.1012.114 79 10/12/2024
3.24.1009.115 90 10/9/2024
3.24.1008.160 89 10/8/2024
3.24.1008.133 80 10/8/2024
3.24.1007.185 88 10/7/2024
3.24.1003.33 91 10/2/2024
3.24.1002.162 90 10/2/2024
3.24.929.143 87 9/29/2024
3.24.929.141 85 9/29/2024
3.24.929.131 86 9/29/2024
3.24.929.122 88 9/29/2024
3.24.926.184 92 9/26/2024
3.24.926.182 92 9/26/2024
3.24.926.175 95 9/26/2024
3.24.924.160 90 9/24/2024
3.24.924.133 96 9/24/2024
3.24.924.124 87 9/24/2024
3.24.924.10 99 9/23/2024
3.24.924.1 81 9/23/2024
3.24.923.234 89 9/23/2024
3.24.923.232 86 9/23/2024
3.24.923.155 86 9/23/2024
3.24.919.92 99 9/19/2024
3.24.914.125 94 9/14/2024
3.24.914.115 92 9/14/2024
3.24.914.111 98 9/14/2024
3.24.911.95 87 9/11/2024
3.24.908.215 82 9/8/2024
3.24.904.200 89 9/4/2024
3.24.828.163 94 8/28/2024
3.24.820.173 95 8/20/2024
3.24.814.92 105 8/14/2024
3.24.812.115 101 8/12/2024
3.24.802.100 77 8/2/2024
3.24.801.162 82 8/1/2024
3.24.801.160 86 8/1/2024
3.24.801.155 85 8/1/2024
3.24.730.164 77 7/30/2024
3.24.730.91 73 7/30/2024
3.24.724.91 79 7/24/2024
3.24.718.105 102 7/18/2024
3.24.716.95 90 7/16/2024
3.24.712.94 90 7/12/2024
3.24.710.14 85 7/9/2024
3.24.709.105 90 7/9/2024
3.24.704.94 92 7/4/2024
3.24.701.90 86 7/1/2024
3.24.628.114 97 6/28/2024
3.24.627.145 90 6/27/2024
3.24.620.160 96 6/20/2024
3.24.613.115 89 6/13/2024
3.24.612.95 95 6/12/2024
3.24.528.90 88 5/28/2024
3.24.522.84 103 5/22/2024
3.24.512.213 88 5/12/2024
3.24.508.112 105 5/8/2024
2.2024.428.71 97 4/28/2024
2.2024.427.1128 97 4/27/2024
2.2.72 113 4/14/2024
2.2.71 90 4/12/2024
2.2.8 94 4/26/2024
2.2.6 89 4/10/2024
2.2.5 114 3/26/2024
2.2.4 105 3/25/2024
2.2.3 97 3/24/2024
2.2.2 108 3/21/2024
2.2.1 109 3/20/2024
2.2.0 111 3/13/2024
2.1.9 104 2/21/2024
2.1.8 107 2/18/2024
2.1.7 111 2/16/2024
2.1.6 121 2/14/2024
2.1.5 98 2/14/2024
2.1.4 123 2/9/2024
2.1.3 105 2/8/2024
2.1.2 130 2/5/2024
2.1.1.2 177 12/26/2023
2.1.1.1 113 12/26/2023
2.1.1 115 12/25/2023
2.1.0 133 12/17/2023
2.0.11 151 12/6/2023
2.0.1 148 11/15/2023
2.0.0 106 11/14/2023
1.9.1 121 11/1/2023
1.9.0 121 10/19/2023
1.9.0-preview2 237 10/12/2023
1.9.0-preview1 94 10/12/2023
1.8.9 152 10/11/2023
1.8.8 141 10/11/2023
1.8.7-rc2 101 9/21/2023
1.8.7-rc1 98 9/12/2023
1.8.6 144 8/31/2023
1.8.5 571 8/25/2023
1.8.4 134 8/24/2023
1.8.3 132 8/23/2023
1.8.2 174 8/22/2023
1.8.1 136 8/18/2023
1.8.0 140 8/15/2023
1.7.9 162 8/11/2023
1.7.8 136 8/11/2023
1.7.7 149 8/10/2023
1.7.6 144 8/9/2023
1.7.5 170 8/9/2023
1.7.4 184 8/3/2023
1.7.3 152 8/1/2023
1.7.2 150 7/31/2023
1.7.1 143 7/27/2023
1.7.0 154 7/25/2023
1.6.9 153 7/25/2023
1.6.8 140 7/24/2023
1.6.7 156 7/20/2023
1.6.6 155 7/19/2023
1.6.5 121 7/19/2023
1.6.4 141 7/17/2023
1.6.3 138 7/17/2023
1.6.2 158 7/12/2023
1.6.1 158 6/30/2023
1.6.0 140 6/30/2023