Javaソケット通信とは？TCP/IPをわかりやすく解説【コード付】

Javaの「ソケット通信」とは、ネットワーク越しに2つのプログラムがデータをやり取りする仕組みのことです。Javaでは標準ライブラリの Socket／ServerSocket クラスを使い、TCP/IPによる通信を数十行のコードで実装できます。

この記事では、Socket・ServerSocketクラスの役割の違いから、TCP接続が確立する3ウェイ・ハンドシェイクの流れまでを解説します。さらに、実際に動くサーバー／クライアントのサンプルコードも、初心者にもわかりやすく紹介します。

読み終えるころには、以下ができます。

• Java Socket／ServerSocketクラスでTCP通信を実装できる
• 3ウェイ・ハンドシェイクの流れを自分の言葉で説明できる
• try-with-resourcesで安全にソケットを閉じられる
• Java 21以降の仮想スレッドで複数クライアントに対応する方法が分かる

前提はJava 21以降（2026年9月時点の最新LTSはJava 25。最新のフィーチャーリリースはJava 27〔2026年9月15日リリース〕だが、長期運用にはLTS版のJava 25以降を推奨）とJDKの動作環境のみ。ネットワーク初心者でも追体験しやすいサンプルコード付きで解説します。

Javaソケット通信とは？

ソケット通信とは、ネットワーク上の2つのプログラムが、ソケットと呼ばれる通信口を使ってやりとりする仕組みです。

具体的には、以下のような構成です。

この2者が1対1でつながり、データをやり取りします。

ソケットとは？

「ソケット」とは、通信を行うための“窓口”のようなものです。

送る側（クライアント）と受け取る側（サーバー）が、ソケットという窓口を通じてデータをやり取りします。

Javaでは、クライアントは Socket クラスを使って接続し、サーバーは ServerSocket クラスを使って接続を待ち受けます。

ポート番号とは｜12345は空いてる？

ポート番号は、1台のマシン内で複数の通信を区別するための識別子（0〜65535）です。Javaでサーバーを立てる際は、以下のレンジを意識してください。

既にそのポートが使われていると BindException: Address already in use が発生します。使用中のポートは lsof -i :12345（macOS/Linux）や netstat -ano | findstr :12345（Windows）で確認できます。

SimpleServer を起動した状態で lsof -P -i :12345（-P を付けるとポート番号がサービス名に変換されず数字のまま表示されます）を実行すると、次のような出力になり、SimpleServerプロセスがポートを掴んでいることが分かります（PIDなどの値は実行ごとに変わります）。

$ lsof -P -i :12345
COMMAND   PID     USER   FD   TYPE             DEVICE SIZE/OFF NODE NAME
java    69398 suzuki   5u  IPv6 0x8736310458a4dfb5      0t0  TCP *:12345 (LISTEN)

ソケット通信はどうやって実現してるの？

Javaのソケット通信は、裏側でTCP（Transmission Control Protocol）という通信プロトコルを使っています。

TCPは、以下のような特徴を持っています。

つまりTCPは、確実に・順番どおり・欠けずにデータを届けてくれる「書留郵便」のような仕組みです。

JavaでSocketやServerSocketを使った通信は、基本的にこのTCP通信の仕組みにのっとって動いています。

ネットワークの知識が浅くても、Javaのソケット通信を使えば「正しく届く通信」を自然に実現できます。

3ウェイ・ハンドシェイク

3ウェイ・ハンドシェイクの流れを3ステップで見ていきましょう。

手順1：クライアント → サーバーへ「SYN」（接続要求）

クライアントが「これから通信したいよ！」とサーバーにリクエストを送ります。

このとき送られるのが「SYN（シンクロナイズ）」という信号。

手順2：サーバー → クライアントへ「SYN-ACK」（許可と応答）

サーバーはそれを受け取って、「いいよ、準備できてるよ」と返事します。

これが「SYN-ACK（シンクロナイズ＋応答）」。

手順3：クライアント → サーバーへ「ACK」（最終確認）

クライアントは、サーバーからの返事を確認して「じゃあ始めますね！」と返します。

これが「ACK（確認応答）」です。

※ 3ウェイ・ハンドシェイクの仕様詳細は RFC 9293（TCP）（2022年発行）で定義されています。

Javaソケット通信の使いどころ｜どんな場面で使われる？

