C＃套接字编程
嘿，我正在做C＃异步套接字编程的噩梦。 你能指点我一本指南或教程或一本深入解释异步编程的书。 如果可能包含如何使用Begin Send / Receive函数中的state参数来处理多个客户端。
你可以阅读
C＃中的异步套接字编程第1部分
和
C＃中的异步套接字编程：第二部分
这些是Google快速搜索的结果。
可以通过以下方案组织服务器：用于客户端连接的separeted线程侦听端口。
/// Async server public class AsyncServer { /// Server socket private Socket _serverSocket; /// Element for sync wait private static ManualResetEvent _connectionMutex = new ManualResetEvent(false); /// Client handler private ClientManager _clientManager; public AsyncServer(string ipAddrees, int port) { try { this._serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); this._serverSocket.Bind( new IPEndPoint(IPAddress.Parse(ipAddrees), port)); } catch (Exception ex) { throw new Exception("Server Init Error.", ex); } } private BackgroundWorker _listenThread = new BackgroundWorker(); public void Start() { this._clientManager = new ClientManager(this._clientConnections); this._listenThread.WorkerReportsProgress = true; this._listenThread.WorkerSupportsCancellation = true; this._listenThread.DoWork += new DoWorkEventHandler(ListenThread_DoWork); this._listenThread.RunWorkerAsync(this._serverSocket); } /// Thread for listening port private void ListenThread_DoWork(object sender, DoWorkEventArgs e) { Socket serverSocket = (Socket)e.Argument; serverSocket.Listen(100); while (true) { // reset mutex _connectionMutex.Reset(); serverSocket.BeginAccept( new AsyncCallback(this.AcceptCallback), this._serverSocket); // waiting for the next connection _connectionMutex.WaitOne(); } } /// List of client connections private List _clientConnections = new List(); public int ConnectionsCount { get { return this._clientConnections.Count; } } /// Callback method for handling connections private void AcceptCallback(IAsyncResult asyncResult) { _connectionMutex.Set(); Socket serverSocket = (Socket)asyncResult.AsyncState; Socket clientSocket = (Socket)serverSocket.EndAccept(asyncResult); this._clientConnections.Add(clientSocket); this._clientManager.HandleClient(clientSocket); } }
方法AcceptCallback（IAsyncResult asyncResult）处理所有新客户端连接并传输到ClientManager ，后者为每个客户端创建单独的线程。
public class ClientManager { private List _clientProcessors = new List(); private List _connections; public ClientManager(List connections) { this._connections = connections; } /// Handling of client connection public void HandleClient(Socket clientSocket) { BackgroundWorker clientProcessor = new BackgroundWorker(); clientProcessor.DoWork += new DoWorkEventHandler(ClientProcessing); this._clientProcessors.Add(clientProcessor); List args = new List(); // // args.Add(...); clientProcessor.RunWorkerAsync(args); } private void ClientProcessing(object sender, DoWorkEventArgs e) { // reading args List args = (List)e.Argument; ProtocolSerializer serializer = new ProtocolSerializer(); try { while (socket.Connected) { // ... } } catch (SocketException) { // ... } catch (Exception) { // ... } } }
以下链接提供了有关C＃异步套接字编程的分步教程。
http://csharp.net-informations.com/communications/csharp-socket-programming.htm
阿尔多。