找回密码
 立即注册

QQ登录

只需一步,快速开始

搜索
查看: 1951|回复: 4
打印 上一主题 下一主题
收起左侧

求助APP线程连接问题(TCP)—安卓软件

[复制链接]
跳转到指定楼层
楼主
ID:245521 发表于 2019-2-24 20:53 | 只看该作者 回帖奖励 |倒序浏览 |阅读模式
我自己做了一个手机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();
                }
            }
        }
    }


分享到:  QQ好友和群QQ好友和群 QQ空间QQ空间 腾讯微博腾讯微博 腾讯朋友腾讯朋友
收藏收藏1 分享淘帖 顶 踩
回复

使用道具 举报

沙发
ID:123289 发表于 2019-2-25 07:55 | 只看该作者
我想用单片机及其它电子部分知识换你的手机APP知识。加我QQ,下方有。加时注明手机APP。
回复

使用道具 举报

板凳
ID:245521 发表于 2019-2-25 11:03 | 只看该作者
yzwzfyz 发表于 2019-2-25 07:55
我想用单片机及其它电子部分知识换你的手机APP知识。加我QQ,下方有。加时注明手机APP。

什么意思?给你app吗还是
回复

使用道具 举报

地板
ID:123289 发表于 2019-2-25 11:57 | 只看该作者
互相学习而矣
回复

使用道具 举报

5#
ID:245521 发表于 2019-2-25 19:35 | 只看该作者
有玩安卓的大佬吗
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

手机版|小黑屋|51黑电子论坛 |51黑电子论坛6群 QQ 管理员QQ:125739409;技术交流QQ群281945664

Powered by 单片机教程网

快速回复 返回顶部 返回列表