androidでsocket通信

Question

#実現させたいこと
androidから獲得したジャイロセンサーの値をnetcatを使いマックに連続して表示させたい。
#該当のコード

import android.app.Activity;
import android.content.Context;
import android.hardware.Sensor;
import android.hardware.SensorEvent;
import android.hardware.SensorEventListener;
import android.hardware.SensorManager;
import android.os.AsyncTask;
import android.os.Bundle;
import android.view.SurfaceHolder;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.OutputStream;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.util.List;


public class MainActivity extends Activity
        implements SensorEventListener, SurfaceHolder.Callback{

    SensorManager mSensorManager;
    Sensor mAccSensor;

    float mVX;
    float mVY;




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

        mSensorManager = (SensorManager) getSystemService(Context.SENSOR_SERVICE);
        mAccSensor = mSensorManager.getDefaultSensor(Sensor.TYPE_GYROSCOPE);


       /* Button btn = (Button) findViewById(R.id.Button01);
        btn.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                connect("koko");
            }
        });*/

    }

    @Override
    protected void onStop() {
        super.onStop();
        mSensorManager.unregisterListener(this);
    }

    @Override
    protected void onResume() {
        super.onResume();
        List<Sensor> sensors = mSensorManager.getSensorList(Sensor.TYPE_GYROSCOPE);
        if(sensors.size() > 0) {
            Sensor s = sensors.get(0);
            mSensorManager.registerListener(this, s, SensorManager.SENSOR_DELAY_UI);
        }
    }

    public void connect(final String str) {
        new AsyncTask<Void, Void, String>() {


            @Override
            protected String doInBackground(Void... voids) {
                try {

                    Socket socket = new Socket("10.0.33.13",4000);
                    OutputStream os = socket.getOutputStream();

                    BufferedWriter bufwriter
                            = new BufferedWriter(new OutputStreamWriter( os ) );
                    bufwriter.write(str);
                    //bufwriter.newLine();
                    bufwriter.flush();
                    bufwriter.close();
                    socket.close();



                } catch (IOException e) {
                    e.printStackTrace();
                }
                return null;
            }
        }.execute();
    }

    @Override
    public void onSensorChanged(SensorEvent event) {
        if(event.sensor.getType() == Sensor.TYPE_GYROSCOPE) {


            float y = event.values[1];
            float x = event.values[2];

            mVX = mVX + x;
            mVY = mVY + y;


            String str = "X:" + mVX +"\n"
                    +  "Y:" + mVY +"\n";

            connect(str);
        }
    }

    @Override
    public void onAccuracyChanged(Sensor sensor, int accuracy) {//使わない
    }

    @Override
    public void surfaceCreated(SurfaceHolder holder) {
        registerSensor();
    }

    public void registerSensor() {
        mSensorManager.registerListener(this, mAccSensor, SensorManager.SENSOR_DELAY_GAME);
    }

    @Override
    public void surfaceChanged(SurfaceHolder holder, int format, int width, int height) {

        mVX = 0;
        mVY = 0;
    }

    @Override
    public void surfaceDestroyed(SurfaceHolder holder) {
        mSensorManager.unregisterListener(this);
    }
}

onSensorChanged()でセンサーが獲得する値が変わるたびにconnect()は呼ばれるので連続に表示されると思いましたが一度だけ表示されるだけでうまくいきませんでした。

connect()の bufwriter.flush();が終了させているのでしょうか？

そもそもこの通信方法で連続して文字列を返すのはできませんか？

ご存知の方がいましたらご教授ください

#Server.java

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 Server {
    public static void main(String[] args) {
        // サーバーソケットを生成＆待機
        try {
            ServerSocket server = new ServerSocket();
            server.bind(new InetSocketAddress("アドレス", ポート番号));
            try {
                Socket socket = server.accept();
                BufferedReader reader = new BufferedReader(
                        new InputStreamReader(socket.getInputStream()));
                PrintWriter writer = new PrintWriter(
                        socket.getOutputStream(), true);
                // 入力を受け取ったら、大文字に変換の上で応答
                while (true) {
                    String line = reader.readLine();
                    if (line == "q") {
                        break;
                    }
                    
                    writer.println(line.toUpperCase());
                    System.out.println(line);
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

Answer 1

TCPクライアント側になるプログラムは、一連の通信が終わったらソケットを閉じる必要があります。

//bufwriter.close();
//socket.close();

のコメントアウトを取り除きましょう。

ポートを開きっぱなしにするのはサーバー側となるプログラムです。

---

簡易TCPサーバーのサンプル

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

public class Server {
    public static void main(String[] args) {
        try {
            ServerSocket server = new ServerSocket();
            server.bind(new InetSocketAddress(4000)); // ポート4000で待ち受ける
            // 無限ループで待ち受けを続ける
            while (true) {
                Socket socket = server.accept();  // 接続を受け付け
                BufferedReader reader = new BufferedReader(
                        new InputStreamReader(socket.getInputStream()));
                String line;
                // 受信した本文を標準出力に表示する
                while ((line = reader.readLine()) != null) {
                    System.out.println(line);
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

Comments

[退会済みユーザー]

今サーバー側のプログラムをSv.javaとして載せたのですが、これを変えればいいのでしょうか？

[keicha_hrs]

netcatコマンドを使うのではなかったのですか？もしnetcatを簡易サーバーとする方法がわからなかったのなら、
netcat -lk -p 4000
でできると思います。（Linuxでは検証済み、macOSだとわからないが多分同じ）

sv.javaの方は、これではサーバーになりません。JavaのServerSocketクラスを調べてみましょう。

[退会済みユーザー]

すいません。sv.javaはぜんぜん違うこと書いていました！netcat -lk -p 4000 だとうまくいかず、http://sweng.web.fc2.com/ja/program/shellscript/nc.htmlここにはnc -k -l 8888と書いたにもかかわらずエラーが出てしまいました。

[退会済みユーザー]

また、新しくServer.javaを作ったのですが、Exception in thread "main" java.lang.NullPointerException at Server.main(Server.java:30)とエラーが出てしまいました

[keicha_hrs]

どこからか丸写ししてきたコードのようですが、意味を理解して引用しないと決して思うようには動いてくれませんよ？

簡易的ですがサーバーになるコードを回答欄に書いてみました。これで連続して受け取れると思います。

[keicha_hrs]

あと、質問のタグがJavaScriptになっていますが、全く関係ないので修正しておくべきでしょう。

[退会済みユーザー]

すいません。ありがとうございました。