socket编程中服务器端不能接收多个客户端发信

baishengjie 2009-11-18 10:08:36

问题如题，要是单一客户端可以收到信息，但多个的话就不能收到信息，请大家帮忙看看，代码不完善的地方指点指点。本来服务器还要连接一个接收客户端的，那个就不贴出来了，这样也可以运行。

服务器端



class Server

    {

        #region 定义初始化全局变量



        int port = 81;



        IPAddress ip = IPAddress.Parse("127.0.0.1");



        TcpListener listener;



        TcpListener sendListener;



        ArrayList clients;



        ArrayList sendClients;



        Socket socket;



        Socket sendSocket;



        int flag = 0;



        int sendFlag = 0;



        byte[] buffer;



        int rec;



        string[] messageStr = new string[500];



        Hashtable socketMessage = new Hashtable();



        #endregion

        

        public Server()

        {

            Thread receiveThread = new Thread(new ThreadStart(receive));

            Thread sendThread = new Thread(new ThreadStart(send));

            receiveThread.Start();

            sendThread.Start();



        }





        //监听客户端口

        public void receive()

        {

            clients = new ArrayList();



            try

            {

                listener = new TcpListener(ip, port);



                listener.Start();



                Console.WriteLine("Server start listenning : ");



                while (true)

                {                  



                    socket = listener.AcceptSocket();



                    Console.WriteLine("port[{0}]已连接" , this.getPort(socket));                    



                    if (!clients.Contains(socket))

                    {

                        clients.Add(socket);



                        Thread listenThread = new Thread(new ThreadStart(listen));



                        listenThread.Start();

                    }

                }

            }

            catch (Exception e)

            {

                Console.WriteLine("无客户端可连接");

                return;

            }



        }





        public void listen()

        {            

            int CurrentSocketNo = flag;



            Console.WriteLine("*****************Thread{0} is running*******************",CurrentSocketNo);



            flag++;



            //用死循环控制监听

            while (true)

            {

                try

                {

                    messageStr[CurrentSocketNo] = "";

                    

                    Socket clientSocket = (Socket)clients[CurrentSocketNo];



                    buffer = new byte[256];



                    int rec = clientSocket.Receive(buffer);



                    messageStr[CurrentSocketNo] = Encoding.ASCII.GetString(buffer);



                    Console.WriteLine("*******************************New message****************************** " + CurrentSocketNo);



                    if (rec < messageStr[CurrentSocketNo].Length)

                    {

                        messageStr[CurrentSocketNo] = messageStr[CurrentSocketNo].Substring(0, rec);

                    }



                    Console.WriteLine("No.{0} Message : {1}",CurrentSocketNo , messageStr[CurrentSocketNo]);

                    

                    if (sendClients != null && sendClients.Count != 0)

                    {

                        Thread sendThread = new Thread(new ParameterizedThreadStart(send_listen));



                        sendThread.Start(messageStr[CurrentSocketNo]);

                    }                  



                }

                catch (Exception e)

                {

                    

                    //clients = this.DeleteClosedSocket(clients);



                    flag--;



                    if (clients.Count == 0 || clients == null)

                    {

                        Console.WriteLine("无客户端连接，等待连接");

                    }



                    return;

                }

            }

        }



        //监听收信客户端

        public void send()

        {

            sendClients = new ArrayList();



            try

            {            



                sendListener = new TcpListener(ip, 91);



                sendListener.Start();



                Console.WriteLine("Server is listening Send_Port...");



                while (true)

                {



                    sendSocket = sendListener.AcceptSocket();



                    Console.WriteLine("port : " + this.getPort(sendSocket));



                    if (!sendClients.Contains(sendSocket))

                    {

                        sendClients.Add(sendSocket);



                    }



                    sendClients = this.DeleteClosedSocket(sendClients);



                    foreach (Socket s in sendClients)

                    {

                        Console.WriteLine(this.getPort(s));

                    }

                }



            }

            catch (Exception e)

            {

                Console.WriteLine(e.ToString());



                sendClients = this.DeleteClosedSocket(sendClients);

            }

        }





        public void send_listen(object obj)

        {



            string sendMessage = obj as string;



            if (sendClients != null && sendClients.Count != 0) 

            {

                //用循环控制向接收客户端发送信息

                for (int i = 0; i < sendClients.Count; i++)

                {

                    //向接收客户端发送数据代码

                    Console.WriteLine("正在向接收客户端发送信息...[{0}]" ,i);



                    try

                    {

                        Socket clientSocket = (Socket)sendClients[i];



                        IPEndPoint clientip = (IPEndPoint)clientSocket.RemoteEndPoint;



                        buffer = Encoding.ASCII.GetBytes(sendMessage.ToCharArray());



                        clientSocket.Send(buffer, buffer.Length, SocketFlags.None);



                    }

                    catch (Exception e)

                    {

                        return;

                    }

                }

            }            

        }





        #region Get IP by socket

        public string getIp(Socket socket)

        {

            IPEndPoint sip = (IPEndPoint)socket.RemoteEndPoint;

            string socketIP = sip.Address.ToString();

            return socketIP;

        }

        #endregion



        #region Get Port by socket

        public string getPort(Socket socket)

        {

            IPEndPoint sip = (IPEndPoint)socket.RemoteEndPoint;

            string socketPort = sip.Port.ToString();

            return socketPort;

        }

        #endregion



        #region GetNowTime



        public string GetNowTime()

        {

            DateTime dt = DateTime.Now;

            string time = dt.ToString() + " . " + dt.Millisecond.ToString();

            return time;

        }



        #endregion



        #region  Delete socket in Arraylist which is closed



        public ArrayList DeleteClosedSocket(ArrayList socketlist)

        {

            ArrayList slist = new ArrayList();



            foreach (Socket s in socketlist)

            {

                if (s.Poll(10, SelectMode.SelectRead))

                {

                    slist.Add(s);

                }

            }



            foreach (Socket s in slist)

            {

                socketlist.Remove(s);

            }



            return socketlist;



        }



        #endregion



        static void Main(string[] args)

        {

            Server server = new Server();

        }

    }

