Framework

服务项目调试时需要“附加到进程”开发体验比较差影响效率使用控制台不仅可以随时打断点调试还可以随时打印调试信息非常方便

Topshelf

app){//app.UseErrorPage();app.UseCors(CorsOptions.AllowAll);//

http://go.microsoft.com/fwlink/?LinkID316888//Hub

new

HubConfiguration());app.Map(/signalr,

map

true};//config.EnableCrossDomain

true;//

downmap.UseCors(CorsOptions.AllowAll).RunSignalR(config);});Make

long

reconnect.//GlobalHost.Configuration.ConnectionTimeout

maximum

connection.//GlobalHost.Configuration.DisconnectTimeout

transports

value.//GlobalHost.Configuration.KeepAlive

Turn

programmaticallyGlobalHost.TraceManager.Switch.Level

}建立可在服务里运行的服务类使用了上面的Startup配置实例化宿主对象里面定义了服务的启动暂停关闭等触发时的一些动作本文就建立一个

JobManager

System.Threading.Tasks;namespace

{public

$http://{JsonConfig.Instance.Root()?.Debug?.Ip}:{JsonConfig.Instance.Root()?.Debug?.Port};var

Port

${JsonConfig.Instance.Root()?.Debug?.Port};

#elsevar

$http://{JsonConfig.Instance.Root()?.Release?.Ip}:{JsonConfig.Instance.Root()?.Release?.Port};var

Port

${JsonConfig.Instance.Root()?.Release?.Port};

#endifStartOptions

StartOptions();options.Urls.Add(url);options.Urls.Add($http://:{Port});//此处需要用一个全局变量来保存WebApp,否则在发布为后台服务的时候生命周期会提前结束,被系统回收掉SignalR

WebApp.StartStartup(options);Task.Delay(TimeSpan.FromSeconds(1)).Wait();Console.WriteLine(Server

running

url);Console.WriteLine(${displayName}服务开始);Console.ReadLine();LogHelper.GetInstance().Information(${displayName}服务开始,地址

{url});return

ex){LogHelper.GetInstance().Error(ex);}return

false;}public

Stop(){SignalR.Dispose();LogHelper.GetInstance().Information(${displayName}服务停止);System.Threading.Thread.Sleep(1500);return

true;}public

Shutdown(){SignalR.Dispose();LogHelper.GetInstance().Information(${displayName}服务停止);System.Threading.Thread.Sleep(1500);return

true;}}

HenryMes.SignalR.Hosting;static

void

tc.Shutdown());s.WhenStopped(tc

tc.Stop());});x.RunAsLocalSystem();x.StartAutomatically();x.SetDescription(displayName);x.SetDisplayName(displayName);x.SetServiceName(displayName);});}}

下面定义一个

的连接和断开一个线程管理一个连接连接断开线程自动取消建立一个抽象类

BaseHub

System.Threading.Tasks;namespace

{///

/summary[HubName(nameof(T))]public

abstract

OnConnected(){//获取客户端IDConsole.WriteLine({0}已连接,

Context.ConnectionId);LogHelper.GetInstance().Information($服务端与客户端【{typeof(T).Name}】{Context.ConnectionId}

成功建立连接);return

OnReconnected(){Console.WriteLine({0}已重连,

Context.ConnectionId);LogHelper.GetInstance().Information($服务端与客户端【{typeof(T).Name}】{Context.ConnectionId}

已重连);Send(Context.ConnectionId);return

summary///

IsCompletedAllTasks(CancellationTokenSource

tokenSource,

ex){LogHelper.GetInstance().Error($系统错误:{this.GetType().Name},{ex.Flatten().InnerException.Message});tokenSource.Cancel();}return

false;}///

CancellationTokenSource();Connections.TryAdd(connectId,

{while

(!tokenSource.Token.IsCancellationRequested){try{//

(runMultiTask

正在回传数据!;LogHelper.GetInstance().Information(message);//

把组装好的数据推送到前端BaseNotiferT.Refresh(connectId,

JsonConvert.SerializeObject(result));tokenSource.Token.WaitHandle.WaitOne(intervalTime);}else{//

(isCompleted,

RunMultiTaskMethod(tokenSource);if

(isCompleted){var

正在回传数据!;LogHelper.GetInstance().Information(message);//

把组装好的数据推送到前端BaseNotiferT.Refresh(connectId,

JsonConvert.SerializeObject(result));//

下一次推送等待N秒后进行tokenSource.Token.WaitHandle.WaitOne(intervalTime);}else{//

打印超时错误日志LogHelper.GetInstance().Error(${this.GetType().Name}

推送超时!

当前超时时间设置为{millisecondsTimeout}毫秒!);//

重新执行Connections.TryRemove(connectId,

out

tokenSource);Send(connectId);}}}catch(AggregateException

ex){LogHelper.GetInstance().Error($系统错误:{this.GetType().Name},{ex.Flatten().InnerException.Message});tokenSource.Token.WaitHandle.WaitOne(intervalTime);}}},

summary///

Connections[Context.ConnectionId];Connections.TryRemove(Context.ConnectionId,

out

tokenSource);tokenSource.Cancel();LogHelper.GetInstance().Information($服务端与客户端【{typeof(T).Name}】{Context.ConnectionId}

连接已断开);}catch

(Connections.ContainsKey(Context.ConnectionId)){var

tokenSource

Connections[Context.ConnectionId];Connections.TryRemove(Context.ConnectionId,

out

打印错误日志LogHelper.GetInstance().Error(${this.GetType().Name}

已断开!

base.OnDisconnected(stopCalled);}}

Hub

HenryMes.WebApi.Controllers.O***r;

using

System.Threading.Tasks;namespace

{///

controller.ControlCenter_Center_Sum4Rapeseed();return

data.Content;});//

controller.ControlCenter_Center_Sum4Oil();return

data.Content;});//

