powerfun-new-net/Services/TcpService1.cs

using NetCoreServer;
using OnlineUserPool.Model;
using OnlineUserPool.Unility;
using Serilog;
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.Linq;
using System.Net;
using System.Net.Sockets;
using System.Text;

namespace OnlineUserPool.Services
{
    public class TcpService1 : IService
    {
        private PfTcpServer _server;

        public void Close()
        {
            //throw new NotImplementedException();
        }

        public void RunServer(Action<IPEndPoint, MsgModel, IService> action)
        {
            //throw new NotImplementedException();
            //_action = action;
            _server = new PfTcpServer(IPAddress.Any, ConfigHelp.TcpPort, (ip, model)=> {
                action(ip, model, this);
            });
            //_server.OptionNoDelay = true;
            _server.Start();
        }



        public void Send(byte[] dgram, int bytes, IPEndPoint endPoint)
        {
            if (dgram == null || !dgram.Any())
            {
                return;
            }
            _server.Multicast(dgram);
            
        }

        class PfTcpServer : TcpServer
        {
            Action<IPEndPoint, MsgModel> _action;
            public PfTcpServer(IPAddress address, int port, Action<IPEndPoint, MsgModel> action) :base(address, port)
            {
                _action = action;
            }

            protected override TcpSession CreateSession()
            {
                //return base.CreateSession()
                return new PfTcpSession(this, _action);
            }

            protected override void OnError(SocketError error)
            {
                //base.OnError(error);
                Debug.WriteLine(error);
            }
        }

        class PfTcpSession : TcpSession
        {
            Action<IPEndPoint, MsgModel> _action;
            public PfTcpSession(TcpServer server, Action<IPEndPoint, MsgModel> action) : base(server) {
                _action = action;
            }

            protected override void OnConnected()
            {
                //base.OnConnected();
                Debug.WriteLine("有新的Tcp连接");
            }

            protected override void OnDisconnected()
            {
                //base.OnDisconnected();
                Debug.WriteLine("Tcp断开连接");
            }
            private string temp = "";
            protected override void OnReceived(byte[] buffer, long offset, long size)
            {
                //base.OnReceived(buffer, offset, size);

                //Debug.WriteLine(returnData);
                //Log.Information(returnData + "\r\n");
                string returnData = "";
                try
                {
                    returnData = Encoding.UTF8.GetString(buffer, (int)offset, (int)size);
                    //var msg = Newtonsoft.Json.JsonConvert.DeserializeObject<MsgModel>(returnData);
                    //var ipEndPoint = IPEndPoint.Parse(this.Socket.RemoteEndPoint.ToString());
                    //_action(ipEndPoint, msg);
                    foreach (var item in returnData)
                    {
                        if(item == '}')
                        {
                            temp += item;
                            var msg = Newtonsoft.Json.JsonConvert.DeserializeObject<MsgModel>(temp);
                            var ipEndPoint = IPEndPoint.Parse(this.Socket.RemoteEndPoint.ToString());
                            _action(ipEndPoint, msg);

                            temp = "";
                        }
                        else
                        {
                            temp += item;
                        }
                    }

                    //foreach (var item in returnData.Split(new string[] { "}" }, StringSplitOptions.RemoveEmptyEntries))
                    //{
                    //    //if (string.IsNullOrWhiteSpace(item)) continue;
                    //    var msg = Newtonsoft.Json.JsonConvert.DeserializeObject<MsgModel>(item + "}");
                    //    var ipEndPoint = IPEndPoint.Parse(this.Socket.RemoteEndPoint.ToString());
                    //    _action(ipEndPoint, msg);
                    //}
                }
                catch (Exception ex)
                {
                    Log.Error($"接受到的数据处理时出错：{ returnData }\r\n{ ex.Message }\r\n{ ex.StackTrace }");
                }
            }

            protected override void OnError(SocketError error)
            {
                //base.OnError(error);
                Debug.WriteLine(error);
            }
        }
    }
}