代码拉取完成,页面将自动刷新
using System;
using System.IO;
using System.Net.Security;
using System.Net.Sockets;
using System.Threading;
namespace WatsonTcp
{
internal class ClientMetadata : IDisposable
{
internal TcpClient TcpClient
{
get
{
return _TcpClient;
}
}
internal NetworkStream NetworkStream
{
get
{
return _NetworkStream;
}
set
{
_NetworkStream = value;
if (_NetworkStream != null)
{
_DataStream = _NetworkStream;
}
}
}
internal SslStream SslStream
{
get
{
return _SslStream;
}
set
{
_SslStream = value;
if (_SslStream != null)
{
_DataStream = _SslStream;
}
}
}
internal Stream DataStream
{
get
{
return _DataStream;
}
}
internal string IpPort
{
get
{
return _IpPort;
}
}
internal CancellationTokenSource TokenSource = new CancellationTokenSource();
internal CancellationToken Token;
private TcpClient _TcpClient = null;
private NetworkStream _NetworkStream = null;
private SslStream _SslStream = null;
private Stream _DataStream = null;
private string _IpPort = null;
internal ClientMetadata(TcpClient tcp)
{
if (tcp == null) throw new ArgumentNullException(nameof(tcp));
_TcpClient = tcp;
_IpPort = tcp.Client.RemoteEndPoint.ToString();
NetworkStream = tcp.GetStream();
Token = TokenSource.Token;
}
/// <summary>
/// Tear down the object and dispose of resources.
/// </summary>
public void Dispose()
{
if (_SslStream != null)
{
_SslStream.Close();
}
if (_NetworkStream != null)
{
_NetworkStream.Close();
}
if (TokenSource != null)
{
if (!TokenSource.IsCancellationRequested) TokenSource.Cancel();
TokenSource.Dispose();
TokenSource = null;
}
if (_TcpClient != null)
{
_TcpClient.Close();
_TcpClient.Dispose();
}
}
}
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。