「基本はわかったけれど、実務でどう使うの？」という疑問に答えます。Javaのソケット通信は、以下のような場面で使われています。

• チャットアプリ・リアルタイム通信：メッセージングアプリの土台となる技術
• 社内システムのプロセス間通信：マイクロサービス間で独自プロトコルによる通信を行う場合
• IoT・組み込み機器の制御：工場の製造ラインの機械制御など、独自プロトコルで低レイテンシが求められる場面
• オンラインゲームのサーバー間通信：プレイヤーの操作をリアルタイムに同期する処理

「HTTPで十分では？」と思うかもしれませんが、HTTPもソケット通信の上に成り立つ一プロトコルにすぎません。独自の通信ルールが必要な場面や、HTTPのオーバーヘッドを避けたい場面では、SocketやServerSocketを直接使います。

ただし、いつでも生の Socket/ServerSocket を直接書けばよいわけではありません。学習目的や小規模な独自プロトコルの試作ならこの記事のようにSocket/ServerSocketを直接使うのが分かりやすい一方、本番運用の大規模チャットサーバーやマイクロサービス基盤のように大量接続・再接続・プロトコル拡張への対応が必要になると、コネクション管理やプロトコル実装を自前で書き続けるコストが割に合わなくなります。そのタイミングでNettyのようなNIOベースの高レベルライブラリへの移行を検討するのが現実的な判断基準です。

TCPとUDPの違い｜Javaでどちらを選ぶべきか

ソケット通信にはTCP（Socket/ServerSocket）とUDP（DatagramSocket）の2種類があります。用途が大きく異なるため、Javaで実装する前に違いを押さえておきましょう。

この記事で扱うのはTCPです。「データが確実に順番どおりに届いてほしい」アプリケーション（チャット・ログ転送など）はTCPを選びます。逆に、多少の欠損より速度を優先したい場合はUDPを検討してください。

HTTPステータスコード一覧｜意味と対処法を初心者向けに解説

HTTPステータスコード一覧を200番台〜500番台まで15種類以上を表付きで解説。各コードの意味・原因・対処法を初心者にもわかりやすく整理。DevToolsでの確認方法も紹介します。

Javaでソケット通信をどう実装する？

実際にコードを書いてみるとイメージがつかみやすくなります。ここでは、Java 21（LTS）環境を前提に、サーバーとクライアントを別々のJavaクラスとして実装します。最初の基本形（SimpleServer／SimpleClient）はJava 8のAPIだけで書けるのでJava 8以降でも動かせますが、後半の仮想スレッド版はJava 21以降が必要です。2026年9月時点の最新LTSであるJava 25でも同様に動作します。

コードを読む前に、サーバーとクライアントがどの順番でメソッドを呼び、どこで処理が待たされるのかを押さえておきましょう。accept() と readLine() は相手の動きがあるまで止まる（ブロッキングする）点がポイントです。

図のとおり、TCPの接続確立（3ウェイ・ハンドシェイク）はOSが自動で行うため、Java側は accept() と new Socket() を呼ぶだけです。以降はストリームを使って1行ずつ送受信し、クライアントが切断すると readLine() が null を返して終了します。

Javaのサーバー側のコード

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

public class SimpleServer {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(12345);
        System.out.println("サーバーがポート12345で待機中...");

        Socket clientSocket = serverSocket.accept();
        System.out.println("クライアントが接続しました。");

        BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
        PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);

        String inputLine;
        while ((inputLine = in.readLine()) != null) {
            System.out.println("受信: " + inputLine);
            out.println("サーバーからの応答: " + inputLine);
        }

        in.close();
        out.close();
        clientSocket.close();
        serverSocket.close();
    }
}

⚠️ 注意: 上記は説明用の基本形です。例外が発生すると close() がスキップされリソースリークするため、実務では後述の「try-with-resourcesで安全にソケットを閉じる」の書き方を使ってください。

サーバー側コードのポイント解説

ServerSocket serverSocket = new ServerSocket(12345);
System.out.println("サーバーがポート12345で待機中...");

Socket clientSocket = serverSocket.accept();
System.out.println("クライアントが接続しました。");

BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true);

String inputLine;
while ((inputLine = in.readLine()) != null) {
    System.out.println("受信: " + inputLine);
    out.println("サーバーからの応答: " + inputLine);
}

