Java服务器和客户端在一个程序中

Question

我想同步2个集合。如果服务器端有什么变化，连接的客户端就会更新。我有一个非常基本的问题。我现在需要复制我的java项目，并在一个项目中编程服务器，在另一个项目中编程客户端吗？但这听起来像是相当多不必要的工作。我不能在一个项目中实现这一切，然后在一个主项目中启动服务器和客户端吗？我需要线程吗？我有点纠结于最好的方法是什么。提前谢谢。

Answer 1

因为codereview不允许我的代码，因为它还不起作用，我现在把它发布在这里，希望你能帮助我。

public class Server implements Runnable{
private String hostName = "127.0.0.1";
private int portNumber;
private ServerSocket serverSocket;
private Socket clientSocket;

public Server(int port){
    this.portNumber = port;
}

public void run(){
    String line = "";
    PrintWriter out = null;
    BufferedReader in = null;
    BufferedReader stdIn = null;

    try{
        this.serverSocket = new ServerSocket(this.portNumber); 
    }catch (IOException e) {
        System.out.println("Could not listen on port");
    }

    try{
        clientSocket = serverSocket.accept();
    } catch (IOException e) {
        System.out.println("Accept failed");
    }

    try{
        in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
        out = new PrintWriter(clientSocket.getOutputStream(), true);
    }catch (IOException e) {
        System.out.println("Read failed");
    }

    while(true){

        try{
            line = in.readLine();

        }catch (IOException e) {
            System.out.println("Read failed");
        }

        System.out.println("line: "+line);
    }


}

protected void finalize(){
//Objects created in run method are finalized when
//program terminates and thread exits
    try{
        serverSocket.close();
    }catch (IOException e) {
        System.out.println("Could not close socket");
    }
 }

}

public class Client implements Runnable{
private String hostName = "127.0.0.1";
private int portNumber = 6602;
private Socket clientSocket = null;

public Client(Socket client){
    this.clientSocket = client;
}

public Client(int portNumber, String hostName){
    this.portNumber = portNumber;
    this.hostName = hostName;
}

public void run(){
    String line;
    PrintWriter out = null;
    BufferedReader in = null;
    BufferedReader stdIn = null;

    try{
        if(clientSocket == null)
            this.clientSocket = new Socket(this.hostName, this.portNumber);
        out = new PrintWriter(clientSocket.getOutputStream(), true);
        in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
        stdIn = new BufferedReader(new InputStreamReader(System.in));
        out.println("Test string from client");
    }catch (IOException e){
        System.out.println("in or out failed");
    }   

}

}

public class DebugServerClient {

public static void testServerClient(){
    int port = 6602;
    Server srv = new Server(port);
    Client clt = new Client(port, "127.0.0.1");

    Thread s = new Thread(srv);
    s.start();

    Thread c = new Thread(clt);
    c.start();


}

}

我现在把它改成了这个，看起来很管用。这是个好办法吗？