EasilyNET.RabbitBus.AspNetCore 1.9.0-preview1

This is a prerelease version of EasilyNET.RabbitBus.AspNetCore.
There is a newer version of this package available.
See the version list below for details.
dotnet add package EasilyNET.RabbitBus.AspNetCore --version 1.9.0-preview1                
NuGet\Install-Package EasilyNET.RabbitBus.AspNetCore -Version 1.9.0-preview1                
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="1.9.0-preview1" />                
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add EasilyNET.RabbitBus.AspNetCore --version 1.9.0-preview1                
#r "nuget: EasilyNET.RabbitBus.AspNetCore, 1.9.0-preview1"                
#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 EasilyNET.RabbitBus.AspNetCore as a Cake Addin
#addin nuget:?package=EasilyNET.RabbitBus.AspNetCore&version=1.9.0-preview1&prerelease

// Install EasilyNET.RabbitBus.AspNetCore as a Cake Tool
#tool nuget:?package=EasilyNET.RabbitBus.AspNetCore&version=1.9.0-preview1&prerelease                
EasilyNET.RabbitBus.AspNetCore
如何使用
  • 首先使用 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";
    ...
});

// 注册服务
builder.Services.AddTransient<TestEventHandler>();
  • Step2.接下来配置事件和事件处理器
/// <summary>
/// 测试消息类型
/// </summary>
[Rabbit("hoyo.test", EExchange.Routing, "test", "orderqueue2")]
public class TestEvent : IntegrationEvent
{
    /// <summary>
    /// 消息
    /// </summary>
    public string Message { get; set; } = default!;
}

