NetUdpClient.cs
5.19 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
122
123
124
125
using System;
using System.Collections.Generic;
using System.Linq;
using System.Net;
using System.Net.Sockets;
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
}
}