実務Tips: TCPソケットはデフォルトで「Nagleアルゴリズム」が有効になっており、送信済みのデータへのACK（確認応答）が戻るまで、小さいデータをバッファしてまとめて送信する仕組みが働きます。チャットのように1行ずつ低遅延で即時送信したい用途では、socket.setTcpNoDelay(true) を呼んでNagleアルゴリズムを無効化することで送信遅延を減らせます（Socket公式Javadoc）。

Javaのクライアント側のコード

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

public class SimpleClient {
    public static void main(String[] args) throws IOException {
        Socket socket = new Socket("localhost", 12345);
        BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in));
        BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        PrintWriter out = new PrintWriter(socket.getOutputStream(), true);

        String userInput;
        System.out.println("メッセージを入力してください:");
        while ((userInput = stdIn.readLine()) != null) {
            out.println(userInput);
            System.out.println("サーバーから: " + in.readLine());
        }

        in.close();
        out.close();
        stdIn.close();
        socket.close();
    }
}

⚠️ 注意: クライアント側も同様に、例外時のリソースリーク対策として実務では try-with-resources を使ってください。

クライアント側コードのポイント解説

Socket socket = new Socket("localhost", 12345);

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

System.out.println("メッセージを入力してください:");
while ((userInput = stdIn.readLine()) != null) {
    out.println(userInput);
    System.out.println("サーバーから: " + in.readLine());
}

in.close();
out.close();
stdIn.close();
socket.close();

ソケットをtry-with-resourcesで安全に閉じる

先ほどのサンプルコードは基本を掴むためにあえて明示的な close() を書きましたが、実務では例外発生時のリソースリークを防ぐためtry-with-resources（Java 7以降）を使うのが必須です。

// サーバー側（try-with-resources版）
try (ServerSocket serverSocket = new ServerSocket(12345);
     Socket clientSocket = serverSocket.accept();
     BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
     PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true)) {

    String inputLine;
    while ((inputLine = in.readLine()) != null) {
        out.println("サーバーからの応答: " + inputLine);
    }
} catch (IOException e) {
    e.printStackTrace();
}

Socket・ServerSocket・BufferedReader・PrintWriter はすべて AutoCloseable を実装しているため、tryの括弧に並べるだけで逆順に close() が自動実行されます。これで例外が起きても確実にリソースが解放されます。

クライアント側も同じ考え方で書き直すと、次のようになります。送受信の文字コードを StandardCharsets.UTF_8 で明示し、サーバー未起動時の ConnectException は分かりやすいメッセージで表示するようにしました（Java 21でコンパイル・実行を確認済み）。

import java.io.*;
import java.net.*;
import java.nio.charset.StandardCharsets;

public class SafeClient {
    public static void main(String[] args) {
        try (Socket socket = new Socket("localhost", 12345);
             BufferedReader in = new BufferedReader(
                     new InputStreamReader(socket.getInputStream(), StandardCharsets.UTF_8));
             PrintWriter out = new PrintWriter(
                     new OutputStreamWriter(socket.getOutputStream(), StandardCharsets.UTF_8), true);
             BufferedReader stdIn = new BufferedReader(new InputStreamReader(System.in))) {

            System.out.println("メッセージを入力してください:");
            String userInput;
            while ((userInput = stdIn.readLine()) != null) {
                out.println(userInput);
                System.out.println("サーバーから: " + in.readLine());
            }
        } catch (ConnectException e) {
            System.err.println("サーバーに接続できません: " + e.getMessage());
        } catch (IOException e) {
            System.err.println("通信エラー: " + e.getMessage());
        }
    }
}

サーバーを起動せずに実行すると、スタックトレースではなく「サーバーに接続できません: Connection refused」と1行で表示されて終了します。ConnectException は IOException のサブクラスなので、catch は必ず ConnectException を先に書きます（逆順はコンパイルエラーになります）。

Java例外処理とは｜try-catch・検査例外・カスタム例外まで初心者向け解説

Javaの例外処理をtry-catch-finallyの基本から、throw・throws、検査例外と非検査例外の違い、カスタム例外、Spring Bootでの設計まで初心者向けに解説。ラムダ式での扱いやベストプラクティスもサンプルコード付きで網羅します。

複数クライアントに対応するには？（スレッド化）

現状のサンプルは accept() が1回だけ呼ばれ、クライアント切断後にサーバーも終了します。チャットサーバーのように複数人を同時に受け入れるには、accept() をループし、受理ごとに新スレッドで処理させます。

