首先,我是 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();
}
}
}
}
最佳答案
我很惊讶你没有崩溃。单击处理程序在主线程上运行。主线程不能做网络IO——它应该抛出一个异常来尝试。 BufferedWriter 可能会将您保存在那里 - 如果消息很小,它可能不会写入实际的套接字并缓冲所有内容,因为您没有刷新流。
因此,您需要做的第一件事是在另一个线程(可能是您的 ClientThread)上进行写入,并使用某种形式的消息传递向其发送写入命令。您需要做的第二件事是简化您的输出编写器 - 您真的不需要将其包装在任何东西中,只需直接写入输出流就足以满足您的使用需求。
关于java - Android套接字客户端 - 无法发送消息,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/44739832/