java サーバにマウスの座標を送る

Question

前提・実現したいこと

プログラム超初心者大学生です。
サーバにマウスの座標を送り、受信した座標で線を引くお絵かきチャットを作りたいです。

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

回答者様の通り改善したところ、座標の送信受信はできたと思います。しかし、端末を二つ開きそれぞれMyClient4を実行し、片方の実行画面で線を引いても、もう片方の実行画面に線が描かれません。一方の画面で線を引いた時、どちらの画面にも線を引くにはどうしたらよいでしょうか。何度もすいませんが解答お願いいたします。

Exception in thread "Thread-0" java.lang.NumberFormatException: For input string: "Hello,"
	at java.base/java.lang.NumberFormatException.forInputString(NumberFormatException.java:68)
	at java.base/java.lang.Integer.parseInt(Integer.java:658)
	at java.base/java.lang.Integer.parseInt(Integer.java:776)
	at MyClient4$MesgRecvThread.run(MyClient4.java:75)

該当のソースコード

public class MyClient4 extends JFrame {
	private Container c;
	PrintWriter out;//出力用のライター
        MyCanvas2 mc;
        int x, y;   // mouse pointer position
        int px, py; // preliminary position

	public MyClient4() {
		//名前の入力ダイアログを開く
		String myName = JOptionPane.showInputDialog(null,"名前を入力してください","名前の入力",JOptionPane.QUESTION_MESSAGE);
		if(myName.equals("")){
			myName = "No name";//名前がないときは，"No name"とする
		}

		//ウィンドウを作成する
		setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);//ウィンドウを閉じるときに，正しく閉じるように設定する
		setTitle("DrawingApli");//ウィンドウのタイトルを設定する
		setSize(500,500);//ウィンドウのサイズを設定する
		c = getContentPane();//フレームのペインを取得する
		mc = new MyCanvas2(this); // mc のオブジェクト（実体）を作成
		this.setLayout(new BorderLayout(10, 10)); // レイアウト方法の指定
		this.add(mc,  BorderLayout.CENTER);       // 左側に mc （キャンバス）を配置
		this.setVisible(true); //可視化
		
		//サーバに接続する
		Socket socket = null;
		try {
			//"localhost"は，自分内部への接続．localhostを接続先のIP Address（"133.42.155.201"形式）に設定すると他のPCのサーバと通信できる
			//10000はポート番号．IP Addressで接続するPCを決めて，ポート番号でそのPC上動作するプログラムを特定する
			socket = new Socket("localhost", 10000);
		} catch (UnknownHostException e) {
			System.err.println("ホストの IP アドレスが判定できません: " + e);
		} catch (IOException e) {
			 System.err.println("エラーが発生しました: " + e);
		}
		
		MesgRecvThread mrt = new MesgRecvThread(socket, myName);//受信用のスレッドを作成する
		mrt.start();//スレッドを動かす（Runが動く）
	}
		
	//メッセージ受信のためのスレッド
	public class MesgRecvThread extends Thread {
		
		Socket socket;
		String myName;
		
		public MesgRecvThread(Socket s, String n){
			socket = s;
			myName = n;
		}
		
		//通信状況を監視し，受信データによって動作する
		public void run() {
		    try{
			    
				InputStreamReader sisr = new InputStreamReader(socket.getInputStream());
				BufferedReader br = new BufferedReader(sisr);
				out = new PrintWriter(socket.getOutputStream(), true);
				out.println(myName);//接続の最初に名前を送る   L68
				while(true) {
					String inputLine = br.readLine();//データを一行分だけ読み込んでみる
					if (inputLine != null) {//読み込んだときにデータが読み込まれたかどうかをチェックする
						System.out.println(inputLine);//デバッグ（動作確認用）にコンソールに出力する
						String[] inputTokens = inputLine.split(" ");	//入力データを解析するために、スペースで切り分ける
						String cmd = inputTokens[0];//コマンドの取り出し．１つ目の要素を取り出す
						int px = Integer.parseInt(inputTokens[0]);//数値に変換する   L75
						int py = Integer.parseInt(inputTokens[1]);//数値に変換する
						int x = Integer.parseInt(inputTokens[2]);//数値に変換する
						int y = Integer.parseInt(inputTokens[3]);//数値に変換する
						mc.paint2(px, py, x, y);
						mc.repaint();
						
					}else{
						break;
						}
				
				}
			    
				socket.close();
			} catch (IOException e) {
				System.err.println("エラーが発生しました: " + e);
				}
		}
	}


	public static void main(String[] args) {
		MyClient4 net = new MyClient4();
		net.setVisible(true);
	}
}


