72 lines
2.6 KiB
C#
72 lines
2.6 KiB
C#
using Plane.Communication;
|
||
using System.Text;
|
||
using System.Threading.Tasks;
|
||
|
||
namespace PlaneGcsSdk.Contract.DtuClient
|
||
{
|
||
/// <summary>
|
||
/// 基于PLNet的用户登录体系的Udp连接实体类。
|
||
/// <para>具体登陆流程：1，利用用户名和密码登陆PLNet，获取随机码；2，利用随机码登陆Dtu透传服务器；</para>
|
||
/// </summary>
|
||
public partial class BasedOnEhNetUdpDtuServiceConnection : UdpThroughDtuServiceConnection
|
||
{
|
||
#region Fields
|
||
public int _randCode;
|
||
#endregion
|
||
|
||
#region Properties
|
||
|
||
#endregion
|
||
|
||
/// <summary>
|
||
/// 基于PLNet的用户登录体系的Udp连接实体类。
|
||
/// <para>具体登陆流程：1，利用用户名和密码登陆PLNet，获取随机码；2，利用随机码登陆Dtu透传服务器；</para>
|
||
/// </summary>
|
||
/// <param name="dtuServiceIp"></param>
|
||
/// <param name="dtuServicePort"></param>
|
||
/// <param name="randCode">用户随机数</param>
|
||
public BasedOnEhNetUdpDtuServiceConnection(string dtuServiceIp, int dtuServicePort, int randCode)
|
||
: base(dtuServiceIp, dtuServicePort)
|
||
{
|
||
FLAG_DTU_HANDSHAKE_HEAD = "ehnetrnd";
|
||
_randCode = randCode;
|
||
}
|
||
|
||
protected override byte[] ConstructHandShakeDatagramToDTUService()
|
||
{
|
||
return Encoding.ASCII.GetBytes($"{FLAG_DTU_HANDSHAKE_HEAD}{_randCode}");
|
||
}
|
||
|
||
/// <summary>
|
||
/// 分析由DTU服务端返回的握手包
|
||
/// </summary>
|
||
/// <param name="buffer"></param>
|
||
/// <returns></returns>
|
||
protected override DTUHandShakeResult AnalyzeHandShakeDatagramFromDTUService(byte[] buffer)
|
||
{
|
||
var strResult = Encoding.ASCII.GetString(buffer);//返回的格式为“ehnetrndxxxx”
|
||
if (strResult.StartsWith(FLAG_DTU_HANDSHAKE_HEAD))
|
||
{
|
||
return DTUHandShakeResult.Successful;
|
||
}
|
||
return DTUHandShakeResult.Unknown;
|
||
}
|
||
|
||
public override async Task<int> ReadAsync(byte[] buffer, int offset, int count)
|
||
{
|
||
var iRet = await base.ReadAsync(buffer, offset, count);
|
||
//解密数据
|
||
buffer.DecryptByKey((byte)(_randCode % byte.MaxValue), offset, count);
|
||
return iRet;
|
||
}
|
||
|
||
public override Task WriteAsync(byte[] buffer, int offset, int count)
|
||
{
|
||
//加密数据
|
||
buffer.EncryptByKey((byte)(_randCode % byte.MaxValue), offset, count);
|
||
var iRet = base.WriteAsync(buffer, offset, count);
|
||
return iRet;
|
||
}
|
||
}
|
||
}
|