スレッドとハッシュを使ったTCPプログラミング

Question

前提・実現したいこと

サーバ側は接続したら文字列を送り、その接続をスレッドに渡して多数のクライアントから接続できるようにしたいです。クライアントは送られた文字列を4つのスレッドを使い前方2バイトが0になるようにハッシュ値を探してその数字をサーバに送り返すようにしたいです。Judgeクラスはサーバーのスレッドでクライアントから送られたハッシュ値が正しいか判断するようにしたいです。NonceFinderクラスはクライアントのスレッドでハッシュ値を探すようにしたいです。大学の課題なのですが、色々調べながら自分で解決しようとしたのですがどうしても解決できなくなってしまったのでお力を借りたいと思い質問させてもらいました。

発生している問題・エラーメッセージ

エラーメッセージは出ない状況なのですが、クライアントの35行目で数値が入ってるのは確認できていて、その後のJudgeクラスでは送られてこないという状態です。

エラーメッセージ

該当のソースコード

package sp1;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

public class TcpSockClient {
	public static void main(String args[]) {
		String ipAddress = "127.0.0.1";
		int portNumber = 34567;
		Socket socket = null;
		int numOfThreads=4;
		PrintWriter pw = null;
		BufferedReader br = null;


		try {
			socket = new Socket(ipAddress, portNumber);
			br = new BufferedReader(new InputStreamReader(socket.getInputStream()));

			String message = br.readLine();

			int[] nonces = {0,0};
			NonceFinder[] NF =new NonceFinder[numOfThreads];
			for(int i=0;i<numOfThreads;i++) {
				NF[i] = new NonceFinder(message,nonces);
				NF[i].start();
			}


			while(nonces[0] !=0) {
				String as=Integer.toString(nonces[1]);
				pw = new PrintWriter(socket.getOutputStream(), true);
				pw.println(as);

				break;
			}


			br.readLine();






		} catch(UnknownHostException e) {
			e.printStackTrace();
		} catch(IOException e) {
			e.printStackTrace();
		}
	}
}

package sp1;

import java.io.BufferedReader;
import java.io.PrintWriter;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.util.Random;

public class NonceFinder extends Thread{


	private String message;
	private MessageDigest md;
	byte[] value;
	int answer;
	int[] nonces;
	Random rand =new Random();
	int i=rand.nextInt();
	PrintWriter pw = null;
	BufferedReader br = null;


	public NonceFinder(String message,int[] nonces) {
		this.message = message;
		this.nonces =nonces;
	}

	public void run() {
		try {

			while(true) {
				String input =message +i;
				boolean ans =true;
				md = MessageDigest.getInstance("SHA-1");
				value = md.digest(input.getBytes());
				for(int j=0;j<2;j++) {
					if(value[j]==0) {
					}else {
						ans =false;
					}
				}
				if(ans) {
					nonces[0]=1;
					nonces[1]=i;
					break;
				}

				if(i < Integer.MAX_VALUE) {
					i++;
				} else {
					i = Integer.MIN_VALUE;
				}
			}





		} catch (NoSuchAlgorithmException e) {
			// TODO 自動生成された catch ブロック
			e.printStackTrace();
		}
		return;
	}
}

package sp1;


import java.io.BufferedReader;
import java.io.IOException;
import java.io.PrintWriter;
import java.net.Socket;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;

public class Judge extends Thread {

	private Socket socket;
	private String answer;

	private MessageDigest md;
	byte[] value;
	PrintWriter pw;
	boolean as=true;

	BufferedReader br;


	public Judge(Socket socket,String answer,BufferedReader br,PrintWriter pw) {
		this.socket = socket;
		this.answer = answer;
		this.br = br;
		this.pw =pw;
	}

	public void run() {

		try {
			try {



				//Thread.sleep(1000);
				/*while(true) {
					if(br.readLine() !=null) {
						break;
					}
				}*/

				while(br.readLine() !=null) {

					int nonce =Integer.parseInt(br.readLine());


					answer=answer+nonce;
					md = MessageDigest.getInstance("SHA-1");
					value = md.digest(answer.getBytes());
					for(int i=0;i<2;i++) {
						if(value[0]==0) {

						}else {
							as=false;
						}
						if(as) {
							System.out.println(getId()+","+nonce);
							pw.println("ok");
						}else {
							System.out.print("s");
							pw.println("miss");
						}
					}


					socket.close();
				}

			} catch(IOException e) {
				e.printStackTrace();
			} catch (NoSuchAlgorithmException e) {
				// TODO 自動生成された catch ブロック
				e.printStackTrace();
			}
		} catch (NumberFormatException e) {
			// TODO 自動生成された catch ブロック
			e.printStackTrace();
		}
		return;
	}
}

package sp1;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;



public class TcpSockServer {
	public static void main(String[] args) {
		String str = "Taro2Jiro100;John2Ken235";

		int portNumber = 34567;

		ServerSocket serverSocket = null;
		Socket socket = null;
		PrintWriter pw = null;
		BufferedReader br = null;





		try {

			serverSocket =new ServerSocket();

			serverSocket.bind(new InetSocketAddress(portNumber));




			while(true) {
				socket =serverSocket.accept();
				pw = new PrintWriter(socket.getOutputStream(), true);
				pw.println(str);
				br = new BufferedReader(new InputStreamReader(socket.getInputStream()));


				Judge judge = new Judge(socket,str,br,pw);
				judge.start();

			}

		} catch (IOException e) {
			// TODO 自動生成された catch ブロック
			e.printStackTrace();
		}
	}
}

ソースコード

Java

試したこと

printWriterがうまくいっていないのかと思い、バイナリ送受信も試してみましたがダメでした。

補足情報（FW/ツールのバージョンなど）

eclipseを使っています。

Answer 1

Judgeクラス

                while(br.readLine() !=null) {

                    int nonce =Integer.parseInt(br.readLine());

whileの継続条件の中でreadLine()しているので、クライアントから1行読み込みの入力を待ちます。
クライアントから1行入力したら、次の行でさらにreadLine()しているので、ここでもクライアントから1行データ送信されるのを待っています。
クライアント側のソースを見るかぎり1行送信してサーバからの受信待ちになるので、ここでお互いが永遠に相手の送信を待つことになります。

クライアントからは1行だけの読み込みであれば、ここでwhileを使った待ち合わせは必要ないのではないでしょうか。

Comments

[yuyu9]

ありがとうございます。確かにその部分はいりませんでした。error文がnullで読み取れないということがあったのでその部分を追加したのです。実際の問題は、処理が早くて、サーバーとクライアント側の対応がうまくいっていなかったようです。ありがとうございました。