有没有更好的方法来制作服务器客户端应用程序？

Question

我正在使用 c# 中的 tcp 套接字创建一个应用程序服务器客户端。

该应用程序有多个任务，例如文件传输..文件管理器..聊天..（稍后语音聊天）

所以我决定创建一个套接字来接收命令作为细绳 和另一个用于传输文件的套接字..
这是编写服务器客户端应用程序的好方法还是我应该尝试其他方法？ 因为用户可以在接收/发送文件时发送消息

以及我如何告诉（文件传输服务器）仅接受已与主服务器连接的同一客户端

例如：服务器侦听端口8000 并接受客户端..并在端口 8111 上传输文件

public StartSever()
{
    sr = new StreamReader(networkStream);
while(connected)
{
        string[] command = sr.ReadLine().split(',');
        switch (Command[0])
        {
            case "RecFile":
                StartFileTransferServer();  // creating new socket tcp listens on port 8111
                Receiving();
                break;
            case "SendFile":
                StartFileTransferServer();  // creating new socket tcp listens on port 8111
                Sending();
                break;
            case "Chat":
                chat(Command[1]);
                break;
            default:
                break;
        }

}

Answer 1

您可以使用某种通信框架或库，它可以抽象 TCP/IP 套接字的详细信息，并允许您在客户端和服务器端之间发送对象、消息和文件，而不必担心所有细节。

您可以考虑使用一些东西：

• WCF
• ZeroMQ
• RabbitMQ

这些只是一些例子我突然想到有大量这样的框架，它们在不同的抽象级别上工作，并提供更重或更轻的实现。我相信您一定能找到一款满足您基本需求的产品。

Answer 2

该应用程序具有多项任务，例如文件传输..文件管理器..聊天..（稍后语音聊天）

如果您没有比使用冒号分隔的字符串协议和switch语句更长的时间，我建议您就停在那里。

我强烈建议您使用带有 netTcpBinding 和双工绑定的 WCF： http://www.dotnetconsult.co.uk/weblog2/PermaLink,guid,b891610a-6b78-4b54-b9a6-4ec81c82b7c0.aspx

仅靠 VoiceChat 是不会成功的。为此购买一个组件。

Answer 3

当您调用 Accept 时，您会收到新用户的套接字。之后您可以创建 NetworkStream。
Write 和 Read 是阻塞方法。您可以尝试使用异步方法：BeginRead 和 BeginWrite。
如果您有数千个用户，那么为每个用户创建新线程也不好。
我提出这样的解决方案：一个线程接受连接并将工作发送到线程池。

像这样的东西（注意这只是草稿）：

using System;
using System.Net;
using System.Net.Sockets;
using System.Threading;

namespace ConsoleServer
{
class Program
{
    private static void Worker(Object sockObj)
    {
        var mySocket = (Socket) sockObj;
        using(var netStream = new NetworkStream(mySocket))
        {
            //Handle work;
        }            
    }

    static void Main(string[] args)
    {
        int port = 80;
        // create the socket
        Socket listenSocket = new Socket(AddressFamily.InterNetwork,
                                         SocketType.Stream,
                                         ProtocolType.Tcp);

        // bind the listening socket to the port
        IPAddress hostIP = (Dns.Resolve(IPAddress.Any.ToString())).AddressList[0];
        IPEndPoint ep = new IPEndPoint(hostIP, port);
        listenSocket.Bind(ep);

        // start listening
        listenSocket.Listen(125);

        while (true)
        {
            Socket mySocket = listenSocket.Accept();
            ThreadPool.QueueUserWorkItem(new WaitCallback(Worker), mySocket);
        }
    }
}

}