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

using microsoft.aspnet.signalr;namespace txsms.singalr
{
public static class notifier 
{ 
private static readonly ihubcontext context = globalhost.connectionmanager.gethubcontext<qrcodehub>(); 
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
{ 
/// <summary> 
/// 二维码推送
/// 
</summary> 
//[hubname("qrcode")] public class qrcodehub : hub {
/// <summary> /// 给客户端发送时间间隔 /// 
</summary> /// <param name="time">
</param>
public void sendtimeoutnotice(int time) 
{
clients.client(context.connectionid).alertclient(time);
}
public void checkelapsedtime(int time) 
{
clients.client(context.connectionid).sendelapsedtime(time); } 
/// <summary> 
/// 发送二维码uuid内容
///
</summary>
/// <param name="uuid">
</param> 
public void sendqrcodeuuid(string uuid) 
{ 
clients.client(context.connectionid).sendqrcodeuuid(uuid); }
///
<summary>
/// called when the connection connects to this hub instance.
/// </summary> ///
<returns>a <see cref="t:system.threading.tasks.task" />
</returns> public override task onconnected() 
{
sessiontimer.starttimer(context.connectionid); return base.onconnected();
}
/// <summary> 
/// called when a connection disconnects from this hub gracefully or due to a timeout. 
///
</summary> 
/// 
<param name="stopcalled">
/// true, if stop was called on the client closing the connection gracefully;
/// false, if the connection has been lost for longer than the /// <see cref="p:microsoft.aspnet.signalr.configuration.iconfigurationmanager.disconnecttimeout" />. 
/// timeouts can be caused by clients reconnecting to another signalr server in scaleout. /// </param> /// <returns>a <see cref="t:system.threading.tasks.task" />
</returns> public override task ondisconnected(bool stopcalled) { sessiontimer.stoptimer(context.connectionid); return base.ondisconnected(stopcalled);
} 
/// <summary> /// 
called when the connection reconnects to this hub instance. /// </summary> ///
<returns>a <see cref="t:system.threading.tasks.task" />
</returns> public override task onreconnected()
{
if (!sessiontimer.timers.containskey(context.connectionid)) 
{ 
sessiontimer.starttimer(context.connectionid);
} 
return base.onreconnected(); }
///
<summary> /// 重置时钟 /// 
</summary> public void resettimer() 
{ sessiontimer timer;
if (sessiontimer.timers.trygetvalue(context.connectionid, out timer))
{ timer.resettimer(); 
} 
else
{
sessiontimer.starttimer(context.connectionid);
}
} /// 
<summary> /// 
发送普通消息 /// 
</summary> ///
<param name="name">
</param> /// <param name="message">
</param>
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 
{ 
///
<summary> /// 存储客户端对应的timer /// 
</summary> 
public static readonly concurrentdictionary<string, sessiontimer> timers; private readonly timer _timer; static sessiontimer() 
{ timers = new concurrentdictionary<string, sessiontimer>(); 
}
/// <summary> /// 构造函数 /// </summary> /// 
<param name="connectionid"></param> private sessiontimer(string connectionid)
{
connectionid = connectionid; _timer = new timer { interval = utility.activitytimerinterval() }; _timer.elapsed += (s, e) => monitorelapsedtime(); _timer.start(); 
}
public int timecount { get; set; } /// <summary> /// 客户端连接id ///
</summary> public string connectionid { get; set; } /// <summary> /// 启动timer /// 
</summary> ///
<param name="connectionid">
</param>
public static void starttimer(string connectionid) 
{ 
var newtimer = new sessiontimer(connectionid);
if (!timers.tryadd(connectionid, newtimer)) 
{ newtimer.dispose();
}
} 
/// <summary>
/// 停止timer /// </summary> ///
<param name="connectionid">
</param> public static void stoptimer(string connectionid) 
{
sessiontimer oldtimer; 
if (timers.tryremove(connectionid, out oldtimer))
{ 
oldtimer.dispose();
} 
} 
/// <summary> /// 
重置timer /// 
</summary> 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(); 
} ///

<summary> ///
给客户端发送消息 /// 
</summary> 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; /// 
<summary> /// 时间间隔 /// 
</summary> ///
<returns></returns> 
public static int timervalue() 
{ return 1000;
} 
public static double activitytimerinterval()
{ return 1000.0;
}
/// <summary> /// 获取当前uuid
/// </summary>
/// <returns></returns> public static string getuuid(string connectionid)
{
try 
{ 
var model = new qrcodeaction().getvalidmodel(connectionid); 
return model.tojson(connectionid); 
} 
catch 
{ return "error"; 
} } /// <summary> /// 删除过期uuid /// 
</summary> 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); 
} }}

<script type="text/javascript" src="~/scripts/jquery.signalr-2.2.1.min.js">
</script> 
<script type="text/javascript" src="~/signalr/hubs">
</script

 var codeuuid = "";
 $(function () {
 // reference the auto-generated proxy for the hub. var qrcode = $.connection.qrcodehub;
 // create a function that the hub can call back to display messages. qrcode.client.addnewmessagetopage = function (name, message)
 { // add the message to the page. console.log(message); //jquery('#divqrcode').qrcode({ width: 180, height: 180, correctlevel: 0, text: message }); 
 }; 
 qrcode.client.sendelapsedtime = function (time) { console.log(time); 
 }; 
 qrcode.client.sendqrcodeuuid = function (uuid) { console.log("sendqrcodeuuid");
 console.log(codeuuid); if (codeuuid === uuid) { return; } codeuuid = uuid; if (codeuuid !== "error") { var jsonuuid = $.parsejson(codeuuid);
 if (jsonuuid.islogin === 1) { //判断是否登录 window.location.href = "/home/index/@model.name"; } } $("#divqrcode").html("");
 $('#divqrcode').qrcode({ width: 180, height: 180, correctlevel: 0, text: codeuuid });
 };
 // start the connection. $.connection.hub.start().done(function () { //qrcode.server.updateconnectionid($.connection.hub.id); qrcode.server.send("qrcode", math.random());
 });
 });