/// <summary>
/// 消息处理Handler
/// </summary>
public class TestEventHandler : IIntegrationEventHandler<TestEvent>
{
    private readonly ILogger<TestEventHandler> _logger;
    /// <summary>
    /// 构造函数
    /// </summary>
    /// <param name="logger"></param>
    public TestEventHandler(ILogger<TestEventHandler> logger)
    {
        _logger = logger;
    }
    /// <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 IIntegrationEventBus _ibus;
// 控制器构造函数伪代码
construct(IIntegrationEventBus ibus){
   _ibus = ibus;
}
/// <summary>
/// 创建一个延时消息,同时发送一个普通消息做对比
/// </summary>
[HttpPost("TTLTest")]
public void 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}" };
    // 延时队列需要服务端安装延时队列插件.
    _ibus.Publish(ttlobj, (uint)ttl);
    _ibus.Publish(ttlobj);
}
Product Compatible and additional computed target framework versions.
.NET net6.0 is compatible.  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 is compatible.  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 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. 
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
3.24.1224.141 29 12/24/2024
3.24.1216.116 78 12/16/2024
3.24.1206.100 52 12/6/2024
3.24.1205.171 55 12/5/2024
3.24.1202.150 50 12/2/2024
3.24.1126.231 55 11/26/2024
3.24.1126.172 54 11/26/2024
3.24.1126.114 53 11/26/2024
3.24.1126.104 51 11/26/2024
3.24.1125.181 44 11/25/2024
3.24.1125.104 53 11/25/2024
3.24.1121.183 49 11/21/2024
3.24.1120.183 51 11/20/2024
3.24.1119.31 50 11/18/2024
3.24.1115.143 39 11/15/2024
3.24.1113.100 52 11/13/2024
3.24.1112.125 137 11/12/2024
3.24.1107.140 47 11/7/2024
3.24.1107.54 49 11/7/2024
3.24.1107.34 51 11/7/2024
3.24.1105.111 54 11/5/2024
3.24.1103.31 58 11/2/2024
3.24.1103 54 11/2/2024
3.24.1031.135 46 10/31/2024
3.24.1031.112 48 10/31/2024
3.24.1031.104 48 10/31/2024
3.24.1029.142 52 10/29/2024
3.24.1025.30 150 10/24/2024
3.24.1022.142 43 10/22/2024
3.24.1018.204 107 10/18/2024
3.24.1018.175 104 10/18/2024
3.24.1018.166 103 10/18/2024
3.24.1018.93 106 10/18/2024
3.24.1017.42 54 10/16/2024
3.24.1016.161 56 10/16/2024
3.24.1015.231 56 10/15/2024
3.24.1015.14 58 10/14/2024
3.24.1012.114 52 10/12/2024
3.24.1009.115 57 10/9/2024
3.24.1008.160 57 10/8/2024
3.24.1008.133 51 10/8/2024
3.24.1007.185 54 10/7/2024
3.24.1003.33 60 10/2/2024
3.24.1002.162 59 10/2/2024
3.24.929.143 55 9/29/2024
3.24.929.141 53 9/29/2024
3.24.929.131 53 9/29/2024
3.24.929.122 57 9/29/2024
3.24.926.184 59 9/26/2024
3.24.926.182 56 9/26/2024
3.24.926.175 59 9/26/2024
3.24.924.160 57 9/24/2024
3.24.924.133 68 9/24/2024
3.24.924.124 57 9/24/2024
3.24.924.10 60 9/23/2024
3.24.924.1 50 9/23/2024
3.24.923.234 56 9/23/2024
3.24.923.232 56 9/23/2024
3.24.923.155 55 9/23/2024
3.24.919.92 67 9/19/2024
3.24.914.125 63 9/14/2024
3.24.914.115 63 9/14/2024
3.24.914.111 63 9/14/2024
3.24.911.95 62 9/11/2024
3.24.908.215 56 9/8/2024
3.24.904.200 64 9/4/2024
3.24.828.163 68 8/28/2024
3.24.820.173 72 8/20/2024
3.24.814.92 80 8/14/2024
3.24.812.115 72 8/12/2024
3.24.802.100 50 8/2/2024
3.24.801.162 56 8/1/2024
3.24.801.160 58 8/1/2024
3.24.801.155 58 8/1/2024
3.24.730.164 47 7/30/2024
3.24.730.91 43 7/30/2024
3.24.724.91 53 7/24/2024
3.24.718.105 76 7/18/2024
3.24.716.95 65 7/16/2024
3.24.712.94 60 7/12/2024
3.24.710.14 59 7/9/2024
3.24.709.105 68 7/9/2024
3.24.704.94 61 7/4/2024
3.24.701.90 59 7/1/2024
3.24.628.114 68 6/28/2024
3.24.627.145 61 6/27/2024
3.24.620.160 67 6/20/2024
3.24.613.115 63 6/13/2024
3.24.612.95 68 6/12/2024
3.24.528.90 65 5/28/2024
3.24.522.84 81 5/22/2024
3.24.512.213 62 5/12/2024
3.24.508.112 81 5/8/2024
2.2024.428.71 74 4/28/2024
2.2024.427.1128 76 4/27/2024
2.2.72 84 4/14/2024
2.2.71 65 4/12/2024
2.2.8 69 4/26/2024
2.2.6 65 4/10/2024
2.2.5 85 3/26/2024
2.2.4 82 3/25/2024
2.2.3 73 3/24/2024
2.2.2 78 3/21/2024
2.2.1 80 3/20/2024
2.2.0 86 3/13/2024
2.1.9 78 2/21/2024
2.1.8 79 2/18/2024
2.1.7 80 2/16/2024
2.1.6 93 2/14/2024
2.1.5 70 2/14/2024
2.1.4 99 2/9/2024
2.1.3 77 2/8/2024
2.1.2 107 2/5/2024
2.1.1.2 156 12/26/2023
2.1.1.1 92 12/26/2023
2.1.1 92 12/25/2023
2.1.0 108 12/17/2023
2.0.11 141 12/6/2023
2.0.1 136 11/15/2023
2.0.0 92 11/14/2023
1.9.1 109 11/1/2023
1.9.0 102 10/19/2023
1.9.0-preview2 205 10/12/2023
1.9.0-preview1 80 10/12/2023
1.8.9 128 10/11/2023
1.8.8 122 10/11/2023
1.8.7-rc2 86 9/21/2023
1.8.7-rc1 82 9/12/2023
1.8.6 122 8/31/2023
1.8.5 536 8/25/2023
1.8.4 112 8/24/2023
1.8.3 108 8/23/2023
1.8.2 152 8/22/2023
1.8.1 112 8/18/2023
1.8.0 113 8/15/2023
1.7.9 137 8/11/2023
1.7.8 110 8/11/2023
1.7.7 123 8/10/2023
1.7.6 119 8/9/2023
1.7.5 141 8/9/2023
1.7.4 159 8/3/2023
1.7.3 126 8/1/2023
1.7.2 124 7/31/2023
1.7.1 117 7/27/2023
1.7.0 124 7/25/2023
1.6.9 125 7/25/2023
1.6.8 115 7/24/2023
1.6.7 129 7/20/2023
1.6.6 123 7/19/2023
1.6.5 93 7/19/2023
1.6.4 115 7/17/2023
1.6.3 111 7/17/2023
1.6.2 128 7/12/2023
1.6.1 129 6/30/2023
1.6.0 108 6/30/2023