临时提交，新版本的设计

Author: oujun

RabbitMQ.EventBus.AspNetCore.Sample/Controllers/MessageBody1.cs

@@ -5,7 +5,7 @@
 
 namespace RabbitMQ.EventBus.AspNetCore.Simple.Controllers
 {
-    public class MessageBodyHandle : IEventHandler<MessageBody1>, IDisposable
+    public class MessageBodyHandle : IEventResponseHandler<MessageBody, string>, IDisposable
     {
         private Guid id;
         private readonly ILogger<MessageBodyHandle> _logger;
@@ -17,18 +17,13 @@ public MessageBodyHandle(ILogger<MessageBodyHandle> logger)
         }
         public void Dispose()
         {
-            Console.WriteLine("释放");
+            _logger.LogInformation("MessageBodyHandle Disposable.");
         }
 
-        public Task Handle(EventHandlerArgs<MessageBody1> args)
+
+        public Task<string> HandleAsync(HandlerEventArgs<MessageBody> args)
         {
-            Console.WriteLine("==================================================");
-            Console.WriteLine(id + "=>" + typeof(MessageBody1).Name);
-            Console.WriteLine(args.Event.Body);
-            Console.WriteLine(args.Original);
-            Console.WriteLine(args.Redelivered);
-            Console.WriteLine("==================================================");
-            return Task.CompletedTask;
+            return Task.FromResult("收到消息，已确认");
         }
     }
 }

RabbitMQ.EventBus.AspNetCore.Sample/Controllers/MessageBodyHandle.cs

@@ -1,4 +1,5 @@
 using Microsoft.AspNetCore.Mvc;
+using Newtonsoft.Json;
 using System;
 using System.Threading.Tasks;
 
@@ -19,23 +20,18 @@ public ValuesController(IRabbitMQEventBus eventBus)
         [HttpGet]
         public async Task<ActionResult<string>> Get()
         {
-            //_eventBus.Publish(new
-            //{
-            //    Body = "rabbitmq.eventbus.test=>发送消息",
-            //    Time = DateTimeOffset.Now
-            //}, exchange: "RabbitMQ.EventBus.Simple", routingKey: "rabbitmq.eventbus.test");
 
-            for (int i = 0; i < 1000; i++)
+            Console.WriteLine($"发送消息{1}");
+            var body = new
             {
-                _eventBus.Publish(new
-                {
-                    Body = $"rabbitmq.eventbus.test1=>发送消息/t{i}",
-                    Time = DateTimeOffset.Now,
-                }, exchange: "RabbitMQ.EventBus.Simple", routingKey: "rabbitmq.eventbus.test1");
-                await Task.Yield();
-                await Task.Delay(500);
-            }
-            return "Ok";
+                requestId = Guid.NewGuid(),
+                Body = $"rabbitmq.eventbus.test=>发送消息/t{1}",
+                Time = DateTimeOffset.Now,
+            };
+            var r = await _eventBus.PublishAsync<string>(body, exchange: "RabbitMQ.EventBus.Simple", routingKey: "rabbitmq.eventbus.test");
+            Console.WriteLine($"返回了{r}");
+            await Task.Delay(500);
+            return r;
         }
 
         // GET api/values/5

RabbitMQ.EventBus.AspNetCore.Sample/Controllers/MessageBodyHandle00.cs

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk.Web">
 
   <PropertyGroup>
-    <TargetFramework>net5.0</TargetFramework>
+    <TargetFramework>net6.0</TargetFramework>
     <AspNetCoreHostingModel>InProcess</AspNetCoreHostingModel>
     <IncludeOpenAPIAnalyzers>true</IncludeOpenAPIAnalyzers>
   </PropertyGroup>

RabbitMQ.EventBus.AspNetCore.Sample/Controllers/MessageBodyHandle111.cs

@@ -27,19 +27,19 @@ public void ConfigureServices(IServiceCollection services)
             services.AddControllers();
             services.AddHealthChecks();
 
