套接字服務器構建問題

Question

從http://pirate.shu.edu/~wachsmut/Teaching/CSAS2214/Virtual/Lectures/chat-client-server.html在步驟3中列出的套接字服務器建立乾淨（Java版本「1.7.0_02」），並沒有錯誤運行，但它退出沒有錯誤，而不是等待接受客戶。

更新的ChatServer缺少ARG代碼：

的ChatServer：

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

public class ChatServer implements Runnable 
{ private ServerSocket  server = null; 
    private Thread   thread = null; 
    private ChatServerThread client = null; 

    public ChatServer(int port) 
    { try 
     { System.out.println("Binding to port " + port + ", please wait ..."); 
     server = new ServerSocket(port); 
     System.out.println("Server started: " + server); 
     start(); 
     } 
     catch(IOException ioe) 
     { System.out.println(ioe); } 
    } 
    public void run() 
    { while (thread != null) 
     { try 
     { System.out.println("Waiting for a client ..."); 
      addThread(server.accept()); 
     } 
     catch(IOException ie) 
     { System.out.println("Acceptance Error: " + ie); } 
     } 
    } 
    public void addThread(Socket socket) 
    { System.out.println("Client accepted: " + socket); 
     client = new ChatServerThread(this, socket); 
     try 
     { client.open(); 
     client.start(); 
     } 
     catch(IOException ioe) 
     { System.out.println("Error opening thread: " + ioe); } 
    } 
    public void start() { 
    thread = new Thread(this); 
    thread.start(); 
} 
    public void stop()     { /* no change */ } 
    public static void main(String args[]) { 
     ChatServer server = null; 
     if (args.length != 1) 
     System.out.println("Usage: java ChatServer port"); 
     else 
     server = new ChatServer(Integer.parseInt(args[0])); 
} 
} 

ChatServerThread：

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

public class ChatServerThread extends Thread 
{ private Socket   socket = null; 
    private ChatServer  server = null; 
    private int    ID  = -1; 
    private DataInputStream streamIn = null; 

    public ChatServerThread(ChatServer _server, Socket _socket) 
    { server = _server; socket = _socket; ID = socket.getPort(); 
    } 
    public void run() 
    { System.out.println("Server Thread " + ID + " running."); 
     while (true) 
     { try 
     { System.out.println(streamIn.readUTF()); 
     } 
     catch(IOException ioe) { 
      System.out.println(ioe.getMessage()); 
     } 
     } 
    } 
    public void open() throws IOException 
    { streamIn = new DataInputStream(new BufferedInputStream(socket.getInputStream())); 
    } 
    public void close() throws IOException 
    { if (socket != null) socket.close(); 
     if (streamIn != null) streamIn.close(); 
    } 
} 

Answer 1

編輯：我的更新回答一個工作解決方案。

更改這些方法在你ChatServer類爲像這些

public void start() { 
    thread = new Thread(this); 
    thread.start(); 
} 

public void stop() { 
    // You should implement this too 
} 

public static void main(String args[]) { 
    // Instantiate a CharServer with the listening port 9191 
    ChatServer chatServer = new ChatServer(9191); 
    // CharServer.start() should not be confused with Thread.start(); 
    // This calls our custom method up above, which includes a call to 
    // Thread(ChatServer).start(); 
    chatServer.start(); 

} 

其中9191是我編了一個端口號。

執行CharServer #main方法產生下面的輸出，並保持活着

Binding to port 9191, please wait ... 
Server started: ServerSocket[addr=0.0.0.0/0.0.0.0,port=0,localport=9191] 
Waiting for a client ... 
Waiting for a client ... 

你也應該實施的功能緣故stop()方法。

Answer 2

{ while (thread != null) 

你從來沒有線程，以便它都將是空 而你從來沒有創建一個線程

嘗試改變start（）方法來：

public void start()     { 
    thread = new Thread(this); 
    thread.start(); 
}