2019-11-06

<?xml version="1.0" encoding="utf-8"?>

<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"

    android:layout_width="match_parent"

    android:background="@color/colorPrimary"

    android:layout_height="match_parent">

    <TextView

        android:layout_width="wrap_content"

        android:layout_height="wrap_content"

        android:text="接受:"

        android:textColor="#fff"

        android:id="@+id/tvrece"

        android:textSize="30sp"/>

    <TextView

        android:layout_width="match_parent"

        android:layout_height="wrap_content"

        android:textColor="#fff"

        android:textSize="30sp"

        android:id="@+id/tv"

        android:layout_toRightOf="@id/tvrece"

    />

    <TextView

        android:layout_width="wrap_content"

        android:layout_height="wrap_content"

        android:text="发送:"

        android:id="@+id/tvsend"

        android:textColor="#fff"

        android:layout_below="@id/tvrece"

        android:textSize="30sp"/>

    <EditText

        android:layout_width="match_parent"

        android:layout_height="wrap_content"

        android:textColor="#fff"

        android:textSize="30sp"

        android:id="@+id/tv1"

        android:layout_toRightOf="@id/tvsend"

        android:layout_below="@id/tv"

        />

    <Button

        android:layout_width="wrap_content"

        android:layout_height="wrap_content"

        android:layout_below="@id/tv1"

        android:id="@+id/btnsend"

        android:text="发送"/>

</RelativeLayout>



package com.example.app1;

import android.app.Activity;

import android.os.Bundle;

import android.os.Handler;

import android.os.Message;

import android.view.View;

import android.widget.Button;

import android.widget.TextView;

import android.widget.Toast;

import androidx.annotation.NonNull;

import androidx.annotation.Nullable;

import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;

import org.eclipse.paho.client.mqttv3.MqttCallback;

import org.eclipse.paho.client.mqttv3.MqttClient;

import org.eclipse.paho.client.mqttv3.MqttConnectOptions;

import org.eclipse.paho.client.mqttv3.MqttException;

import org.eclipse.paho.client.mqttv3.MqttMessage;

import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;

import java.util.concurrent.Executors;

import java.util.concurrent.ScheduledExecutorService;

import java.util.concurrent.TimeUnit;

public class MainActivity_my extends Activity {

    MqttClient client;

    MqttConnectOptions options;

    ScheduledExecutorService scheduler;

    Handler handler;

    String myTopic="a/b/c";

    String myTopic1="a/b";

    TextView tv,tv1;

    Button btnsend;

    String ms;

    @Override

    protected void onCreate(@Nullable Bundle savedInstanceState) {

        super.onCreate(savedInstanceState);

        setContentView(R.layout.activity_my);

        tv=(TextView)findViewById(R.id.tv);

        tv1=(TextView)findViewById(R.id.tv1);

        btnsend=(Button)findViewById(R.id.btnsend);

        btnsend.setOnClickListener(new View.OnClickListener() {

            @Override

            public void onClick(View v) {

                MqttMessage message=new MqttMessage();

                ms=tv1.getText().toString();

                message.setPayload(ms.getBytes());

                try {

                    client.publish(myTopic1,message);

                } catch (MqttException e) {

                    e.printStackTrace();

                }

            }

        });

        initMQTT();

        handler=new Handler(){

            @Override

            public void handleMessage(@NonNull Message msg) {

                super.handleMessage(msg);

                if (msg.what==1){

                    tv.setText((String)msg.obj);

                    Toast.makeText(MainActivity_my.this,(String)msg.obj,Toast.LENGTH_SHORT).show();

                }else if(msg.what==2){

                    Toast.makeText(MainActivity_my.this, "连接成功", Toast.LENGTH_SHORT).show();

                    try {

                        client.subscribe(myTopic, 1);

                    } catch (Exception e) {

                        e.printStackTrace();

                    }

                }else if(msg.what==3){

                    Toast.makeText(MainActivity_my.this, "连接失败，系统正在重连", Toast.LENGTH_SHORT).show();

                }

            }

        };

        startReconnect();

    }

    private void startReconnect() {

        scheduler= Executors.newSingleThreadScheduledExecutor();

        scheduler.scheduleAtFixedRate(new Runnable() {

            @Override

            public void run() {

                if(!client.isConnected()){

                    connect();

                }

            }

        },0*1000,10*1000, TimeUnit.MILLISECONDS);

    }

    private void initMQTT() {

        try {

            client = new MqttClient("tcp://192.168.221.60:1883", "T001",new MemoryPersistence());

            // MQTT的连接设置

            options = new MqttConnectOptions();

            // 设置是否清空session,这里如果设置为false表示服务器会保留客户端的连接记录，这里设置为true表示每次连接到服务器都以新的身份连接

            options.setCleanSession(true);

            // 设置连接的用户名

            options.setUserName("admin");

            // 设置连接的密码

            options.setPassword("password".toCharArray());

            // 设置超时时间 单位为秒

            options.setConnectionTimeout(10);

            // 设置会话心跳时间 单位为秒 服务器会每隔1.5*20秒的时间向客户端发送个消息判断客户端是否在线，但这个方法并没有重连的机制

            options.setKeepAliveInterval(20);

            client.setCallback(new MqttCallback() {

                @Override

                public void messageArrived(String topicName, MqttMessage message) throws Exception {

                    // TODO Auto-generated method stub

                    //subscribe后得到的消息会执行到这里面

                    System.out.println("messageArrived----------");

                    System.out.println("========================"+message.toString());

                    Message msg = new Message();

                    //Toast.makeText(MainActivity.this,message.toString(),Toast.LENGTH_SHORT);

                    msg.what = 1;

                  // msg.obj = topicName+"---"+message.toString();

                    msg.obj=message.toString();

                    handler.sendMessage(msg);

                }

                @Override

                public void deliveryComplete(IMqttDeliveryToken token) {

                    // TODO Auto-generated method stub

                    //publish后会执行到这里

                    System.out.println("deliveryComplete---------" + token.isComplete());

                }

                @Override

                public void connectionLost(Throwable arg0) {

                    // TODO Auto-generated method stub

                    //连接丢失后，一般在这里面进行重连

                    System.out.println("connectionLost----------");

                }

            });

        } catch (MqttException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }

    }

    // 连接mqtt

    private void connect() {

        new Thread(new Runnable() {

            @Override

            public void run() {

                try {

                    client.connect(options);

                    Message msg = new Message();

                    msg.what = 2;

                    handler.sendMessage(msg);

                } catch (Exception e) {

                    e.printStackTrace();

                    Message msg = new Message();

                    msg.what = 3;

                    handler.sendMessage(msg);

                }

            }

        }).start();

    }

}

©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 199,711评论 5赞 468
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 83,932评论 2赞 376
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 146,770评论 0赞 330
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 53,799评论 1赞 271
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 62,697评论 5赞 359
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 48,069评论 1赞 276
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 37,535评论 3赞 390
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,200评论 0赞 254
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 40,353评论 1赞 294
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,290评论 2赞 317
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,331评论 1赞 329
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,020评论 3赞 315
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 38,610评论 3赞 303
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,694评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 30,927评论 1赞 255
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 42,330评论 2赞 346
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 41,904评论 2赞 341

推荐阅读更多精彩内容