主机中的软件中止了已建立的连接
本文关键字:建立 连接 软件 主机 | 更新日期: 2023-09-27 18:24:45
我在某些主题中找不到答案。我有一个客户端/服务器代码。我有一个客户端和服务器端独立的程序。这是客户端:
try
{
byte[] bytes = new byte[1024];
string text = "";
text = uitbtextmsg.Text;
byte[] msg = Encoding.ASCII.GetBytes(text);
int bytesSent = User.Send(msg);
int bytesRec = User.Receive(bytes);
uirtbmsg.Text = uirtbmsg.Text + ''n' + " " + text;
}
catch (Exception E)
{
MessageBox.Show(E.ToString());
}
这是当我连接到服务器时,我想用那个插座聊天。这是我的连接:
byte[] bytes = new byte[1024];
IPHostEntry ipHostInfo = Dns.GetHostEntry(Dns.GetHostName());
IPAddress ipAddress = ipHostInfo.AddressList[2];
IPEndPoint remoteEP = new IPEndPoint(ipAddress, 11000);
Socket User = new Socket(AddressFamily.InterNetwork,
SocketType.Stream, ProtocolType.Tcp);
User.Connect(remoteEP);
这是服务器端:
byte[] bytes = new Byte[1024];
IPHostEntry ipHostInfo = Dns.GetHostEntry(Dns.GetHostName());
IPAddress ipAddress = ipHostInfo.AddressList[2];
IPEndPoint localEndPoint = new IPEndPoint(ipAddress, 11000);
Socket listener = new Socket(AddressFamily.InterNetwork,
SocketType.Stream, ProtocolType.Tcp);
try
{
listener.Bind(localEndPoint);
listener.Listen(10000);
while (true)
{
Socket handler = listener.Accept();
data = null;
while (true)
{
bytes = new byte[1024];
int bytesRec = handler.Receive(bytes);
data += Encoding.ASCII.GetString(bytes, 0, bytesRec);
TextRecieved = data;
Thread textbox = new Thread(new ThreadStart(WriteInReachTextBox));
textbox.Start();
break;
}
//uirtbreport.Text = data;
byte[] msg = Encoding.ASCII.GetBytes(data);
handler.Send(msg);
handler.Shutdown(SocketShutdown.Both);
handler.Close();
}
}
catch (Exception e)
{
MessageBox.Show(e.ToString());
}
当客户端第一次向服务器发送消息时,此过程可以!但当它发送另一条消息时,它会抛出一个异常:
System.Net.Socket.SocketException(0x80004005):已建立连接已被位于的主机中的软件中止System.Net.Socket.Socket.Receive(Byte[]缓冲区,Int32偏移量,Int32大小,SocketFlags SocketFlags)位于的System.Net.Socket.Socket.Receive(Byte[]缓冲区)''r''nClient.Form1.uibtnsendmsg_Click(对象发件人,EventArgs e)在。。。
可能是因为你打破了while循环(查看我的评论)
while (true)
{
Socket handler = listener.Accept();
data = null;
while (true)
{
bytes = new byte[1024];
int bytesRec = handler.Receive(bytes);
data += Encoding.ASCII.GetString(bytes, 0, bytesRec);
TextRecieved = data;
Thread textbox = new Thread(new ThreadStart(WriteInReachTextBox));
textbox.Start();
// -----------> HERE!!!!!!
break;
}
//uirtbreport.Text = data;
byte[] msg = Encoding.ASCII.GetBytes(data);
handler.Send(msg);
handler.Shutdown(SocketShutdown.Both);
handler.Close();
}
为什么要在"断开"循环中创建线程?
此外,别忘了这是一个流套接字,这意味着"数据包"可以作为一个缓冲区发送,也可以拆分为多个"数据包"
我不清楚是什么文本框。Start()确实如此,但在我看来,在服务器从客户端读取一些数据后,它会打破的"while(true)"并关闭套接字连接。这就是为什么您只能发送一条消息。
Socket handler = listener.Accept();
...
while (true)
{
.... read data
textbox.Start();
break;
}
/* Here you close the connection */
handler.Shutdown(SocketShutdown.Both);
handler.Close();
我认为您希望在同一套接字上有一个持久的tcp连接。
只是不要为了不关闭套接字而破坏循环。