我自己做了一个手机APP,主要是连接一个物联网模块【esp8266】,但是app一直显示通讯失败,所以把代码贴出来希望大家帮帮小白,可能是线程某个地方的问题。
package com.example.afan.one;
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.Toast;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;
public class MainActivity extends AppCompatActivity implements View.OnClickListener {
private EditText mIp; // IP
private EditText mPort; // 端口号
private String mStrIp; // 字符串类型ip
private int miPort; // 字符类型端口
private Button mBtnConnect; // 连接
private Button mLedON; // 按钮LED灯开
private Button mLedOFF; // 按钮LED灯关
private Socket mSocket; // 套接字
private PrintStream out; // 打印输出流
private ConnectThread mConnectThread; // TCP连接线
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
mBtnConnect = (Button) findViewById(R.id.bt1);
mLedON = (Button) findViewById(R.id.bt2);
mLedOFF = (Button) findViewById(R.id.bt3);
mIp = (EditText) findViewById(R.id.edit_IP);
mPort = (EditText) findViewById(R.id.edit_PORT);
mBtnConnect.setOnClickListener(this);
mLedON.setOnClickListener(this);
mLedOFF.setOnClickListener(this);
}
@Override
public void onClick(View view) {
switch (view.getId()) {
case R.id.bt1:
if (mSocket == null || !mSocket.isConnected()) {
mStrIp = mIp.getText().toString();
miPort = Integer.valueOf(mPort.getText().toString());
mConnectThread = new ConnectThread(mStrIp, miPort);
mConnectThread.start();
}
if (mSocket != null && mSocket.isConnected()) {
try {
mSocket.close();
mSocket = null; // 清空mSocket
mBtnConnect.setText("连接");
Toast.makeText(MainActivity.this, "连接已关闭", Toast.LENGTH_LONG).show();
} catch (IOException e) {
e.printStackTrace();
}
}
break;
case R.id.bt2:
if (out != null) {
out.print("0");
out.flush();
}
break;
case R.id.bt3:
if (out != null) {
out.print("1");
out.flush();
}
break;
}
}
private class ConnectThread extends Thread {
private String ip;
private int port; public ConnectThread(String ip, int port) {
this.ip = ip;
this.port = port;
}
public void run() {
try {
mSocket = new Socket(ip, port);
out = new PrintStream(mSocket.getOutputStream());
runOnUiThread(new Runnable() {
@Override
public void run() {
mBtnConnect.setText("断开");
Toast.makeText(MainActivity.this, "连接成功", Toast.LENGTH_LONG).show();
}
});
new HeartBeatThread().start();
} catch (IOException e) {
e.printStackTrace();
runOnUiThread(new Runnable() {
@Override
public void run() {
Toast.makeText(MainActivity.this, "连接失败", Toast.LENGTH_LONG).show();
}
});
}
}
}
private class HeartBeatThread extends Thread {
@Override
public void run() {
while (true) {
try {
Thread.sleep(3000);
if (!mSocket.isConnected()) {
runOnUiThread(new Runnable() {
@Override
public void run() {
mBtnConnect.setText("连接");
Toast.makeText(MainActivity.this, "连接已关闭", Toast.LENGTH_SHORT).show();
}
});
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
package com.example.afan.one;
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.Toast;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.net.Socket;
public class MainActivity extends AppCompatActivity implements View.OnClickListener {
private EditText mIp; // IP
private EditText mPort; // 端口号
private String mStrIp; // 字符串类型ip
private int miPort; // 字符类型端口
private Button mBtnConnect; // 连接
private Button mLedON; // 按钮LED灯开
private Button mLedOFF; // 按钮LED灯关
private Socket mSocket; // 套接字
private PrintStream out; // 打印输出流
private ConnectThread mConnectThread; // TCP连接线
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
mBtnConnect = (Button) findViewById(R.id.bt1);
mLedON = (Button) findViewById(R.id.bt2);
mLedOFF = (Button) findViewById(R.id.bt3);
mIp = (EditText) findViewById(R.id.edit_IP);
mPort = (EditText) findViewById(R.id.edit_PORT);
mBtnConnect.setOnClickListener(this);
mLedON.setOnClickListener(this);
mLedOFF.setOnClickListener(this);
}
@Override
public void onClick(View view) {
switch (view.getId()) {
case R.id.bt1:
if (mSocket == null || !mSocket.isConnected()) {
mStrIp = mIp.getText().toString();
miPort = Integer.valueOf(mPort.getText().toString());
mConnectThread = new ConnectThread(mStrIp, miPort);
mConnectThread.start();
}
if (mSocket != null && mSocket.isConnected()) {
try {
mSocket.close();
mSocket = null; // 清空mSocket
mBtnConnect.setText("连接");
Toast.makeText(MainActivity.this, "连接已关闭", Toast.LENGTH_LONG).show();
} catch (IOException e) {
e.printStackTrace();
}
}
break;
case R.id.bt2:
if (out != null) {
out.print("0");
out.flush();
}
break;
case R.id.bt3:
if (out != null) {
out.print("1");
out.flush();
}
break;
}
}
private class ConnectThread extends Thread {
private String ip;
private int port; public ConnectThread(String ip, int port) {
this.ip = ip;
this.port = port;
}
public void run() {
try {
mSocket = new Socket(ip, port);
out = new PrintStream(mSocket.getOutputStream());
runOnUiThread(new Runnable() {
@Override
public void run() {
mBtnConnect.setText("断开");
Toast.makeText(MainActivity.this, "连接成功", Toast.LENGTH_LONG).show();
}
});
new HeartBeatThread().start();
} catch (IOException e) {
e.printStackTrace();
runOnUiThread(new Runnable() {
@Override
public void run() {
Toast.makeText(MainActivity.this, "连接失败", Toast.LENGTH_LONG).show();
}
});
}
}
}
private class HeartBeatThread extends Thread {
@Override
public void run() {
while (true) {
try {
Thread.sleep(3000);
if (!mSocket.isConnected()) {
runOnUiThread(new Runnable() {
@Override
public void run() {
mBtnConnect.setText("连接");
Toast.makeText(MainActivity.this, "连接已关闭", Toast.LENGTH_SHORT).show();
}
});
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
解决方案 »
- 关于ffmpeg移植到android遇到的问题
- 问一个矩阵键盘键值映射的问题,求高手指导
- listview的onScrollStateChanged问题
- 求助如何将选项卡放到页面布局的底部
- ANDROID SHELL提示符
- android开发 使用讯飞的jar包开发文字转语音功能是不是也得需要手机上安装有讯飞的tts才行?
- Android Studio,无法创建新工程
- 请问 如何设置全部的Activity使用一个actionbar
- listview
- 如何spinner对象存入sqlite数据库呢
- 萌新求教android studio greendao数据库问题
- ImageButton通过selector 设置图标的问题,请教各位老师
e.printStackTrace();
runOnUiThread(new Runnable() {
@Override
public void run() {
Toast.makeText(MainActivity.this, "连接失败", Toast.LENGTH_LONG).show();
}
});
}e.printStackTrace()这里有日志输出,看下具体什么错误
没报错会Toast 连接失败?看Log啊 你try{}catch{}了又不会Crash,但是Log有输出错误信息
没报错会Toast 连接失败?看Log啊 你try{}catch{}了又不会Crash,但是Log有输出错误信息我在虚拟机上运行了
显示这个 啥意思啊
ip端口能否ping通?
服务器是否支持?