-            services.AddRabbitMQEventBus(() => "amqp://guest:guest@localhost:5672/", eventBusOptionAction: eventBusOption =>
-             {
-                 eventBusOption.ClientProvidedAssembly(assemblyName);
-                 eventBusOption.EnableRetryOnFailure(true, 5000, TimeSpan.FromSeconds(30));
-                 eventBusOption.RetryOnFailure(TimeSpan.FromSeconds(1));
-                 eventBusOption.MessageTTL(2000);
-                 eventBusOption.SetBasicQos(10);
-                 eventBusOption.DeadLetterExchangeConfig(config =>
-                 {
-                     config.Enabled = true;
-                     config.ExchangeNameSuffix = "-test";
-                 });
-             });
+            services.AddRabbitMQEventBus(() => "amqp://guest:guest@172.30.239.244:5672/", eventBusOptionAction: eventBusOption =>
+            {
+                eventBusOption.ClientProvidedAssembly(assemblyName);
+                eventBusOption.EnableRetryOnFailure(true, 5000, TimeSpan.FromSeconds(30));
+                eventBusOption.RetryOnFailure(TimeSpan.FromSeconds(1));
+                eventBusOption.MessageTTL(2000);
+                eventBusOption.SetBasicQos(10);
+                eventBusOption.DeadLetterExchangeConfig(config =>
+                {
+                    config.Enabled = false;
+                    config.ExchangeNameSuffix = "-test";
+                });
+            });
         }
 
         // This method gets called by the runtime. Use this method to configure the HTTP request pipeline.
@@ -50,7 +50,6 @@ public void Configure(IApplicationBuilder app, IWebHostEnvironment env)
                 app.UseDeveloperExceptionPage();
             }
             app.UseRouting();
-            app.RabbitMQEventBusAutoSubscribe();
             app.UseEndpoints(endpoints =>
             {
                 endpoints.MapControllers();

RabbitMQ.EventBus.AspNetCore.Sample/Controllers/ValuesController.cs

@@ -2,8 +2,8 @@
   "Logging": {
     "LogLevel": {
       "Default": "Debug",
-      "System": "Information",
-      "Microsoft": "Information"
+      "System": "Debug",
+      "Microsoft": "Debug"
     }
   }
 }

RabbitMQ.EventBus.AspNetCore.Sample/RabbitMQ.EventBus.AspNetCore.Sample.csproj

@@ -1,7 +1,7 @@
 {
   "Logging": {
     "LogLevel": {
-      "Default": "Warning"
+      "Default": "Debug"
     }
   },
   "AllowedHosts": "*"

RabbitMQ.EventBus.AspNetCore.Sample/Startup.cs

@@ -1,31 +1,31 @@
-using System;
-
-namespace RabbitMQ.EventBus.AspNetCore.Attributes
+namespace RabbitMQ.EventBus.AspNetCore.Attributes;
+/// <summary>
+/// 
+/// </summary>
+[AttributeUsage(AttributeTargets.Class, AllowMultiple = true)]
+public class EventBusAttribute : Attribute
 {
+    /// <summary>
+    /// 队列名
+    /// </summary>
+    public string Queue { get; set; }
+    /// <summary>
+    /// 交换机名
+    /// </summary>
+    public string Exchange { get; set; }
+    /// <summary>
+    /// 路由Key
+    /// </summary>
+    public string RoutingKey { get; set; }
+    /// <summary>
+    /// Configures QoS parameters of the Basic content-class.
+    /// </summary>
+    public ushort? BasicQos { get; set; }
     /// <summary>
     /// 
     /// </summary>
-    [AttributeUsage(AttributeTargets.Class, AllowMultiple = true)]
-    public class EventBusAttribute : Attribute
+    public EventBusAttribute()
     {
-        /// <summary>
-        /// 队列名
-        /// </summary>
-        public string Queue { get; set; }
-        /// <summary>
-        /// 交换机名
-        /// </summary>
-        public string Exchange { get; set; }
-        /// <summary>
-        /// 路由Key
-        /// </summary>
-        public string RoutingKey { get; set; }
-        /// <summary>
-        /// 
-        /// </summary>
-        public EventBusAttribute()
-        {
-            RoutingKey = "";
-        }
+        RoutingKey = "";
     }
-}
+}