java - Android套接字客户端 - 无法发送消息

Question

首先，我是 Android、Java 的完全新手，并且在 Stacks Overflow 上发帖，如果我做错了什么，我深表歉意!

我正在尝试为一个使用套接字的项目创建一个简单的应用程序。我想在 Android 设备上设置一个客户端，该客户端将命令发送到在 PC 上运行的服务器。我用 Python 编写了我的服务器并对其进行了测试，所以我知道该项目的那一面是有效的。我在实现 Android 应用程序时遇到问题。

我按照本指南编写了我的客户端应用程序: https://examples.javacodegeeks.com/android/core/socket-core/android-socket-example/

当我运行我的应用程序时，我的服务器确认客户端已连接到它。但是，当我尝试发送数据时，服务器没有收到任何信息。这就是我的代码的样子(它与上面链接中的代码几乎相同):

MainActivity.java

package com.example.user.sockettest;

import java.io.BufferedWriter;
import java.io.IOException;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.Socket;
import java.net.UnknownHostException;

import android.app.Activity;
import android.os.Bundle;
import android.view.View;
import android.widget.EditText;

public class MainActivity extends Activity {


    private Socket socket;

    private static final int SERVERPORT = 8000;
    private static final String SERVER_IP = "192.168.0.17";

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

        new Thread(new ClientThread()).start();
    }

    public void onClick(View view) {
        try {
            EditText et = (EditText) findViewById(R.id.editText);
            String str = et.getText().toString();
            PrintWriter out = new PrintWriter(new BufferedWriter(
                    new OutputStreamWriter(socket.getOutputStream())),
                    true);
            out.println(str);
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    class ClientThread implements Runnable {

        @Override
        public void run() {

            try {
                InetAddress serverAddr = InetAddress.getByName(SERVER_IP);

                socket = new Socket(serverAddr, SERVERPORT);

            } catch (UnknownHostException e1) {
                e1.printStackTrace();
            } catch (IOException e1) {
                e1.printStackTrace();
            }

        }

    }
}

activity_main.xml

<?xml version="1.0" encoding="utf-8"?>
    <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
        android:layout_width="fill_parent"
        android:layout_height="fill_parent"
        android:orientation="vertical" >

        <EditText
            android:id="@+id/editText"
            android:layout_width="fill_parent"
            android:layout_height="wrap_content"
            android:text="TestData" >
        </EditText>

        <Button
            android:id="@+id/myButton"
            android:layout_width="wrap_content"
            android:layout_height="wrap_content"
            android:onClick="onClick"
            android:text="Send" >
        </Button>

    </LinearLayout>

AndroidManifest.xml

<?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
    package="com.example.user.sockettest">

    android:versionCode="1"
    android:versionName="1.0" >

    <uses-sdk
        android:minSdkVersion="8"
        android:targetSdkVersion="17" />

    <uses-permission android:name="android.permission.INTERNET" >
    </uses-permission>

    <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" >
    </uses-permission>

    <uses-permission android:name="android.permission.ACCESS_WIFI_STATE" />

    <application
        android:allowBackup="true"
        android:icon="@mipmap/ic_launcher"
        android:label="@string/app_name"
        android:theme="@style/AppTheme" >

        <activity android:name="com.example.user.sockettest.MainActivity">
            <intent-filter>
                <action android:name="android.intent.action.MAIN" />

                <category android:name="android.intent.category.LAUNCHER" />
            </intent-filter>
        </activity>
    </application>

</manifest>

如您所见，我已经按照其他人在其他线程上的建议设置了权限，但这似乎没有帮助。套接字在单独的线程上运行，所以我怀疑这也是一个阻塞问题。

我的套接字编程经验主要是在 Python 中，所以我确信我在其 Java 实现中遗漏了一些非常基本的东西!

任何帮助或指点将不胜感激!

编辑:感谢 Gabe Sechan 的回答，更新现在可以使用的代码

public class MainActivity extends Activity {


    private Socket socket;
    boolean sendData = false;   // Flag to indicate whether data should be sent
    String message;

    private static final int SERVERPORT = 8000;
    private static final String SERVER_IP = "192.168.0.17";

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

        new Thread(new ClientThread()).start();
    }

    public void onClick(View view) {
        EditText et = (EditText) findViewById(R.id.editText);
        message = et.getText().toString();
        sendData = true;
    }

    class ClientThread implements Runnable {

        @Override
        public void run() {
            try {
                InetAddress serverAddr = InetAddress.getByName(SERVER_IP);

                socket = new Socket(serverAddr, SERVERPORT);
                BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));

                // Loop forever checking if a message needs to be send
                while (socket.isConnected()){
                    if (sendData){
                        // If a message is ready to be sent, call sendMessage method
                        sendMessage();
                    }
                }
            } catch (UnknownHostException e1) {
                e1.printStackTrace();
            } catch (IOException e1) {
                e1.printStackTrace();
            }
        }

        private void sendMessage(){
            // Send message over socket
            try {
                PrintWriter out = new PrintWriter(socket.getOutputStream());
                out.println(message);
                out.flush();
                // Reset flag
                sendData=false;
            } catch (UnknownHostException e) {
                e.printStackTrace();
            } catch (IOException e) {
                e.printStackTrace();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

Answer 1

我很惊讶你没有崩溃。单击处理程序在主线程上运行。主线程不能做网络IO——它应该抛出一个异常来尝试。 BufferedWriter 可能会将您保存在那里 - 如果消息很小，它可能不会写入实际的套接字并缓冲所有内容，因为您没有刷新流。

因此，您需要做的第一件事是在另一个线程(可能是您的 ClientThread)上进行写入，并使用某种形式的消息传递向其发送写入命令。您需要做的第二件事是简化您的输出编写器 - 您真的不需要将其包装在任何东西中，只需直接写入输出流就足以满足您的使用需求。