在網上找到一個demo，很多論壇都給的一個socket異步的例子。我除錯發現問題：服務端接收任務只能收到客戶端第一包資料，然后客戶端發資料服務端沒有接收到了，除錯的時候，服務端收到第一包資料然后執行發送動作，然后就跳出除錯程序了。。。麻煩哪位大神幫忙看看為什么。示例如下：
public static void StartListening()
{
// Data buffer for incoming data.
byte[] bytes = new Byte[1024];
// Establish the local endpoint for the socket.
// The DNS name of the computer
// running the listener is "host.contoso.com".
IPHostEntry ipHostInfo = Dns.GetHostEntry(Dns.GetHostName());
IPAddress ipAddress = ipHostInfo.AddressList[0];
IPEndPoint localEndPoint = new IPEndPoint(ipAddress, 11000);
// Create a TCP/IP socket.
Socket listener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
// Bind the socket to the local endpoint and listen for incoming connections.
try
{
listener.Bind(localEndPoint);
listener.Listen(100);
while (true)
{
// Set the event to nonsignaled state.
allDone.Reset();
// Start an asynchronous socket to listen for connections.
Console.WriteLine("Waiting for a connection...");
listener.BeginAccept(new AsyncCallback(AcceptCallback), listener);
// Wait until a connection is made before continuing.
allDone.WaitOne();
}
}
catch (Exception e)
{
Console.WriteLine(e.ToString());
}
Console.WriteLine("\nPress ENTER to continue...");
Console.Read();
}
public static void AcceptCallback(IAsyncResult ar)
{
// Signal the main thread to continue.
allDone.Set();
// Get the socket that handles the client request.
Socket listener = (Socket)ar.AsyncState;
Socket handler = listener.EndAccept(ar);
// Create the state object.
StateObject state = new StateObject();
state.workSocket = handler;
handler.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, new AsyncCallback(ReadCallback), state);
}
public static void ReadCallback(IAsyncResult ar)
{
String content = String.Empty;
// Retrieve the state object and the handler socket from the asynchronous state object.
StateObject state = (StateObject)ar.AsyncState;
Socket handler = state.workSocket;
// Read data from the client socket.
int bytesRead = handler.EndReceive(ar);
if (bytesRead > 0)
{
// There might be more data, so store the data received so far.
state.sb.Append(Encoding.ASCII.GetString(state.buffer, 0, bytesRead));
// Check for end-of-file tag. If it is not there, read more data.
content = state.sb.ToString();
if (content.IndexOf("<EOF>") > -1)
{
// All the data has been read from the client. Display it on the console.
Console.WriteLine("Read {0} bytes from socket. \n Data : {1}", content.Length, content);
// Echo the data back to the client.
Send(handler, content);
}
else
{
// Not all data received. Get more.
handler.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0, new AsyncCallback(ReadCallback), state);
}
}
}
private static void Send(Socket handler, String data)
{
// Convert the string data to byte data using ASCII encoding.
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);
}
private static void SendCallback(IAsyncResult ar)
{
try
{
// Retrieve the socket from the state object.
Socket handler = (Socket)ar.AsyncState;
// Complete sending the data to the remote device.
int bytesSent = handler.EndSend(ar);
Console.WriteLine("Sent {0} bytes to client.", bytesSent);
handler.Shutdown(SocketShutdown.Both);
handler.Close();
}
catch (Exception e)
{
Console.WriteLine(e.ToString());
}
}
uj5u.com熱心網友回復：
其實異步就是while（ture）的變體
A-B-A，他的回圈調，所以檢查你的代碼，看是否復合這種回圈調
當然我們還是那句話，如果你是實際專案，不建議在這里折騰。乘著你還沒有做下一步，立刻換用dotnetty。想研究IAsyncResult自己在屋里玩明白（當然現在的情況是，就是這個都只是說當個興趣，因為現在是await/ async，而不是IAsyncResult）
uj5u.com熱心網友回復：
Socket listener = (Socket)ar.AsyncState;Socket handler = listener.EndAccept(ar);
handler.Shutdown(SocketShutdown.Both);
handler.Close();
你忘記關listener 了吧，加上
listener .Shutdown(SocketShutdown.Both);
listener .Close();
把listener,handler放到StateObject 里傳遞。另外，服務端你是不打算埠復用了嗎？
uj5u.com熱心網友回復：
研究研究也有好處吧~~ 輪子不造么，車轱轆看看清楚以后有啥問題可以除錯。服務端為啥只收到一幀，要看你客戶端怎么寫的，這個服務端只監聽socket連接，連上后只接收一次資料就沒了。所以就一幀。
你的客戶端得每發一次資料連一次服務端，才能源源不斷的發出資料。。。。
實際專案里，如果是很少頻次的資料，那么可以這么寫，短鏈接，發一次資料建一個連接。如果是長時間大量資料，那就要在獲取到socket后監聽資料。。。。。
uj5u.com熱心網友回復：
哎~ 回頭研究下dotnetty，替換下老專案里的~
uj5u.com熱心網友回復：
最好是關聯客戶端呼叫代碼一起看，我這為什么說listener .Shutdown(SocketShutdown.Both);listener .Close();這個listener也要關閉，是因為前不久我做了接收聯通短信上行資料的服務，發現這個問題，一旦有將近2分鐘沒有上行資料，聯通呼叫方就把連接斷了，重開連接可以收到驗證用戶名密碼的包，但是上行資料就再也收不到了，只有handler,listener 全部關閉才能收到。我也不知道他們客戶端是怎么寫的，連個技術人員也找不到。如果有客戶端代碼可以查那最好。
uj5u.com熱心網友回復：
只有handler,listener 全部關閉才能收到。重建監聽連接，才可以收到uj5u.com熱心網友回復：
你是說每次收到資料，等我服務端send動作結束后就把這個通道關了，然后等客戶端重新建立連接么？
uj5u.com熱心網友回復：
可以試試，我上面說了，我是和聯通接短信上行的遇到問題這樣解決了，聯通的SGIP協議是歷史很悠久的協議，他們現在也不升級維護了，當初的開發人員早就沒有了（保計總部有但我也聯系不上啊）。所以當時對接的時候我根本找不到對方技術人員問，不知道他們那是如何實作的，只能我這試，就這樣試通了。有呼叫端代碼的你可以具體查查再決定。
uj5u.com熱心網友回復：
先不說代碼如果lz是通過下斷點逐步跟著除錯，那么建議換種方法
因為socket可能會因為下斷除錯，
接收處理時間過長會導致socket例外
建議使用列印日志的方式來除錯，
建設debug對程式本身流程的影響
uj5u.com熱心網友回復：
好的，我了解下這個框架，看入門容易不
uj5u.com熱心網友回復：
你還沒明白socket監聽的意義。 你的監聽的是連接。我猜你的客戶端是建立連接后就開始源源不斷發訊息。而你的訊息接收并不是一個執行緒對獲取到的socket進行反復監聽，所以實際情況是你應該在recieve的地方用一個執行緒去反復收取。當然，客戶端也可以先關閉再連接，但那費事費力啊，建立連接那點時間可以發很多訊息了。我覺得你目前還沒明白socket的用法，看框架沒意義
轉載請註明出處，本文鏈接：https://www.uj5u.com/net/39806.html
標籤：C#
上一篇：c#使用OLEDB操作EXCEL，怎么換電腦無法找到列0？
下一篇：有沒有識別聲音轉文字的軟體？