<script type="text/javascript" src="~/scripts/qrcode.min.js">
</script> 
<script type="text/javascript" src="~/scripts/jquery.qrcode.min.js">
</script>

 <!--二维码登录开始--> 
<div> 
<div>安全登录 防止被盗</div>
 <div>
</div> 
<div>扫一扫登录</div> 
</div> 
<!--二维码登录结束-->

$("#divqrcode").html(""); 
$('#divqrcode').qrcode({ width: 180, height: 180, correctlevel: 0, text: codeuuid });

{"connectionid":"19c12e95-26d7-410c-8292-2a3afdd1a4da","uuid":"a04702df-6a52-4e1c-be8b-9b3dbeef4d72","islogin":0,"isvalid":1}

using abp.application.services.dto;using system;using system.componentmodel.dataannotations;
namespace txsms.inputs{ /// <summary> /// 二维码登录认证 /// </summary> [serializable]
public class qrcodeverifyinput : iinputdto { /// <summary> /// 构造函数 /// </summary>
public qrcodeverifyinput() { connectionid = guid.empty.tostring();
uuid = guid.empty; username = password = ""; } /// <summary> /// 当前回话id /// </summary> 
[displayformat(convertemptystringtonull = false)] public string connectionid { get; set;
} /// <summary> /// 唯一标识符号 /// </summary> 
public guid uuid { get; set; } /// <summary> /// 用户账号 /// </summary>
[displayformat(convertemptystringtonull = false)]
public string username { get; set; } /// <summary> /// 登录密码 /// </summary>
[displayformat(convertemptystringtonull = false)] 
public string password { get; set; } /// <summary> /// 平台 /// </summary>
[displayformat(convertemptystringtonull = false)] 
public string platform { get; set; 
} }}

using abp.application.services.dto;
using newtonsoft.json;using system.componentmodel.dataannotations;using system.web.mvc;using txsms.mvc;namespace txsms.outputs{ /// <summary> /// 输出基类 /// </summary> [modelbinder(typeof(emptystringmodelbinder))] public class txsmsoutputdto : ioutputdto { /// <summary> /// 构造函数 /// 
</summary> public txsmsoutputdto() 
{ result = 0; //默认为0，表示初始值或正确 message = ""; 
} /// <summary> /// 错误代码 ///
</summary> [jsonproperty("result")] public int result { get; set; } /// <summary> /// 错误信息 /// </summary>
[displayformat(convertemptystringtonull = false)] [jsonproperty("message")] 
public string message { get; set; } }}

using system;using system.threading.tasks;using system.web.http;using txsms.actions;using txsms.inputs;using txsms.outputs;namespace txsms{ /// <summary> /// 二维码接口 /// </summary> public class qrcodecontroller : txsmsapicontroller { /// <summary> /// 二维码登录认证 /// </summary> /// <returns> /// 0:登录成功；-1:参数错误 -2:connectionid、uuid、username、password不允许为空-3:connectionid回话id不存在-4:uuid输入错误-5:uuid已过期 /// -6:本uuid已登录-7:登录账号已停用-8:登录账号已删除-9:登录密码输入错误-10:登录账号不存在 /// </returns> [allowanonymous] [httppost] public async task<txsmsoutputdto> qrcodeverify([frombody]qrcodeverifyinput model) { txsmsoutputdto result = new txsmsoutputdto(); #region 参数验证 if (model.isnull()) { result.result = -1; result.message = "参数错误"; return result; } if (model.connectionid.isnullorempty() || model.uuid.equals(guid.empty) || model.username.isnullorempty() || model.password.isnullorempty()) { result.result = -2; result.message = "connectionid、uuid、username、password不允许为空"; return result; } #endregion 参数验证 #region 有效性判断 //验证connectionid合法性 if (qrcodeaction.qrcodelists.containskey(model.connectionid)) { result.result = -3; result.message = "connectionid回话id不存在"; return result; } //验证uuid有效性 var findcode = qrcodeaction.qrcodelists[model.connectionid]; if (!model.uuid.equals(findcode.uuid)) { result.result = -4; result.message = "uuid输入错误"; return result; } if (!findcode.isvalid()) { result.result = -5; result.message = "uuid已过期"; return result; } if (findcode.islogin) { result.result = -6; result.message = "本uuid已登录"; return result; } #endregion 有效性判断 loginusernameinput loginparam = new loginusernameinput { username = model.username, password = model.password, platform = model.platform }; loginoutput loginresult = await new sessioncontroller().loginusername(loginparam); switch (loginresult.result) { case -1: result.result = -7; result.message = "登录账号已停用"; break; case -2: result.result = -8; result.message = "登录账号已删除"; break; case -3: result.result = -9; result.message = "登录密码输入错误"; break; case -4: result.result = -10; result.message = "登录账号不存在"; break; } if (loginresult.result > 0) //登录成功，值为accid { result.result = 0; findcode.islogin = true; //更改登录状态 result.message = "成功登录"; } return result; } }}