添加实时通信

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();
 //<2F><><EFBFBD>ʻ<EFBFBD><CABB><EFBFBD><EFBFBD><EFBFBD>
 #endregion
 builder.Services.AddLocalizerService();
+#region
+//<2F><><EFBFBD><EFBFBD>signalR
+#endregion
+builder.Services.AddSignalR();
 //-----------------------------------------------------------------------------------------------------------
 var app = builder.Build();
 #region
@@ -172,10 +177,13 @@ app.UseConsulService();
 #endregion
 app.UseRedisSeedInitService();
 #region
-//Endpointsע<EFBFBD><EFBFBD>
+//SignalR<EFBFBD><EFBFBD><EFBFBD><EFBFBD>
 #endregion
+app.MapHub<MainHub>("/hub/main");
+
 app.UseEndpoints(endpoints =>
 {
     endpoints.MapControllers();
 });
+
 app.Run();

Yi.Framework.Net6/Yi.Framework.WebCore/SignalRHub/MainHub.cs

@@ -0,0 +1,27 @@
+using 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);
+        }
+    }
+}