Socketでの接続処理とは別のクラスでデータ送信を行いたい

Question

Socketでの接続処理とは別のクラスでデータ送信を行いたい

私はandroidstudioでアプリ開発を行っている初心者です。

MainActivityでSocketの接続処理を行っておりこの処理は動作が確認できました。MyDialogFragmentクラスでダイアログを表示し、ダイアログのOKボタンを押したときに３つのEditTextの内容をサーバーへ送信したいと考えています。

このような場合MainActivityのSocketの内容をMyDialogFragmentに反映させるにはどうしたらいいのでしょうか？

また、Socket.connect();での接続はできるのですが、切断処理がわかりません。こちらもわかる方がいましたらお願いします。

#MainActivity.java

package to.msn.wings.dialogargs;

import androidx.appcompat.app.AppCompatActivity;
import androidx.fragment.app.DialogFragment;

import android.content.Intent;
import android.os.Bundle;
import android.os.Parcelable;
import android.widget.Button;
import android.widget.CompoundButton;
import android.widget.EditText;
import android.widget.Toast;
import android.widget.ToggleButton;

import java.io.IOException;
import java.io.PrintWriter;
import java.net.InetSocketAddress;
import java.net.Socket;

public class MainActivity extends AppCompatActivity {

    @Override

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

        Button btn = findViewById(R.id.button1);
        ToggleButton toggle = findViewById(R.id.toggleButton);

        btn.setOnClickListener(view -> {
            EditText txtName1 = findViewById(R.id.editText1);
            EditText txtName2 = findViewById(R.id.editText2);
            EditText txtName3 = findViewById(R.id.editText3);

            DialogFragment dialog = new MyDialogFragment();
            Bundle args = new Bundle();
            args.putString("txtName1", txtName1.getText().toString());
            args.putString("txtName2", txtName2.getText().toString());
            args.putString("txtName3", txtName3.getText().toString());
            dialog.setArguments(args);
            dialog.show(getSupportFragmentManager(), "dialog_basic");
        });

