using System;
|
using System.Threading.Tasks;
|
using Microsoft.Extensions.Hosting;
|
using Microsoft.Extensions.Logging;
|
using Microsoft.Extensions.Options;
|
using SuperSocket;
|
using SuperSocket.Channel;
|
using SuperSocket.ProtoBase;
|
using SuperSocket.Server;
|
|
namespace IStation.Server
|
{
|
internal class MyServer : SuperSocketService<PackageInfo>
|
{
|
|
public MyServer(IServiceProvider serviceProvider, IOptions<ServerOptions> serverOptions)
|
: base(serviceProvider, serverOptions)
|
{
|
}
|
|
protected override async ValueTask OnSessionConnectedAsync(IAppSession session)
|
{
|
await base.OnSessionConnectedAsync(session);
|
}
|
|
protected override async ValueTask OnSessionClosedAsync(IAppSession session, CloseEventArgs e)
|
{
|
await base.OnSessionClosedAsync(session, e);
|
}
|
|
protected override ValueTask OnStartedAsync()
|
{
|
LogHelper.Info($"苏州金庭肯特流量仪数据对接,端口:{this.Options.Listeners.First().Port},开启!");
|
return base.OnStartedAsync();
|
}
|
|
protected override ValueTask OnStopAsync()
|
{
|
LogHelper.Info($"苏州金庭肯特流量仪数据对接,端口:{this.Options.Listeners.First().Port},关闭!");
|
return base.OnStopAsync();
|
}
|
|
|
|
}
|
}
|