java - Java クライアント ブロック サーバー アプリケーション

Question

クライアント/サーバー アプリケーションがあります。クライアントからいくつかの情報を送信し、サーバーがこの情報を読み取り、操作を実行して結果をクライアントに送信します。

クライアントに結果が出るのを待つと、サーバーアプリケーションがブロックされます。サーバーは情報を受け取りますが、アプリケーションを実行しません...クライアントで結果を待たないと、サーバーはアプリケーションを実行しますが...クライアントの結果がありません。

ps: これは宿題用です。通常、これには rmi を使用する方がよいと思います。

ここに私のクライアントコード:

public static void transfertFile(BufferedReader in,Socket so,long sizeFile) throws IOException{
    BufferedReader buffRes;
    buffRes = new BufferedReader(new InputStreamReader(so.getInputStream()));
    PrintWriter printOut;      
    printOut = new PrintWriter(so.getOutputStream());
    String taille = String.valueOf(sizeFile);
    printOut.println(taille);
    printOut.flush();
    printOut.println("client.Calc");
    printOut.flush();
    printOut.println("add");
    printOut.flush();
    printOut.println("10");
    printOut.flush();
    printOut.println("2");
    printOut.flush();
    String str;
    int n;
    String line;
    System.out.println("file=>"+ "\n\n");
    System.out.println("Sending file...");
    while((line = in.readLine())!= null){
         str = line;
         System.out.println(str);
         printOut.println(str);
         printOut.flush();
    }
    in.close();
    String res="";
    res = buffRes.readLine();
    System.out.println("res:"+res);
}

サーバーでの最初の機能（実行するファイルと情報を受け取るだけです）：

public static String[] transfert(InputStream in, OutputStream out) throws IOException, InterruptedException {
        //reception des params et de la class
        buffIn = new BufferedReader(new InputStreamReader(in));
        String size = buffIn.readLine();
        System.out.println("size:"+size);
        String nomClasse = buffIn.readLine();
        System.out.println("Name class:" + nomClasse + " !");
        String methode = buffIn.readLine();
        System.out.println("Method :" + methode + " !");
        String param1 = buffIn.readLine();
        System.out.println("Parameter 1 :" + param1 + " !");
        String param2 = buffIn.readLine();
        System.out.println("Parameter 2:" + param2 + " !");
        String fileReadLine ="";
        String file ="";
        while((fileReadLine = buffIn.readLine()) != null){
            System.out.println(fileReadLine);
            file += fileReadLine;
        }

        System.out.println("file :" + file + " !");
 //       byte buff[] = DatatypeConverter.parseHexBinary(file);
        byte[] buff = file.getBytes();
        out.write(buff);
        out.close();
        out.flush();
        //Tableau qui contient les valeurs à connaitre pour excevuter la classe
        String param[] = new String[4];
        param[0] = nomClasse;
        param[1] = methode;
        param[2] = param1;
        param[3] = param2;
        return param;
    }

そして、メソッドを実行して結果をクライアントに送信する2番目の関数:

public void reflexion(String[] param, OutputStream out) {
        String className = param[0];
        Class saClass;
        try {
            saClass = Class.forName(className);
            try {
                Object obj = saClass.newInstance();
                try {
                    Method m = saClass.getMethod(param[1], int.class, int.class);
                    int res;
                    try {
                        Object[] args = {Integer.parseInt(param[2]), Integer.parseInt(param[3])};
                        res = (int) m.invoke(obj, args);
                        String taille = Integer.toString(res);
                        taille = "Le resultat du calcul est:"+res+"\r";
                        System.out.println(taille);
                        System.out.println("Envoie du resultat...");
                        PrintWriter printOut;
                        printOut = new PrintWriter(out);
                        printOut.flush();
                        printOut.checkError();
                        printOut.print(taille);
                        printOut.flush();
                        printOut.close();
                        System.out.println("fin");
                    } catch (IllegalArgumentException ex) {
                        Logger.getLogger(AcceptClient.class.getName()).log(Level.SEVERE, null, ex);
                    } catch (InvocationTargetException ex) {
                        Logger.getLogger(AcceptClient.class.getName()).log(Level.SEVERE, null, ex);
                    }
                } catch (NoSuchMethodException ex) {
                    Logger.getLogger(AcceptClient.class.getName()).log(Level.SEVERE, null, ex);
                } catch (SecurityException ex) {
                    Logger.getLogger(AcceptClient.class.getName()).log(Level.SEVERE, null, ex);
                }

            } catch (InstantiationException ex) {
                Logger.getLogger(AcceptClient.class.getName()).log(Level.SEVERE, null, ex);
            } catch (IllegalAccessException ex) {
                Logger.getLogger(AcceptClient.class.getName()).log(Level.SEVERE, null, ex);
            }
        } catch (ClassNotFoundException ex) {
            Logger.getLogger(AcceptClient.class.getName()).log(Level.SEVERE, null, ex);
        }



    }