Plane.Sdk3/PlaneGcsSdk_Shared/Communication/TcpConnection.cs

#if !NETFX_CORE

using System;
using System.Net;
using System.Net.Sockets;
using System.Threading.Tasks;

namespace Plane.Communication
{
    /// <summary>
    /// 提供作为 TCP 客户端通信的能力。
    /// </summary>
    public class TcpConnection : TcpConnectionBase
    {
        private string _remoteHostname;
        const int tcpReceiveBufferSize = 20 * 1024;  //40 * 1024,
        const int tcpReceiveTimeout = 1200;

        private int _remotePort;

        public TcpConnection(string remoteHostname, int remotePort = 5250)
        {
            _remoteHostname = remoteHostname;
            _remotePort = remotePort;
            _client = new TcpClient
            {
                ReceiveBufferSize = tcpReceiveBufferSize,
                ReceiveTimeout = tcpReceiveTimeout
            };
        }

        public void Open()
        {
            if (!IsOpen)
            {
                try
                {
                    _client.Connect(_remoteHostname, _remotePort);
                }
                catch (SocketException)
                {
                    CreateClientAndConnect();
                }
                catch (ObjectDisposedException)
                {
                    CreateClientAndConnect();
                }
                _isBroken = false;
            }
            
            _stream = _client.GetStream();
        }

        public async Task<bool> BindIP(string ip)
        {
            bool bind = false;
            try
            {
                IPAddress IPLocal = IPAddress.Parse(ip);
                _client.Client.Bind(new IPEndPoint(IPLocal, 0));
                bind = true;
            }
            catch
            {
                bind = false;
            }
            await Task.Delay(10).ConfigureAwait(false);
            return bind;
        }

        public override async Task OpenAsync()
        {
            string logstr;
            if (!IsOpen)
            {
                try
                {
                    await _client.ConnectAsync(_remoteHostname, _remotePort).ConfigureAwait(false);
                }
                //屏蔽掉异常处理
                //CreateClientAndConnectAsync会new一个TcpClient并且重新连接  
                //之前设置的TcpClient中Socket Bind会无效，在多网卡工作时会导致断线重连的时间特别长
                catch (SocketException e)
                {
                    logstr= e.Message;
                    //await CreateClientAndConnectAsync();
                }
                catch (ObjectDisposedException)
                {
                    //await CreateClientAndConnectAsync();
                }
                _isBroken = false;
            }
            _stream = _client.GetStream();
        }

        private void CreateClientAndConnect()
        {
            _client = new TcpClient(_remoteHostname, _remotePort)
            {
                ReceiveBufferSize = tcpReceiveBufferSize,
                ReceiveTimeout = tcpReceiveTimeout
            };
        }

        private async Task CreateClientAndConnectAsync()
        {
            _client = new TcpClient
            {
                ReceiveBufferSize = tcpReceiveBufferSize,// 40 * 1024,
                ReceiveTimeout = tcpReceiveTimeout// 1200
            };
            await _client.ConnectAsync(_remoteHostname, _remotePort).ConfigureAwait(false);
        }
    }
}

#endif