本地局域网服务器搭建选型求助：SignalR、Socket或类MQTT方案

方案一：修复ASP.NET Core SignalR局域网连接问题（优先推荐） #

你之前遇到的SignalR无法通过IP连接，大概率是配置问题而非框架本身限制，这个方案能复用你已有的Web技术栈，同时满足定时推送、MySQL对接需求：

• 解决连接问题的关键配置：
  1. 在Program.cs中绑定局域网IP而非仅localhost，比如：

     builder.WebHost.UseUrls("http://0.0.0.0:5000", "http://192.168.x.x:5000");
     

  2. 配置跨域策略，允许局域网内客户端域名/IP：

     builder.Services.AddCors(options =>
     {
         options.AddPolicy("LanCors", policy =>
         {
             policy.WithOrigins("http://192.168.x.xxx:xxxx") // 客户端IP+端口
                   .AllowAnyHeader()
                   .AllowAnyMethod()
                   .AllowCredentials();
         });
     });
     app.UseCors("LanCors");
     

  3. 确保Windows防火墙开放SignalR服务端口（如5000），并关闭服务器端的网络隔离限制。
• 实现定时推送与MySQL对接：
  1. 创建HostedService后台服务，每900毫秒从MySQL拉取最新数据：

     public class TimedDataPushService : BackgroundService
     {
         private readonly IHubContext<DataHub> _hubContext;
         private readonly IServiceScopeFactory _scopeFactory;
         private readonly PeriodicTimer _timer = new(TimeSpan.FromMilliseconds(900));
     
         public TimedDataPushService(IHubContext<DataHub> hubContext, IServiceScopeFactory scopeFactory)
         {
             _hubContext = hubContext;
             _scopeFactory = scopeFactory;
         }
     
         protected override async Task ExecuteAsync(CancellationToken stoppingToken)
         {
             while (await _timer.WaitForNextTickAsync(stoppingToken) && !stoppingToken.IsCancellationRequested)
             {
                 using var scope = _scopeFactory.CreateScope();
                 var dbContext = scope.ServiceProvider.GetRequiredService<YourDbContext>();
                 var latestData = await dbContext.YourDataTable.OrderByDescending(d => d.UpdateTime).FirstOrDefaultAsync(stoppingToken);
                 if (latestData != null)
                 {
                     await _hubContext.Clients.All.SendAsync("ReceiveLatestData", latestData, stoppingToken);
                 }
             }
         }
     }
     

  2. 注册该服务并创建SignalR Hub，处理客户端的订阅/按需发送请求：

     builder.Services.AddHostedService<TimedDataPushService>();
     builder.Services.AddSignalR();
     app.MapHub<DataHub>("/dataHub");
     

• 客户端连接：直接使用服务器局域网IP+端口+Hub路径连接，比如JS客户端：

  const connection = new signalR.HubConnectionBuilder()
      .withUrl("http://192.168.x.x:5000/dataHub")
      .build();
  connection.on("ReceiveLatestData", (data) => { /* 处理数据 */ });
  connection.start();
  

方案二：轻量MQTT服务器+自定义业务服务（最贴合MQTT需求） #

如果需要原生的发布订阅能力，直接用成熟的MQTT服务器替代自研Socket，大幅减少异常处理工作量：

• 部署MQTT服务器：选择轻量型的EMQX或Mosquitto，直接在Windows上安装运行，配置监听局域网IP（如0.0.0.0:1883），开放防火墙1883端口。
• 编写业务服务：开发一个Windows服务/控制台程序，完成两个核心逻辑：
  1. 每900毫秒从MySQL拉取数据，发布到MQTT的server/data/latest主题。
  2. 订阅客户端发送数据的主题（如client/request/*），接收客户端请求后处理并写入MySQL。
• 客户端实现：使用MQTT客户端库（如MQTTnet、paho-mqtt），订阅server/data/latest接收推送，发布到指定主题向服务器发送数据。
• 优势：MQTT服务器原生支持连接管理、心跳重连、主题过滤，完全不用自己处理Socket异常，稳定性极高。

方案三：TcpListener封装简易发布订阅（适合无第三方依赖场景） #

如果必须自研通信层，基于.NET的TcpListener封装轻量发布订阅逻辑，比原生Socket减少重复工作：

• 实现连接池管理客户端连接，维护订阅主题与客户端的映射关系。
• 用PeriodicTimer实现900毫秒定时任务，从MySQL拉取数据后推送给订阅对应主题的客户端。
• 封装心跳检测、异常重连逻辑，避免单个连接崩溃影响整体服务。
• 注意：该方案仍需手动处理TCP粘包、断连重连等问题，开发成本高于前两个方案，仅适合特殊场景。

内容的提问来源于stack exchange，提问作者Vijay Amni