客户端



class Client

    {

        string ip = "127.0.0.1";



        int port = 81;



        TcpClient clientSocket;



        NetworkStream ns;



        StreamReader sr;



        bool connected;



        string message;



        Thread connectThread;



        int id;



        public Client()

        {

            connected = true;



            DateTime dt = DateTime.Now;

            id = dt.Millisecond;



            connectThread = new Thread(new ThreadStart(connection));

            connectThread.Start();

        }      

            



        public void connection()

        {



            while (connected)

            {

                try

                {

                    clientSocket = new TcpClient(ip, port);



                    ns = clientSocket.GetStream();



                    sr = new StreamReader(ns);



                    connected = false;



                    this.SendMessage();



                }

                catch (Exception e)

                {

                    Console.WriteLine("Could not connect to Server! Next connection later.");



                    connected = true;



                    Thread.Sleep(5000);



                }

            }

            

        }





        public void SendMessage()

        {

            //循环发送message

            while(true)

            {

                DateTime dt = DateTime.Now;

                string time = dt.ToString() + "." + dt.Millisecond.ToString();

                message = id + " at " + time ;

                Console.WriteLine(message);



                try

                {

                    Byte[] bytes = Encoding.ASCII.GetBytes(message.ToCharArray());

                    ns.Write(bytes, 0, bytes.Length);                

                }

                catch (Exception e)

                {

                    Console.WriteLine("服务器断开");

                    

                    break;

                }

                Thread.Sleep(1234);

            }                

                

        }



        public static void Main(string[] args)

        {

            Client client = new Client(); 

        }



    }

...全文

486 25 打赏收藏转发到动态举报

写回复

用AI写文章

25 条回复

切换为时间正序

请发表友善的回复…

发表回复

lzsh0622 2009-11-18

打赏
举报

[Quote=引用 21 楼 cqsfd 的回复:]
19楼的可以提供些UDP传输文件的资料吗？
[/Quote]

你用私信给我发个邮箱地址。项目中用到过,我稍微整理一下,给你发过去。

PS: 技术外的信息，本人不感兴趣，不再回复。

qldsrx 2009-11-18

打赏
举报

[Quote=引用 19 楼 lzsh0622 的回复:]
引用 13 楼 qldsrx 的回复:
鄙视上来就要别人用UDP的，难道看不出楼主是个新手吗？新手适合用UDP吗？我都用不好UDP呢，相信你也是，就不要随便叫别人用UDP了，那个数据同步校验需要自己处理，很麻烦的。

UDP和TCP是一个层次，哪个适合用哪个，和新手不新手有关系吗？　你用不好，见议你多看看，自己还没用好的技术点，给别人介绍经验时慎重。
[/Quote]
你就用得好了吗？别只复制些人家的代码来，你贴点自己的可行代码出来看看，只有嘴上工夫有什么用。

cqsfd 2009-11-18

打赏
举报

我之前也做过服务器端的，但是不能公开给你
给你一个我认为非常有价值的链接吧，自己好好体会下
http://topic.csdn.net/u/20091014/16/523754e5-8897-4223-9bf1-f44bcbdc082c.html

另外，19楼的前辈可以提供些UDP传输文件的资料吗？100分求，可直接运行,带说明的300分+

满衣兄 2009-11-18

打赏
举报

tcplistener本身就应该是多线程，你接到新连接的时候是否需要再创建线程？
建议先找几个可以正确运行的例子看一下。

lzsh0622 2009-11-18

打赏
举报

[Quote=引用 13 楼 qldsrx 的回复:]
鄙视上来就要别人用UDP的，难道看不出楼主是个新手吗？新手适合用UDP吗？我都用不好UDP呢，相信你也是，就不要随便叫别人用UDP了，那个数据同步校验需要自己处理，很麻烦的。
[/Quote]

