sin365/HaoYueNet
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
sin365 2023-12-25 17:37:33 +08:00
parent f204fe1deb
commit ced393767e
2 changed files with 48 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
NetLib/HaoYueNet.ClientNetwork/NetworkHelperCore.cs
View File

@ -38,11 +38,13 @@ namespace HaoYueNet.ClientNetwork
public static string LastConnectIP; public static string LastConnectIP;
public static int LastConnectPort; public static int LastConnectPort;
public bool bDetailedLog = false;
public bool Init(string IP, int port, bool bBindReuseAddress = false,int bBindport = 0) public bool Init(string IP, int port,bool isHadDetailedLog = true, bool bBindReuseAddress = false,int bBindport = 0)
{ {
LogOut("==>初始化网络核心"); LogOut("==>初始化网络核心");
bDetailedLog = isHadDetailedLog;
RevIndex = MaxRevIndexNum; RevIndex = MaxRevIndexNum;
SendIndex = MaxSendIndexNum; SendIndex = MaxSendIndexNum;
@ -63,13 +65,21 @@ namespace HaoYueNet.ClientNetwork
//带回调的 //带回调的
try try
{ {
LogOut("连接到远程IP " + IP + ":" + port); if(bDetailedLog)
LogOut("连接到远程IP " + IP + ":" + port);
else
LogOut("连接到远程服务");
client.Connect(IP, port); client.Connect(IP, port);
Thread thread = new Thread(Recive); Thread thread = new Thread(Recive);
thread.IsBackground = true; thread.IsBackground = true;
thread.Start(client); thread.Start(client);
int localport = ((IPEndPoint)client.LocalEndPoint).Port; int localport = ((IPEndPoint)client.LocalEndPoint).Port;
LogOut($"连接成功!连接到远程IP->{IP}:{port} | 本地端口->{localport}");
if (bDetailedLog)
LogOut($"连接成功!连接到远程IP->{IP}:{port} | 本地端口->{localport}");
else
LogOut("连接成功!");
if (_heartTimer == null) if (_heartTimer == null)
{ {
@ -79,14 +89,20 @@ namespace HaoYueNet.ClientNetwork
_heartTimer.Elapsed += CheckUpdatetimer_Elapsed; _heartTimer.Elapsed += CheckUpdatetimer_Elapsed;
_heartTimer.AutoReset = true; _heartTimer.AutoReset = true;
_heartTimer.Enabled = true; _heartTimer.Enabled = true;
LogOut("开启心跳包检测");
if (bDetailedLog)
LogOut("开启心跳包检测");
OnConnected?.Invoke(true); OnConnected?.Invoke(true);
return true; return true;
} }
catch (Exception ex) catch (Exception ex)
{ {
LogOut("连接失败：" + ex.ToString()); if (bDetailedLog)
LogOut("连接失败：" + ex.ToString());
else
LogOut("连接失败");
OnConnected?.Invoke(false); OnConnected?.Invoke(false);
return false; return false;
} }
@ -216,7 +232,9 @@ namespace HaoYueNet.ClientNetwork
/// </summary> /// </summary>
private void OnCloseReady() private void OnCloseReady()
{ {
LogOut("关闭心跳包计数");
if (bDetailedLog)
LogOut("关闭心跳包计数");
_heartTimer.Enabled = false; _heartTimer.Enabled = false;
_heartTimer.Elapsed -= CheckUpdatetimer_Elapsed; _heartTimer.Elapsed -= CheckUpdatetimer_Elapsed;
LogOut("关闭连接"); LogOut("关闭连接");

30
NetLib/HaoYueNet.ClientNetworkNet4x/NetworkHelperCore.cs
View File

@ -40,11 +40,13 @@ namespace HaoYueNet.ClientNetworkNet4x
public static string LastConnectIP; public static string LastConnectIP;
public static int LastConnectPort; public static int LastConnectPort;
public bool bDetailedLog = false;
public bool Init(string IP, int port, bool bBindReuseAddress = false, int bBindport = 0) public bool Init(string IP, int port, bool isHadDetailedLog = true, bool bBindReuseAddress = false, int bBindport = 0)
{ {
LogOut("==>初始化网络核心"); LogOut("==>初始化网络核心");
bDetailedLog = isHadDetailedLog;
RevIndex = MaxRevIndexNum; RevIndex = MaxRevIndexNum;
SendIndex = MaxSendIndexNum; SendIndex = MaxSendIndexNum;
@ -65,13 +67,21 @@ namespace HaoYueNet.ClientNetworkNet4x
//带回调的 //带回调的
try try
{ {
LogOut("连接到远程IP " + IP + ":" + port); if (bDetailedLog)
LogOut("连接到远程IP " + IP + ":" + port);
else
LogOut("连接到远程服务");
client.Connect(IP, port); client.Connect(IP, port);
Thread thread = new Thread(Recive); Thread thread = new Thread(Recive);
thread.IsBackground = true; thread.IsBackground = true;
thread.Start(client); thread.Start(client);
int localport = ((IPEndPoint)client.LocalEndPoint).Port; int localport = ((IPEndPoint)client.LocalEndPoint).Port;
LogOut($"连接成功!连接到远程IP->{IP}:{port} | 本地端口->{localport}");
if (bDetailedLog)
LogOut($"连接成功!连接到远程IP->{IP}:{port} | 本地端口->{localport}");
else
LogOut("连接成功!");
if (_heartTimer == null) if (_heartTimer == null)
{ {
@ -81,14 +91,20 @@ namespace HaoYueNet.ClientNetworkNet4x
_heartTimer.Elapsed += CheckUpdatetimer_Elapsed; _heartTimer.Elapsed += CheckUpdatetimer_Elapsed;
_heartTimer.AutoReset = true; _heartTimer.AutoReset = true;
_heartTimer.Enabled = true; _heartTimer.Enabled = true;
LogOut("开启心跳包检测");
if (bDetailedLog)
LogOut("开启心跳包检测");
OnConnected?.Invoke(true); OnConnected?.Invoke(true);
return true; return true;
} }
catch (Exception ex) catch (Exception ex)
{ {
LogOut("连接失败：" + ex.ToString()); if (bDetailedLog)
LogOut("连接失败：" + ex.ToString());
else
LogOut("连接失败");
OnConnected?.Invoke(false); OnConnected?.Invoke(false);
return false; return false;
} }
@ -218,7 +234,9 @@ namespace HaoYueNet.ClientNetworkNet4x
/// </summary> /// </summary>
private void OnCloseReady() private void OnCloseReady()
{ {
LogOut("关闭心跳包计数");
if (bDetailedLog)
LogOut("关闭心跳包计数");
_heartTimer.Enabled = false; _heartTimer.Enabled = false;
_heartTimer.Elapsed -= CheckUpdatetimer_Elapsed; _heartTimer.Elapsed -= CheckUpdatetimer_Elapsed;
LogOut("关闭连接"); LogOut("关闭连接");