class MyCanvas2 extends Canvas implements MouseListener, MouseMotionListener {
  // ■ フィールド変数
  int x, y;   // mouse pointer position
  int px, py; // preliminary position
  int ow, oh; // width and height of the object
  int mode;   // drawing mode associated as below
  Image img = null;   // 仮の画用紙
  Graphics gc = null; // 仮の画用紙用のペン
  Dimension d; // キャンバスの大きさ取得用
  PrintWriter out;//出力用のライター
  MyClient4 client4;

  // ■ コンストラクタ
  MyCanvas2(MyClient4 obj){
    this.setSize(500,500);        // キャンバスのサイズを指定
    setBackground(new Color(255, 255, 255));
    addMouseListener(this);       // マウスのボタンクリックなどを監視するよう指定
    addMouseMotionListener(this); // マウスの動きを監視するよう指定
    client4 = obj;
  }

  // ■ メソッド（オーバーライド）
  // フレームに何らかの更新が行われた時の処理
  public void update(Graphics g) {
    paint(g); // 下記の paint を呼び出す
  }

  // ■ メソッド（オーバーライド）
  public void paint(Graphics g) {
    d = getSize();   // キャンバスのサイズを取得
    if (img == null) // もし仮の画用紙の実体がまだ存在しなければ
      img = createImage(d.width, d.height); // 作成
    if (gc == null)  // もし仮の画用紙用のペン (GC) がまだ存在しなければ
      gc = img.getGraphics(); // 作成

    paint2(px,py,x,y);
    g.drawImage(img, 0, 0, this); // 仮の画用紙の内容を MyCanvas に描画
  }

    public void paint2(int px, int py, int x, int y){
	gc.drawLine(px, py, x, y);
    }
	
   
  // ■ メソッド
  // 下記のマウス関連のメソッドは，MouseListener をインターフェースとして実装しているため
  // 例え使わなくても必ず実装しなければならない
  public void mouseClicked(MouseEvent e){}// 今回は使わないが、無いとコンパイルエラー
  public void mouseEntered(MouseEvent e){
      //System.out.println("マウスが入った");
  }// 今回は使わないが、無いとコンパイルエラー
  public void mouseExited(MouseEvent e){
      //System.out.println("マウス脱出");
  } // 今回は使わないが、無いとコンパイルエラー
  public void mousePressed(MouseEvent e){ // マウスボタンが押された時の処理
      System.out.println("マウスを押した");
      x = e.getX();
      y = e.getY();
      System.out.println(x+", "+y);
      
  }
  public void mouseReleased(MouseEvent e){ // マウスボタンが離された時の処理
      System.out.println("マウスを放した");
  }

  // ■ メソッド
  // 下記のマウス関連のメソッドは，MouseMotionListener をインターフェースとして実装しているため
  // 例え使わなくても必ず実装しなければならない
  public void mouseDragged(MouseEvent e){ // マウスがドラッグされた時の処理
      System.out.println("マウスをドラッグ");
      px = x;
      py = y;
      x = e.getX();
      y = e.getY();
      System.out.println(px+", "+py+", "+x+", "+y);
      
      //送信情報を作成する（受信時には，この送った順番にデータを取り出す．スペースがデータの区切りとなる）
      String msg = px+" "+py+" "+x+" "+y;

      //サーバに情報を送る
      client4.out.println(msg);//送信データをバッファに書き出す
      client4.out.flush();//送信データをフラッシュ（ネットワーク上にはき出す）する 
      repaint(); // 再描画  
  }
  public void mouseMoved(MouseEvent e){
      //System.out.println("マウスをドラッグ");
  } // 今回は使わないが、無いとコンパイルエラー
}
*********************************************************************
MyServer.java

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