try (ServerSocket serverSocket = new ServerSocket(12345)) {
    ExecutorService pool = Executors.newFixedThreadPool(10);
    while (true) {
        Socket client = serverSocket.accept();
        pool.submit(() -> handleClient(client));
    }
}

ExecutorService で並列度を制御することで、スレッド無制限生成による OOM を防げます。ただしこれはJava 17以前でも動く従来の書き方です。Java 21以降（2026年9月時点の最新LTS Java 25を含む）であれば、Executors.newVirtualThreadPerTaskExecutor() で仮想スレッドを使うのが現在の第一候補です。完全なコードは後述の「Java 21以降は仮想スレッドで1接続1スレッドにする」で紹介します。

参考: OpenJDKの JEP 444: Virtual Threads（Java 21で正式機能化）では、1リクエスト（1接続）に1スレッドを割り当てる素直な書き方のまま、サーバーのスループットを高められることが仮想スレッドの目的として説明されています。大量同時接続が必要なチャット／ゲームサーバーでは検討の価値があります。

Java 21以降は仮想スレッドで1接続1スレッドにする

仮想スレッドはJVMが管理する軽量スレッドで、OSスレッドより生成コストがはるかに小さいため、プールで本数を絞らず「1接続に1本」割り当てても問題になりにくいのが特徴です。ここまでの内容（try-with-resources・文字コード指定・タイムアウト・ポート再利用）をすべて反映した、そのまま動くサーバーの完全版は以下のとおりです。

import java.io.*;
import java.net.*;
import java.nio.charset.StandardCharsets;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class VirtualThreadServer {
    public static void main(String[] args) throws IOException {
        try (ServerSocket serverSocket = new ServerSocket();
             ExecutorService executor = Executors.newVirtualThreadPerTaskExecutor()) {
            serverSocket.setReuseAddress(true); // 環境によらず再起動しやすくする（macOS/Linuxは既定で有効）
            serverSocket.bind(new InetSocketAddress(12345));
            System.out.println("サーバーがポート12345で待機中（仮想スレッド）...");

            while (true) {
                Socket client = serverSocket.accept();
                executor.submit(() -> handleClient(client)); // 1接続につき仮想スレッド1本
            }
        }
    }

    private static void handleClient(Socket client) {
        try (client;
             BufferedReader in = new BufferedReader(
                     new InputStreamReader(client.getInputStream(), StandardCharsets.UTF_8));
             PrintWriter out = new PrintWriter(
                     new OutputStreamWriter(client.getOutputStream(), StandardCharsets.UTF_8), true)) {
            client.setSoTimeout(30_000); // 30秒無通信なら SocketTimeoutException
            String line;
            while ((line = in.readLine()) != null) {
                System.out.println(Thread.currentThread() + " 受信: " + line);
                out.println("サーバーからの応答: " + line);
            }
        } catch (IOException e) {
            System.err.println("通信エラー: " + e.getMessage());
        }
    }
}

