java socket编程对话

Question

大家好，我想在服务器和客户端之间进行 java 套接字对话，它与第一条消息一起工作，然后对话停止，在我的情况下，我想从客户端发送 hi 消息并从服务器接收 hi 消息，然后服务器必须还发送另一个消息“输入要检查的数字”并等待输入

我的客户代码是：

public class ClientSide {
    /**
     * @param args
     * @throws Exception
     */
    public static void main(String[] args) throws Exception{
        ClientSide clientSideInstance = new ClientSide();
        clientSideInstance.run();
    }

    /**
     * @throws Exception
     */
    public void run() throws Exception{

        Socket soc = new Socket("localhost",4321);
        PrintStream printStream = new PrintStream(soc.getOutputStream());
        printStream.println("hi");
        InputStreamReader Inputreader = new InputStreamReader(soc.getInputStream());
        BufferedReader bufferedReader = new BufferedReader(Inputreader);
        String receivedMsg =  bufferedReader.readLine();
        System.out.println(receivedMsg);
    }
}

我的服务器代码是：

public class ServerSide {
    private PrintStream printStream;

    /**
     * @param args
     * @throws Exception
     */
    public static void main(String[] args) throws Exception{
        ServerSide serverSideInstance = new ServerSide();
        serverSideInstance.run();
    }

    /**
     * @throws Exception
     */
    public void run() throws Exception{

        ServerSocket socket = new ServerSocket(4321);
        Socket soc = socket.accept();
        InputStreamReader Inputreader = new InputStreamReader(soc.getInputStream());
        BufferedReader bufferedReader = new BufferedReader(Inputreader);

        String receivedMsg =  bufferedReader.readLine();
        System.out.println(receivedMsg);

        // parsing client massage 
        if(receivedMsg.trim().equalsIgnoreCase("hi")){

            printStream = new PrintStream(soc.getOutputStream());
            printStream.println("hi");

            printStream.println("enter number to check ");

            InputStreamReader InputreaderForPrimeNumber = new InputStreamReader(soc.getInputStream());
            BufferedReader bufferedReaderForPrimeNumber = new BufferedReader(InputreaderForPrimeNumber);
            String number = bufferedReaderForPrimeNumber.readLine();

            if(isPrime(Integer.parseInt(number))){
                printStream.println("yes - it is Prime number :)");
            }else{
                printStream.println("No - it is not a Prime number :(");
            }

        }
    }

    private boolean isPrime(int n) {
        for(int i=2;i<n;i++) {
            if(n%i==0)
                return false;
        }
        return true;
    }
}

有人可以帮忙吗？

Answer 1

你有一些错误，实施确实没有完成。
这是您修复的代码。另外，请注意 1 不是素数 AFAIK。
当客户端发送“再见”而不是数字时，对话结束。

服务器：

        import java.io.BufferedReader;
        import java.io.InputStreamReader;
        import java.io.PrintStream;
        import java.net.ServerSocket;
        import java.net.Socket;

        public class ServerSide {
            private PrintStream printStream;

            /**
             * @param args
             * @throws Exception
             */
            public static void main(String[] args) throws Exception{
                ServerSide serverSideInstance = new ServerSide();
                serverSideInstance.run();
            }

            /**
             * @throws Exception
             */
            public void run() throws Exception{

                ServerSocket socket = new ServerSocket(4321);
                Socket soc = socket.accept();
                InputStreamReader Inputreader = new InputStreamReader(soc.getInputStream());
                BufferedReader bufferedReader = new BufferedReader(Inputreader);

                printStream = new PrintStream(soc.getOutputStream());

                while (true){
                    String receivedMsg =  bufferedReader.readLine();
                    System.out.println(receivedMsg);

                    // parsing client massage 
                    if(receivedMsg.trim().equalsIgnoreCase("hi")){
                        printStream.println("hi");
                        printStream.println("enter number to check: ");
                    }else if (receivedMsg.trim().equalsIgnoreCase("bye")){
                        // printStream.println("bye");
                        break;
                    }else{
                        if(isPrime(Integer.parseInt(receivedMsg))){
                            printStream.println("Yes - it is a prime number :)");
                        }else{
                            printStream.println("No - it is not a prime number :(");
                        }
                        printStream.println("enter number to check: ");
                    }
                }
            }

            private boolean isPrime(int n) {
                if (n==1) return false;

                for(int i=2;i<n;i++) {
                    if(n%i==0){
                        return false;
                    }
                }
                return true;
            }

        }

客户：

    import java.io.BufferedReader;
    import java.io.InputStreamReader;
    import java.io.PrintStream;
    import java.net.Socket;

    public class ClientSide {
        /**
         * @param args
         * @throws Exception
         */
        public static void main(String[] args) throws Exception{
            ClientSide clientSideInstance = new ClientSide();
            clientSideInstance.run();
        }

        /**
         * @throws Exception
         */
        public void run() throws Exception{
            BufferedReader brr = new BufferedReader(new InputStreamReader(System.in));
            Socket soc = new Socket("localhost", 4321);
            PrintStream printStream = new PrintStream(soc.getOutputStream());
            printStream.println("hi");

            InputStreamReader Inputreader = new InputStreamReader(soc.getInputStream());
            BufferedReader bufferedReader = new BufferedReader(Inputreader);
            String receivedMsg =  bufferedReader.readLine().trim();
            System.out.println(receivedMsg);

            while (true){
                receivedMsg =  bufferedReader.readLine();
                System.out.println(receivedMsg);

                if (receivedMsg.equalsIgnoreCase("enter number to check: ")){
                    String userMessage = brr.readLine().trim(); // read from stdin
                    printStream.println(userMessage); // send message/number to server
                    if (userMessage.equalsIgnoreCase("bye")){
                        break;
                    }
                    receivedMsg =  bufferedReader.readLine().trim();
                    System.out.println(receivedMsg);
                }
            }
        }
    }