UDP和TCP是一个层次，哪个适合用哪个，和新手不新手有关系吗？　你用不好，见议你多看看，自己还没用好的技术点，给别人介绍经验时慎重。

baishengjie 2009-11-18

打赏
举报

[Quote=引用 17 楼 hack95 的回复:]
C# code listener.Bind(new IPEndPoint(aryLocalAddr[0], nPortListen));
listener.Listen(50000);
[/Quote]

楼上这个是什么意思，可否解释下

柳晛 2009-11-18

打赏
举报

            listener.Bind(new IPEndPoint(aryLocalAddr[0], nPortListen));

            listener.Listen(50000);

baishengjie 2009-11-18

打赏
举报

[Quote=引用 11 楼 yuxuanji 的回复:]
C# codeif (!clients.Contains(socket))
{
clients.Add(socket);

Thread listenThread=new Thread(new ThreadStart(listen));

listenThread.Start();
}

你这个socket对所有客户端来说都是同一个实例，当然只有一个运行listen的线程跑起来了
[/Quote]

我这么写是为了监听一个客户端开一个线程去执行接收信息。调试的时候也能跑起来多个线程监听不同端口，可就是收到信息有错误，显示出来时空的

baishengjie 2009-11-18

打赏
举报

[Quote=引用 12 楼 yfqvip 的回复:]
TcpListener t = new TcpListener(。。。);
t.Start(20);//这个参数应该是指定最大挂起连接数的，也就是允许的最大连接数。你试一下吧。
[/Quote]
我试了，也不是这个问题

baishengjie 2009-11-18

打赏
举报

恩，我知道了。我原先也看了有关异步的资料，我写这个例子是先学习同步，然后在学习异步的。你给的例子我下载好了，我先把我这个程序的问题排除了在学习异步的，感谢 qldsrx 和每个给与帮助的人

qldsrx 2009-11-18

打赏
举报

[Quote=引用 7 楼 lzsh0622 的回复:]
单一客户端可以收到信息，但多个的话就不能收到信息用UDP
[/Quote]
鄙视上来就要别人用UDP的，难道看不出楼主是个新手吗？新手适合用UDP吗？我都用不好UDP呢，相信你也是，就不要随便叫别人用UDP了，那个数据同步校验需要自己处理，很麻烦的。

这里有个例子我上传Socket的例子，如果你是VS2008的话，可以下载了运行下，同时开多个客户端没任何问题。C#实现简单的Socket文件传输示例主要看服务器端是如何异步接受请求的，以及客户端又是如何异步创建连接的。连接创建后为了保持接收发送的顺序，我采用的同步收发，如果是传输消息，不需要考虑顺序的话，数据收发也可以采用异步。

想要更多Socket的示例，就到MSDN上找。

满衣兄 2009-11-18

打赏
举报

TcpListener t = new TcpListener(。。。);
t.Start(20);//这个参数应该是指定最大挂起连接数的，也就是允许的最大连接数。你试一下吧。

LutzMark 2009-11-18

打赏
举报

   if (!clients.Contains(socket))

                    {

                        clients.Add(socket);



                        Thread listenThread = new Thread(new ThreadStart(listen));



                        listenThread.Start();

                    }

你这个socket对所有客户端来说都是同一个实例，当然只有一个运行listen的线程跑起来了

满衣兄 2009-11-18

打赏
举报

C++在使用tcp的时候需要指定连接个数的，也就是说当连接个数大于这个数字的时候其它连接就会被丢弃。C#应该同理，我帮你查一下看看。

baishengjie 2009-11-18

打赏
举报

[Quote=引用 7 楼 lzsh0622 的回复:]
单一客户端可以收到信息，但多个的话就不能收到信息用UDP
[/Quote]
可能是我没表达清楚，是服务器可以收到单一客户端信息，收不到多个的！

baishengjie 2009-11-18

打赏
举报

[Quote=引用 5 楼 qldsrx 的回复:]
好糟糕的代码，我想没人愿意看它，典型的线程滥用的例子。

自己创建Thread类的对象，必须要全局捕获，在程序退出事件中好关闭所有正在运行的Thread，否则程序将不能正常退出。所以Thread不适合大量的线程操作，这种情况应该使用Socket自带的异步方法操作，让系统管理线程池。
[/Quote]
初写socket，对Thread运用还不熟练，学习中

lzsh0622 2009-11-18

打赏
举报

单一客户端可以收到信息，但多个的话就不能收到信息用UDP

baishengjie 2009-11-18

打赏
举报

[Quote=引用 2 楼 ruby0602 的回复:]
rec > messageStr[CurrentSocketNo].Length情况没判断
[/Quote]
rec是为了后来截取messageStr[CurrentSocketNo]中有用信息的，你说这种情况就不用截取，这个地方没问题的，这个地方我试过的

qldsrx 2009-11-18