EasilyNET.RabbitBus.AspNetCore
2.0.11
There is a newer version of this package available.
See the version list below for details.
See the version list below for details.
dotnet add package EasilyNET.RabbitBus.AspNetCore --version 2.0.11
NuGet\Install-Package EasilyNET.RabbitBus.AspNetCore -Version 2.0.11
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="2.0.11" />
For projects that support PackageReference, copy this XML node into the project file to reference the package.
paket add EasilyNET.RabbitBus.AspNetCore --version 2.0.11
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
#r "nuget: EasilyNET.RabbitBus.AspNetCore, 2.0.11"
#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=2.0.11
// Install EasilyNET.RabbitBus.AspNetCore as a Cake Tool
#tool nuget:?package=EasilyNET.RabbitBus.AspNetCore&version=2.0.11
The NuGet Team does not provide support for this client. Please contact its maintainers for support.
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 | Versions 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.
-
net6.0
- EasilyNET.RabbitBus.Core (>= 2.0.11)
- Microsoft.Extensions.DependencyModel (>= 8.0.0)
- Microsoft.Extensions.Hosting.Abstractions (>= 8.0.0)
- Microsoft.Extensions.Logging.Abstractions (>= 8.0.0)
- Polly (>= 8.2.0)
- RabbitMQ.Client (>= 7.0.0-alpha.1)
-
net7.0
- EasilyNET.RabbitBus.Core (>= 2.0.11)
- Microsoft.Extensions.DependencyModel (>= 8.0.0)
- Microsoft.Extensions.Hosting.Abstractions (>= 8.0.0)
- Microsoft.Extensions.Logging.Abstractions (>= 8.0.0)
- Polly (>= 8.2.0)
- RabbitMQ.Client (>= 7.0.0-alpha.1)
-
net8.0
- EasilyNET.RabbitBus.Core (>= 2.0.11)
- Microsoft.Extensions.DependencyModel (>= 8.0.0)
- Microsoft.Extensions.Hosting.Abstractions (>= 8.0.0)
- Microsoft.Extensions.Logging.Abstractions (>= 8.0.0)
- Polly (>= 8.2.0)
- RabbitMQ.Client (>= 7.0.0-alpha.1)
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.704.94 | 30 | 7/4/2024 |
3.24.701.90 | 32 | 7/1/2024 |
3.24.628.114 | 40 | 6/28/2024 |
3.24.627.145 | 30 | 6/27/2024 |
3.24.620.160 | 42 | 6/20/2024 |
3.24.613.115 | 38 | 6/13/2024 |
3.24.612.95 | 39 | 6/12/2024 |
3.24.528.90 | 44 | 5/28/2024 |
3.24.522.84 | 56 | 5/22/2024 |
3.24.512.213 | 44 | 5/12/2024 |
3.24.508.112 | 56 | 5/8/2024 |
2.2024.428.71 | 53 | 4/28/2024 |
2.2024.427.1128 | 53 | 4/27/2024 |
2.2.72 | 67 | 4/14/2024 |
2.2.71 | 45 | 4/12/2024 |
2.2.8 | 39 | 4/26/2024 |
2.2.6 | 45 | 4/10/2024 |
2.2.5 | 65 | 3/26/2024 |
2.2.4 | 57 | 3/25/2024 |
2.2.3 | 53 | 3/24/2024 |
2.2.2 | 60 | 3/21/2024 |
2.2.1 | 62 | 3/20/2024 |
2.2.0 | 60 | 3/13/2024 |
2.1.9 | 62 | 2/21/2024 |
2.1.8 | 63 | 2/18/2024 |
2.1.7 | 65 | 2/16/2024 |
2.1.6 | 71 | 2/14/2024 |
2.1.5 | 56 | 2/14/2024 |
2.1.4 | 74 | 2/9/2024 |
2.1.3 | 59 | 2/8/2024 |
2.1.2 | 80 | 2/5/2024 |
2.1.1.2 | 140 | 12/26/2023 |
2.1.1.1 | 72 | 12/26/2023 |
2.1.1 | 68 | 12/25/2023 |
2.1.0 | 91 | 12/17/2023 |
2.0.11 | 120 | 12/6/2023 |
2.0.1 | 120 | 11/15/2023 |
2.0.0 | 70 | 11/14/2023 |
1.9.1 | 91 | 11/1/2023 |
1.9.0 | 78 | 10/19/2023 |
1.9.0-preview2 | 160 | 10/12/2023 |
1.9.0-preview1 | 64 | 10/12/2023 |
1.8.9 | 111 | 10/11/2023 |
1.8.8 | 104 | 10/11/2023 |
1.8.7-rc2 | 71 | 9/21/2023 |
1.8.7-rc1 | 67 | 9/12/2023 |
1.8.6 | 99 | 8/31/2023 |
1.8.5 | 318 | 8/25/2023 |
1.8.4 | 98 | 8/24/2023 |
1.8.3 | 93 | 8/23/2023 |
1.8.2 | 131 | 8/22/2023 |
1.8.1 | 99 | 8/18/2023 |
1.8.0 | 97 | 8/15/2023 |
1.7.9 | 123 | 8/11/2023 |
1.7.8 | 89 | 8/11/2023 |
1.7.7 | 108 | 8/10/2023 |
1.7.6 | 104 | 8/9/2023 |
1.7.5 | 127 | 8/9/2023 |
1.7.4 | 143 | 8/3/2023 |
1.7.3 | 111 | 8/1/2023 |
1.7.2 | 108 | 7/31/2023 |
1.7.1 | 95 | 7/27/2023 |
1.7.0 | 109 | 7/25/2023 |
1.6.9 | 103 | 7/25/2023 |
1.6.8 | 99 | 7/24/2023 |
1.6.7 | 108 | 7/20/2023 |
1.6.6 | 106 | 7/19/2023 |
1.6.5 | 79 | 7/19/2023 |
1.6.4 | 99 | 7/17/2023 |
1.6.3 | 89 | 7/17/2023 |
1.6.2 | 112 | 7/12/2023 |
1.6.1 | 113 | 6/30/2023 |
1.6.0 | 86 | 6/30/2023 |