我没有很好地学习网络。我知道 TCP/IP 的基础知识,但我面临一项任务,我必须为在同一解决方案中相互通信的多个项目管理多个线程。我在 Window 的窗体、C# 中工作,为了简单起见,我将只写需要写的内容。
这是我的客户端类,它连接到服务器,处理进出服务器的消息,以及从服务器注销。
private TcpClient ClientConnection = null;
private NetworkStream CommandStream = null;
private Thread ClientThread = null;
bool isRunning = false;
public Client()
{
InitializeComponent();
try
{
//open the connection to the command port
ClientConnection = new TcpClient(address, Convert.ToInt32(port));
//Get the command stream
CommandStream = ClientConnection.GetStream();
if (CommandStream != null)
{
isConnected = true;
ClientThread = new Thread(Receive);
isRunning = true;
ClientThread.Start();
}
errorLabel.Visible = false;
}
catch (Exception ex)
{
errorLabel.Visible = true;
errorLabel.Text = "Failed to Connect";
}
}
private void Receive()
{
Byte[] data = new Byte[1024];
string message = string.Empty;
int BytesReceived = 0;
while (isRunning == true)
{
BytesReceived = CommandStream.Read(data, 0, 1024);
message = Encoding.ASCII.GetString(data, 0, BytesReceived);
//Do something with the message
}
}
private void logoutButton_Click(object sender, EventArgs e)
{
//Do logout logic here
errorLabel.Visible = false;
try
{
if (ClientConnection != null)
{
Byte[] command = new Byte[1024];
string commandStr = "SHUTDOWN";
command = Encoding.ASCII.GetBytes(commandStr);
CommandStream.Write(command, 0, command.GetLength(0));
ClientConnection.Close();
CommandStream.Close();
isRunning = false;
if (ClientThread.IsAlive == true)
{
errorLabel.Visible = true;
errorLabel.Text = "Thread still alive. Failed to Disconnect";
}
}
}
catch(Exception ex)
{
errorLabel.Visible = true;
errorLabel.Text = "Failed to Disconnect";
}
}
这是我的服务器类的进程处理函数:
private void CommandProcessHandler(Socket client)
{
Byte[] data = new Byte[1024];
NetworkStream NetStream = null;
//Exception check
if(client.Connected == true)
NetStream = new NetworkStream(client);
while(bCommandListener == true)
{
//Read the command from the client
int bytes = NetStream.Read(data, 0, 1024);
string Command = Encoding.ASCII.GetString(data, 0, bytes);
//Do something with the command
if (Command == "SHUTDOWN")
{
NetStream.Close();
client.Close();
bCommandListener = false;
continue;
}
//Display the command in the command list box
string buttonPressed;
string buttonLetter;
buttonPressed = CommandDataObject.Instance.DecodeUIDFromMessage(Command);
buttonLetter = CommandDataObject.Instance.DecodeMessageFromUID(Command);
Command = ((client.RemoteEndPoint) as IPEndPoint).Address.ToString() + ">>>" + Command;
UpdateCommandsListBox(Command);
}
}
我确信我可以完美地启动线程,但问题在于关闭它们。这是我从未被正确教导过的一个方面,并且在学习上遇到了困难。就目前而言,我按下“注销”按钮,它应该向服务器发送一条消息以关闭,并关闭 TcpClient 和 NetworkStream。它还将保持客户端的接收线程处于事件状态的 isRunning bool 值设置为 false。
但是,就目前而言,当我执行此操作时,在第 98 行(在客户端的 Receive 函数期间,当 BytesReceived = CommandStream.Read 时)我一直收到错误,如下所示:
An unhandled exception of type 'System.IO.IOException' occurred in System.dll
Additional information: Unable to read data from the transport connection: A blocking operation was interrupted by a call to WSACancelBlockingCall.
我不确定错误指的是什么,但我已经坚持了一段时间并希望修复它。任何解决方案?
最佳答案
当您使用 NetworkStream 时,如果底层套接字在尝试读取时关闭,它将抛出 IOException,see MSDN documentation .所以你的代码非常好。您只需处理异常。
如果您直接读取套接字,当套接字关闭时您只会收到 0。
关于c# - 如何关闭 TCP/IP 连接,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/29516240/