        toggle.setOnCheckedChangeListener((buttonView, isChecked) ->{
            String ip = "10.22.18.109";
            int port = 50015;
            InetSocketAddress address = new InetSocketAddress(ip,  port);
            Socket socket = new Socket();
            if (isChecked) {
                new Thread (() -> {
                    try {
                        socket.connect(address, 3000);
                        MainActivity.this.runOnUiThread(() ->
                                Toast.makeText(MainActivity.this, "接続に成功しました。", Toast.LENGTH_LONG).show());
                    } catch (Exception e) {
                        MainActivity.this.runOnUiThread(() ->
                                Toast.makeText(MainActivity.this, "接続に失敗しました。", Toast.LENGTH_LONG).show());
                    }
                    PrintWriter pw = null;
                    try {
                        pw = new PrintWriter(socket.getOutputStream(), true);
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                    pw.println("タブレット端末接続開始");
                }).start();
            } else {
                // The toggle is disabled
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        });
    }

#MyDialogFragment.java

package to.msn.wings.dialogargs;

import android.app.AlertDialog;
import android.app.Dialog;
import android.os.Bundle;
import android.content.Intent;
import androidx.annotation.NonNull;
import androidx.fragment.app.DialogFragment;

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



public class MyDialogFragment extends DialogFragment {
    @NonNull
//    @Override
    /*組立・仕分けST*/


    public Dialog onCreateDialog(Bundle savedInstanceState) {
        Bundle args = requireArguments();
        String txtName1 = args.getString("txtName1");
        String txtName2 = args.getString("txtName2");
        String txtName3 = args.getString("txtName3");

        AlertDialog.Builder builder = new AlertDialog.Builder(getActivity());

        builder.setTitle("                  !!最終確認!!")
                .setMessage(String.format("X座標 : %30s\n\n" + "Y座標 : %30s\n\n" + "Z座標 : %30s", txtName1, txtName2, txtName3))
                .setPositiveButton("OK", (dialog, id) -> {
                    //OKボタンを押したときの動作
//                    Socket socket = getIntent().getExtra("txtName");
                    Socket socket = new Socket();
                    PrintWriter pw = null;
                    try {
                        pw = new PrintWriter(socket.getOutputStream(), true);
                        pw.println(txtName1);
                        pw.println(txtName2);
                        pw.println(txtName3);
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                })
                .setIcon(R.drawable.chuui)
                .setNegativeButton("キャンセル", null);

        return builder.create();
    }
}

Comments

[jimbe]

ダイアログのOKボタンを押した時にも new Socket が書いてありますが、そのまま、メインで行っている接続をダイアログに移動させるのではダメなのでしょうか。

[jimbe]

ご質問にタグ付けされている "Socket.IO" は js のライブラリのことですので、関係ありません。外されたほうが良いように思います。

Answer 1

例えば、 Thread で接続した結果として PrintWriter をフィールドにし、 DialogFragment が OK されたら FragmentResultListener 経由で Main で出力というのは如何でしょう。

MainActivity.java

import androidx.appcompat.app.*;

import android.os.*;
import android.util.Log;
import android.widget.*;

import java.io.*;
import java.net.*;

public class MainActivity extends AppCompatActivity {
  public static final String LOG_TAG = "MainActivity";
  private static String CONFIRM_SEND_REQUESTKEY = "confirmSend";

  private Socket socket;
  private BufferedReader br;
  private PrintWriter pw;

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

    getSupportFragmentManager().setFragmentResultListener(CONFIRM_SEND_REQUESTKEY, this, (requestKey, result) -> {
      new Thread (() -> {
        try {
          String name1 = result.getString(MyDialogFragment.RESULT_TXTNAME1);
          String name2 = result.getString(MyDialogFragment.RESULT_TXTNAME2);
          String name3 = result.getString(MyDialogFragment.RESULT_TXTNAME3);
          Log.d(LOG_TAG, "send:" + name1);
          pw.println(name1);
          String line = br.readLine();
          if(!line.endsWith(":OK")) Log.e(LOG_TAG, "Error: "+line);
          Log.d(LOG_TAG, "send:" + name2);
          pw.println(name2);
          line = br.readLine();
          if(!line.endsWith(":OK")) Log.e(LOG_TAG, "Error: "+line);
          Log.d(LOG_TAG, "send:" + name3);
          pw.println(name3);
          line = br.readLine();
          if(!line.endsWith(":OK")) Log.e(LOG_TAG, "Error: "+line);
        } catch(IOException e) {
          e.printStackTrace();
        }
      }).start();
    });

    EditText txtName1 = findViewById(R.id.editText1);
    EditText txtName2 = findViewById(R.id.editText2);
    EditText txtName3 = findViewById(R.id.editText3);

    Button btn = findViewById(R.id.button1);
    btn.setEnabled(false);
    btn.setOnClickListener(view -> {
      String name1 = txtName1.getText().toString();
      String name2 = txtName2.getText().toString();
      String name3 = txtName3.getText().toString();
      MyDialogFragment.newInstance(CONFIRM_SEND_REQUESTKEY, name1, name2, name3).show(getSupportFragmentManager(), null);
    });

    ToggleButton toggle = findViewById(R.id.toggleButton);
    toggle.setOnCheckedChangeListener((buttonView, isChecked) -> {
      String ip = "10.22.18.109";
      //String ip = "10.0.2.2"; //エミュレータホスト
      int port = 50015;
      InetSocketAddress address = new InetSocketAddress(ip,  port);
      socket = new Socket();
      if (isChecked) {
        Log.d(LOG_TAG, "connect start");
        new Thread (() -> {
          try {
            socket.connect(address, 3000);
            br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            pw = new PrintWriter(socket.getOutputStream(), true);
            pw.println("タブレット端末接続開始");
            String line = br.readLine();
            if(line.endsWith(":OK")) {
              MainActivity.this.runOnUiThread(() -> {
                Log.d(LOG_TAG, "接続に成功しました。");
                Toast.makeText(MainActivity.this, "接続に成功しました。", Toast.LENGTH_LONG).show();
                btn.setEnabled(true);
              });
            } else {
              throw new IOException(line);
            }
          } catch (Exception e) {
            Log.d(LOG_TAG, "接続に失敗しました。");
            MainActivity.this.runOnUiThread(() -> Toast.makeText(MainActivity.this, "接続に失敗しました。", Toast.LENGTH_LONG).show());
            e.printStackTrace();
          }
        }).start();
      } else {
        Log.d(LOG_TAG, "disconnect start");
        btn.setEnabled(false);
        try {
          br.close();
        } catch (IOException ignore) {}
        pw.close();
        try {
          socket.close();
        } catch (IOException ignore) {}
        socket = null;
        pw = null;
        br = null;
      }
    });
  }
}

MyDialogFragment.java

import android.app.Dialog;
import android.os.Bundle;

import androidx.annotation.NonNull;
import androidx.appcompat.app.AlertDialog;
import androidx.fragment.app.DialogFragment;

public class MyDialogFragment extends DialogFragment {
  static final String RESULT_TXTNAME1 = "txtName1";
  static final String RESULT_TXTNAME2 = "txtName2";
  static final String RESULT_TXTNAME3 = "txtName3";

  private static final String PARAM_REQUESTKEY = "requestKey";
  private static final String PARAM_TXTNAME1 = "txtName1";
  private static final String PARAM_TXTNAME2 = "txtName2";
  private static final String PARAM_TXTNAME3 = "txtName3";

  static MyDialogFragment newInstance(String requestKey, String name1, String name2, String name3) {
    MyDialogFragment dialog = new MyDialogFragment();
    Bundle args = new Bundle();
    args.putString(PARAM_REQUESTKEY, requestKey);
    args.putString(PARAM_TXTNAME1, name1);
    args.putString(PARAM_TXTNAME2, name2);
    args.putString(PARAM_TXTNAME3, name3);
    dialog.setArguments(args);
    return dialog;
  }

  @NonNull
  public Dialog onCreateDialog(Bundle savedInstanceState) {
    Bundle args = requireArguments();
    String requestKey = args.getString(PARAM_REQUESTKEY);
    String txtName1 = args.getString(PARAM_TXTNAME1);
    String txtName2 = args.getString(PARAM_TXTNAME2);
    String txtName3 = args.getString(PARAM_TXTNAME3);

    return new AlertDialog.Builder(requireActivity()).setTitle("!!最終確認!!")
            //.setIcon(R.drawable.chuui)
            .setMessage(String.format("X座標 : %30s\n\n" + "Y座標 : %30s\n\n" + "Z座標 : %30s", txtName1, txtName2, txtName3)).setPositiveButton("OK", (dialog, id) -> {
              Bundle result = new Bundle();
              result.putString(PARAM_TXTNAME1, txtName1);
              result.putString(PARAM_TXTNAME2, txtName2);
              result.putString(PARAM_TXTNAME3, txtName3);
              getParentFragmentManager().setFragmentResult(requestKey, result);
            }).setNegativeButton("キャンセル", null).create();
  }
}

以下はテストに使用したサーバプログラムです。

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class Server {
  public static void main(String[] args) throws IOException {
    try(ServerSocket ss = new ServerSocket(50015);) {
      System.out.println("start.");
      try(Socket client = ss.accept();
          BufferedReader br = new BufferedReader(new InputStreamReader(client.getInputStream()));
          PrintWriter pw = new PrintWriter(client.getOutputStream(), true);) {
        for(String line; (line = br.readLine()) != null; ) {
          System.out.println("[client] " + line);
          pw.println(line + ":OK");
        }
      }
      System.out.println("end.");
    }
  }
}

実行操作
トグル ON → X:10, Y:12, Z:14 を入力 → SEND 押下 → ダイアログ OK 押下 → トグル OFF

実行結果(クライアント側ログ)

D/MainActivity: connect start
D/MainActivity: 接続に成功しました。
D/MainActivity: send:10
D/MainActivity: send:12
D/MainActivity: send:14
D/MainActivity: disconnect start

実行結果(サーバ側)

start.
[client] タブレット端末接続開始
[client] 10
[client] 12
[client] 14
end.

Comments

[abcdssh]

ありがとうございます。回答のように書き換え実行しましたが、「接続が成功しました」と表示された直後に「接続が失敗しました」となってしまいます。また、btn.setOnClickListenerのボタンを押すとアプリが停止してしまうのですが原因などわかりますでしょうか？

[jimbe]

「成功しました」の後すぐに「失敗しました」と出るとすれば、 PrintWriter で「タブレット端末接続開始」と送信するところで異常が発生したのではないでしょうか。
回答のコードでは「失敗しました」とトーストした場合は e.printStackTrace していますので、 logcat 等に詳細が出力されているはずですので、それらをお調べください。

なお、通信するプログラムですので、当然通信相手 (サーバ) の動作の影響を受けます。通信相手とのやり取りの方法はご提示のコードであっているのでしょうか。

ボタンを押した場合に「停止」という表現をされましても、直接見ていない側としましては何が起きているのかを想像することは困難です。
ボタンを押したら最後、アプリが何の操作も受け付けなくなるのでしょうか。それとも画面に「停止しました」と表示されるのでしょうか。

もし回答のコード通りに書き換えられたとすれば、「失敗しました」と表示された場合はポタンは Disable になっていて押せないはずですが(^^;

可能でしたら、ご質問の編集・追加等で「書き換え実行した」コードをご提示いただけますか。また、通信相手の仕様(プロトコル?)等もあるとこちらでも実験できます。

[abcdssh]

プログラムとしては回答のコードをそのまま使ったので変更はないです。
また停止するといった件につきましては、btn.setOnClickListenerのボタンを押すとDialogが表示される前にアプリが落ちてしまい画面には「停止しています」または「繰り返し停止しています」と表示されます。
サーバとしてはUbuntuを用いておりJAVAではないのですが以下のようになっています
---------------------------
#include <stdio.h>
#include <ctype.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <signal.h>
#include <sys/param.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <netdb.h>
#include <sys/wait.h>
#define SRV_IP "10.22.18.45"
#define PORTNO 50015
int ServerSocket(char* srvIP, int portnum);
int AcceptLoop(int s);
int SendRecvLoop(int acc);
int main(void)
{
int sockDesctipt;
sockDesctipt = ServerSocket(SRV_IP, PORTNO);
fprintf(stderr, "ready for accept\n");
AcceptLoop(sockDesctipt);
close(sockDesctipt);
return 0;
}
int ServerSocket(char* srvIP, int portnum){
int s;
int opt;
struct sockaddr_in ssock;
/*----- set address -----*/
memset(&ssock, 0, sizeof(ssock));
ssock.sin_family = AF_INET;
ssock.sin_addr.s_addr = inet_addr(srvIP);
/*----- port number -----*/
ssock.sin_port = htons(portnum);
fprintf(stderr, "port = %d \n", ntohs(ssock.sin_port));
/*-----generate of socket-----*/
s = socket(AF_INET, SOCK_STREAM, 0);
if(s < 0){
printf("socket erro !!\n");
return -1;
}
/*----- set of socket option -----*/
opt = 1;
if(setsockopt(s, SOL_SOCKET, SO_REUSEADDR, &opt, (socklen_t)sizeof(int)) != 0){
perror("setsockopt");
close(s);
return(-1);
}
/*----- set address in socket -----*/
if(bind(s, (struct sockaddr *)&ssock, sizeof(ssock)) == -1){
perror("bind");
close(s);
return(-1);
}
/*----- listen -----*/
if(listen(s, SOMAXCONN) == -1){
perror("listen");
close(s);
return(-1);
}
return(s);
}
int AcceptLoop(int s){
int acc;
int len;
struct sockaddr_in from;
while(1){
len = sizeof(from);
/*----- accept -----*/
acc = accept(s, (struct sockaddr *)&from, (socklen_t *)&len);
if(acc < 0){
printf("error : accept\n");
return -1;
}
else{
printf("accept : %s : %d \n", inet_ntoa(from.sin_addr), ntohs(from.sin_port));
}
SendRecvLoop(acc);
close(acc);
acc = 0;
}
return(0);
}
int SendRecvLoop(int acc){
int len;
char buf[512], *ptr;
while(1){
/*----- receive -----*/
len = recv(acc, buf, sizeof(buf), 0);
if(len < 0){
return (-1);
}
buf[len] = '\0';
/*----- return code -----*/
if((ptr = strpbrk(buf, "\r\n")) != NULL){
*ptr = '\0';
}
fprintf(stderr, "[client]%s \n", buf);
/*----- echo to client -----*/
strcat(buf, ":OK\r\n");
len = strlen(buf);
/*----- send -----*/
send(acc, buf, len, 0);
}
return (0);
}
----------------------------------

[abcdssh]

何度もすみません
btnを押したときの動作の画像を上に追加しております
またlogcatには次のようなエラーが出るといった現状となっています
---------------------------
2022-06-06 15:51:06.958 7646-7646/to.msn.wings.dialogargs E/AndroidRuntime: FATAL EXCEPTION: main
Process: to.msn.wings.dialogargs, PID: 7646
java.lang.IllegalStateException: Fragment to.msn.wings.dialogargs.MyDialogFragment must be a public static class to be properly recreated from instance state.
at androidx.fragment.app.FragmentTransaction.doAddOp(FragmentTransaction.java:249)
at androidx.fragment.app.BackStackRecord.doAddOp(BackStackRecord.java:183)
at androidx.fragment.app.FragmentTransaction.add(FragmentTransaction.java:171)
at androidx.fragment.app.DialogFragment.show(DialogFragment.java:259)
at to.msn.wings.dialogargs.MainActivity.lambda$onCreate$1$MainActivity(MainActivity.java:46)
at to.msn.wings.dialogargs.MainActivity$$ExternalSyntheticLambda0.onClick(Unknown Source)
at android.view.View.performClick(View.java:5657)
at com.google.android.material.button.MaterialButton.performClick(MaterialButton.java:1119)
at android.view.View$PerformClick.run(View.java:22314)
at android.os.Handler.handleCallback(Handler.java:751)
at android.os.Handler.dispatchMessage(Handler.java:95)
at android.os.Looper.loop(Looper.java:241)
at android.app.ActivityThread.main(ActivityThread.java:6217)
at java.lang.reflect.Method.invoke(Native Method)
at com.android.internal.os.ZygoteInit$MethodAndArgsCaller.run(ZygoteInit.java:865)
at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:755)
---------------------------------------------

[jimbe]

有難う御座います。
linux-c の再現は少し時間がかかりますが、調べてみます。
基本的には受信した文字列に ok を付けて返すだけのようですが、文字列が一回で全部 recv 出来る前提の作りなのが気になりますが…。

[jimbe]

すみません、発生している例外は、MyDialogFragment が public で無いということですね。つい Main と同じファイル内に書いてしまいました。
ご質問のオリジナル通り、 MyDailogFrament を MainActivity と別ファイルとして public クラスとしてください。
他にも問題がありましたので、それまた修正出来次第お知らせ致します。

[abcdssh]

すみませんありがとうございます

[jimbe]

ボタンの有効/無効処理を Main スレッドでやっていなかったり、逆にダイアログで OK した後の送信を Main スレッドでやっていたりで怒られていました^^;;;
かなり雑な状態になっていますが、一応送信が確認出来ましたので回答コードを修正しました。

[abcdssh]

返信遅くなってすみません。数日空けておりました。
修正後のプログラムで実行したところ送信動作ができることを確認できました！ありがとうございました。今後細かな修正、また実行動作の追加がありましたらまたお世話になるかもしれません。そのときはよろしくお願いします。

[jimbe]

お疲れ様です(^^
他にも ViewModel を介する方法とかあると思いますので、時間があればこの方法に拘らず他にも探されたら…と思います。