RabbitMQ添加多消费者支持，实现多线程消费

Admin.NET/Admin.NET.Application/Startup.cs

@@ -4,9 +4,11 @@
 //
 // 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动！任何基于本项目二次开发而产生的一切法律纠纷和责任，我们不承担任何责任！
 
+using Admin.NET.Core;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting;
 using Microsoft.Extensions.Hosting;
+using NewLife.Reflection;
 
 namespace Admin.NET.Application;
 
@@ -15,8 +17,11 @@ public class Startup : AppStartup
 {
     public void ConfigureServices(IServiceCollection services)
     {
+        var option = App.GetConfig<RabbitMqConsumerOptions>("RabbitMqConsumerOptions");
+        var consumerCount = option.ConsumerCount.ToIntOrDefault(1);
+
         // 注册RabbitMQ服务
-        services.AddRabbitMQ<RabbitMqHandler>();
+        services.AddRabbitMQ<RabbitMqHandler>(consumerCount);
 
         // 后台服务异常，不影响主程序（配置的服务器连接异常）
         services.Configure<HostOptions>(options =>

Admin.NET/Admin.NET.Core/RabbitMQ/RabbitMQSetup.cs

@@ -12,8 +12,9 @@ public static class RabbitMQSetup
     /// 注册RabbitMQ
     /// </summary>
     /// <param name="services"></param>
+    /// <param name="consumerCount">消费者数量，默认1个</param>
     /// <returns></returns>
-    public static void AddRabbitMQ<THandler>(this IServiceCollection services)
+    public static void AddRabbitMQ<THandler>(this IServiceCollection services, int consumerCount = 1)
         where THandler : class, IMessageHandler
     {
         if (App.GetConfig<string>("EventBus:EventSourceType", true) != "RabbitMQ") return;
@@ -21,6 +22,11 @@ public static class RabbitMQSetup
         services.AddSingleton<IMessageHandler, THandler>();
         services.AddSingleton<RabbitMqConnection>();
         services.AddSingleton<RabbitMqProducer>();
-        services.AddHostedService<RabbitMqConsumer>();
+
+        // 注册多个消费者服务
+        for (int i = 0; i < consumerCount; i++)
+        {
+            services.AddHostedService<RabbitMqConsumer>();
+        }
     }
 }

Admin.NET/Admin.NET.Core/RabbitMQ/RabbitMqConsumerOptions.cs

@@ -0,0 +1,23 @@
+// Admin.NET 项目的版权、商标、专利和其他相关权利均受相应法律法规的保护。使用本项目应遵守相关法律法规和许可证的要求。
+//
+// 本项目主要遵循 MIT 许可证和 Apache 许可证（版本 2.0）进行分发和使用。许可证位于源代码树根目录中的 LICENSE-MIT 和 LICENSE-APACHE 文件。
+//
+// 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动！任何基于本项目二次开发而产生的一切法律纠纷和责任，我们不承担任何责任！
+
+namespace Admin.NET.Core;
+
+/// <summary>
+/// RabbitMQ消费者配置
+/// </summary>
+public class RabbitMqConsumerOptions : IConfigurableOptions
+{
+    /// <summary>
+    /// 队列名称
+    /// </summary>
+    public string QueueName { get; set; }
+
+    /// <summary>
+    ///  消费者数量
+    /// </summary>
+    public string ConsumerCount { get; set; }
+}

Admin.NET/Admin.NET.Core/Utils/Collections/StringExtensions.cs

@@ -0,0 +1,34 @@
+// Admin.NET 项目的版权、商标、专利和其他相关权利均受相应法律法规的保护。使用本项目应遵守相关法律法规和许可证的要求。
+//
+// 本项目主要遵循 MIT 许可证和 Apache 许可证（版本 2.0）进行分发和使用。许可证位于源代码树根目录中的 LICENSE-MIT 和 LICENSE-APACHE 文件。
+//
+// 不得利用本项目从事危害国家安全、扰乱社会秩序、侵犯他人合法权益等法律法规禁止的活动！任何基于本项目二次开发而产生的一切法律纠纷和责任，我们不承担任何责任！
+namespace Admin.NET.Core;
+
+/// <summary>
+/// 字符串扩展
+/// </summary>
+public static class StringExtensions
+{
+    /// <summary>
+    /// string转int
+    /// </summary>
+    /// <param name="str"></param>
+    /// <param name="defaultValue"></param>
+    /// <returns></returns>
+    public static int ToIntOrDefault(this string? str, int defaultValue = 0)
+    {
+        return int.TryParse(str, out var value) ? value : defaultValue;
+    }
+
+    /// <summary>
+    /// string转long
+    /// </summary>
+    /// <param name="str"></param>
+    /// <param name="defaultValue"></param>
+    /// <returns></returns>
+    public static long ToLongOrDefault(this string? str, long defaultValue = 0)
+    {
+        return long.TryParse(str, out var value) ? value : defaultValue;
+    }
+}

Admin.NET/Admin.NET.Web.Core/ProjectOptions.cs

@@ -36,6 +36,7 @@ public static class ProjectOptions
         services.AddConfigurableOptions<OAuthOptions>();
         services.AddConfigurableOptions<SMSOptions>();
         services.AddConfigurableOptions<RabbitMqOptions>();
+        services.AddConfigurableOptions<RabbitMqConsumerOptions>();
         services.AddConfigurableOptions<AlipayOptions>();
         services.AddConfigurableOptions<MqttOptions>();
         services.AddConfigurableOptions<HttpRemotesOptions>();