Java サーバー・マルチクライアント通信

Question

Javaサーバークライアント通信についての質問です。

複数のクライアントに対応するサーバーをつくろうとしています。
クライアントと接続されたときに新しくスレッドを作成し、
その中で、サーバー側コンソール入力が行われた場合に、全クライアントに送信するという
処理を書いたのですが、
なぜか、サーバー側(Server.java)の各クライアントスレッドのコメントの部分(質問下部にソースコードを記載しました)にあるように
そこに何かの処理が無いと、その次にあるif文の中に入ってくれないようです。
それはなぜなのでしょうか？

自身の考えとしては、
Modelクラスのdataフィールドに同時にアクセスすることによる何かなのではないかと考えてはいますが、
具体的になぜ起こるのか、などがわかりません。
なぜこのようなことになるのか、また、その対処策を教えていただきたく、質問しました。

よろしくお願いします。

Server.java

import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;

public class Server {
	
	Socket socket;
	ServerSocket server;
	Scanner scan;
	
	public Server() throws Exception {
		server = new ServerSocket(8000);
		scan = new Scanner(System.in);
		
		new Thread(new Runnable() {
			@Override
			public void run() {
				while (true) {
					try {
						socket = server.accept();
						new Multi(socket).start();
					} catch (Exception e) {
						e.printStackTrace();
					}
				}
			}
		}).start();
		
		while (true) {
			System.out.println("書き込みループの中: " + Model.data);
			Model.data = scan.next();
		}
	}
	
	public static void main(String[] args) throws Exception {
		new Server();
	}
	
}


class Multi extends Thread {
	Socket socket;
	ObjectOutputStream oos;
	ObjectInputStream ois;
	PrintWriter out;
	
	String data;
	
	public Multi(Socket _socket) throws Exception {
		socket = _socket;
		System.out.println(socket.getRemoteSocketAddress() + "と接続中");
		out = new PrintWriter(socket.getOutputStream(), true);
	}
	
	@Override
	public void run() {
		System.out.println("スレッドの中");
		while (true) {
			try {
// この文が無いとclient側が認識しない
// sleepでなくても、コンソール出力など何か適当な処理でよい
				sleep(1000);
			} catch (InterruptedException e1) {}
			if (Model.data != null && data != Model.data) {
				data = Model.data;
				try {
					System.out.println("out.println");
					out.println(data);
				} catch (Exception e) {
					e.printStackTrace();
				}
			}
		}
	}
}

Client.java

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.ObjectInputStream;
import java.net.InetSocketAddress;
import java.net.Socket;

public class Client {
	Socket socket;
	ObjectInputStream ois;
	InetSocketAddress adress;
	BufferedReader in;
	
	String line;
	
	public Client() throws Exception {
		socket = new Socket();
		adress = new InetSocketAddress(8000);
		
		socket.connect(adress);
		System.out.println(socket.getRemoteSocketAddress() + "と接続中");
		in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
		
		while ((line = in.readLine()) != null) {
			System.out.println("ループの中");
			System.out.println(line);
		}
	}
	
	public static void main(String[] args) throws Exception {
		new Client();
	}
}

Model.java

public class Model {
	public static String data;
}

Answer 1

こちら現象から推測で回答いたします。
間違っていたら読み捨てていただいて構いません。

マルチスレッドは何年も前にやっていたので、
不確かなのですが、現象からするとコンパイラが最適化してしまっているので、
処理が行われないのではないかと思います。

上記が原因であれば、対応方法ですが下記になるかと思います。

volatile String data;

参考になれば幸いです。

Comments

[meriyasu]

ありがとうございます、おっしゃるやり方で実装し直すと、解決しました。
また、よろしくお願いします。

Answer 2

回答ではありませんが、ひとつ疑問があります。
もしこのプログラムを実際のクライアント/サーバープログラムに適用するとしたら、サーバーとクライアントで同じメモリー領域を共有できないのですから、Model.dataを共有することはできませんね。実際には使わない部分なのでしょうか。

Comments

[meriyasu]

すみません、説明不足でした。
今回のプログラムの場合、Model.dataはサーバーのみで使用します。
サーバークライアント同士の値の共有のためではありません。

サーバーでは、常時コンソール入力を受け付け、入力されれば、Model.dataを書き換えます。
そこでは、まだクライアントには送らずに、サーバー内の別のスレッドで、常時Model.dataを監視し、Model.dataに変化があった場合、クライアント側に送信するという内容になっております。
このようにする目的は、
実際はGUIのプログラムを開発しているのですが、その場合、クライアントに送る情報は、
コンソール入力1種類ではなく、ボタンの押下や、テキストボックスへ入力など様々なものがあり、
その都度、クライアントに送るのは、まとまりがありません。
そのために、クライアントに送る場所はあるスレッドのみで、ボタンを押した時などは、Modelクラスを更新するのみとしています。
(クライアントがサーバーに送るときも同様の処理を行います)

説明ベタではありますが、ご理解いただけたでしょうか？

[argius]

解説ありがとうございます。
理解しました。