はじめに
表記の件の備忘録です。ネットワークと、スレッドについて学習したかったのでまとめました。
ソケットを用いた通信の手順
- サーバーでServerSocketを作成し、クライアントからの接続を待ち受ける
- クライアントがソケットを作成すると、サーバーとクライアントの間で接続が確立される
- サーバーが文字列を書き出し、それをクライアントが読み込む
- ソケットをクローズする
プログラム例
サーバ側を先に起動すること。
サーバ側プログラム
package com.example;
import java.io.BufferedWriter;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
public final class Server {
private Server() {
}
public static final int PORT = 10000;
public static void main(String[] args) {
try (ServerSocket serverSocket = new ServerSocket(PORT)) {
System.out.println("待機します。");
while (true) {
Socket socket = serverSocket.accept(); // 接続を受け付ける
System.out.println("ようこそ。");
PrintWriter printWriter = new PrintWriter(
new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())));
printWriter.println("こちらはサーバです。");
printWriter.flush();
printWriter.close();
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
クライアント側プログラム
package com.example;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.Socket;
public class Client {
public static final String HOST = "localhost"; // 接続先のホスト名
public static final int PORT = 10000; // 接続先のポート番号
public static void main(String[] args) {
try (Socket socket = new Socket(HOST, PORT)) {
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
String str = bufferedReader.readLine();
System.out.println(str);
bufferedReader.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
サーバ側出力
$ java <プログラム実行のコマンド>
待機します。
ようこそ。
ようこそ。
クライアント側出力
$ java <プログラム実行のコマンド>
こちらはサーバです。
$ java <プログラム実行のコマンド>
こちらはサーバです。
スレッドも利用した通信
概要
Javaでは、スレッドはjava.lang.Threadクラスを使って作成する。スレッドを利用する方法は主に2つある。
- Threadクラスを拡張する
Threadクラスを拡張して、自分のスレッドクラスを作成する。run()メソッドをオーバライドし、start()でスレッドを起動する。 - Runnableインターフェースを実装する
Runnableインターフェースを実装して、Threadクラスに渡す。
プログラム例
サーバ側メインスレッド
public class Server {
public static void main(String[] args) {
ServerThread serverThread = new ServerThread();
serverThread.start();
while (true) {
try {
Thread.sleep(5000); // 5秒間スリープ
System.out.println("サーバ側メインスレッドも起動中です。");
} catch (InterruptedException e) {
System.out.println("スリープが中断されました: " + e.getMessage());
}
}
}
}
サーバ側通信用スレッド
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class ServerThread extends Thread {
public static final int PORT = 10000;
public ServerThread() {
}
public void run() {
try (ServerSocket serverSocket = new ServerSocket(PORT)) {
Socket socket = serverSocket.accept();
try (BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter printWriter = new PrintWriter(
new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())))) {
String message;
while ((message = bufferedReader.readLine()) != null) {
printWriter.println("サーバ：" + message + "受け付けました。");
printWriter.flush();
}
} catch (Exception e) {
e.printStackTrace();
}
} catch (Exception ex) {
ex.printStackTrace();
}
}
}
クライアント側メインスレッド
public class Client {
// メインスレッドは、コンソールから入力を受け付け、サーバーに送信する
public static void main(String[] args) {
// サーバから受信を行うスレッドを立ち上げる
Thread thread = new Thread(new ClientThread());
thread.start();
while (true) {
try {
Thread.sleep(3000);
System.out.println("クライアント側メインスレッドも起動中です");
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
クライアント側通信用スレッド
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
public class ClientThread implements Runnable {
public static final String HOST = "localhost";
public static final int PORT = 10000;
// サーバーからの文字列を受信し続け、コンソールに出力する
public void run() {
try (Socket socket = new Socket(HOST, PORT);
BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter printWriter = new PrintWriter(new OutputStreamWriter(socket.getOutputStream()));
BufferedReader consoleReader = new BufferedReader(new InputStreamReader(System.in))) {
System.out.println("サーバに接続しました。");
String userInput;
while (true) {
System.out.print("サーバに送信するメッセージを入力してください。>");
userInput = consoleReader.readLine();
printWriter.println(userInput);
printWriter.flush();
String serverResponse = bufferedReader.readLine();
System.out.println(serverResponse);
}
} catch (Exception e) {
e.printStackTrace();
}
}
}