【发布时间】：2015-03-01 17:09:19
【问题描述】：
在我的 android 应用程序中，我想连续读取传入数据（使用 Telnet 协议）。我能够读取一行（然后应用程序在空闲状态下运行），我想知道如何创建一个简单的无限主循环。
我认为在这一行周围放一个循环是有意义的：
telnetThread.start();
我已经尝试实现一个looper，但没有任何成功。
这是我的代码：
package com.example.clienttel;
import android.os.Handler;
import android.os.Message;
import android.support.v7.app.ActionBarActivity;
import android.os.Bundle;
import android.util.Log;
import org.apache.commons.net.telnet.TelnetClient;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
public class MainActivity extends ActionBarActivity {
// Variables
public final String ADDRESS = "194.66.82.11";
public final int PORT = 50100;
public String NMEA = null;
public final String TAG = "TestApp";
public boolean first = true;
public MyTelnetClass mtc;
public Thread telnetThread;
// Handler in mainthread
Handler handler = new Handler() {
public void handleMessage(Message msg) {
String dataString = "";
Bundle bundle = msg.getData();
Log.d("handleMessage", bundle.toString());
if (bundle.containsKey("outgoingString")) {
dataString = bundle.getString("outgoingString");
}
}
};
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
createThread();
}
private void createThread() {
final Runnable runnable = new Runnable() {
public void run() {
try {
mtc = new MyTelnetClass();
mtc.mhandler = handler;
mtc.run();
Bundle b = new Bundle();
b.putString("TCPThread", "visible");
Message m = handler.obtainMessage();
m.setData(b);
handler.sendMessage(m);
} catch (Exception e) {
Log.e("createTCPThread", "exception: " + e.getMessage());
Bundle b = new Bundle();
b.putString("TCPThread", "unvisible");
Message m = handler.obtainMessage();
m.setData(b);
handler.sendMessage(m);
}
}
};
// create the thread needed and run it, LOOP HERE?
telnetThread = new Thread(runnable);
telnetThread.start();
}
// catch NMEA-sentences and send them using mhandler
class MyTelnetClass {
public Handler mhandler = null;
public void run() {
TelnetClient telnet = new TelnetClient();
Log.i(TAG, "telnetThread active");
if (first) {
// Connect To Server in 1st Iteration
try {
telnet.connect(ADDRESS, PORT);
} catch (IOException e) {
e.printStackTrace();
}
first = false;
}
// Process NMEA-sentences
InputStream inStream = telnet.getInputStream();
BufferedReader r = new BufferedReader(new InputStreamReader(inStream));
try {
NMEA = r.readLine();
} catch (IOException e) {
e.printStackTrace();
}
// Handler in MyTelnetClass to send back
Bundle b = new Bundle();
b.putString("outgoingString", NMEA);
Message m = mhandler.obtainMessage();
m.setData(b);
mhandler.sendMessage(m);
}
}
}
什么是处理这个问题的有效方法？
编辑：
我把 looper 放在了 run() 的“周围”，但它只执行一次（我不确定循环是否可以这样工作）：
public void run() {
try {
Looper.prepare(); // HERE...
Log.d(TAG,"executing run");
mtc = new MyTelnetClass();
mtc.mhandler = handler;
mtc.run();
Bundle b = new Bundle();
b.putString("TCPThread", "visible");
Message m = handler.obtainMessage();
m.setData(b);
handler.sendMessage(m);
Looper.loop(); // ...AND HERE
} catch (Exception e) {
Log.e("createTCPThread", "exception: " + e.getMessage());
Bundle b = new Bundle();
b.putString("TCPThread", "unvisible");
Message m = handler.obtainMessage();
m.setData(b);
handler.sendMessage(m);
}
}
【问题讨论】：
-
弯针并不是你想象的那样。可能你想要的是在你的线程中像 while() 构造一样简单的东西，但如果它不与 Activity 紧密联系，你可能希望在服务中使用该线程。
-
我花了一段时间，但它让我不停
createTCPThread﹕ exception: null -
你的 catch 需要做一个 e.printStackTrace()。然后检查完整的异常并修复它。
-
Error is here (NullpointerException) :
BufferedReader r = new BufferedReader(new InputStreamReader(inStream));我已经遇到了这个问题，我不知道如何解决它...可能与我正在使用的 Telnet 库有关 -
可以用简单的
if (inStream != null)解决问题。现在的问题是我每次都得到相同的数据......要处理那个......