362 lines
12 KiB
C#
362 lines
12 KiB
C#
using System.Net;
|
||
using System.Net.Sockets;
|
||
using System.Text;
|
||
using System.Text.RegularExpressions;
|
||
using SocketTool.Entity;
|
||
|
||
namespace SocketTool;
|
||
|
||
/// <summary>
|
||
/// socket 客户端 .net6 版
|
||
/// </summary>
|
||
public class SocketClient
|
||
{
|
||
#region 全局变量
|
||
|
||
private List<SocketModel> NeedConnectSockets = []; // 需要连接的socket
|
||
|
||
int IPCount;//传入的连接数
|
||
|
||
#endregion
|
||
|
||
#region 全局属性
|
||
/// <summary>
|
||
/// 字符串解析格式
|
||
/// </summary>
|
||
private Encoding? Encod { get; set; }
|
||
#endregion
|
||
|
||
/// <summary>
|
||
/// socket连接类，自带自动重连功能
|
||
/// 传入参数示例：127.0.0.1:8090
|
||
/// </summary>
|
||
/// <param name="encoding"></param>
|
||
/// <param name="IPPorts"></param>
|
||
/// <exception cref="Exception"></exception>
|
||
public SocketClient(Encoding? encoding, params string?[] IPPorts)
|
||
{
|
||
Encod = encoding;
|
||
IPCount = IPPorts.Length;//数量赋值
|
||
foreach (string? IPPort in IPPorts)
|
||
{
|
||
if (string.IsNullOrEmpty(IPPort))
|
||
{
|
||
continue;
|
||
}
|
||
string ipAndPort = IPPort.Replace("：", ":");//将中文冒号替换成英文冒号
|
||
if (!ipAndPort.Contains(':'))
|
||
{
|
||
// 不含有端口号的直接抛异常，必须处理
|
||
throw new Exception($"地址：{IPPort} 格式不正确，必须处理以后才能正常运行。");
|
||
}
|
||
string[] ipp = ipAndPort.Split(':');
|
||
if (ipp.Length != 2 || string.IsNullOrEmpty(ipp[0]) || string.IsNullOrEmpty(ipp[1]))
|
||
{
|
||
// 拆分后没有地址或者端口号的直接抛异常，必须处理
|
||
throw new Exception($"地址：{IPPort} 格式不正确，必须处理以后才能正常运行。");
|
||
}
|
||
string IP = ipp[0];
|
||
int Port = CheckIP(IP, ipp[1]);
|
||
if (Port != 0)
|
||
{
|
||
Socket socket = new(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
|
||
NeedConnectSockets.Add(new SocketModel()
|
||
{
|
||
Socket = socket,
|
||
SocketIp = IPPort,
|
||
IsConnected = false,
|
||
HostEP = new IPEndPoint(IPAddress.Parse(IP), Port)
|
||
});
|
||
}
|
||
}
|
||
}
|
||
/// <summary>
|
||
/// 检查IP地址和端口号是否满足格式
|
||
/// 如果格式错误返回0，否则返回Int格式的端口号
|
||
/// </summary>
|
||
/// <param name="IP"></param>
|
||
/// <param name="Portstr"></param>
|
||
/// <returns></returns>
|
||
private static int CheckIP(string? IP, string? Portstr)
|
||
{
|
||
if (string.IsNullOrEmpty(IP) || string.IsNullOrEmpty(Portstr))
|
||
{
|
||
throw new Exception("传入的IP或者端口存在异常");
|
||
}
|
||
int Port;//int格式的端口号
|
||
try
|
||
{
|
||
Port = Convert.ToInt32(Portstr);
|
||
}
|
||
catch
|
||
{
|
||
return 0;
|
||
}
|
||
string CheckString = "^((1[0-9][0-9]\\.)|(2[0-4][0-9]\\.)|(25[0-5]\\.)|([1-9][0-9]\\.)|([0-9]\\.)){3}((1[0-9][0-9])|(2[0-4][0-9])|(25[0-5])|([1-9][0-9])|([0-9]))$";
|
||
bool IsIPOK = Regex.IsMatch(IP, CheckString);
|
||
if (!IsIPOK || Port < 1 || Port > 65535)
|
||
{
|
||
throw new Exception($"地址：{IP} 的端口号：{Portstr} 格式不正确，必须处理以后才能正常运行。");
|
||
}
|
||
return Port;
|
||
}
|
||
|
||
/// <summary>
|
||
/// 连接事件，需要调用
|
||
/// </summary>
|
||
public void Connect()
|
||
{
|
||
if (NeedConnectSockets.Count < 1)
|
||
{
|
||
return;
|
||
}
|
||
// 连接 socket
|
||
foreach (SocketModel needConnectSocket in NeedConnectSockets)
|
||
{
|
||
Thread connectSocket = new(() =>
|
||
{
|
||
ConnectSocket(needConnectSocket);
|
||
})
|
||
{
|
||
IsBackground = true
|
||
};
|
||
connectSocket.Start();
|
||
//Task.Factory.StartNew(()=>ConnectSocket(needConnectSocket));
|
||
}
|
||
// 启用重连
|
||
Thread reConnectSocket = new(ReConnectSocket)
|
||
{
|
||
IsBackground = true
|
||
};
|
||
reConnectSocket.Start();
|
||
//Task.Factory.StartNew(ReConnectSocket);
|
||
}
|
||
/// <summary>
|
||
/// 连接 socket
|
||
/// </summary>
|
||
/// <param name="socketInfo"></param>
|
||
private void ConnectSocket(SocketModel socketInfo)
|
||
{
|
||
while (true)//此循环经本人考虑再三后加上，去掉此循环将导致=>在服务端未开启的情况下开启客户端,后面服务端开启，虽然可以通过下方重连连上服务端，但无法接受数据
|
||
{
|
||
try
|
||
{
|
||
SocketConnecting?.Invoke(socketInfo.SocketIp ?? "");//触发连接中事件
|
||
socketInfo.Socket!.Connect(socketInfo.HostEP!);//尝试连接
|
||
SocketOnline?.Invoke(socketInfo.SocketIp ?? "");//触发连接成功事件
|
||
socketInfo.Thread = Thread.CurrentThread;
|
||
socketInfo.IsConnected = true;
|
||
break;
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
SocketConnectFail?.Invoke(socketInfo.SocketIp ?? "", ex);//出发连接中事件
|
||
Thread.Sleep(2000);
|
||
}
|
||
}
|
||
Socket socket = socketInfo.Socket; // 拉取地址
|
||
while (true)
|
||
{
|
||
byte[] recvBytes = new byte[1024 * 1024];
|
||
try
|
||
{
|
||
int bytes = socket.Receive(recvBytes, recvBytes.Length, SocketFlags.None);
|
||
if (bytes <= 0) continue;
|
||
GetTcpData?.BeginInvoke(recvBytes, socketInfo.SocketIp ?? "", null, null);
|
||
if (GetTcpData != null) continue;
|
||
string? recvStr = Encod?.GetString(recvBytes, 0, bytes); //此处编码方式请根据服务端发送的编码方式修改对应，否则可能造成部分字符乱码
|
||
if (string.IsNullOrEmpty(recvStr)) continue;
|
||
if (recvStr.Trim().Length > 0)
|
||
{
|
||
GetSocketMessage?.Invoke(recvStr, socketInfo.SocketIp ?? "");
|
||
if (HandleCodeInfo != null)
|
||
{
|
||
ManCode(recvStr, socketInfo.SocketIp ?? ""); //处理条码并触发其他事件
|
||
}
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
_ = ex;
|
||
RecevErrEvent?.Invoke(socketInfo.SocketIp ?? "", ex);
|
||
socketInfo.IsConnected = false;
|
||
return;
|
||
}
|
||
}
|
||
}
|
||
|
||
|
||
/// <summary>
|
||
/// 重新连接 Socket
|
||
/// </summary>
|
||
private void ReConnectSocket()
|
||
{
|
||
Thread.Sleep(5000);
|
||
while (true)
|
||
{
|
||
foreach (SocketModel needConnectSocket in NeedConnectSockets)
|
||
{
|
||
Socket socket = needConnectSocket.Socket!;
|
||
Thread.Sleep(300);
|
||
try
|
||
{
|
||
try
|
||
{
|
||
socket.SendTimeout = 1000;
|
||
socket.Send(Encoding.ASCII.GetBytes(" "));
|
||
if (!socket.Connected)
|
||
{
|
||
needConnectSocket.IsConnected = false;
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
_ = ex.ToString();
|
||
SocketOffline?.Invoke(needConnectSocket.SocketIp ?? ""); //触发掉线事件
|
||
try
|
||
{
|
||
socket.Close(); //关闭已经断开的socket
|
||
}
|
||
catch (Exception exception)
|
||
{
|
||
_ = exception;
|
||
}
|
||
|
||
Thread connectSocket = new(() =>
|
||
{
|
||
ConnectSocket(needConnectSocket);
|
||
})
|
||
{
|
||
IsBackground = true
|
||
};
|
||
connectSocket.Start();
|
||
//Task.Factory.StartNew(() => ConnectSocket(needConnectSocket));
|
||
}
|
||
}
|
||
catch (Exception ex)
|
||
{
|
||
_ = ex.ToString();
|
||
}
|
||
}
|
||
}
|
||
|
||
}
|
||
|
||
|
||
|
||
|
||
|
||
/// <summary>
|
||
/// 处理收到的条码，并引发事件
|
||
/// </summary>
|
||
/// <param name="code"></param>
|
||
/// <param name="IPAddress"></param>
|
||
private void ManCode(string? code, string? IPAddress)
|
||
{
|
||
//多线程处理，增加程序运行速度
|
||
ThreadPool.QueueUserWorkItem((useless) =>
|
||
{
|
||
List<ScanCodeClass>? scanCodeClasses = SplitCode(code, IPAddress);
|
||
if (scanCodeClasses != default)
|
||
{
|
||
foreach (ScanCodeClass scc in scanCodeClasses)
|
||
{
|
||
HandleCodeInfo?.Invoke(scc);
|
||
}
|
||
}
|
||
});
|
||
}
|
||
/// <summary>
|
||
/// 拆条码，将前缀和条码拆下来
|
||
/// </summary>
|
||
/// <param name="GetCode"></param>
|
||
/// <param name="Ipaddress"></param>
|
||
/// <returns></returns>
|
||
private List<ScanCodeClass>? SplitCode(string? GetCode, string? Ipaddress)
|
||
{
|
||
if (string.IsNullOrEmpty(GetCode) || string.IsNullOrEmpty(Ipaddress))
|
||
{
|
||
return default;
|
||
}
|
||
if (!GetCode.Contains('('))
|
||
{
|
||
return default;
|
||
}
|
||
List<ScanCodeClass> sccs = [];
|
||
string[] GetCodeCuts = GetCode.Split('(');
|
||
foreach (string GetCodeCut in GetCodeCuts)
|
||
{
|
||
if (GetCodeCut == "" || GetCodeCut.Trim().Length == 0 || !GetCodeCut.Contains(')')) { continue; }
|
||
string[] ScanCode = GetCodeCut.Split(')');
|
||
if (ScanCode.Length < 2) { continue; }
|
||
ScanCodeClass scc = new()
|
||
{
|
||
IpAddress = Ipaddress,
|
||
ScanID = Convert.ToInt32(ScanCode[0]),
|
||
StrScanID = ScanCode[0],
|
||
Code = ScanCode[1]
|
||
};
|
||
sccs.Add(scc);
|
||
}
|
||
return sccs;
|
||
}
|
||
|
||
#region 事件
|
||
|
||
public delegate void HandleInfo(ScanCodeClass scc);
|
||
/// <summary>
|
||
/// 条码处理事件,
|
||
/// ScanID或者ScanIDStr为null的是没有前缀的条码
|
||
/// </summary>
|
||
public event HandleInfo? HandleCodeInfo;
|
||
|
||
|
||
|
||
public delegate void GetMessage(string Message, string IPAddress);
|
||
/// <summary>
|
||
/// 条码处理事件,
|
||
/// </summary>
|
||
public event GetMessage? GetSocketMessage;
|
||
|
||
|
||
public delegate void GetData(byte[] data, string IPAddress);
|
||
/// <summary>
|
||
/// 字节返回事件
|
||
/// </summary>
|
||
public event GetData? GetTcpData;
|
||
|
||
|
||
public delegate void OffLine(string IPAddress);
|
||
/// <summary>
|
||
/// 当有地址掉线时触发
|
||
/// </summary>
|
||
public event OffLine? SocketOffline;
|
||
|
||
public delegate void OnLine(string IPAddress);
|
||
/// <summary>
|
||
/// 当地址连接成功时触发
|
||
/// </summary>
|
||
public event OnLine? SocketOnline;
|
||
|
||
public delegate void Connecting(string IPAddress);
|
||
/// <summary>
|
||
/// 当地址连接正在连接时触发
|
||
/// </summary>
|
||
public event Connecting? SocketConnecting;
|
||
|
||
public delegate void ConnectFail(string IPAddress, Exception ex);
|
||
/// <summary>
|
||
/// 当地址连接正在连接时触发
|
||
/// </summary>
|
||
public event ConnectFail? SocketConnectFail;
|
||
|
||
public delegate void RecevErr(string IPAddress, Exception ex);
|
||
/// <summary>
|
||
/// 当地址连接接收数据异常时触发
|
||
/// </summary>
|
||
public event RecevErr? RecevErrEvent;
|
||
#endregion
|
||
|
||
|
||
|
||
} |