C#TCP Server用于简单聊天

use*_*370 6 c# sockets tcp

我正在使用Microsoft提供的Async示例编写我的第一个TCP服务器.

https://msdn.microsoft.com/en-us/library/fx6588te(v=vs.110).aspx

我从示例中得到了一切.我将它扩展为一个简单的聊天程序.但是我无法遵循这个程序的步骤(可能是因为它的异步性质).收到消息后,它会回送给客户端并关闭套接字.我没有看到它重新打开插座的位置.

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.Resolve(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();

    }

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());
        }
    }
Run Code Online (Sandbox Code Playgroud)

另外,将插座打开是不正常的?

Phi*_*yck 2

当收到消息时,它会回显给客户端并关闭套接字。我没有看到它返回到哪里重新打开套接字。

那是因为事实并非如此。通信完成,服务器接收、发送回复并完成该连接。它只是继续等待侦听套接字上的新连接。你还有一段时间(正确)。您将在接受呼叫中继续等待新的传入连接。您将为每个新客户端获得一个新套接字。

另外,让插座保持打开状态是不正常的吗?

是的,监听套接字保持打开状态。它保持打开状态以继续使用accept接收新连接

使用异步和等待编写回显服务器的更好方法可以在这里找到:Using .Net 4.5 Async Feature for Socket programming