using SuperSocket;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using SuperSocket.ProtoBase;
|
using SuperSocket.Server;
|
using SuperSocket.Channel;
|
using Microsoft.Extensions.Hosting;
|
using Microsoft.Extensions.Logging;
|
using IStation.Model;
|
using IStation.Server.SZJTKT.Interface;
|
|
namespace IStation.Server
|
{
|
internal class ServerHelper :IJobHelper
|
{
|
private IServer _server = null;
|
public async void Start()
|
{
|
if (_server != null)
|
return;
|
var host = SuperSocketHostBuilder.Create<PackageInfo>();
|
host.UsePipelineFilterFactory<PipeLineFilterFactory>();
|
host.UseSession<MySession>();
|
host.UseHostedService<MyServer>();
|
host.ConfigureSuperSocket(options =>
|
{
|
options.Name = "SZJTKT";
|
options.MaxPackageLength = 1000000;
|
options.ReceiveBufferSize = 1000000;
|
options.SendBufferSize = 1000000;
|
options.Listeners = new List<ListenOptions>()
|
{
|
new ListenOptions(){ Ip="Any",Port=ConfigHelper.ServerPort}
|
};
|
});
|
host.UsePackageHandler(RequestReceivedHelper.Receive);
|
_server= host.BuildAsServer();
|
await _server.StartAsync();
|
LogHelper.Info($"Socket服务，端口：{ConfigHelper.ServerPort},开启成功！");
|
}
|
|
public async void Cancel()
|
{
|
if (_server == null)
|
return;
|
await _server.StopAsync();
|
LogHelper.Info($"Socket服务，端口：{ConfigHelper.ServerPort},关闭成功！");
|
}
|
|
|
}
|
}
|
