public class StateObject {
public Socket workSocket = null;
public const int BufferSize = 1024;
public byte[] buffer = new byte[BufferSize];
public StringBuilder sb = new StringBuilder();
}
public class AsynchronousSocketListener {
public static string data = null;
public static ManualResetEvent allDone = new ManualResetEvent(false);
public AsynchronousSocketListener() {
}
public static void StartListening() {
byte[] bytes = new Byte[1024];
IPHostEntry ipHostInfo = Dns.Resolve(Dns.GetHostName());
IPAddress ipAddress = ipHostInfo.AddressList[0];
IPEndPoint localEndPoint = new IPEndPoint(ipAddress, 11000);
Socket listener = new Socket(AddressFamily.InterNetwork,
SocketType.Stream, ProtocolType.Tcp );
try {
listener.Bind(localEndPoint);
listener.Listen(100);
while (true) {
allDone.Reset();
Console.WriteLine("Waiting for a connection...");
listener.BeginAccept(
new AsyncCallback(AcceptCallback),
listener );
allDone.WaitOne();
}
} catch (Exception e) {
Console.WriteLine(e.ToString());
}
Console.WriteLine("\nPress ENTER to continue...");
Console.Read();
}
public static void AcceptCallback(IAsyncResult ar) {
allDone.Set();
Socket listener = (Socket) ar.AsyncState;
Socket handler = listener.EndAccept(ar);
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;
StateObject state = (StateObject) ar.AsyncState;
Socket handler = state.workSocket;
int bytesRead = handler.EndReceive(ar);
if (bytesRead > 0) {
state.sb.Append(Encoding.ASCII.GetString(
state.buffer,0,bytesRead));
content = state.sb.ToString();
if (content.IndexOf("<EOF>") > -1) {
Console.WriteLine("Read {0} bytes from socket. \n Data : {1}",
content.Length, content );
Send(handler, content);
} else {
handler.BeginReceive(state.buffer, 0, StateObject.BufferSize, 0,
new AsyncCallback(ReadCallback), state);
}
}
}
private static void Send(Socket handler, String data) {
byte[] byteData = Encoding.ASCII.GetBytes(data);
handler.BeginSend(byteData, 0, byteData.Length, 0,
new AsyncCallback(SendCallback), handler);
}
private static void SendCallback(IAsyncResult ar) {
try {
Socket handler = (Socket) ar.AsyncState;
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());
}
}
public static int Main(String[] args) {
StartListening();
return 0;
}
}
以上是MSDN中關于異步SOCLET服務端的代碼，我的問題是：
在服務端監聽到了一個客戶端連接后，將在AcceptCallback函式中創建用戶處理這個客戶端的物件。并且指定ReadCallback為處理接收的回呼函式。
那么ReadCallback函式中的函式程序是否是執行緒安全的？？比如說：如果第一個客戶端連接上來了，并且正在ReadCallback中處理，并且在短時間之內不會結束處理。第2個客戶端這時候連接上來了，那么第2個客戶端的處理是會等待第一個執行完畢之后才進入ReadCallback呢？還是直接也進入ReadCallback？？如果第2個客戶端也進入ReadCallback進行處理了，那么會將第一個客戶端的資料沖掉嗎？？
另外C#中回呼函式的處理機制是否是另外啟動一個新的執行緒？即是否是呼叫這個回呼一次，就會啟動一個新的執行緒來處理這個回呼？不過回呼也是委托，按照道理來說，應該不會重新啟動一個執行緒的。并且兩次呼叫回呼，那么呼叫的應該是同一個執行緒中的統一個回呼吧。
這個問題困惑了我很久了····請大家幫忙解惑。。。
剛上論壇不久，分不多，請見諒～～～～
uj5u.com熱心網友回復：
會，因為這時候資料都在緩沖區呢，你沒去Receive相應的Socket，自然不會有新的執行緒出來。uj5u.com熱心網友回復：
要怎樣解決這個問題呢，uj5u.com熱心網友回復：
回呼函式最好設計為執行緒安全的,不要對全域變數、物件進行修改,最好用區域變數,執行緒區域變數uj5u.com熱心網友回復：
像DOWN 個VSS，可惜都要積分，有沒有免費給一個的啊！
uj5u.com熱心網友回復：
明明是VB.NET轉載請註明出處，本文鏈接：https://www.uj5u.com/gongcheng/121730.html
標籤：網絡編程