pcをサーバーとし、androidをクライアントとしたソケット通信を行いたい。

Question

前提・実現したいこと

pcをサーバーとし、androidをクライアントとしたソケット通信を行いたい。

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

pcでサーバーのプログラムを起動し待ち状態にした後に、クライアントとしたandroid studioを実行しているが、サーバー側で受信出来ないでいます。
内容としてはandroid studioでボタンを押すことで文字列を送った際に、サーバー側で偶数か奇数か判別するものになっており、今はクライアント側で「２」を送信しています。eclipseもandroid studioもエラーははかず実行できている状態です。
android studioではインターネット接続を行うパーミッションは追加してあります。
エラーが出ないためなぜサーバー側で受信できていないのか、もしくはクライアント側が送信できていないのか教えて頂けないでしょうか。よろしくお願い致します。
ソースコードは以下になります。

該当のソースコード

//クライアント側
import android.app.Activity;
import android.util.Log;

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

class SocketConnection extends Activity {

    void Connect(){

        Socket cSocket = null;
        PrintWriter writer = null;
        BufferedReader reader = null;

        try{
            cSocket = new Socket(IPアドレス, ポート番号);

            //送信
            writer = new PrintWriter
                    (cSocket.getOutputStream(), true);

            //受診
            reader = new BufferedReader
                    (new InputStreamReader
                            (cSocket.getInputStream()));

            while (true) {
                writer.println("2");

                Log.d("test","サーバー側回答：" + reader.readLine());
            }
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            try {
                if (reader != null) {
                    reader.close();
                }
                if (writer != null) {
                    writer.close();
                }
                if (cSocket != null) {
                    cSocket.close();
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
            System.out.println("終了");
        }
    }
}

import android.os.Bundle;
import android.support.v7.app.AppCompatActivity;
import android.util.Log;
import android.view.View;
import android.widget.Button;

public class MainActivity extends AppCompatActivity {

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        Button b1=findViewById(R.id.button);
        b1.setOnClickListener(new View.OnClickListener() {
            public void onClick(View view) {
                SocketConnection s = new SocketConnection();
                s.Connect();
            }
        });
    }
}

//サーバー側
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;

class Socket_Connection {
	

	void connect() throws Exception {

		ServerSocket sSocket = null;
		Socket socket = null;
		BufferedReader reader = null;
		PrintWriter writer = null;

		try{
			//ソケットを作成
			sSocket = new ServerSocket();
			sSocket.bind(new InetSocketAddress
					(IPアドレス,ポート番号));

			System.out.println("入力待ち");
			
			socket = sSocket.accept();

			//受信
			reader = new BufferedReader(
					new InputStreamReader
					(socket.getInputStream()));

			//送信
			writer = new PrintWriter(
					socket.getOutputStream(), true);

			String line = null;
			int num;
			while (true) {
				
				line = reader.readLine();

				try{
					num = Integer.parseInt(line);

					if(num%2==0){
						writer.println("OK");        		
					}else{
						writer.println("NG");
					}
				}catch(NumberFormatException e){
					writer.println("偶数を入力して下さい");
				}
				System.out.println("文字列＝" + line);
			}			
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			try{
				if (reader!=null){
					reader.close();
				}
				if (writer!=null){
					writer.close();
				}
				if (socket!=null){
					socket.close();
				}
				if (sSocket!=null){
					sSocket.close();
				}
				System.out.println("サーバー側終了です");
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
}

public class Main {
	public static void main(String[] args) throws Exception{
		Socket_Connection sc =new Socket_Connection();
		sc.connect();
	}
}

Comments

[euledge]

サーバーとAndroid Studioは同じPCで動いていませんよね? 同じポート番号では片方のソケット開けなくなります。

[wanwanteikoku]

別のPCでおこなっております。

[euledge]

WireSharkなどのパケット解析ツールで送受信されている様子を確認すると解決が早いかもです。

Answer 1

コードに改めるべき点がいくらか見られますが、私が開発環境を動かせる状況にないため、細かいことを記すことができません。少し待っていただければ、検証したコードの例示付きで回答します。

---

遅くなりましたが、回答の詳細です。

まずサーバー側ですが、「ソケットを作成」というコメントの部分で、bind()の引数にIPアドレスを与えると接続を受け付けるネットワークを指定することになります。どこからでも受け付けるサーバーを作る場合、通常はポート番号を指定するだけです。ですから、

            //ソケットを作成
            sSocket = new ServerSocket();
            sSocket.bind(new InetSocketAddress(ポート番号));

のようにしましょう。

それから連続で待ち受けるように繰り返す区間ですが、この繰り返し方では正しく動作しないと思います。

            while (true) {
                socket = sSocket.accept();

のように、繰り返し開始をaccept()の前に持ってくるべきでしょう。

次にクライアント側ですが、前回のご質問での私の回答に誤りがあって、Android 3.0以降ではUIスレッド上でネットワーク接続を行うとNetworkOnMainThreadExceptionという例外が飛んで正常に動作しないという問題がありました。ですから、リンクを示したサンプルは現在のAndroid SDKでは動きません。大変申し訳ありませんでした。

正しく動くようにするには、その回答の末尾に書いた通りThreadやAsyncTaskといった別スレッド実装が必要です。記していただいたコードから修正するには、SocketConnectionクラスは

class SocketConnection extends AsyncTask {
    @Override
    protected Void doInBackground(Void... voids) {
        Connect();
        return null;
    }

    void Connect(){
        // ここは現状通り
    }
}

のようにAsyncTaskを継承するように改めて、これを呼び出すMainActivityでは

            public void onClick(View view) {
                SocketConnection s = new SocketConnection();
                s.execute();
            }

のようにすれば、SocketConnectionに記述したConnect()を非同期タスクとして動かすことができるでしょう。

また、Connect()の中でwhile文による永久ループを作っていますが、スレッドを永久に回す設計では正しく動作しません。このwhile文は除去して、一度のConnect()実行で一つのメッセージのやり取りのみを行う方向にしましょう。

            //while (true) {
                writer.println("2");

                Log.d("test","サーバー側回答：" + reader.readLine());
            //}

これだけ改修すれば、ボタンを1度押せば一つのメッセージの送受信を行えるようになるのではないかと思います。

Answer 2

まずは、クライアントからサーバにpingがとおるかやってみることですね