11

DW5S.WebApi/TestHub.cs

@@ -0,0 +1,26 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+using Microsoft.AspNetCore.SignalR;
+
+namespace DW5S.WebApi
+{
+    /// <summary>
+    /// SignalR测试
+    /// </summary>
+    public class TestHub : Hub
+    {
+        /// <summary>
+        /// 
+        /// </summary>
+        /// <param name="user"></param>
+        /// <param name="message"></param>
+        /// <returns></returns>
+        public async Task SendMessage(string user, string message)
+        {
+            await Clients.All.SendAsync("ReceiveMessage", user, message);
+        }
+    }
+}

DW5S.WebApi/WebApiHelper.cs

@@ -134,6 +134,7 @@ namespace DW5S.WebApi
             #region 注入常用服务
             //系统缓存,可以其它地方使用IMemoryCache接口
             builder.Services.AddMemoryCache();
+            builder.Services.AddSignalR(); 
             //http上下文
             builder.Services.AddSingleton<IHttpContextAccessor, Microsoft.AspNetCore.Http.HttpContextAccessor>();
             //HttpClient
@@ -302,7 +303,9 @@ namespace DW5S.WebApi
             app.MapControllers();
             //app.Map("/", () => "必须通过GRPC客户端访问此接口");
 
-             app.RunAsync(_cts.Token);
+            //app.MapHub<ChatHub>("/Chat");
+
+            app.RunAsync(_cts.Token);
             //app.Run();
         }