0

使用http://www.developerfusion.com上的资源， 我想出了以下服务器代码。它适用于单个客户。我怎样才能为多个客户制作它。我尝试添加数组和 beiginreceive 的不同实例，但无法添加。服务器代码：

class Program
{
    public static AsyncCallback pfnWorkerCallBack;
    public static Socket m_socListener;
    public static Socket m_socWorker;

    static void Main(string[] args)
    {
        try
        {
            //create the listening socket...
            m_socListener = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
            IPEndPoint ipLocal = new IPEndPoint(IPAddress.Any, 8221);
            //bind to local IP Address...
            m_socListener.Bind(ipLocal);
            Console.WriteLine("UCManager Started");
            //start listening...
            m_socListener.Listen(4);
            // create the call back for any client connections...
            m_socListener.BeginAccept(new AsyncCallback(OnClientConnect), null);
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.Message);
        }

        Console.ReadLine();
    }

    public static void OnClientConnect(IAsyncResult asyn)
    {
        try
        {
            m_socWorker = m_socListener.EndAccept(asyn);

            WaitForData(m_socWorker);
        }
        catch (Exception se)
        {
            Console.WriteLine(se.Message);
        }

    }
    public class CSocketPacket
    {
        public System.Net.Sockets.Socket thisSocket;
        public byte[] dataBuffer = new byte[1];
    }

    public static void WaitForData(System.Net.Sockets.Socket soc)
    {
        try
        {
            if (pfnWorkerCallBack == null)
            {
                pfnWorkerCallBack = new AsyncCallback(OnDataReceived);
            }
            CSocketPacket theSocPkt = new CSocketPacket();
            theSocPkt.thisSocket = soc;
            // now start to listen for any data...
            soc.BeginReceive(theSocPkt.dataBuffer, 0, theSocPkt.dataBuffer.Length, SocketFlags.None, pfnWorkerCallBack, theSocPkt);
        }
        catch (SocketException se)
        {
            Console.WriteLine(se.Message);
        }

    }

    public static void OnDataReceived(IAsyncResult asyn)
    {
        try
        {
            CSocketPacket theSockId = (CSocketPacket)asyn.AsyncState;
            //end receive...
            int iRx = 0;
            iRx = theSockId.thisSocket.EndReceive(asyn);
            char[] chars = new char[iRx + 1];
            Decoder d = Encoding.UTF8.GetDecoder();
            int charLen = d.GetChars(theSockId.dataBuffer, 0, iRx, chars, 0);
            String szData = new String(chars);
            Console.WriteLine(szData);
            int code = Convert.ToInt32(szData); 

            WaitForData(m_socWorker);
        }

        catch (Exception se)
        {
            Console.WriteLine(se.Message);
        }
    }

}

}

编辑：好的，我在Async TCP Server for multiple Clients上做了一些事情。 

public static void OnClientConnect(IAsyncResult asyn)
        {
            try
            {
                Socket m_socWorkerInstance = m_socListener.EndAccept(asyn);
                clientSocketList.Add(m_socWorkerInstance);

                WaitForData(m_socWorkerInstance);
            }
            catch (ObjectDisposedException)
            {
                System.Diagnostics.Debugger.Log(0, "1", "\n OnClientConnection: Socket has been closed\n");
            }
            catch (SocketException se)
            {
                Console.WriteLine(se.Message);
            }

        }
public static void WaitForData(System.Net.Sockets.Socket soc)
        {
            try
            {
                if (pfnWorkerCallBack == null)
                {
                    pfnWorkerCallBack = new AsyncCallback(OnDataReceived);
                }
                CSocketPacket theSocPkt = new CSocketPacket();
                theSocPkt.thisSocket = soc;
                // now start to listen for any data...
                soc.BeginReceive(theSocPkt.dataBuffer, 0, theSocPkt.dataBuffer.Length, SocketFlags.None, pfnWorkerCallBack, theSocPkt);
                m_socListener.BeginAccept(new AsyncCallback(OnClientConnect), null);
            }
            catch (SocketException se)
            {
                Console.WriteLine(se.Message);
            }

        }

现在我可以连接两个客户端但无法通信...我无法从服务器向客户端发送消息...任何建议...如果我与两个客户端连接，我是否应该为两个客户端提供不同的读取功能？？？

4

2 回答 2

2

您BeginAccept只调用一次，因此在接受一个客户端后，您的服务器将不会接受任何新连接。您应该BeginAccept在接受连接后再次调用。

于 2013-08-21T09:59:04.860 回答
0

好的，我能够 为多个客户端使用 Async TCP Server来解决它：

public static void OnClientConnect(IAsyncResult asyn)
            {
                try
                {
                    Socket m_socWorkerInstance = m_socListener.EndAccept(asyn);
                    clientSocketList.Add(m_socWorkerInstance);

                    WaitForData(m_socWorkerInstance);
                }
                catch (ObjectDisposedException)
                {
                    System.Diagnostics.Debugger.Log(0, "1", "\n OnClientConnection: Socket has been closed\n");
                }
                catch (SocketException se)
                {
                    Console.WriteLine(se.Message);
                }

            }
    public static void WaitForData(System.Net.Sockets.Socket soc)
            {
                try
                {
                    if (pfnWorkerCallBack == null)
                    {
                        pfnWorkerCallBack = new AsyncCallback(OnDataReceived);
                    }
                    CSocketPacket theSocPkt = new CSocketPacket();
                    theSocPkt.thisSocket = soc;
                    // now start to listen for any data...
                    soc.BeginReceive(theSocPkt.dataBuffer, 0, theSocPkt.dataBuffer.Length, SocketFlags.None, pfnWorkerCallBack, theSocPkt);
                    m_socListener.BeginAccept(new AsyncCallback(OnClientConnect), null);
                }
                catch (SocketException se)
                {
                    Console.WriteLine(se.Message);
                }

            }
于 2013-08-21T10:07:23.997 回答