TK.TSocket 1.3.1

TK.TSocket

介绍

基于touchsocket的二次封装

使用说明

namespace Demo
{
    class Program
    {
        static void Main(string[] args)
        {
            var server = new TcpSocketServer((config) =>
            {
                config.DataAdapterFunc = (adapterConfig) =>
                {
                    return new TouchSocket.Sockets.FixedHeaderPackageAdapter();
                };
            });
            var receive = new ReceiveData(server);
            server.Start(receive);            
            Console.WriteLine($"socket服务监听中......");
            Console.ReadKey();
            server.Dispose();
        }
    }

    public class ReceiveData : IReceiveData
    {
        private readonly ITcpSocketServer _server;

        public ReceiveData(ITcpSocketServer server)
        {
            _server = server;
        }

        public Task ReceiveDataAsync(DataPacket dataPacket)
        {
            var tt = dataPacket;
            Console.WriteLine(JsonSerializer.Serialize(dataPacket,new JsonSerializerOptions { Encoder = JavaScriptEncoder.UnsafeRelaxedJsonEscaping } ));
            if (dataPacket.DataType == DataType.Receive)
            {
                _server.SendData(dataPacket.ClientId, dataPacket.Data);
            }
            return Task.CompletedTask;
        }
    }
}