controller.ControlCenter_Center_Sum4Top();return

data.Content;});//

controller.ControlCenter_Center_SaleDispatch4Month();return

data.Content;});//

controller.ControlCenter_Center_PreInStore4Lately();return

data.Content;});//

ProductionTaskController();dynamic

data

ListSqlSugar.ConditionalModel()});return

data.Content;});#endregion#region

同步阻塞等待所有Task执行完//

IsCompletedAllTasks(TokenSource,

new

{taskSum4Rapeseed,taskSum4Oil,taskSum4Top,taskTankOilQuantity,taskSaleDispatch4Month,taskPreInStore4Lately,taskProductionTask});#endregionif

所有Task已完成//

RapeseedResult?.Data?.Rapeseed_GYS?.PurchaseReceiveQuantity,BalanceQuantity

RapeseedResult?.Data?.Rapeseed_GYS?.BalanceQuantity,},SD

RapeseedResult?.Data?.Rapeseed_SD?.PurchaseReceiveQuantity,BalanceQuantity

RapeseedResult?.Data?.Rapeseed_SD?.BalanceQuantity,}};//

油品生产销售dynamic

Sum4OilResult?.Data?.TankOil?.ProductReceiveQuantity,//

Sum4OilResult?.Data?.PackageOil?.ProductReceiveQuantity,//

销售包装油SaleOilQuantity

Sum4OilResult?.Data?.PackageOil?.SaleDispatchQuantity};//

Sum4TopResult

new{Sum4TopResult?.Data?.DataSource};//

罐区存油var

taskSaleDispatch4Month.Result;var

SaleDispatch4Month

TaskSaleDispatch4MonthResult?.Data?.SaleDispatch.Details,Product

TaskSaleDispatch4MonthResult?.Data?.ProductReceive.Details};//

最近10条采购信息var

taskPreInStore4Lately.Result;var

PreInStore4Lately

TaskPreInStore4LatelyResult?.Data?.DataSource;//

最近10条生产计划var

taskProductionTaskResult?.Data;return

(isCompleted,

new{Rapeseed,Sum4Oil,Sum4Top,TankOilQuantity,SaleDispatch4Month,PreInStore4Lately,ProductionTask});#endregion}return

(isCompleted,

的后台推送基本就完成了再来就是web前端的接收推送和断线下的自动重新连接比如说后台服务程序做了更新此时需要关闭服务再启动服务这个时候要求web端不断尝试重新连接直到后台服务启动并重新连接上为止

前端使用

../../pages/kanban/OperationKanBanEcharts.vue;

export

是否需要断线重连的标记当页面关闭时是不需要继续推送的tryReconnect

true}},methods:

从SignalR推送过来的数据刷新看板refreshKanban(message)

{//

$.hubConnection(process.env.SignalR);//

定义服务器端SignalR推送过来的消息接收代理this.proxy

this.connection.createHubProxy(OperationKanBanHub);this.proxy.on(Refresh,

(message)

的数据!)this.refreshKanban(message)});//

创建连接到服务器端SignalR的连接this.connection.start().done(()

{//

客户端发送信息到服务器this.proxy.invoke(Send,

this.connection.id);}).fail((err)

{console.log(err);});this.connection.disconnected(()

{setTimeout(()

{console.log(连接已断开,正尝试重新连接!)this.connection.start().done(()

this.connection.id);

清除缓存this.$vnode.parent.componentInstance.cache

{};this.$vnode.parent.componentInstance.keys

[];}},

};最后的一个步骤怎么把后台的控制台SignalR宿主程序安装成

Windows

ansi不要问我为什么......因为不改的话打开批处理命令窗口的时候中文会显示成乱码

Install.bat

vbscript:CreateObject(Shell.Application).ShellExecute(cmd.exe,/c

%~s0

vbscript:CreateObject(Shell.Application).ShellExecute(cmd.exe,/c

%~s0