如何將線程添加到我的服務器？

Question

我是Java初學者，我有一個任務來構建P2p文件共享Java應用程序。 我開始創建服務器和客戶端。客戶端可以發送消息給服務器和服務器響應。我相信下一步應該是將Thread插入到服務器類中。我讀了所有關於它，並試圖萌芽，我不能把它關閉。我希望有一個人可以幫助我。 這裏是服務器類：

import java.net.*; 
import java.io.*; 
import java.util.*; 

public class Server { 

    private static ServerSocket serverskiSoket; 
    private final static int PORT = 3334; 

    public static void main(String[] args) { 
    System.out.println("Server se povezuje na port: "+PORT); 

    try { 
     serverskiSoket = new ServerSocket(PORT); 
     System.out.println("Server aktivan: " + serverskiSoket); 
     System.out.println("Ceka se klijent ..."); 
    } catch (IOException ex) { 
     String dodatnaPoruka = ex.getMessage().toString(); 

     if (dodatnaPoruka.equals("Address already in use: JVM_Bind")) 
      System.out.println("Nemoguce je povezati se na port "+ PORT +" jer je zauzet od strane drugog servera."); 
      System.exit(1); 
    } 

    do { 
     handleClient(); 
    } while(true); 
    } 

    private static void handleClient() { 
    Socket link = null; 

    try { 
     link = serverskiSoket.accept(); 
     System.out.println("Klijent povezan: " + link); 

     Scanner ulazniTok = new Scanner(link.getInputStream()); 
     PrintWriter izlazniTok = new PrintWriter(link.getOutputStream(), true); 

     int brojPoruka = 0; 
     String poruka = ulazniTok.nextLine(); 

     while(!poruka.equals("zatvori")) { 
      System.out.println("Klijent kaze: " + poruka); 
      brojPoruka++; 
      izlazniTok.println("Poruka: " + brojPoruka + ": " + poruka); 
      poruka = ulazniTok.nextLine(); 
     } 

     izlazniTok.println(brojPoruka + " poruka poslato."); 
    } catch (IOException ex) { 
     ex.printStackTrace(); 
    } finally { 
     try { 
      System.out.println("Konekcija se zatvara..."); 
      link.close(); 
     } catch(IOException ioEx) { 
      System.out.println("Diskonekcija nije moguca! \nRazlog: " + ioEx.getMessage()); 
      System.exit(1); 
     }  
    } 
    } 
} 

這裏是Client類：

import java.net.*; 
import java.io.*; 
import java.util.*; 

public class Klijent { 

    private static InetAddress host; 
    private static final int PORT = 3334; 

    public static void main(String[] args) { 
    System.out.println("Povezivanje klijenta u toku. Molim sacekajte..."); 

    try { 
     host = InetAddress.getLocalHost(); 
    } catch (UnknownHostException ex) { 
     System.out.println("ID hosta nije pronadjen"); 
     System.exit(1); 
    } 

    pristupiServeru(); 
    } 

    private static void pristupiServeru() { 
    Socket link = null; 

    try { 
     link = new Socket(host, PORT); 
     String IPAdresa = StringCutter.RaseciString(host.toString()); 
     System.out.println("Povezan na host cija je IP adresa: "+IPAdresa+", a port: "+PORT); 


     Scanner ulazniTok = new Scanner(link.getInputStream()); 
     PrintWriter izlazniTok = new PrintWriter(link.getOutputStream(), true); 

     Scanner unosKorisnika = new Scanner(System.in); 

     String poruka, odgovor; 

     do { 
     System.out.println("Unesite poruku: "); 
     poruka = unosKorisnika.nextLine(); 
     izlazniTok.println(poruka); 
     odgovor = ulazniTok.nextLine(); 
     if (!odgovor.contains("primljeno")) 
      System.out.println("Rekli ste serveru: " + odgovor); 
     else System.out.println(odgovor); 
    } while (!poruka.equals("zatvori")); 
    } catch (IOException ex) { 
    ex.printStackTrace(); 
    } finally { 
    try { 
     System.out.println("\n*Zatvara se konekcija sa serverom...*"); 
     link.close(); 
    } catch (IOException ex){ 
     System.out.println("Diskonekcija je nemoguca"); 
     System.exit(1); 
    } 
    } 
} 
} 

Answer 1

這裏做的一個非常簡單的方法 - 我沒有通過所有的代碼閱讀，因此，測試是爲了確保它不會破壞任何東西。

private static void handleClient() { 
    new Thread() { 
    public void run() { 
     Socket link = null; 
     ... 
     } catch(IOException ioEx) { 
      System.out.println("Diskonekcija nije moguca! \nRazlog: " + ioEx.getMessage()); 
      System.exit(1); 
     }  
    } // end outer try 
    }.start() // end thread 
} 

基本上，您每次都在一個新線程中執行處理程序。它看起來像處理程序不需要將數據返回到主循環，所以應該沒問題。

除了那麼你可能有太多的線程，所以你真的應該看看Executors.newFixedThreadPool()（http://java.sun.com/j2se/1.5.0/docs/api/java/util/concurrent/Executors.html#newFixedThreadPool%28int%29）的池。

編輯：瀏覽代碼，我能看到的一個問題是您的輸出可能會在線程間交錯。不知道你是否在乎 - 我無法閱讀任何輸出語言。

Answer 2

你看過Java插座教程嗎？他們給出了其中一個頁面上的多線程服務器的示例。嘗試模仿他們在他們的代碼中做什麼（你將需要創建另一個類）。 您可以在此頁面底部的示例代碼：http://java.sun.com/docs/books/tutorial/networking/sockets/clientServer.html

查找標題爲「支持多個客戶端」