From 9dc1c5c9e9497baaff8bbc849a92377f4acaf250 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=99=88=E6=B7=B3?= <chenchun@hymson.com>
Date: Sun, 4 Sep 2022 18:47:39 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E5=AE=9E=E6=97=B6=E9=80=9A?=
 =?UTF-8?q?=E4=BF=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Yi.Framework.ApiMicroservice/Program.cs   | 10 ++++++-
 .../SignalRHub/MainHub.cs                     | 27 +++++++++++++++++++
 2 files changed, 36 insertions(+), 1 deletion(-)
 create mode 100644 Yi.Framework.Net6/Yi.Framework.WebCore/SignalRHub/MainHub.cs

diff --git a/Yi.Framework.Net6/Yi.Framework.ApiMicroservice/Program.cs b/Yi.Framework.Net6/Yi.Framework.ApiMicroservice/Program.cs
index 63e6ac9d..b9cf8ffb 100644
--- a/Yi.Framework.Net6/Yi.Framework.ApiMicroservice/Program.cs
+++ b/Yi.Framework.Net6/Yi.Framework.ApiMicroservice/Program.cs
@@ -8,6 +8,7 @@ using Yi.Framework.Common.Models;
 using Yi.Framework.Language;
 using Microsoft.Extensions.Localization;
 using Yi.Framework.WebCore.AttributeExtend;
+using Yi.Framework.WebCore.SignalRHub;
 
 var builder = WebApplication.CreateBuilder(args);
 builder.Configuration.AddCommandLine(args);
@@ -110,6 +111,10 @@ builder.Services.AddCAPService();
 //国际化配置
 #endregion
 builder.Services.AddLocalizerService();
+#region
+//添加signalR
+#endregion
+builder.Services.AddSignalR();
 //-----------------------------------------------------------------------------------------------------------
 var app = builder.Build();
 #region
@@ -172,10 +177,13 @@ app.UseConsulService();
 #endregion
 app.UseRedisSeedInitService();
 #region
-//Endpoints注入
+//SignalR配置
 #endregion
+app.MapHub<MainHub>("/hub/main");
+
 app.UseEndpoints(endpoints =>
 {
     endpoints.MapControllers();
 });
+
 app.Run();
\ No newline at end of file
diff --git a/Yi.Framework.Net6/Yi.Framework.WebCore/SignalRHub/MainHub.cs b/Yi.Framework.Net6/Yi.Framework.WebCore/SignalRHub/MainHub.cs
new file mode 100644
index 00000000..9db773c9
--- /dev/null
+++ b/Yi.Framework.Net6/Yi.Framework.WebCore/SignalRHub/MainHub.cs
@@ -0,0 +1,27 @@
+锘縰sing Microsoft.AspNetCore.SignalR;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Yi.Framework.WebCore.SignalRHub
+{
+    public class MainHub : Hub
+    {
+        public override Task OnConnectedAsync()
+        {
+            return base.OnConnectedAsync();
+        }
+
+        public override Task OnDisconnectedAsync(Exception exception)
+        {
+            return base.OnDisconnectedAsync(exception);
+        }
+
+        public async Task SendAllTest(string test)
+        {
+            await Clients.All.SendAsync("ReceiveAllInfo", test);
+        }
+    }
+}