0

マルチスレッド サーバー ソケットを作成しようとしました。使用可能なファイルの文字列またはファイルをストリームとして送信できます。問題は、要求されたファイルをストリームとして送信するelseブロックが一度だけ機能することです。コードの問題はどこにあり、なぜ一度だけ応答するのですか?

public class ServerThread extends Thread {

Socket socket = null;

public ServerThread(Socket socket) {
    this.socket = socket;
}


public void run() {
    try {
        String message = null;
        PrintStream ps = null;
        String string = null;
        File file = null;


        BufferedReader bufferedreader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        ps = new PrintStream(socket.getOutputStream());

        while ((message = bufferedreader.readLine()) != null) {

            if (message.equals("list")) {
                ps.println(Arrays.toString(getServerFiles()));

            } else {
                message = "FilesServer\\" + message;
                file = new File(message);

                //JOptionPane.showConfirmDialog(null, message);
                if (file.exists()) {
                    BufferedInputStream bfInStream =
                            new BufferedInputStream(new FileInputStream(message));
                    BufferedOutputStream bufOutStream =
                            new BufferedOutputStream(socket.getOutputStream());

                    byte[] buffer = new byte[1024];
                    int read = 0;

                    while ((read = bfInStream.read(buffer)) != -1) {
                        bufOutStream.write(buffer, 0, read);
                        bufOutStream.flush();
                    }
                    bufOutStream.close();
                    System.out.println("File transfered");
                }
            }
        }
    } catch (Exception e) {
        //JOptionPane.showConfirmDialog(null, e.getMessage());
    }
}

private static String[] getServerFiles() {
    String result[];
    File folder = new File("FilesServer\\");
    File[] listOfFiles = folder.listFiles();



    result = new String[listOfFiles.length];
    for (int i = 0; i < listOfFiles.length; i++) {
        if (listOfFiles[i].isFile()) {
            result[i] = listOfFiles[i].getName();
        }
    }
    return result;
}

}

上記のクラスは、このクラスから呼び出されます。

public class Server {

private int defaultPort = 8088;

public static void main(String[] args) throws IOException {
    new Server().InitServer();
}


private void InitServer() throws IOException{
    ServerSocket serversocket = new ServerSocket(8081);

    while(true){
        Socket socket = serversocket.accept();
        new ServerThread(socket).start();
    } 
}

}

4

2 に答える 2

0

サーバー アプリケーションの場合は、ServerSocket を使用する必要があります。ServerSocket は、新しいクライアントが (accept() メソッドを介して) ファイルを要求するたびに、新しいソケットを作成する必要があります。次に、新しく作成されたソケットにバイトを送信し、安全に閉じることができます。

于 2013-10-20T07:37:18.340 に答える