|
|
@ -35,7 +35,7 @@ public class TcpServer<TH, TD, TE> : IDisposable where TH : IChannelHandler
|
|
|
|
|
|
|
|
|
|
|
|
public Action? ChannelInActiveAction { get; set; }
|
|
|
|
public Action? ChannelInActiveAction { get; set; }
|
|
|
|
|
|
|
|
|
|
|
|
public TcpServer()
|
|
|
|
public void InitBootstrap()
|
|
|
|
{
|
|
|
|
{
|
|
|
|
|
|
|
|
|
|
|
|
if (LogLevel != null)
|
|
|
|
if (LogLevel != null)
|
|
|
@ -131,6 +131,7 @@ public class TcpServer<TH, TD, TE> : IDisposable where TH : IChannelHandler
|
|
|
|
{
|
|
|
|
{
|
|
|
|
_port = port;
|
|
|
|
_port = port;
|
|
|
|
Log.Info(" Start Listen");
|
|
|
|
Log.Info(" Start Listen");
|
|
|
|
|
|
|
|
InitBootstrap();
|
|
|
|
Task<IChannel>? channel = bootstrap?.BindAsync(_port);
|
|
|
|
Task<IChannel>? channel = bootstrap?.BindAsync(_port);
|
|
|
|
Log.Info($"netty success listen {_port}");
|
|
|
|
Log.Info($"netty success listen {_port}");
|
|
|
|
}
|
|
|
|
}
|
|
|
|