台达PLC解密台达PLC解密次数限度【业余】【信用【18230062509】在通信利用中很多时候须要和已有规范的利用协定进行通信，针对这状况就要针对相应协定的实现；标准协议上思考的状况比拟多，所以协定的复杂度也绝对高些，比照之前的Protobuf通信的简略协定来说则会简单。接下来用组件去实现一个简略的HTTP协定服务，让浏览器能够去拜访它。
HTTP协定
对于HTTP协定的介绍置信也不必过多形容，毕竟这个协定曾经利用了N年了，网上针对这一协定的介绍也十分多。这协定的版本有1.0,1.1和2.0，接下来实现的是HTTP1.1。其实更合乎多场景利用是2.0，不过2.0的协定复杂度就比拟高了，所以就不在这里实现介绍了。
HTTP 1.1协定只容许同一时间解决一个申请，就是当服务端接管到申请后直到响应实现才会解决下一下申请。为了满足这须要针对通信协定制订了Request和Response对象。
Request对象
该对象次要用于收集HTTP的申请信息，定义如下：
class HttpRequest { //以后HTTP版本信息 public string HttpVersion { get; set; } //申请的办法 public string Method { get; set; } //根底的url public string BaseUrl { get; set; } //客户端IP public string ClientIP { get; set; } //申请门路 public string Path { get; set; } //Url参数 public string QueryString { get; set; } //残缺URL public string Url { get; set; } //头部信息 public Dictionary<string, string> Headers { get; private set; } = new Dictionary<string, string>(); //HTTP内容 public byte[] Body { get; set; } //HTTP内容长度 public int ContentLength { get; set; } //申请对象状态 public RequestStatus Status { get; set; } = RequestStatus.None; }复制代码以上是一个HTTP申请的简略形容对象，服务会依据网络数据依据HTTP协定转换成相应的对象音讯。
HttpResponse对象
该对象用于设置申请响应内容，定义如下:
class HttpResponse : IWriteHandler { public HttpResponse() { Headers["Content-Type"] = "text/html"; } public string HttpVersion { get; set; } = "HTTP/1.1"; public int Status { get; set; } public string StatusMessage { get; set; } = "OK"; public string Body { get; set; } public Dictionary<string, string> Headers = new Dictionary<string, string>(); public void Write(Stream stream) { var pipeStream = stream.ToPipeStream(); //写入响应状态 pipeStream.WriteLine($"{HttpVersion} {Status} {StatusMessage}"); //写入头部信息 foreach (var item in Headers) pipeStream.WriteLine($"{item.Key}: {item.Value}"); byte[] bodyData = null; if (!string.IsNullOrEmpty(Body)) { bodyData = Encoding.UTF8.GetBytes(Body); } if (bodyData != null) { pipeStream.WriteLine($"Content-Length: {bodyData.Length}"); } pipeStream.WriteLine(""); //写入响应音讯体 if (bodyData != null) { pipeStream.Write(bodyData, 0, bodyData.Length); } Completed?.Invoke(this); } public Action<IWriteHandler> Completed { get; set; } }复制代码对象实现了IWriteHandler接口，用于通知组件提供自定义流输入实现。
协定实现
在这个示例中协定剖析并没有实现IPacket,而是间接接管SessionReceive办法来对流进行HTTP协定剖析，具体实现代码如下:
public override void SessionReceive(IServer server, SessionReceiveEventArgs e){ var request = GetRequest(e.Session); var pipeStream = e.Stream.ToPipeStream(); if (LoadRequest(request, pipeStream) == RequestStatus.Completed) { OnCompleted(request, e.Session); }}private RequestStatus LoadRequest(HttpRequest request, PipeStream stream){ //剖析HTTP申请信息 LoadRequestLine(request, stream); //剖析头信息 LoadRequestHeader(request, stream); //加载Body LoadRequestBody(request, stream); return request.Status;}private void LoadRequestLine(HttpRequest request, PipeStream stream){ if (request.Status == RequestStatus.None) { if (stream.TryReadLine(out string line)) { var subItem = line.SubLeftWith(' ', out string value); request.Method = value; subItem = subItem.SubLeftWith(' ', out value); request.Url = value; request.HttpVersion = subItem; subItem = request.Url.SubRightWith('?', out value); request.QueryString = value; request.BaseUrl = subItem; request.Path = subItem.SubRightWith('/', out value); if (request.Path != "/") request.Path += "/"; request.Status = RequestStatus.LoadingHeader; } }}private void LoadRequestHeader(HttpRequest request, PipeStream stream){ if (request.Status == RequestStatus.LoadingHeader) { while (stream.TryReadLine(out string line)) { if (string.IsNullOrEmpty(line)) { if (request.ContentLength == 0) { request.Status = RequestStatus.Completed; } else { request.Status = RequestStatus.LoadingBody; } return; } var name = line.SubRightWith(':', out string value); if (String.Compare(name, "Content-Length", true) == 0) { request.ContentLength = int.Parse(value); } request.Headers[name] = value.Trim(); } }}private void LoadRequestBody(HttpRequest request, PipeStream stream){ if (request.Status == RequestStatus.LoadingBody) { if (stream.Length >= request.ContentLength) { var data = new byte[request.ContentLength]; ; stream.Read(data, 0, data.Length); request.Body = data; request.Status = RequestStatus.Completed; } }}复制代码在剖析过程中最罕用的办法是TryReadLine,次要起因HTTP的头信息数据都是以换行的形式来形容，直到读取一个空行表明头部已结。如果存在Content-Length头信息形容阐明存在音讯体(HTTP有两种形容音讯体的状况，这里就不多作介绍了)。
服务解决
协定解决好后就能够集成在服务中，绝对于协定剖析来说集成就更简略了。
public static void Main(string[] args){ mServer = SocketFactory.CreateTcpServer<Program>(); mServer.Options.DefaultListen.Port = 80; mServer.Options.AddListenSSL("ssl.pfx", "123456"); mServer.Open(); System.Threading.Thread.Sleep(-1);}private void OnCompleted(HttpRequest request, ISession session){ HttpResponse response = new HttpResponse(); StringBuilder sb = new StringBuilder(); sb.AppendLine("<html>"); sb.AppendLine("<body>"); sb.AppendLine($"<p>Method:{request.Method}</p>"); sb.AppendLine($"<p>Url:{request.Url}</p>"); sb.AppendLine($"<p>Path:{request.Path}</p>"); sb.AppendLine($"<p>QueryString:{request.QueryString}</p>"); sb.AppendLine($"<p>ClientIP:{request.ClientIP}</p>"); sb.AppendLine($"<p>Content-Length:{request.ContentLength}</p>"); foreach (var item in request.Headers) { sb.AppendLine($"<p>{item.Key}:{item.Value}</p>"); } sb.AppendLine("</body>"); sb.AppendLine("</html>"); response.Body = sb.ToString(); ClearRequest(session); session.Send(response);}复制代码在服务中把默认监听的端口改成80，而后增加一个SSL监听用于反对HTTPS拜访；示例中通过OnCompleted办法响应申请内容，次要返回的内容是把以后申请的申请详细信息输入。
拜访后果
启动服务后能够通过浏览器拜访相干地址：
- HTTP
- HTTPS
因为证书是本人创立的，所以会被浏览器标记为不平安。