多线程Udp套接字编程

Question

这是我的客户端和服务器的代码。

class Client1{Client1（int no）{try{String message；message=“Hello this is client”+no；byte[]b=message.getBytes（）；DatagramPacket dp=new DatagramPacket（b,b length,inetAddress.getLocalHost（）,3700）；DatagramSocket sender=new DatagramSocket（）；sender.send(dp)；}catch（异常e）{system.out.println（“客户端关闭”）；}}}

则我的服务器类是

class Server1{

int cnt=0;
String s1;
Server1()
{

    try {
            byte[] buffer = new byte[65536];
            DatagramPacket  incoming = new DatagramPacket(buffer, buffer.length);
            DatagramSocket  ds = new DatagramSocket(3700);
            ds.receive(incoming);
            byte[] data = incoming.getData();
            String s = new String(data, 0, incoming.getLength());
            System.out.println("Port" + incoming.getPort() + " on " + incoming.getAddress() + " sent this message:");

            System.out.println(s.toUpperCase());
            }

            catch (IOException e) 
            {
            System.err.println(e); 
            }
}   

}

那么我的可运行实现是

类prothread实现Runnable{

//long time=0;
    //int portno;
    int flag=0; // this is to differentiate between a server and client
    private String capitalizedSentence;
prothread(long l)
{
    if(l==1)
        { // it is a server
            flag=1;
        }
        else
        {
            flag=(int) l;
        }
}

@Override
public void run(){
    // TODO Auto-generated method stub

        System.out.println("Starting thread");    
        if(flag==1)// Code for server
            {
           Server1 s=new Server1();

            }
            else   // code for client
            {                   
              Client1 c=new Client1(flag);

             }

    }

}

最后，部署此客户端和服务器的类是

公共类Samplepro31{

public static void main(String[] args) {
    // First i'm going to create a server and then clients for it
        int i=1;
        int cnt=0;

         prothread[] p;
        Thread[] th;
        Random r =new Random();
         // Array has been declared 
        p=new prothread[10];// Memory allocated to it
        th= new Thread[1000];
        p[0]=new prothread(1);
        cnt=1;
        //p[0].setportno(cnt);
        th[0]=new Thread(p[0]);
        th[0].start();
        while(cnt<3)
        {

                p[cnt]=new prothread(cnt); 
                // here send the port number
                th[cnt]=new Thread(p[cnt]);
                //p[cnt1].setportno(cnt1);
                th[cnt].start();
                cnt++;
        }

  }

}

所以我遇到的问题是一个服务器同时只有一个客户端在运行，而不是两个客户端在运行，我得到的O/P是：

启动线程启动线程启动线程在Clinet的构造函数2内部java.net.bindexception：Address已经在使用：无法绑定HELLO这是客户端2

有人能告诉我我做错了什么吗？

Answer 1

不要将客户端绑定到任何特定端口。让实现选择要绑定到的可用端口。