import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetAddress;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketAddress;


public class ServerDemo {


    /** IPv4のアドレス構造を採用してサービスを構築する場合、IPV4_HOSTを使用します。 */
    public static final String IPV4_HOST = "0.0.0.0";


    /** IPv6のアドレス構造を採用してサービスを構築する場合、IPV6_HOSTを使用します。 */
    public static final String IPV6_HOST = "::";


    public static void main(String[] args) {
        int serverPort = 10000;
        try (ServerSocket serverSocket = new ServerSocket()) {
            // アドレス再利用を設定します。
            serverSocket.setReuseAddress(true);
            // サーバーアドレスとポートをバインドします。ここではIPv4を使用します。
            serverSocket.bind(new InetSocketAddress(InetAddress.getByName(IPV4_HOST), serverPort));
            System.out.println("Server is listening on port " + serverPort);


            while (true) {
                // クライアント接続を受け付けます。
                Socket clientSocket = serverSocket.accept();
                System.out.println("New client connected: " + clientSocket.getRemoteSocketAddress());


                // クライアントリクエストを処理します。
                handleClientRequest(clientSocket);
            }
        } catch (IOException e) {
            System.err.println("Failed to create server socket: " + e.getMessage());
        }
    }


    /**
     * 処理関数。具体的な業務に応じて実装します。ここでは例として示します。
     * この関数の役割は、clientの入力をそのままclientに返すことです。
     */
    private static void handleClientRequest(Socket clientSocket) {
        try (InputStream inputStream = clientSocket.getInputStream();
             OutputStream outputStream = clientSocket.getOutputStream()) {


            // クライアントから送信されたデータを読み取ります。
            byte[] buffer = new byte[1024];
            int bytesRead;
            while ((bytesRead = inputStream.read(buffer)) != -1) {
                // 受信したデータをそのままクライアントに返信します。
                outputStream.write(buffer, 0, bytesRead);
            }


        } catch (IOException e) {
            // クライアントが接続を切断した後
            System.err.println("Failed to handle client request: " + e.getMessage());
        } finally {
            try {
                clientSocket.close();
            } catch (IOException e) {
                System.err.println("Failed to close client socket: " + e.getMessage());
            }
        }
    }
}