|
|
我自己做了一個(gè)手機(jī)APP，主要是連接一個(gè)物聯(lián)網(wǎng)模塊【esp8266】，但是app一直顯示通訊失敗，所以把代碼貼出來(lái)希望大家?guī)蛶托“祝赡苁蔷�程某個(gè)地方的問(wèn)題。
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; // 端口號(hào)
private String mStrIp; // 字符串類(lèi)型ip
private int miPort; // 字符類(lèi)型端口
private Button mBtnConnect; // 連接
private Button mLedON; // 按鈕LED燈開(kāi)
private Button mLedOFF; // 按鈕LED燈關(guān)
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, "連接已關(guān)閉", 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("斷開(kāi)");
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, "連接已關(guān)閉", Toast.LENGTH_SHORT).show();
}
});
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
|
|
QQ好友和群
QQ空間
騰訊微博
騰訊朋友
收藏
淘帖
頂
踩
