【Java×Socket通信】リアルタイムチャットアプリを自作！初心者でも動かせるコード解説付き

「Javaでリアルタイム通信を学びたいけど難しそう」
「チャットアプリのような双方向のやりとりを作れるようになりたい」
そんな悩みをお持ちの方にぴったりなのが、Javaで作る簡易チャットアプリの自作体験です。

Socket通信を使えば、1対1の通信をリアルタイムで実現できます。
シンプルな構造から始めることで、ネットワーク通信の仕組みとエラー処理の基本が自然と身につきます。

この記事では、初心者でも作れるチャットアプリを、
プロ目線でわかりやすくコード付きで解説します。

チャットアプリとは？
1. リアルタイム通信を学ぶ最高の題材です
構成と必要な機能
1. 最低限2つのプログラムが必要です
サーバー側のコード：ChatServer.java
クライアント側のコード：ChatClient.java
躓きやすいエラーと対策
応用アイデアでさらに実用的に
完成形構成のまとめ
まとめ：リアルタイム通信はJavaで学べる

チャットアプリとは？

リアルタイム通信を学ぶ最高の題材です

結論：チャットアプリを作ると、ネットワーク通信の基礎が一通り身につきます。

Javaには Socket という通信の仕組みが用意されており、
これを使うと、プログラム同士でメッセージを送ったり受け取ったりできます。

リアルタイム通信は、LINEやゲームなどあらゆる分野で使われています。
この仕組みを自作して体験することは、実践力アップに直結します。

構成と必要な機能

最低限2つのプログラムが必要です

結論：サーバー側とクライアント側をそれぞれ作ります。

構成は以下のとおりです：

src/
├─ ChatServer.java
└─ ChatClient.java

実現する機能：

クライアントがメッセージを送信
サーバーがメッセージを受信し、全員に中継
双方向のやりとりをスレッドで並行処理

サーバー側のコード：ChatServer.java

import java.io.*;
import java.net.*;
import java.util.*;

public class ChatServer {
    private static final int PORT = 5000;
    private static List<PrintWriter> clientWriters = new ArrayList<>();

    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(PORT);
        System.out.println("サーバー起動：" + PORT + "番ポートで待機中...");

        while (true) {
            Socket socket = serverSocket.accept();
            System.out.println("クライアント接続：" + socket);
            new ClientHandler(socket).start();
        }
    }

    static class ClientHandler extends Thread {
        private Socket socket;
        private PrintWriter out;

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

        public void run() {
            try (
                BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            ) {
                out = new PrintWriter(socket.getOutputStream(), true);
                clientWriters.add(out);

                String msg;
                while ((msg = in.readLine()) != null) {
                    System.out.println("受信：" + msg);
                    for (PrintWriter writer : clientWriters) {
                        writer.println(msg);
                    }
                }
            } catch (IOException e) {
                System.out.println("通信エラー：" + e.getMessage());
            } finally {
                if (out != null) clientWriters.remove(out);
                try {
                    socket.close();
                } catch (IOException e) {
                    System.out.println("ソケット閉鎖失敗");
                }
            }
        }
    }
}

クライアント側のコード：ChatClient.java

import java.io.*;
import java.net.*;

public class ChatClient {
    public static void main(String[] args) throws IOException {
        Socket socket = new Socket("localhost", 5000);
        System.out.println("サーバーに接続しました");

        BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
        BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in));

        new Thread(() -> {
            try {
                String fromServer;
                while ((fromServer = in.readLine()) != null) {
                    System.out.println("サーバーから：" + fromServer);
                }
            } catch (IOException e) {
                System.out.println("読み取りエラー");
            }
        }).start();

        String input;
        while ((input = stdIn.readLine()) != null) {
            out.println(input);
        }

        socket.close();
    }
}