NetUdpClient.cs
5.04 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
using System;
using System.Text;
namespace HslCommunication.Enthernet
{
/// <summary>
/// UDP客户端的类，只负责发送数据到服务器，该数据经过封装
/// </summary>
public class NetUdpClient : Core.Net.NetworkUdpBase
{
/// <summary>
/// 实例化对象，指定发送的服务器地址和端口号
/// </summary>
/// <param name="ipAddress">服务器的Ip地址</param>
/// <param name="port">端口号</param>
public NetUdpClient(string ipAddress, int port)
{
IpAddress = ipAddress;
Port = port;
}
/// <summary>
/// 客户端向服务器进行请求，请求字符串数据，忽略了自定义消息反馈
/// </summary>
/// <param name="customer">用户的指令头</param>
/// <param name="send">发送数据</param>
/// <returns>带返回消息的结果对象</returns>
public OperateResult<string> ReadFromServer(NetHandle customer, string send = null)
{
var read = ReadFromServerBase(HslProtocol.CommandBytes(customer, Token, send));
if (!read.IsSuccess) return OperateResult.CreateFailedResult<string>(read);
return OperateResult.CreateSuccessResult(Encoding.Unicode.GetString(read.Content));
}
/// <summary>
/// 客户端向服务器进行请求，请求字节数据
/// </summary>
/// <param name="customer">用户的指令头</param>
/// <param name="send">发送的字节内容</param>
/// <returns>带返回消息的结果对象</returns>
public OperateResult<byte[]> ReadFromServer(NetHandle customer, byte[] send)
{
return ReadFromServerBase(HslProtocol.CommandBytes(customer, Token, send));
}
/// <summary>
/// 客户端向服务器进行请求，请求字符串数据，并返回状态信息
/// </summary>
/// <param name="customer">用户的指令头</param>
/// <param name="send">发送数据</param>
/// <returns>带返回消息的结果对象</returns>
public OperateResult<NetHandle, string> ReadCustomerFromServer(NetHandle customer, string send = null)
{
var read = ReadCustomerFromServerBase(HslProtocol.CommandBytes(customer, Token, send));
if (!read.IsSuccess) return OperateResult.CreateFailedResult<NetHandle, string>(read);
return OperateResult.CreateSuccessResult(read.Content1, Encoding.Unicode.GetString(read.Content2));
}
/// <summary>
/// 客户端向服务器进行请求，请求字符串数据，并返回状态信息
/// </summary>
/// <param name="customer">用户的指令头</param>
/// <param name="send">发送数据</param>
/// <returns>带返回消息的结果对象</returns>
public OperateResult<NetHandle, byte[]> ReadCustomerFromServer(NetHandle customer, byte[] send)
{
return ReadCustomerFromServerBase(HslProtocol.CommandBytes(customer, Token, send));
}
/// <summary>
/// 需要发送的底层数据
/// </summary>
/// <param name="send">需要发送的底层数据</param>
/// <returns>带返回消息的结果对象</returns>
private OperateResult<byte[]> ReadFromServerBase(byte[] send)
{
var read = ReadCustomerFromServerBase(send);
if (!read.IsSuccess) return OperateResult.CreateFailedResult<byte[]>(read);
return OperateResult.CreateSuccessResult(read.Content2);
}
/// <summary>
/// 需要发送的底层数据
/// </summary>
/// <param name="send">需要发送的底层数据</param>
/// <returns>带返回消息的结果对象</returns>
private OperateResult<NetHandle, byte[]> ReadCustomerFromServerBase(byte[] send)
{
// 核心数据交互
var read = ReadFromCoreServer(send);
if (!read.IsSuccess) return OperateResult.CreateFailedResult<NetHandle, byte[]>(read);
// 提炼数据信息
byte[] headBytes = new byte[HslProtocol.HeadByteLength];
byte[] contentBytes = new byte[read.Content.Length - HslProtocol.HeadByteLength];
Array.Copy(read.Content, 0, headBytes, 0, HslProtocol.HeadByteLength);
if (contentBytes.Length > 0) Array.Copy(read.Content, HslProtocol.HeadByteLength, contentBytes, 0, read.Content.Length - HslProtocol.HeadByteLength);
int customer = BitConverter.ToInt32(headBytes, 4);
contentBytes = HslProtocol.CommandAnalysis(headBytes, contentBytes);
return OperateResult.CreateSuccessResult((NetHandle)customer, contentBytes);
}
#region Object Override
/// <summary>
/// 获取本对象的字符串表示形式
/// </summary>
/// <returns>字符串信息</returns>
public override string ToString()
{
return $"NetUdpClient[{IpAddress}:{Port}]";
}
#endregion
}
}