NoSugarNet/NoSugarNet.ClientCore/Manager/AppLocalClient.cs

312 lines
12 KiB
C#
Raw Normal View History

2024-01-19 21:35:05 +08:00
using AxibugProtobuf;
using Google.Protobuf;
2024-01-22 11:56:02 +08:00
using HaoYueNet.ServerNetwork;
2024-01-19 21:35:05 +08:00
using NoSugarNet.ClientCore;
2024-01-22 11:56:02 +08:00
using NoSugarNet.ClientCore.Common;
using NoSugarNet.ClientCore.Network;
2024-01-25 17:17:16 +08:00
using NoSugarNet.DataHelper;
2024-01-19 21:35:05 +08:00
using System.Net;
namespace ServerCore.Manager
{
public class AppLocalClient
{
Dictionary<byte, Protobuf_Cfgs_Single> mDictTunnelID2Cfg = new Dictionary<byte, Protobuf_Cfgs_Single>();
Dictionary<byte, LocalListener> mDictTunnelID2Listeners = new Dictionary<byte, LocalListener>();
CompressAdapter mCompressAdapter;
2024-01-25 17:17:16 +08:00
E_CompressAdapter compressAdapterType;
2024-01-22 11:56:02 +08:00
public LocalMsgQueuePool _localMsgPool = new LocalMsgQueuePool(1000);
2024-01-19 21:35:05 +08:00
2024-01-25 17:17:16 +08:00
public AppLocalClient()
2024-01-19 21:35:05 +08:00
{
//注册网络消息
NetMsg.Instance.RegNetMsgEvent((int)CommandID.CmdCfgs, Recive_CmdCfgs);
NetMsg.Instance.RegNetMsgEvent((int)CommandID.CmdTunnelS2CConnect, Recive_TunnelS2CConnect);
NetMsg.Instance.RegNetMsgEvent((int)CommandID.CmdTunnelS2CDisconnect, Recive_TunnelS2CDisconnect);
NetMsg.Instance.RegNetMsgEvent((int)CommandID.CmdTunnelS2CData, Recive_TunnelS2CData);
}
public void GetCurrLenght(out long resultReciveAllLenght, out long resultSendAllLenght)
{
resultReciveAllLenght = 0;
resultSendAllLenght = 0;
byte[] Keys = mDictTunnelID2Listeners.Keys.ToArray();
for (int i = 0; i < Keys.Length; i++)
{
resultReciveAllLenght += mDictTunnelID2Listeners[Keys[i]].mReciveAllLenght;
resultSendAllLenght += mDictTunnelID2Listeners[Keys[i]].mSendAllLenght;
}
}
2024-01-19 21:35:05 +08:00
/// <summary>
/// 初始化连接,先获取到配置
/// </summary>
void InitListenerMode()
{
2024-01-25 17:17:16 +08:00
AppNoSugarNet.log.Debug("初始化压缩适配器" + compressAdapterType);
//初始化压缩适配器,代表压缩类型
mCompressAdapter = new CompressAdapter(compressAdapterType);
2024-01-19 21:35:05 +08:00
foreach (var cfg in mDictTunnelID2Cfg)
{
LocalListener listener = new LocalListener(256, 1024, cfg.Key);
2024-01-22 15:08:43 +08:00
AppNoSugarNet.log.Debug($"开始监听配置 Tunnel:{cfg.Key},Port:{cfg.Value.Port}");
2024-01-19 21:35:05 +08:00
listener.Init();
listener.Start(new IPEndPoint(IPAddress.Any.Address, (int)cfg.Value.Port));
2024-03-29 18:02:54 +08:00
//listener.Init((int)cfg.Value.Port);
2024-01-19 21:35:05 +08:00
AddLocalListener(listener);
}
2024-01-19 21:35:05 +08:00
}
#region
/// <summary>
/// 追加监听者
/// </summary>
/// <param name="tunnelId"></param>
/// <param name="serverClient"></param>
void AddLocalListener(LocalListener _listener)
{
lock (mDictTunnelID2Listeners)
{
mDictTunnelID2Listeners[_listener.mTunnelID] = _listener;
}
}
/// <summary>
/// 删除监听
/// </summary>
/// <param name="tunnelId"></param>
/// <param name="serverClient"></param>
void RemoveLocalListener(LocalListener _listener)
{
lock (mDictTunnelID2Listeners)
{
if (mDictTunnelID2Listeners.ContainsKey(_listener.mTunnelID))
{
2024-01-22 11:56:02 +08:00
mDictTunnelID2Listeners.Remove(_listener.mTunnelID);
2024-01-19 21:35:05 +08:00
}
}
}
bool GetLocalListener(byte tunnelId,out LocalListener _listener)
{
_listener = null;
if (!mDictTunnelID2Listeners.ContainsKey(tunnelId))
return false;
_listener = mDictTunnelID2Listeners[tunnelId];
return true;
}
2024-01-22 11:56:02 +08:00
public void StopAll()
{
lock (mDictTunnelID2Listeners)
{
byte[] keys = mDictTunnelID2Listeners.Keys.ToArray();
for (int i = 0; i < keys.Length; i++)
{
LocalListener _listener = mDictTunnelID2Listeners[keys[i]];
_listener.StopAll();
2024-03-29 18:02:54 +08:00
//_listener.Stop();
2024-01-22 11:56:02 +08:00
RemoveLocalListener(_listener);
}
}
}
2024-01-19 21:35:05 +08:00
#endregion
#region
public void Recive_CmdCfgs(byte[] reqData)
{
2024-01-22 11:56:02 +08:00
AppNoSugarNet.log.Debug("Recive_CmdCfgs");
2024-01-19 21:35:05 +08:00
Protobuf_Cfgs msg = ProtoBufHelper.DeSerizlize<Protobuf_Cfgs>(reqData);
2024-01-22 15:08:43 +08:00
for (int i = 0;i < msg.Cfgs.Count;i++)
2024-01-19 21:35:05 +08:00
{
Protobuf_Cfgs_Single cfg = msg.Cfgs[i];
mDictTunnelID2Cfg[(byte)cfg.TunnelID] = cfg;
}
2024-01-25 17:17:16 +08:00
compressAdapterType = (E_CompressAdapter)msg.CompressAdapterType;
2024-01-19 21:35:05 +08:00
InitListenerMode();
}
public void Recive_TunnelS2CConnect(byte[] reqData)
{
2024-01-22 11:56:02 +08:00
AppNoSugarNet.log.Debug("Recive_TunnelS2CConnect");
2024-01-19 21:35:05 +08:00
Protobuf_S2C_Connect msg = ProtoBufHelper.DeSerizlize<Protobuf_S2C_Connect>(reqData);
2024-01-22 15:08:43 +08:00
if(msg.Connected == 1)
OnServerLocalConnect((byte)msg.TunnelID,(byte)msg.Idx);
else
OnServerLocalDisconnect((byte)msg.TunnelID, (byte)msg.Idx);
2024-01-19 21:35:05 +08:00
}
public void Recive_TunnelS2CDisconnect(byte[] reqData)
{
2024-01-22 11:56:02 +08:00
AppNoSugarNet.log.Debug("Recive_TunnelS2CDisconnect");
2024-01-19 21:35:05 +08:00
Protobuf_S2C_Disconnect msg = ProtoBufHelper.DeSerizlize<Protobuf_S2C_Disconnect>(reqData);
OnServerLocalDisconnect((byte)msg.TunnelID,(byte)msg.Idx);
}
public void Recive_TunnelS2CData(byte[] reqData)
{
//AppNoSugarNet.log.Debug("Recive_TunnelS2CData");
2024-01-19 21:35:05 +08:00
Protobuf_S2C_DATA msg = ProtoBufHelper.DeSerizlize<Protobuf_S2C_DATA>(reqData);
OnServerLocalDataCallBack((byte)msg.TunnelID,(byte)msg.Idx, msg.HunterNetCoreData.ToArray());
}
#endregion
#region
/// <summary>
/// 当客户端本地端口连接
/// </summary>
/// <param name="uid"></param>
/// <param name="tunnelId"></param>
public void OnClientLocalConnect(byte tunnelId,byte _Idx)
{
2024-01-22 15:08:43 +08:00
AppNoSugarNet.log.Debug($"OnClientLocalConnect {tunnelId},{_Idx}");
2024-01-19 21:35:05 +08:00
if (!mDictTunnelID2Cfg.ContainsKey(tunnelId))
return;
byte[] respData = ProtoBufHelper.Serizlize(new Protobuf_C2S_Connect()
{
TunnelID = tunnelId,
Idx = _Idx,
});
//告知给服务端,来自客户端本地的连接建立
2024-01-22 11:56:02 +08:00
AppNoSugarNet.networkHelper.SendToServer((int)CommandID.CmdTunnelC2SConnect, respData);
2024-01-19 21:35:05 +08:00
}
/// <summary>
/// 当客户端本地端口连接断开
/// </summary>
/// <param name="uid"></param>
/// <param name="tunnelId"></param>
public void OnClientLocalDisconnect(byte tunnelId, byte _Idx)
{
2024-01-22 15:08:43 +08:00
AppNoSugarNet.log.Debug($"OnClientLocalDisconnect {tunnelId},{_Idx}");
2024-01-19 21:35:05 +08:00
//隧道ID定位投递服务端本地连接
if (!mDictTunnelID2Cfg.ContainsKey(tunnelId))
return;
byte[] respData = ProtoBufHelper.Serizlize(new Protobuf_C2S_Disconnect()
{
TunnelID = tunnelId,
Idx= _Idx,
});
2024-01-22 15:08:43 +08:00
2024-01-19 21:35:05 +08:00
//告知给服务端,来自客户端本地的连接断开
2024-01-22 11:56:02 +08:00
AppNoSugarNet.networkHelper.SendToServer((int)CommandID.CmdTunnelC2SDisconnect, respData);
2024-01-19 21:35:05 +08:00
}
2024-01-19 21:35:05 +08:00
/// <summary>
/// 当服务端本地端口连接
/// </summary>
/// <param name="tunnelId"></param>
public void OnServerLocalConnect(byte tunnelId,byte Idx)
{
2024-01-22 15:08:43 +08:00
AppNoSugarNet.log.Debug($"OnServerLocalConnect {tunnelId},{Idx}");
2024-01-19 21:35:05 +08:00
if (!GetLocalListener(tunnelId, out LocalListener _listener))
return;
2024-01-22 11:56:02 +08:00
//维护状态
_listener.SetRemoteConnectd(Idx, true);
if (_listener.GetDictMsgQueue(Idx, out List<IdxWithMsg> msglist))
{
for(int i = 0; i < msglist.Count; i++)
{
2024-01-22 15:08:43 +08:00
IdxWithMsg msg = msglist[i];
2024-01-22 11:56:02 +08:00
//投递给服务端,来自客户端本地的连接数据
2024-01-22 15:08:43 +08:00
AppNoSugarNet.networkHelper.SendToServer((int)CommandID.CmdTunnelC2SData, msg.data);
//发送后回收
AppNoSugarNet.local._localMsgPool.Enqueue(msg);
2024-01-22 11:56:02 +08:00
}
}
2024-01-19 21:35:05 +08:00
}
/// <summary>
/// 当服务端本地端口连接断开
/// </summary>
/// <param name="uid"></param>
/// <param name="tunnelId"></param>
public void OnServerLocalDisconnect(byte tunnelId, byte Idx)
{
2024-01-22 15:08:43 +08:00
AppNoSugarNet.log.Debug($"OnServerLocalDisconnect {tunnelId},{Idx}");
2024-01-19 21:35:05 +08:00
if (!GetLocalListener(tunnelId, out LocalListener _listener))
return;
2024-01-22 11:56:02 +08:00
_listener.SetRemoteConnectd(Idx,false);
2024-01-19 21:35:05 +08:00
_listener.CloseConnectByIdx(Idx);
}
#endregion
#region
/// <summary>
/// 来自服务端本地连接投递的Tunnel数据
/// </summary>
/// <param name="uid"></param>
/// <param name="tunnelId"></param>
/// <param name="data"></param>
public void OnServerLocalDataCallBack(byte tunnelId,byte Idx, byte[] data)
{
//AppNoSugarNet.log.Debug($"OnServerLocalDataCallBack {tunnelId},{Idx},Data长度{data.Length}");
2024-01-19 21:35:05 +08:00
if (!GetLocalListener(tunnelId, out LocalListener _listener))
return;
//解压
data = mCompressAdapter.Decompress(data);
_listener.SendSocketByIdx(Idx,data);
}
/// <summary>
/// 来自客户端本地连接投递的Tunnel数据
/// </summary>
/// <param name="uid"></param>
/// <param name="tunnelId"></param>
/// <param name="data"></param>
public void OnClientTunnelDataCallBack(byte tunnelId,byte Idx, byte[] data)
{
//AppNoSugarNet.log.Debug($"OnClientTunnelDataCallBack {tunnelId},{Idx}");
int SlienLenght = 1000;
//判断数据量大时分包
if (data.Length > SlienLenght)
{
Span<byte> tempSpan = data;
Span<byte> tempSpanSlien = null;
int PageCount = (int)(data.Length / SlienLenght);
if (data.Length % SlienLenght > 0)
{
PageCount++;
}
for (int i = 0; i < PageCount; i++)
{
int StartIdx = i * SlienLenght;
if (i != PageCount - 1)//不是最后一个包
tempSpanSlien = tempSpan.Slice(StartIdx, SlienLenght);
else//最后一个
tempSpanSlien = tempSpan.Slice(StartIdx);
SendDataToRemote(tunnelId, Idx, tempSpanSlien.ToArray());
}
return;
}
SendDataToRemote(tunnelId, Idx, data);
}
void SendDataToRemote(byte tunnelId, byte Idx, byte[] data)
{
2024-01-19 21:35:05 +08:00
//压缩
data = mCompressAdapter.Compress(data);
2024-01-19 21:35:05 +08:00
byte[] respData = ProtoBufHelper.Serizlize(new Protobuf_C2S_DATA()
{
TunnelID = tunnelId,
Idx = Idx,
HunterNetCoreData = ByteString.CopyFrom(data)
});
2024-01-22 11:56:02 +08:00
if (!GetLocalListener(tunnelId, out LocalListener _listener))
return;
//远程未连接,添加到缓存
if (!_listener.CheckRemoteConnect(Idx))
{
_listener.EnqueueIdxWithMsg(Idx, respData);
return;
}
2024-01-19 21:35:05 +08:00
//投递给服务端,来自客户端本地的连接数据
2024-01-22 11:56:02 +08:00
AppNoSugarNet.networkHelper.SendToServer((int)CommandID.CmdTunnelC2SData, respData);
2024-01-19 21:35:05 +08:00
}
#endregion
2024-01-19 21:35:05 +08:00
}
}