//スレッド部（各クライアントに応じて）
class ClientProcThread extends Thread {
	private int number;//自分の番号
	private Socket incoming;
	private InputStreamReader myIsr;
	private BufferedReader myIn;
	private PrintWriter myOut;
	private String myName;//接続者の名前

	public ClientProcThread(int n, Socket i, InputStreamReader isr, BufferedReader in, PrintWriter out) {
		number = n;
		incoming = i;
		myIsr = isr;
		myIn = in;
		myOut = out;
	}

	public void run() {
		try {
			myOut.println("Hello, client No." + number + "! Enter 'Bye' to exit.");//初回だけ呼ばれる
			
			myName = myIn.readLine();//初めて接続したときの一行目は名前

			while (true) {//無限ループで，ソケットへの入力を監視する
				String str = myIn.readLine();
				System.out.println("Received from client No."+number+"("+myName+"), Messages: "+str);
				if (str != null) {//このソケット（バッファ）に入力があるかをチェック
					if (str.toUpperCase().equals("BYE")) {
						myOut.println("Good bye!");
						break;
					}
					MyServer.SendAll(str, myName);//サーバに来たメッセージは接続しているクライアント全員に配る
				}
			}
		} catch (Exception e) {
			//ここにプログラムが到達するときは，接続が切れたとき
			System.out.println("Disconnect from client No."+number+"("+myName+")");
			MyServer.SetFlag(number, false);//接続が切れたのでフラグを下げる
		}
	}
}

class MyServer{
	
	private static int maxConnection=100;//最大接続数
	private static Socket[] incoming;//受付用のソケット
	private static boolean[] flag;//接続中かどうかのフラグ
	private static InputStreamReader[] isr;//入力ストリーム用の配列
	private static BufferedReader[] in;//バッファリングをによりテキスト読み込み用の配列
	private static PrintWriter[] out;//出力ストリーム用の配列
	private static ClientProcThread[] myClientProcThread;//スレッド用の配列
	private static int member;//接続しているメンバーの数

	//全員にメッセージを送る
	public static void SendAll(String str, String myName){
		//送られた来たメッセージを接続している全員に配る
		for(int i=1;i<=member;i++){
			if(flag[i] == true){
				out[i].println(str);
				out[i].flush();//バッファをはき出す＝＞バッファにある全てのデータをすぐに送信する
				System.out.println("Send messages to client No."+i);
			}
		}	
	}
	
	//フラグの設定を行う
	public static void SetFlag(int n, boolean value){	
		flag[n] = value;
	}
	
	//mainプログラム
	public static void main(String[] args) {
		//必要な配列を確保する
		incoming = new Socket[maxConnection];
		flag = new boolean[maxConnection];
		isr = new InputStreamReader[maxConnection];
		in = new BufferedReader[maxConnection];
		out = new PrintWriter[maxConnection];
		myClientProcThread = new ClientProcThread[maxConnection];
		
		int n = 1;
		member = 0;//誰も接続していないのでメンバー数は０

		try {
			System.out.println("The server has launched!");
			ServerSocket server = new ServerSocket(10000);//10000番ポートを利用する
			while (true) {
				incoming[n] = server.accept();
				flag[n] = true;
				System.out.println("Accept client No." + n);
				//必要な入出力ストリームを作成する
				isr[n] = new InputStreamReader(incoming[n].getInputStream());
				in[n] = new BufferedReader(isr[n]);
				out[n] = new PrintWriter(incoming[n].getOutputStream(), true);
				
				myClientProcThread[n] = new ClientProcThread(n, incoming[n], isr[n], in[n], out[n]);//必要なパラメータを渡しスレッドを作成
				myClientProcThread[n] .start();//スレッドを開始する
				member = n;//メンバーの数を更新する
				n++;
			}
		} catch (Exception e) {
			System.err.println("ソケット作成時にエラーが発生しました: " + e);
		}
	}
}

試したこと

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

サーバとクライアントはこちらを参考にしました。https://yoslab.net/netprog/index.php?%B1%E9%BD%AC3-2%20%A5%CD%A5%C3%A5%C8%A5%EF%A1%BC%A5%AF%C2%D0%C0%EF%A5%B2%A1%BC%A5%E0%A5%AF%A5%E9%A5%A4%A5%A2%A5%F3%A5%C8

