有没有详细的EasyClient的用法

[loveyeguo]

譬如，如何判断Client已经连接，然后不再重新连接呢？ 官方的示例太简单了，有点看不懂。

[loveyeguo]

EasyClient并没有类似：IsConnected方法

[loveyeguo]

我使用的是supersocket2.0

[jcreator35]

@loveyeguo 请仔细看EasyClient这个类的源码，它有一个异步方法ValueTask ConnectAsync(EndPoint remoteEndPoint, CancellationToken cancellationToken)，这个方法执行成功就会返回true，代表客户端连接成功

[loveyeguo]

@jcreator35 感谢回答。我知道这个方法。但是我需要在下次发送数据的时候，判断当前客户端是否连接。而你提供的这个方法，只是第一次连接的时候判断是否连接成功。（实际上在接下来几分钟后服务端会踢出客户端）

[loveyeguo]

我自己写了一个继承类，方便快捷的发送消息，同时支持自动断线重连，有需要可以参考之...

using Microsoft.Extensions.Logging;
using SuperSocket.Client;
using SuperSocket.ProtoBase;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Text;
using System.Threading.Channels;
using System.Threading;
using System.Threading.Tasks;
using Common;
using SuperSocket.Channel;

namespace Beidou
{
    public class EasyClientHelper<TReceivePackage> : EasyClient<TReceivePackage> where TReceivePackage : class
    {
        private readonly IPEndPoint _remoteEndPoint;
        private readonly int _maxRetryCount = 3;
        private int _currentRetryCount = 0;
        private readonly SemaphoreSlim _sendLock = new SemaphoreSlim(1, 1);

        public EasyClientHelper(IPipelineFilter<TReceivePackage> pipelineFilter, IPEndPoint remoteEndPoint)
         : base(pipelineFilter)
        {
            _remoteEndPoint = remoteEndPoint ?? throw new ArgumentNullException(nameof(remoteEndPoint));
        }
        public void StartReceiveData()
        {
            StartReceive();
        }
        /// <summary>
        /// 检查连接状态
        /// </summary>
        public bool IsConnected => Channel != null && !Channel.IsClosed;

        /// <summary>
        /// 发送数据（带自动重连）
        /// </summary>
        public async Task<bool> SendDataAsync(string message, CancellationToken cancellationToken = default)
        {
            await _sendLock.WaitAsync(cancellationToken);
            try
            {
                for (_currentRetryCount = 0; _currentRetryCount < _maxRetryCount; _currentRetryCount++)
                {
                    try
                    {
                        // 如果未连接或连接已关闭，尝试重连
                        if (!IsConnected)
                        {
                            Console.WriteLine("尝试连接服务器...");
                            var connected = await ConnectAsync(_remoteEndPoint, cancellationToken);

                            if (!connected)
                            {
                                Console.WriteLine($"连接服务器失败，重试 {_currentRetryCount + 1}/{_maxRetryCount}");
                                await Task.Delay(1000, cancellationToken); // 等待1秒后重试
                                continue;
                            }
                        }

                        // 发送数据
                        byte[] data = StringHelper.strToToHexByte(message);
                        await SendAsync(data);
                        Console.WriteLine("数据发送成功");

                        return true;
                    }
                    catch (Exception ex)
                    {
                        Console.WriteLine($"发送数据时出错，重试 {_currentRetryCount + 1}/{_maxRetryCount}");

                        // 关闭当前连接以便下次重连
                        if (Channel != null)
                        {
                            await Channel.CloseAsync(CloseReason.Unknown);
                        }

                        if (_currentRetryCount < _maxRetryCount - 1)
                        {
                            await Task.Delay(1000, cancellationToken); // 等待1秒后重试
                        }
                    }
                }

                Console.WriteLine($"发送数据失败，已达到最大重试次数 {_maxRetryCount}");
                return false;
            }
            finally
            {
                _sendLock.Release();
            }
        }

        protected override void OnError(string message, Exception exception)
        {
            Logger?.LogError(exception, message);
        }

        protected override void OnError(string message)
        {
            Logger?.LogError(message);
        }
    }
}