基于SignalR的消息推送与二维码扫描登录实现代码_实用技巧_

 using Microsoft.AspNet.SignalR;namespace TxSms.SingalR { public static class Notifier { private static readonly IHubContext Context = GlobalHost.ConnectionManager.GetHubContext(); public static void SessionTimeOut(string connectionId, int time) { Context.Clients.Client(connectionId).alertClient(time); } public static void SendElapsedTime(string connectionId, int time) { Context.Clients.Client(connectionId).sendElapsedTime(time); } public static void SendQRCodeUUID(string connectionId, string uuid) { Context.Clients.Client(connectionId).sendQRCodeUUID(uuid); } } }

 using Microsoft.AspNet.SignalR; using System.Threading.Tasks; namespace TxSms.SingalR { /// 
 /// 二维码推送 /// 
 //[HubName("qrcode")] public class QRCodeHub : Hub { /// 
 /// 给客户端发送时间间隔 /// 
 ///  public void SendTimeOutNotice(int time) { Clients.Client(Context.ConnectionId).alertClient(time); } public void CheckElapsedTime(int time) { Clients.Client(Context.ConnectionId).sendElapsedTime(time); } /// 
 /// 发送二维码UUID内容 /// 
 ///  public void SendQRCodeUUID(string uuid) { Clients.Client(Context.ConnectionId).sendQRCodeUUID(uuid); } /// 
 /// Called when the connection connects to this hub instance. /// 
 /// A  public override Task OnConnected() { SessionTimer.StartTimer(Context.ConnectionId); return base.OnConnected(); } /// 
 /// Called when a connection disconnects from this hub gracefully or due to a timeout. /// 
 ///  /// true, if stop was called on the client closing the connection gracefully; /// false, if the connection has been lost for longer than the /// . /// Timeouts can be caused by clients reconnecting to another SignalR server in scaleout. ///  /// A  public override Task OnDisconnected(bool stopCalled) { SessionTimer.StopTimer(Context.ConnectionId); return base.OnDisconnected(stopCalled); } /// 
 /// Called when the connection reconnects to this hub instance. /// 
 /// A  public override Task OnReconnected() { if (!SessionTimer.Timers.ContainsKey(Context.ConnectionId)) { SessionTimer.StartTimer(Context.ConnectionId); } return base.OnReconnected(); } /// 
 /// 重置时钟 /// 
 public void ResetTimer() { SessionTimer timer; if (SessionTimer.Timers.TryGetValue(Context.ConnectionId, out timer)) { timer.ResetTimer(); } else { SessionTimer.StartTimer(Context.ConnectionId); } } /// 
 /// 发送普通消息 /// 
 ///  ///  public void Send(string name, string message) { Clients.All.addNewMessageToPage(name, message); } } }

 using System;using System.Collections.Concurrent;using System.Timers;namespace TxSms.SingalR{ public class SessionTimer : IDisposable { /// 
 /// 存储客户端对应的Timer /// 
 public static readonly ConcurrentDictionary Timers; private readonly Timer _timer; static SessionTimer() { Timers = new ConcurrentDictionary(); } /// 
 /// 构造函数 /// 
 ///  private SessionTimer(string connectionId) { ConnectionId = connectionId; _timer = new Timer { Interval = Utility.ActivityTimerInterval() }; _timer.Elapsed += (s, e) => MonitorElapsedTime(); _timer.Start(); } public int TimeCount { get; set; } /// 
 /// 客户端连接Id /// 
 public string ConnectionId { get; set; } /// 
 /// 启动Timer /// 
 ///  public static void StartTimer(string connectionId) { var newTimer = new SessionTimer(connectionId); if (!Timers.TryAdd(connectionId, newTimer)) { newTimer.Dispose(); } } /// 
 /// 停止Timer /// 
 ///  public static void StopTimer(string connectionId) { SessionTimer oldTimer; if (Timers.TryRemove(connectionId, out oldTimer)) { oldTimer.Dispose(); } } /// 
 /// 重置Timer /// 
 public void ResetTimer() { TimeCount = 0; _timer.Stop(); _timer.Start(); } public void Dispose() { // Stop might not be necessary since we call Dispose _timer.Stop(); _timer.Dispose(); } /// 
 /// 给客户端发送消息 /// 
 private void MonitorElapsedTime() { Utility.ClearExpiredUUID(); var uuid = Utility.GetUUID(ConnectionId); //if (TimeCount >= Utility.TimerValue()) //{ // StopTimer(ConnectionId); // Notifier.SendQRCodeUUID(ConnectionId, uuid); // Notifier.SessionTimeOut(ConnectionId, TimeCount); //} //else // { Notifier.SendQRCodeUUID(ConnectionId, uuid); Notifier.SendElapsedTime(ConnectionId, TimeCount); //} TimeCount++; if (TimeCount > 1000) { TimeCount = 0; } } }}

 using TxSms.Actions;namespace TxSms.SingalR { internal class Utility { public static int IntNum = 0; /// 
 /// 时间间隔 /// 
 ///  public static int TimerValue() { return 1000; } public static double ActivityTimerInterval() { return 1000.0; } /// 
 /// 获取当前UUID /// 
 ///  public static string GetUUID(string connectionId) { try { var model = new QRCodeAction().GetValidModel(connectionId); return model.ToJson(connectionId); } catch { return "ERROR"; } } /// 
 /// 删除过期UUID /// 
 public static void ClearExpiredUUID() { IntNum++; if (IntNum <= 1000) return; new QRCodeAction().ClearExpiredUUID(); IntNum = 0; } }}

 using Microsoft.Owin;using Owin; [assembly: OwinStartup(typeof(TxSms.Web.Startup))]namespace TxSms.Web{ public partial class Startup { public void Configuration(IAppBuilder app) { //启动SignalR app.MapSignalR(); ConfigureAuth(app); } }}