このサーバーを起動し、前述の SafeClient を2つのターミナルから同時に接続した実行結果です（macOS／Amazon Corretto 21.0.5で確認）。受信ログの VirtualThread[#22] と VirtualThread[#20] のように、接続ごとに別の仮想スレッドが処理していることが分かります。

# [ターミナル1] サーバー側（Java 21で実行）
$ java VirtualThreadServer
サーバーがポート12345で待機中（仮想スレッド）...
VirtualThread[#22]/runnable@ForkJoinPool-1-worker-2 受信: hello
VirtualThread[#20]/runnable@ForkJoinPool-1-worker-1 受信: java socket
VirtualThread[#22]/runnable@ForkJoinPool-1-worker-2 受信: こんにちは

# [ターミナル2] クライアント1（別ターミナル3でもう1つ起動し「java socket」を送信）
$ java SafeClient
メッセージを入力してください:
hello
サーバーから: サーバーからの応答: hello
こんにちは
サーバーから: サーバーからの応答: こんにちは

バージョンによる注意点: Java 21〜23では、synchronized ブロックの中でI/O待ちが発生すると仮想スレッドがOSスレッド（キャリアスレッド）に固定される「ピン留め」が起き、並列性が落ちる制約がありました。この制約は JEP 491 によりJava 24で解消されています。Java 21で仮想スレッドを使う場合は、ソケットの読み書きを synchronized で囲まず、必要なら ReentrantLock を使うのが安全です。

Javaソケット通信でよくあるエラーと対処法

実務Tips: setSoTimeout() を設定しない場合、相手が応答を返さずに接続を切らないと read() が無期限にブロックし続け、サーバーやクライアントがフリーズしたように見える不具合につながります。本番運用では必ず妥当なタイムアウト値（数秒〜数十秒程度）を設定しておくのが安全です。

実行結果（macOS/Java 21）

手元で SimpleServer と SimpleClient を別ターミナルで起動した際の出力は以下のとおりです。

# [ターミナル1] サーバー側
$ java SimpleServer
サーバーがポート12345で待機中...
クライアントが接続しました。
受信: hello
受信: java socket

# [ターミナル2] クライアント側
$ java SimpleClient
メッセージを入力してください:
hello
サーバーから: サーバーからの応答: hello
java socket
サーバーから: サーバーからの応答: java socket

Javaソケット通信のポイント

実装してみると、以下の点が重要だとわかります。

通信の流れは「クライアントが入力 → サーバーへ送信 → サーバーが応答 → クライアントが表示」の繰り返しです。メソッドの呼び出し順は、実装パートの冒頭にある図で確認できます。

Socket/ServerSocketの主要メソッド

ここまで登場した主要メソッドを一覧にまとめました。実装時のリファレンスとして活用してください。

よくある質問（FAQ）

Q1. SocketとServerSocketの違いは？

A1. ServerSocketはサーバー側でクライアント接続を「待ち受ける」専用クラスで、accept() が返す Socket が実際の双方向通信チャネルです。クライアント側は直接 new Socket(host, port) で接続します。

Q2. Java NIOのSocketChannelとの違いは？

A2. この記事の Socket/ServerSocket はブロッキングI/Oで、1接続1スレッドが基本です。大量接続が必要なら java.nio の SocketChannel + Selector（ノンブロッキングI/O）を検討します。Java 21以降の仮想スレッドを使えば従来型でも大量接続が現実的になり、Java 24以降は synchronized によるピン留めの制約も解消されています。

Q3. 文字化けが発生する場合の対処は？

A3. InputStreamReader／OutputStreamWriter の第2引数で明示的に StandardCharsets.UTF_8 を指定します。Java 18以降は JEP 400 でデフォルト文字セットがUTF-8に統一されましたが、Java 17以前の環境（Windowsでは従来MS932がデフォルト）や、別言語・別OSで動く相手との通信に備えて明示しておくのが安全です。なお、コンソール（標準入出力）の文字コードはJEP 400の対象外です。

Q4. SSL/TLSで暗号化通信したい

A4. SSLSocketFactory.getDefault().createSocket(host, port) で SSLSocket を生成できます。サーバー側は SSLServerSocket を使い、keystore を設定します。本番運用では必須です。

【2026年版】Javaのcacerts確認方法｜読み方・場所・keytoolコマンドを3分で解説

cacertsは「シーエーサーツ」と読みます。Javaでの場所・確認方法をkeytoolコマンドで解説。「PKIX path building failed」エラーの対処まで、コピペで使える手順にまとめました。

Q5. bind()やServerSocket生成でエラーになるときの対処は？

A5. ほとんどの場合、指定したポートを既に別プロセスが使用中で BindException: Address already in use が発生しています。lsof -i :<ポート番号>（macOS/Linux）で該当プロセスを特定してください。Javaの ServerSocket は macOS・Linux では SO_REUSEADDR が既定で有効なため、通常はサーバー側のTIME_WAITが残っていても再 bind できます（Corretto 21 / macOS で確認）。SO_REUSEADDR が無効な環境で TIME_WAIT が原因になる場合に備えるなら、バインド前に ServerSocket#setReuseAddress(true) を明示します。

まとめ：Javaでソケット通信は難しくない

JavaでTCP/IPソケット通信を実装する手順を、基本概念からサンプルコード・よくあるエラーまで見てきました。

TCPプロトコルの仕組みや3ウェイ・ハンドシェイクの流れ、JavaのSocket・ServerSocketクラスの使い方を一貫して学ぶことで、ネットワーク通信の基礎が自然に身につきます。

Javaでのソケット通信は、一見とっつきにくく感じるかもしれませんが、仕組みさえ理解してしまえばシンプルです。

サンプルコードを実行しながら、通信の流れを体感することで、ネットワークプログラミングの土台がしっかりと身につきます。