java - ピアツーピア通信 - Java

Question

ピアが他のピアと通信する必要があるプログラムを作成する必要があります。漠然と構造を作成しましたが、機能しません。私は間違いを犯していることを知っていますが、問題を理解することはできません. サーバー ソケットをスレッドとして作成し、サーバー ソケット スレッドと通信するクライアント ソケット スレッドを作成します。ポートに入った後、プログラムは何もしません...

    server.java
    ------------
    class server
   {
       public static void main(String argv[]) throws Exception
       {

          //server socket
          ServerSocket server = new ServerSocket(1001);
          Socket client;
          while(true)
          {
            client = server.accept();
            Thread t = new Thread(new acceptconnection(client));
            t.start();
          }
      }
   }

   class acceptconnection implements Runnable
   {
       BufferedReader inFromClient,inn;
       DataOutputStream ds;
       Socket clientsocket;
       acceptconnection (Socket socket) throws IOException
       {          
          this.clientsocket = socket;
          inn = new BufferedReader (new InputStreamReader(System.in));
          inFromClient =new BufferedReader(new                        
                        InputStreamReader(clientsocket.getInputStream()));
          ds = new DataOutputStream(clientsocket.getOutputStream());
      }

      @Override
      public void run ()
      {
         try 
         {
           String clientSentence, inp;
           while(( clientSentence = inFromClient.readLine())!=null)
           {                   
              System.out.println("message from remote socket #" +   
                 clientsocket.getRemoteSocketAddress()+ clientSentence);

              inp=inn.readLine();
              ds.writeBytes(inp + "\n");
              ds.flush();
           }
        }
     }
  }

   client.java
   ------------
   class client
   {
      public static void main(String argv[]) throws Exception
      {   
        String sentence;
        String modifiedSentence;
        Socket clientSocket = null;
        //  ss = new  ServerSocket(10002);
        clientSocket = new Socket("localhost", 1001);

        BufferedReader inFromUser = new BufferedReader( new 
           InputStreamReader(System.in));
        DataOutputStream outToServer = new 
           DataOutputStream(clientSocket.getOutputStream());
        BufferedReader inFromServer = new BufferedReader(new 
           InputStreamReader(clientSocket.getInputStream()));

        System.out.println("Enter you name:"); 
        sentence = inFromUser.readLine();  
        outToServer.writeBytes(sentence + "\n" );  

        System.out.println("Enter the port u want:"); 
        sentence = inFromUser.readLine();  
        int serverport = Integer.parseInt(sentence);

        Thread t = new Thread(new acceptconnection1(serverport));
        t.start();
        String msg;        

        clientSocket.close();
     }
  }

 class acceptconnection1 implements Runnable {
 BufferedReader inserver, inn; 
 DataOutputStream ds;
 Socket socket, peersocket;

         int serverport ;

      Socket clientSocket = null;
     acceptconnection1 (int serverport) throws IOException{   
     this.serverport = serverport;}

       public void run () {
     ServerSocket ss;


        String cs,a;
    try {
        ss = new ServerSocket(serverport);

        while(true)
        {
        peersocket =ss.accept();

        Thread t = new Thread(new abc(peersocket) );
        t.start();
        }}}


      class abc implements Runnable {
BufferedReader inn,inp;
DataOutputStream ds;
   Socket peersocket;
public abc(Socket peersocket) throws IOException{
this.peersocket = peersocket;


inn = new BufferedReader (new InputStreamReader(System.in));
      inp =new BufferedReader(new InputStreamReader(peersocket.getInputStream()));
  ds = new DataOutputStream(peersocket.getOutputStream());

}

@Override
public void run()
    {
   String clientSentence;

    Socket client = new Socket();
    try {
        while(( clientSentence = inp.readLine())!=null)
                {

                    ds.writeBytes("wake up!");
                    //System.out.println("message=" + clientSentence);

                }