java - クライアントが接続を要求したときに Android Socket に「接続済み」と表示されるが、「メッセージを送信できない」

Question

だから、それはタイトルのように、Wifi 経由で接続するシンプルな android ソケット サーバーとクライアントを作成しました。両方のデバイスが同じ Wi-Fi ネットワーク上にあります。サーバーは、接続をホストする IP アドレスを表示します....そして、クライアントでは、サーバーがホストされている IP アドレスを記述する必要があります.....

したがって、私の問題は、クライアントにIPアドレスを入力しているときです。サーバーには「接続済み」と表示されます。しかし、メッセージの送信を開始すると、サーバーからクライアントにもクライアントからサーバーにもメッセージが送信されません。

//#Server Java File
package inc.teckzy.wif_chat;

import android.net.wifi.WifiManager;
import android.os.Handler;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.text.format.Formatter;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class Helper extends AppCompatActivity {
    EditText smessage;
    TextView chat,display_status;
    String str,msg="";
    int serverport = 6666;
    ServerSocket serverSocket;
    Socket client;
    Handler handler = new Handler();
    WifiManager wmanager;
    Boolean Alive;
    DataOutputStream out;
    DataInputStream in;
    Button button_sent;


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

        wmanager = (WifiManager) getSystemService(WIFI_SERVICE);
        @SuppressWarnings("deprecation")
        String ip = Formatter.formatIpAddress(wmanager.getConnectionInfo().getIpAddress());
        smessage = (EditText) findViewById(R.id.smessage);
        chat = (TextView) findViewById(R.id.chat);
        display_status = (TextView) findViewById(R.id.display_status);

        Thread serverThread = new Thread(new serverThread());
        serverThread.start();
        Alive = serverThread.isAlive();
        display_status.setText("Hosted on: " + ip);
        button_sent = (Button) findViewById(R.id.button_sent);
        button_sent.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View view) {
                Thread sentThread = new Thread(new sentMessage());
                sentThread.start();
            }
        });
}

    class sentMessage implements Runnable{
        @Override
        public void run() {
            try{
                client = serverSocket.accept();
                out = new DataOutputStream(client.getOutputStream());
                str = smessage.getText().toString();
                msg = msg+"\n Server:" +str;
                handler.post(new Runnable()
                {
                    @Override
                    public void run()
                    {
                        chat.setText(msg);
                    }
                });
                out.writeBytes(str);
                out.flush();
                out.close();
                client.close();

            }catch(IOException e){}
        }
    }

    public class serverThread implements Runnable {
        @Override
        public void run() {
            try {
                while (true) {
                    serverSocket = new ServerSocket(serverport);
                    client = serverSocket.accept();
                    handler.post(new Runnable() {
                        @Override
                        public void run() {
                            display_status.setText("Connected");
                        }
                    });
/*******************************************
 setup i/p streams
 ******************************************/
                    in = new DataInputStream(client.getInputStream());
                    String line = in.readUTF();
                    while (!line.equals("STOP")) {
                        msg = msg + "\n Client : " + line;
                        handler.post(new Runnable() {
                            @Override
                            public void run() {
                                chat.setText(msg);
                            }
                        });
                    }
                    in.close();
                    client.close();
                }
            } catch (Exception e) {
            }

        }
    }
}

---

//#Client Side Java File
package reciever;
import android.os.Handler;
import android.support.v7.app.AppCompatActivity;
import android.os.Bundle;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;

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

import inc.teckzy.wif_chat.R;

public class ClientSide extends AppCompatActivity {
    EditText serverIp,smessage;
    TextView chat;
    String serverIpAddress = "",msg = "",str;
    Handler handler = new Handler();
    Button sent,connectPhones;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_client_side);
        chat = (TextView) findViewById(R.id.chat);
        serverIp = (EditText) findViewById(R.id.server_ip);
        smessage = (EditText) findViewById(R.id.smessage);
        sent = (Button) findViewById(R.id.sent_button);
        connectPhones = (Button) findViewById(R.id.connect_phones);

        //-----------------------Connecting to IP------------------------------//
        connectPhones.setOnClickListener(new View.OnClickListener()
        {
            @Override
            public void onClick(View v)
            {
                serverIpAddress = serverIp.getText().toString();
                if (!serverIpAddress.equals(""))
                {
                    Thread clientThread = new Thread(new
                            ClientThread());
                    clientThread.start();
                }
            }
        });
        //-------------------------------Initializing sent thread----------------//
        sent.setOnClickListener(new View.OnClickListener()
        {
            @Override
            public void onClick(View v)
            {
                Thread sentThread = new Thread(new sentMessage());
                sentThread.start();
            }
        });

    }
class sentMessage implements Runnable
{
    @Override
    public void run()
    {
        try
        {
            InetAddress serverAddr =
                    InetAddress.getByName(serverIpAddress);
            Socket socket = new Socket(serverAddr, 6666); //
            DataOutputStream os = new DataOutputStream(socket.getOutputStream());
            str = smessage.getText().toString();
            str = str + "\n";
            msg = msg + "Client : " + str;
            handler.post(new Runnable() {
                @Override
                public void run() {
                    chat.setText(msg);
                }
            });
            os.writeUTF(str);
            os.flush();
            os.close();
            socket.close();
        }
        catch(IOException e)
        {
        }
    }
}

    public class ClientThread implements Runnable
    {
        InetAddress serverAddr;
        public void run()
        {
            try
            {
                while(true)
                {
                    serverAddr = InetAddress.getByName(serverIpAddress);
                    Socket socket = new Socket(serverAddr, 6666);
/*******************************************
 setup i/p streams
 ******************************************/
                    DataInputStream in = new
                            DataInputStream(socket.getInputStream());
                    String line = in.readUTF();
                    while (!line.equals("Stop"))
                    {
                        msg = msg + "Server : " + line + "\n";
                        handler.post(new Runnable()
                        {
                            @Override
                            public void run()
                            {
                                chat.setText(msg);
                            }
                        });
                    }
                    in.close();
                    socket.close();
                    Thread.sleep(100);
                }

            }
            catch (Exception e)
            {}
        }
    }
}