我以前用C編寫套接字程序，無(wú)法理解為什么會(huì)發(fā)生這種情況 .

我的服務(wù)器在接收調(diào)用時(shí)阻塞，當(dāng)它返回0時(shí)，我打破了while循環(huán)并關(guān)閉了線程 .

public class MyServer {

public MyServer() {

}

public void Init() {

ThreadPool.QueueUserWorkItem(StartListening);

while (true) {

Console.Read();

}

}

public void StartListening(Object state) {

// Establish the local endpoint for the socket.

IPAddress ipAddress = IPAddress.Parse("127.0.0.1");

IPEndPoint localEndPoint = new IPEndPoint(ipAddress, 11000);

Socket listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

try {

// Bind the socket to the local endpoint and listen for incoming connections.

listener.Bind(localEndPoint);

listener.Listen(100);

while (true) {

Console.WriteLine("Waiting for a connection...");

// get connection

Socket client = listener.Accept();

// push client to another thread

ThreadPool.QueueUserWorkItem(HandleClient, client);

}

} catch (Exception e) {

Console.WriteLine(e.ToString());

}

}

private void HandleClient(Object obj) {

// Get the socket that handles the client request.

Socket client = (Socket)obj;

// Create the state object.

StateObject state = new StateObject();

state.workSocket = client;

try {

while (true) {

int bytesRead = client.Receive(state.buffer);

Console.WriteLine("bytesRead=" + bytesRead);

// remote dc.

if (bytesRead == 0)

break;

String content = Encoding.ASCII.GetString(state.buffer, 0, bytesRead);

Console.WriteLine("Read {0} bytes from socket. \n Data : {1}", content.Length, content);

client.Send(state.buffer, 0, state.buffer.Length, 0);

}

} catch (SocketException e) {

Console.WriteLine("SocketException : {0}", e.ToString());

}

client.Shutdown(SocketShutdown.Both);

client.Close();

}

private void Send(Socket handler, String data) {

byte[] byteData = Encoding.ASCII.GetBytes(data);

// Begin sending the data to the remote device.

//handler.BeginSend(byteData, 0, byteData.Length, 0, new AsyncCallback(SendCallback), handler);

}

}

但是，當(dāng)我單擊客戶端的關(guān)閉按鈕("x")時(shí)，服務(wù)器的Receive調(diào)用將拋出SocketException . 根據(jù)MSDN's Remarks section，這不應(yīng)該滿足面向連接的部分(見上文)和客戶端關(guān)閉部分(見下文)的條件 .

Client.cs (pseudo):

public class MyClient {

public void Init() {

byte[] bytes = new byte[1024];

Socket sender = null;

try {

IPAddress ipAddress = IPAddress.Parse("127.0.0.1");

IPEndPoint remoteEP = new IPEndPoint(ipAddress, 11000);

sender = new Socket(AddressFamily.InterNetwork,

SocketType.Stream, ProtocolType.Tcp);

sender.Connect(remoteEP);

Console.WriteLine("Socket connected to {0}",

sender.RemoteEndPoint.ToString());

while (true) {

// Encode the data string into a byte array.

String input = Console.ReadLine();

byte[] msg = Encoding.ASCII.GetBytes(input);

// Send the data through the socket.

int bytesSent = sender.Send(msg);

// Receive the response from the remote device.

int bytesRec = sender.Receive(bytes);

Console.WriteLine("Echoed test = {0}",

Encoding.ASCII.GetString(bytes, 0, bytesRec));

}

} catch (ArgumentNullException ane) {

Console.WriteLine("ArgumentNullException : {0}", ane.ToString());

} catch (SocketException se) {

Console.WriteLine("SocketException : {0}", se.ToString());

} catch (Exception e) {

Console.WriteLine("Unexpected exception : {0}", e.ToString());

} finally {

sender.Shutdown(SocketShutdown.Both);

sender.Close();

}

}

}

我對(duì)finally塊的淺層理解是它總會(huì)執(zhí)行 . 但這似乎并非如此 .

那么，我在這里做錯(cuò)了什么？我是否應(yīng)該捕獲異常，關(guān)閉服務(wù)器端的客戶端套接字然后繼續(xù)，忽略它？但我更愿意，如果沒有拋出異常 .

總結(jié)

以上是生活随笔為你收集整理的10054 java,为什么Socket.Receive在远程主机断开连接时抛出SocketException（10054）？的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。