Comments

[m.ts10806]

アプレットは指定なのでしょうか。
確か9で非推奨11で削除されたはずで、今から学習するメリットは無いのではと

[jimbe]

コードは, ``` で挟まれた "コード" という文字列を置き換える形で記入してください.

[jimbe]

出来るだけコードは全体をご提示ください.
余りにも大きいようでしたら, 不要な個所は削除し, 動作(例外が発生)する状態で, 発生した例外のメッセージを全文掲載してください.

[jimbe]

修正ありがとうございます.
ですが, 例外のメッセージが途中からなので, 何の例外が発生しているのかが分かりません. "～Exception ～" という行から全部ご提示願えますか.

> at MyCanvas2.mouseDragged(MyClient4.java:317)
MyClient4.java の 317 行目とはどこでしょう.

[退会済みユーザー]

そもそも書いた画像を送ればいい気もするが

[退会済みユーザー]

@m.ts10806

JFrame の拡張クラスだから アプレットじゃないとおもうが

[m.ts10806]

asahina1979さん
最初タグがついてたもので。

Answer 1

MyCanvas2のoutはどこにも代入がありません。
よってNullPointerExceptionが出ています。
単純にやるならこうでしょうか（関係のない部分は省略します）

class MyCanvas2 {
    MyClient4 client4;
    MyCanvas2(MyClient4 obj) {
        client4 = obj;
    }
    public void mouseDragged(MouseEvent e) {
        client4.out.println(msg);
        client4.out.flush();
    }
}

MesgRecvThreadのほうで差し込んでもいいです。

あと受信時に描画が即時反映されなかったので、雑にrepaintしました。
入れる場所を気を付けないと、paint無限ループになります（なりました^^;

while (true) {
    mc.paint2(px, py, x, y);
    mc.repaint(); // これ
    } else {
        break;
    }
}

Comments

[1236]

回答者様の通り改善したところ、座標の送信受信はできたと思います！しかし、端末を二つ開きそれぞれMyClient4を実行し、片方の実行画面で線を引いても、もう片方の実行画面に線が描かれません。一方の画面で線を引いた時、どちらの画面にも線を描かれるようにするにはどうしたらよいでしょうか。何度もすいませんが教えていただけると助かります。

[TN8001]

即時反映されないということでしょうか?
それともClientA ClientBどちらに線を引いても自分の分しか出ませんか?

[1236]

自分の分しか線が引かれない状況です。他人が描いた線も自分の画面に表示されるようにしたいです。

[TN8001]

MyServer.javaの
myOut.println("Hello, client No." + number + "! Enter 'Bye' to exit.");
をコメントアウトしてください。

クライアントは座標が来ると思っていますから、余計な文字が来るとエラーになっているはずです。

[1236]

。

[1236]

。

[1236]

不要と思い勝手にコメントアウトしていたところを戻したらうまくいきました。ご親切に何度も解答ありがとうございました!!

Answer 2

java.lang.NumberFormatException: For input string: "Hello,"

サーバー側のコードを見ると, クライアントからの接続時にグリーティングメッセージを送信しています.

myOut.println("Hello, client No." + number + "! Enter 'Bye' to exit.");//初回だけ呼ばれる

クライアント側では即描画のデータが送られてくることを前提に受信した文字列を解析しようとしています.

  String[] inputTokens = inputLine.split(" ");    //入力データを解析するために、スペースで切り分ける
  String cmd = inputTokens[0];//コマンドの取り出し．１つ目の要素を取り出す
  int px = Integer.parseInt(inputTokens[0]);//数値に変換する   L75
  int py = Integer.parseInt(inputTokens[1]);//数値に変換する
  int x = Integer.parseInt(inputTokens[2]);//数値に変換する
  int y = Integer.parseInt(inputTokens[3]);//数値に変換する

しかも px が先頭の文字列([0])を数値化しようとしていますので, そこで例外が発生しているものと思います.

サーバーのグリーティングを無くすか, クライアントが接続直後の1行を読み飛ばすようにする必要があるかと思います.

Comments

[1236]

初めての質問で至らないところが多々あり失礼致しました。修正したところ改善しました!!