回答編集履歴

大幅な改善

2019/07/09 20:21

投稿

reishisu

スコア39

test CHANGED Viewed

@@ -16,6 +16,440 @@
 (今回は通信だけの質問だったので、別スレッドで実行しているので受け取ったメッセージをメインスレッドにデータの送信ができていないので完全に完成はしておりません。)
+[C#のコード](https://gist.github.com/reishisu/c426018f02f9159ae200dbfc651b08ab)
+回答して頂いたjimbe様、解決のヒントを下さり本当にありがとうございました。
+### 追記
+一応、目的のとりあえず動くコードは(多分)作れたので追記させて頂きます。
+[Javaのコード](https://gist.github.com/reishisu/7f2b568d0f598477a651b42647c4c527)
+[C#のコード](https://gist.github.com/reishisu/3f73502ab2319129139939f2585cae37)
+### 追記(2019年7月10日)
+Javaのコードを2つに分けることでうまく、排他制御することに成功しました！！
+サーバー側でアクセスされる度にクライアントのIPアドレスを確認し、クライアントのIPアドレスを管理しているリストにあればそのままThreadを非同期で実行させており、なければリストに追加して同じくThreadを非同期で実行させております。
+Threadの中では、メインスレッドにあるbroadcast関数をsynchronized修飾子をつけ排他制御しながら実行しているのでうまくスレッドの生成順に実行させることができ、上手くできたかなぁと思っております。
+また、アプリを落とした時の切断エラーに関してもエラーをcatchした瞬間に当該IPをリストから削除することで他のスレッドに干渉せずに出来ました！
+```Java
+package raspi_server;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.net.ServerSocket;
+import java.net.Socket;
+import java.util.ArrayList;
+/**
+ * ラズパイ上で動かすチャットのサーバークラスです
+ * @author reishisu
+ */
+public class ChatServer {
+	/**
+	 * ソケット通信を行うポート
+	 */
+	private static final int PORT = 25252;
+	/**
+	 * チャットサーバーの窓口
+	 */
+	private static ServerSocket server_socket;
+	/**
+	 * 接続してきたIPアドレス
+	 */
+	private static ArrayList<Socket> socket_list = new ArrayList<>();
+	/**
+	 * チャットのナンバー
+	 */
+	private static int chat_number = 1;
+	/**
+	 * メイン関数
+	 * @param args コマンドライン引数
+	 */
+	public static void main(String[] args) {
+		try {
+			// 既にサーバーが建っていない時サーバーソケットの生成
+			if (server_socket == null) {
+				server_socket = new ServerSocket(PORT);
+				System.out.println("サーバー稼働中...");
+			}
+			// サーバー稼働
+			while (true) {
+				// クライアントからの接続が来るまで待機
+				Socket client_socket = server_socket.accept();
+				// 新規か確認
+				boolean is_new = true;
+				// 新規のIPがないかを走査する
+				for(Socket client : socket_list) {
+					if ( client.getInetAddress().toString().equals(client_socket.getInetAddress().toString())) {
+						System.out.println("同じとこからきてる！");
+						new ClientReciever(client_socket).start();
+						is_new = false;
+					}
+				}
+				// 新規の場合
+				if (is_new) {
+					// ソケットリストに追加
+					socket_list.add(client_socket);
+					// 新規ソケット用のスレッドを実行
+					new ClientReciever(client_socket).start();
+					System.out.println("新規さん入ります！\nIPアドレス：" + client_socket.getInetAddress().toString() + "\n合計接続数：" + socket_list.size());
+				}
+			}
+		}
+		catch (Exception e) {
+			System.err.println("エラー発生！！");
+			e.printStackTrace();
+		}
+	}
+	/**
+	 * クライアントにメッセージをブロードキャストするための関数
+	 * @param message 送信文字列
+	 */
+	public static synchronized void broadcast(String message) {
+		byte[] buffer = new byte[4096];
+		DataOutputStream dataOutputStream = null;
+		try {
+			buffer = message.getBytes("UTF-8");
+			for (Socket client : socket_list) {
+				try {
+					dataOutputStream = new DataOutputStream(new Socket(client.getInetAddress().toString().split("/")[1], PORT).getOutputStream());
+					dataOutputStream.write(buffer);
+					dataOutputStream.flush();
+				} catch (Exception e) {
+					System.out.println(client.getInetAddress().toString().split("/")[1] + "との接続が切れました");
+					socket_list.remove(client);
+				}
+			}
+		} catch (IOException e) { e.printStackTrace(); }
+	}
+	/**
+	 * チャットナンバーを返す
+	 * @return 現在のチャットナンバー
+	 */
+	public static synchronized int getChat_number() {
+		chat_number++;
+		return chat_number-1;
+	}
+}
+```
+```Java
+package raspi_server;
+import java.io.DataInputStream;
+import java.net.Socket;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+/**
+ * チャットのアプリケーションクラスです
+ * @author reishisu
+ */
+public class ClientReciever extends Thread {
+	/**
+	 * 受信する対象のクライアント
+	 */
+	private Socket client;
+	/**
+	 * クライアントのデータ受信窓口
+	 */
+	private DataInputStream data_input_stream;
+	/**
+	 * 無限ループなのでフラグを使って意図的にスレッドを終了させる
+	 */
+	public boolean do_thread_finish;
+	/**
+	 * // タイムスタンプのテンプレート
+	 */
+	SimpleDateFormat time_stamp = new SimpleDateFormat("yyyy年MM月dd日HH時mm分ss秒");
+	/**
+	 * コンストラクタ
+	 * @param client 受信の対応をするクライアント用の窓口
+	 */
+	public ClientReciever(Socket client) {
+		try {
+			System.out.println("ClientReciever Called!!");
+			this.client = client;
+			this.data_input_stream = new DataInputStream(client.getInputStream());
+		}
+		catch (Exception e) {
+			System.out.println("スレッド生成時にエラーが発生しました...");
+			e.printStackTrace();
+		}
+	}
+	/**
+	 * ひたすらデータの受信を行う
+	 */
+	public void run() {
+		// 文字列を受け取るバッファ
+		byte[] buffer = new byte[4096];
+		// 受信文字列
+		String send_message = "";
+		// スレッド終了の合図が出るまで実行
+		while(!do_thread_finish) {
+			try {
+				int read_resuld = data_input_stream.read(buffer);
+				// データの受信が確認されなかった時は実行されない
+				if (read_resuld == 0 || read_resuld == -1) continue;
+				// 受信時間の計測を開始
+				long start_time = System.currentTimeMillis();
+				// 受信した文字列
+				String recieve_string = new String(buffer, "UTF-8");
+				// 計測終了
+				long end_time = System.currentTimeMillis();
+				// 受信した文字列に付加情報をつけて送信文字列を作成
+				send_message = new StringBuilder().append(ChatServer.getChat_number()).append("  IPアドレス：").append(client.getInetAddress().toString().split("/")[1])
+												  .append("：").append(time_stamp.format(new Date())).append("　[").append((end_time - start_time))
+												  .append("ms]\n").append(recieve_string).append("\n").toString();
+				// 送信文字列を表示
+				System.out.println(send_message);
+				// 登録リストへ送信文字列をブロードキャストする
+				ChatServer.broadcast(send_message);
+				do_thread_finish = !do_thread_finish;
+			}
+			catch (Exception e) {
+				e.printStackTrace();
+				// 受信した文字列に付加情報をつけて送信文字列を作成
+				send_message = new StringBuilder().append(ChatServer.getChat_number()).append("  IPアドレス：").append(client.getInetAddress().toString().split("/")[1])
+												  .append("：").append(time_stamp.format(new Date())).append("　9999[ms]\n受信失敗...\n").toString();
+				// 送信文字列を表示
+				System.out.println(send_message);
+				// 登録リストへ送信文字列をブロードキャストする
+				ChatServer.broadcast(send_message);
+				do_thread_finish = !do_thread_finish;
+			}
+		}
+	}
+}
+```
 ```C#
 using System.Collections;
@@ -36,6 +470,8 @@
 using System.Threading.Tasks;
+using System.Threading;
 public class ChatClient : MonoBehaviour {
@@ -52,6 +488,16 @@
+	public static string a;
+	//おまじない
+	private SynchronizationContext context;
 	// サーバー情報
 	private string server_ip_address = "192.168.0.25";
@@ -88,6 +534,12 @@
 	void Start() {
+		context = SynchronizationContext.Current;
 		//Componentを扱えるようにする
 		input_field = input_field.GetComponent<InputField>();
@@ -102,6 +554,26 @@
+	private void Update() {
+		if (a != "") {
+			GameObject instance = Instantiate(chat_log);
+			instance.transform.parent = content.transform;
+			instance.transform.localScale = new Vector3(1, 1, 1);
+			instance.GetComponent<Text>().text = a;
+			a = "";
+		}
+	}
 	public void InputText() {
 		//テキストにinputFieldの内容を反映
@@ -136,22 +608,6 @@
-		// データを受信
-		//network_stream.Read(buffer, 0, buffer.Length);
-		//string message = Encoding.UTF8.GetString(buffer);
-		//GameObject instance = Instantiate(chat_log);
-		//instance.transform.parent = content.transform;
-		//instance.transform.localScale = new Vector3(1, 1, 1);
-		//instance.GetComponent<Text>().text = message;
 		network_stream.Close();
 	}
@@ -162,6 +618,12 @@
 	public void Listener() {
+		SynchronizationContext.SetSynchronizationContext(context);
 		listener = new TcpListener(IPAddress.Any, port);
@@ -214,13 +676,7 @@
 			Debug.Log(message);
-			GameObject instance = Instantiate(chat_log);
-			instance.transform.parent = content.transform;
-			instance.transform.localScale = new Vector3(1, 1, 1);
-			instance.GetComponent<Text>().text = message;
+			a = message;
@@ -243,523 +699,3 @@
 ```
-回答して頂いたjimbe様、解決のヒントを下さり本当にありがとうございました。
-### 追記
-一応、目的のとりあえず動くコードは(多分)作れたので追記させて頂きます。
-```Java
-import java.io.DataInputStream;
-import java.io.DataOutputStream;
-import java.io.IOException;
-import java.io.InputStream;
-import java.net.InetAddress;
-import java.net.ServerSocket;
-import java.net.Socket;
-import java.text.SimpleDateFormat;
-import java.util.ArrayList;
-import java.util.Date;
-/**
- * ラズパイ上で動かすチャットのサーバークラスです
- * @author reishisu
- */
-public class ChatServer {
-	/**
-	 * ソケット通信を行うポート
-	 */
-	public static final int PORT = 25252;
-	/**
-	 * チャットサーバーの窓口
-	 */
-	private static ServerSocket server_socket;
-	/**
-	 * 接続してきたIPアドレス
-	 */
-	private static ArrayList<InetAddress> client_list = new ArrayList<>();
-	/**
-	 * メイン関数
-	 * @param args コマンドライン引数
-	 */
-	public static void main(String[] args) {
-		try {
-			// 既にサーバーが建っていない時サーバーソケットの生成
-			if (server_socket == null) {
-				server_socket = new ServerSocket(PORT);
-				System.out.println("サーバー稼働中...");
-			}
-			// 受信カウンタ
-			int count = 1;
-			// サーバー稼働
-			while (true) {
-				// クライアントからの接続が来るまで待機
-				Socket client_socket = server_socket.accept();
-				// 新規か確認
-				boolean is_new = true;
-				for(InetAddress ip : client_list) {
-					if (ip.toString().equals(client_socket.getInetAddress().toString())) {
-						is_new = false;
-					} else {
-						System.out.println("違う？" + ip + "==" + client_socket.getInetAddress());
-					}
-				}
-				if (is_new) {
-					client_list.add(client_socket.getInetAddress());
-					System.out.println("追加された：" + client_socket.getInetAddress().toString() + "：" + client_list.size());
-				}
-				// 計測開始
-				long start_time = System.currentTimeMillis();
-				// クライアントから文字列をバイト列で受信
-				InputStream input_stream = client_socket.getInputStream();
-				DataInputStream data_input_stream = new DataInputStream(input_stream);
-				// 文字列を受け取るバッファー
-				byte[] buffer = new byte[4096];
-				int byte_count = 0;
-				String message = "";
-				try {
-					byte_count = data_input_stream.read(buffer);
-					if (byte_count == 0) return;
-					String view_string = new String(buffer, "UTF-8");
-					long end_time = System.currentTimeMillis();
-					SimpleDateFormat time_stamp = new SimpleDateFormat("yyyy年MM月dd日HH時mm分ss秒");
-					message += count + "  IPアドレス：" + ("" + client_socket.getInetAddress()).split("/")[1] + "：" +
-							   time_stamp.format(new Date()) + "　[" + (end_time - start_time) + "ms]" + "\n" + view_string + "\n";
-					System.out.println(message);
-					count++;
-					send(message);
-				}
-				catch (Exception e) {
-					long end_time = System.currentTimeMillis();
-					SimpleDateFormat time_stamp = new SimpleDateFormat("yyyy年MM月dd日HH時mm分ss秒");
-					message += count + "  IPアドレス：" + ("" + client_socket.getInetAddress()).split("/")[1] + "：" +
-							   time_stamp.format(new Date()) + "　[" + (end_time - start_time) + "ms]" + "\n受信失敗...\n";
-					System.out.println(message);
-					count++;
-					send(message);
-				}
-			}
-		}
-		catch (Exception e) {
-			System.err.println("エラー発生！！");
-			e.printStackTrace();
-		}
-	}
-	public static void send(String message) {
-		byte[] buffer = new byte[4096];
-		DataOutputStream dataOutputStream = null;
-		try {
-			buffer = message.getBytes("UTF-8");
-			for (InetAddress ip : client_list) {
-				try {
-					dataOutputStream = new DataOutputStream(new Socket(ip.toString().split("/")[1], PORT).getOutputStream());
-					dataOutputStream.write(buffer);
-					dataOutputStream.flush();
-					dataOutputStream.close();
-				} catch (Exception e) {
-				}
-			}
-		} catch (IOException e) {
-			// TODO 自動生成された catch ブロック
-			e.printStackTrace();
-		}
-	}
-}
-```
-```C#
-using System.Collections;
-using System.Collections.Generic;
-using System;
-using UnityEngine;
-using UnityEngine.UI;
-using System.Net.Sockets;
-using System.Text;
-using System.Net;
-using System.Threading.Tasks;
-using System.Threading;
-public class ChatClient : MonoBehaviour {
-	// ゲームオブジェクト
-	public InputField input_field;
-	public GameObject content;
-	public GameObject chat_log;
-	public static string a;
-	//おまじない
-	private SynchronizationContext context;
-	// サーバー情報
-	private string server_ip_address = "192.168.0.25";
-	private int port = 25252;
-	// クライアントの送信窓口
-	NetworkStream network_stream;
-	// 送信内容
-	private string send_text;
-	// 受信用
-	private TcpListener listener;
-	private float request_span = 10f;
-	private byte[] buffer = new byte[4096];
-	// Start is called before the first frame update
-	void Start() {
-		context = SynchronizationContext.Current;
-		//Componentを扱えるようにする
-		input_field = input_field.GetComponent<InputField>();
-		// 監視
-		Task.Run(Listener);
-	}
-	private void Update() {
-		if (a != "") {
-			GameObject instance = Instantiate(chat_log);
-			instance.transform.parent = content.transform;
-			instance.transform.localScale = new Vector3(1, 1, 1);
-			instance.GetComponent<Text>().text = a;
-			a = "";
-		}
-	}
-	public void InputText() {
-		//テキストにinputFieldの内容を反映
-		send_text = input_field.text;
-	}
-	// ボタンクリック時
-	public void NetworkRequest() {
-		// 接続要求
-		network_stream = new TcpClient(server_ip_address, port).GetStream();
-		// 送信の内容をセット
-		if (send_text.Length == 0) return;
-		byte[] send_string = Encoding.UTF8.GetBytes(send_text);
-		// データを送信
-		network_stream.Write(send_string, 0, send_string.Length);
-		network_stream.Close();
-	}
-	public void Listener() {
-		SynchronizationContext.SetSynchronizationContext(context);
-		listener = new TcpListener(IPAddress.Any, port);
-		Debug.Log("監視開始1");
-		try {
-			listener.Start();
-		}
-		catch (Exception e) {
-			Debug.Log(e.Message);
-			Debug.Log(e.TargetSite);
-			Debug.Log(e.StackTrace);
-		}
-		Debug.Log("監視開始2");
-		while (true) {
-			//接続要求があったら受け入れる
-			TcpClient client = listener.AcceptTcpClient();
-			Debug.Log("きた！");
-			network_stream = client.GetStream();
-			// データを受信
-			network_stream.Read(buffer, 0, buffer.Length);
-			string message = Encoding.UTF8.GetString(buffer);
-			Debug.Log(message);
-			a = message;
-			// バッファリセット
-			buffer = new byte[4096];
-			network_stream.Close();
-		}
-	}
-}
-```

修正したので追記を

2019/07/09 20:21

投稿

reishisu

スコア39

test CHANGED Viewed

@@ -247,3 +247,519 @@
 回答して頂いたjimbe様、解決のヒントを下さり本当にありがとうございました。
+### 追記
+一応、目的のとりあえず動くコードは(多分)作れたので追記させて頂きます。
+```Java
+import java.io.DataInputStream;
+import java.io.DataOutputStream;
+import java.io.IOException;
+import java.io.InputStream;
+import java.net.InetAddress;
+import java.net.ServerSocket;
+import java.net.Socket;
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.Date;
+/**
+ * ラズパイ上で動かすチャットのサーバークラスです
+ * @author reishisu
+ */
+public class ChatServer {
+	/**
+	 * ソケット通信を行うポート
+	 */
+	public static final int PORT = 25252;
+	/**
+	 * チャットサーバーの窓口
+	 */
+	private static ServerSocket server_socket;
+	/**
+	 * 接続してきたIPアドレス
+	 */
+	private static ArrayList<InetAddress> client_list = new ArrayList<>();
+	/**
+	 * メイン関数
+	 * @param args コマンドライン引数
+	 */
+	public static void main(String[] args) {
+		try {
+			// 既にサーバーが建っていない時サーバーソケットの生成
+			if (server_socket == null) {
+				server_socket = new ServerSocket(PORT);
+				System.out.println("サーバー稼働中...");
+			}
+			// 受信カウンタ
+			int count = 1;
+			// サーバー稼働
+			while (true) {
+				// クライアントからの接続が来るまで待機
+				Socket client_socket = server_socket.accept();
+				// 新規か確認
+				boolean is_new = true;
+				for(InetAddress ip : client_list) {
+					if (ip.toString().equals(client_socket.getInetAddress().toString())) {
+						is_new = false;
+					} else {
+						System.out.println("違う？" + ip + "==" + client_socket.getInetAddress());
+					}
+				}
+				if (is_new) {
+					client_list.add(client_socket.getInetAddress());
+					System.out.println("追加された：" + client_socket.getInetAddress().toString() + "：" + client_list.size());
+				}
+				// 計測開始
+				long start_time = System.currentTimeMillis();
+				// クライアントから文字列をバイト列で受信
+				InputStream input_stream = client_socket.getInputStream();
+				DataInputStream data_input_stream = new DataInputStream(input_stream);
+				// 文字列を受け取るバッファー
+				byte[] buffer = new byte[4096];
+				int byte_count = 0;
+				String message = "";
+				try {
+					byte_count = data_input_stream.read(buffer);
+					if (byte_count == 0) return;
+					String view_string = new String(buffer, "UTF-8");
+					long end_time = System.currentTimeMillis();
+					SimpleDateFormat time_stamp = new SimpleDateFormat("yyyy年MM月dd日HH時mm分ss秒");
+					message += count + "  IPアドレス：" + ("" + client_socket.getInetAddress()).split("/")[1] + "：" +
+							   time_stamp.format(new Date()) + "　[" + (end_time - start_time) + "ms]" + "\n" + view_string + "\n";
+					System.out.println(message);
+					count++;
+					send(message);
+				}
+				catch (Exception e) {
+					long end_time = System.currentTimeMillis();
+					SimpleDateFormat time_stamp = new SimpleDateFormat("yyyy年MM月dd日HH時mm分ss秒");
+					message += count + "  IPアドレス：" + ("" + client_socket.getInetAddress()).split("/")[1] + "：" +
+							   time_stamp.format(new Date()) + "　[" + (end_time - start_time) + "ms]" + "\n受信失敗...\n";
+					System.out.println(message);
+					count++;
+					send(message);
+				}
+			}
+		}
+		catch (Exception e) {
+			System.err.println("エラー発生！！");
+			e.printStackTrace();
+		}
+	}
+	public static void send(String message) {
+		byte[] buffer = new byte[4096];
+		DataOutputStream dataOutputStream = null;
+		try {
+			buffer = message.getBytes("UTF-8");
+			for (InetAddress ip : client_list) {
+				try {
+					dataOutputStream = new DataOutputStream(new Socket(ip.toString().split("/")[1], PORT).getOutputStream());
+					dataOutputStream.write(buffer);
+					dataOutputStream.flush();
+					dataOutputStream.close();
+				} catch (Exception e) {
+				}
+			}
+		} catch (IOException e) {
+			// TODO 自動生成された catch ブロック
+			e.printStackTrace();
+		}
+	}
+}
+```
+```C#
+using System.Collections;
+using System.Collections.Generic;
+using System;
+using UnityEngine;
+using UnityEngine.UI;
+using System.Net.Sockets;
+using System.Text;
+using System.Net;
+using System.Threading.Tasks;
+using System.Threading;
+public class ChatClient : MonoBehaviour {
+	// ゲームオブジェクト
+	public InputField input_field;
+	public GameObject content;
+	public GameObject chat_log;
+	public static string a;
+	//おまじない
+	private SynchronizationContext context;
+	// サーバー情報
+	private string server_ip_address = "192.168.0.25";
+	private int port = 25252;
+	// クライアントの送信窓口
+	NetworkStream network_stream;
+	// 送信内容
+	private string send_text;
+	// 受信用
+	private TcpListener listener;
+	private float request_span = 10f;
+	private byte[] buffer = new byte[4096];
+	// Start is called before the first frame update
+	void Start() {
+		context = SynchronizationContext.Current;
+		//Componentを扱えるようにする
+		input_field = input_field.GetComponent<InputField>();
+		// 監視
+		Task.Run(Listener);
+	}
+	private void Update() {
+		if (a != "") {
+			GameObject instance = Instantiate(chat_log);
+			instance.transform.parent = content.transform;
+			instance.transform.localScale = new Vector3(1, 1, 1);
+			instance.GetComponent<Text>().text = a;
+			a = "";
+		}
+	}
+	public void InputText() {
+		//テキストにinputFieldの内容を反映
+		send_text = input_field.text;
+	}
+	// ボタンクリック時
+	public void NetworkRequest() {
+		// 接続要求
+		network_stream = new TcpClient(server_ip_address, port).GetStream();
+		// 送信の内容をセット
+		if (send_text.Length == 0) return;
+		byte[] send_string = Encoding.UTF8.GetBytes(send_text);
+		// データを送信
+		network_stream.Write(send_string, 0, send_string.Length);
+		network_stream.Close();
+	}
+	public void Listener() {
+		SynchronizationContext.SetSynchronizationContext(context);
+		listener = new TcpListener(IPAddress.Any, port);
+		Debug.Log("監視開始1");
+		try {
+			listener.Start();
+		}
+		catch (Exception e) {
+			Debug.Log(e.Message);
+			Debug.Log(e.TargetSite);
+			Debug.Log(e.StackTrace);
+		}
+		Debug.Log("監視開始2");
+		while (true) {
+			//接続要求があったら受け入れる
+			TcpClient client = listener.AcceptTcpClient();
+			Debug.Log("きた！");
+			network_stream = client.GetStream();
+			// データを受信
+			network_stream.Read(buffer, 0, buffer.Length);
+			string message = Encoding.UTF8.GetString(buffer);
+			Debug.Log(message);
+			a = message;
+			// バッファリセット
+			buffer = new byte[4096];
+			network_stream.Close();
+		}
+	}
+}
+```