|
|
@@ -39,7 +39,7 @@ public class GetBarcodeByScan : IHttpHandler, IReadOnlySessionState
|
|
|
string barcodeip = context.Request["barcodeip"].ToString();
|
|
|
string name = context.Request["name"].ToString();
|
|
|
|
|
|
- if (allScokets == null )
|
|
|
+ if (allScokets == null)
|
|
|
{
|
|
|
start(barcodeip);
|
|
|
context.Response.Write("服务启动成功!");
|
|
|
@@ -54,6 +54,15 @@ public class GetBarcodeByScan : IHttpHandler, IReadOnlySessionState
|
|
|
}
|
|
|
Logger.Info("已启动;工位:" + name + "; Scokets:" +allScokets.Count);
|
|
|
}
|
|
|
+
|
|
|
+ }
|
|
|
+
|
|
|
+ //终极启动服务
|
|
|
+ if (context.Request["startfinal"] is object)
|
|
|
+ {
|
|
|
+ start("ws://172.18.32.32:9102");
|
|
|
+ context.Response.Write("服务终极启动成功!");
|
|
|
+ Logger.Info("服务终极启动成功; Scokets:" + allScokets.Count);
|
|
|
|
|
|
}
|
|
|
|
|
|
@@ -222,11 +231,11 @@ public class GetBarcodeByScan : IHttpHandler, IReadOnlySessionState
|
|
|
server = new WebSocketServer(ip);
|
|
|
server.Start(scoket =>
|
|
|
{
|
|
|
- scoket.OnOpen = () => { allScokets.Add(scoket); };
|
|
|
- scoket.OnClose = () => { allScokets.Remove(scoket); };
|
|
|
+ scoket.OnOpen = () => { allScokets.Add(scoket); Logger.Info("新增scoket连接"); };
|
|
|
+ scoket.OnClose = () => { allScokets.Remove(scoket); Logger.Info("关闭scoket连接"); };
|
|
|
scoket.OnMessage = message => { allScokets.ToList().ForEach(s => s.Send(message)); };
|
|
|
});
|
|
|
- }
|
|
|
+ }
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
throw ex;
|