|
|
using System.Collections.Concurrent;
|
|
|
using System.Threading.Channels;
|
|
|
using DotNetty.Handlers.Logging;
|
|
|
using DotNetty.Handlers.Timeout;
|
|
|
using DotNetty.Transport.Bootstrapping;
|
|
|
using DotNetty.Transport.Channels;
|
|
|
using DotNetty.Transport.Channels.Sockets;
|
|
|
using log4net;
|
|
|
|
|
|
namespace HybirdFrameworkServices.Netty
|
|
|
{
|
|
|
/// <summary>
|
|
|
/// netty server
|
|
|
/// </summary>
|
|
|
public class Server : IDisposable
|
|
|
{
|
|
|
private readonly ILog Log = LogManager.GetLogger(typeof(Server));
|
|
|
|
|
|
static MultithreadEventLoopGroup? bossGroup;
|
|
|
static MultithreadEventLoopGroup? workerGroup;
|
|
|
static ServerBootstrap? bootstrap;
|
|
|
|
|
|
static ConcurrentDictionary<IChannelId, IChannel> _container = ServerListenerHandler.Container;
|
|
|
|
|
|
private int _port = 9000;
|
|
|
|
|
|
public Server()
|
|
|
{
|
|
|
bossGroup = new MultithreadEventLoopGroup();
|
|
|
workerGroup = new MultithreadEventLoopGroup();
|
|
|
bootstrap = new ServerBootstrap();
|
|
|
bootstrap
|
|
|
.Group(bossGroup, workerGroup) // 设置主和工作线程组
|
|
|
.Channel<TcpServerSocketChannel>() // 设置通道模式为TcpSocket
|
|
|
.Option(ChannelOption.SoKeepalive, true) //保持连接
|
|
|
.Handler(new LoggingHandler())
|
|
|
.ChildHandler(new ActionChannelInitializer<ISocketChannel>(channel =>
|
|
|
{
|
|
|
var serverListenerHandler = new ServerListenerHandler();
|
|
|
|
|
|
IChannelPipeline pipeline = channel.Pipeline;
|
|
|
pipeline.AddLast(new LoggingHandler(""));
|
|
|
pipeline.AddLast(serverListenerHandler);
|
|
|
// pipeline.AddLast(new FixedLengthFrameDecoder(12)); //定长数据，12byte
|
|
|
pipeline.AddLast(new IdleStateHandler(0, 0, 180));
|
|
|
// pipeline.AddLast(msgHandler);
|
|
|
//业务handler ，这里是实际处理业务的Handler
|
|
|
}));
|
|
|
|
|
|
Begin(_port);
|
|
|
}
|
|
|
|
|
|
|
|
|
private void Begin(int port)
|
|
|
{
|
|
|
_port = port;
|
|
|
Log.Info(" Start Listen");
|
|
|
Task<IChannel>? channel = bootstrap?.BindAsync(_port);
|
|
|
Log.Info($"netty success listen {_port}");
|
|
|
}
|
|
|
|
|
|
public static void Send(byte[] bytes)
|
|
|
{
|
|
|
foreach (IChannel channel in _container.Values)
|
|
|
{
|
|
|
channel.WriteAndFlushAsync(bytes);
|
|
|
}
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/// <summary>
|
|
|
/// ??netty
|
|
|
/// </summary>
|
|
|
public void Dispose()
|
|
|
{
|
|
|
Log.Info(this + " Dispose");
|
|
|
bossGroup?.ShutdownGracefullyAsync();
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
|
