<?xml version="1.0" encoding="utf-8"?>
<manifest xmlns:android="http://schemas.android.com/apk/res/android"
    xmlns:tools="http://schemas.android.com/tools"
    package="me.muphy.android.mqtt.demo">

    <uses-permission android:name="android.permission.INTERNET" />
    <uses-permission android:name="android.permission.ACCESS_NETWORK_STATE" />
    <uses-permission
        android:name="android.permission.READ_PRIVILEGED_PHONE_STATE"
        tools:ignore="ProtectedPermissions" />
    <uses-permission android:name="android.permission.WAKE_LOCK" />


    <application
        android:allowBackup="true"
        android:icon="@mipmap/ic_launcher"
        android:label="@string/app_name"
        android:roundIcon="@mipmap/ic_launcher_round"
        android:supportsRtl="true"
        android:theme="@style/Theme.Androidmqttdemo">

        <service android:name="org.eclipse.paho.android.service.MqttService" /> <!--MqttService-->
        <!--MyMqttService-->

        <activity android:name=".MainActivity">
            <intent-filter>
                <action android:name="android.intent.action.MAIN" />

                <category android:name="android.intent.category.LAUNCHER" />
            </intent-filter>
        </activity>

    </application>

</manifest>

package me.muphy.android.mqtt.demo;

import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;

import androidx.appcompat.app.AppCompatActivity;

import org.eclipse.paho.android.service.MqttAndroidClient;
import org.eclipse.paho.client.mqttv3.IMqttActionListener;
import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken;
import org.eclipse.paho.client.mqttv3.IMqttToken;
import org.eclipse.paho.client.mqttv3.MqttCallback;
import org.eclipse.paho.client.mqttv3.MqttConnectOptions;
import org.eclipse.paho.client.mqttv3.MqttException;
import org.eclipse.paho.client.mqttv3.MqttMessage;

public class MainActivity extends AppCompatActivity {

    private static String TAG = MainActivity.class.getSimpleName();
    private static MqttAndroidClient mqttAndroidClient;
    private Button pubBtn;
    private Button subBtn;
    private Button connBtn;
    private EditText pubText;
    private EditText subText;
    private EditText pubContent;
    private EditText pubTopic;
    private EditText subTopic;
    private EditText subTopics;
    private TextView pubMsg;
    private TextView subMsg;
    private TextView status;
    private EditText passwordEt;
    private EditText usernameEt;
    private EditText clientIdEt;
    private EditText hostEt;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        pubBtn = findViewById(R.id.pubBtn);
        subBtn = findViewById(R.id.subBtn);
        connBtn = findViewById(R.id.connBtn);
        pubText = findViewById(R.id.pubText);
        pubContent = findViewById(R.id.pubContent);
        subText = findViewById(R.id.subText);
        pubTopic = findViewById(R.id.pubTopic);
        subTopic = findViewById(R.id.subTopic);
        subTopics = findViewById(R.id.subTopics);
        pubMsg = findViewById(R.id.pubMsg);
        subMsg = findViewById(R.id.subMsg);
        status = findViewById(R.id.status);
        passwordEt = findViewById(R.id.password);
        usernameEt = findViewById(R.id.username);
        clientIdEt = findViewById(R.id.clientId);
        hostEt = findViewById(R.id.host);

        connBtn.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                connect();
            }
        });

        pubBtn.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                String topic = pubTopic.getText().toString();
                if (topic.isEmpty()) {
                    topic = "test";
                }
                String message = pubContent.getText().toString();
                if (message.isEmpty()) {
                    message = "hello world!";
                }
                publishMessage(topic, message);
            }
        });

        subBtn.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                String topic = subTopic.getText().toString();
                if (topic.isEmpty()) {
                    topic = "test";
                }
                subscribeTopic(topic);
            }
        });
    }

    /**
     * String host = "tcp://";
     * String clientId = "android_mqtt_client";
     * String userName = "admin";
     * String passWord = "";
     */
    public void connect() {
        String host = hostEt.getText().toString();
        String clientId = clientIdEt.getText().toString();
        String userName = usernameEt.getText().toString();
        String passWord = passwordEt.getText().toString();
        /* 获取MQTT连接信息clientId、username、password。 对接阿里云会用到 */
        /*//对接阿里云服务 才会用到
        final String PRODUCTKEY = "a11xsrW****";
        final String DEVICENAME = "paho_android";
        final String DEVICESECRET = "tLMT9QWD36U2SArglGqcHCDK9rK9****";
        AiotMqttOption aiotMqttOption = new AiotMqttOption().getMqttOption(PRODUCTKEY, DEVICENAME, DEVICESECRET);
        if (aiotMqttOption == null) {
            Log.e(TAG, "device info error");
        } else {
            clientId = aiotMqttOption.getClientId();
            userName = aiotMqttOption.getUsername();
            passWord = aiotMqttOption.getPassword();
        }*/
        if (clientId.isEmpty()) {
            clientId = "android_mqtt_client";
        }
        if (host.isEmpty()) {
            host = "tcp://127.0.0.1:1883";
        }

        /* 创建MqttConnectOptions对象，并配置username和password。 */
        MqttConnectOptions mqttConnectOptions = new MqttConnectOptions();
        if (!userName.isEmpty()) {
            mqttConnectOptions.setUserName(userName);
        }
        if (!passWord.isEmpty()) {
            mqttConnectOptions.setPassword(passWord.toCharArray());
        }

        if (mqttAndroidClient != null) {
            try {
                mqttAndroidClient.disconnect(); //断开连接
            } catch (MqttException e) {
                e.printStackTrace();
            }
            mqttAndroidClient = null;
        }

        /* 创建MqttAndroidClient对象，并设置回调接口。 */
        mqttAndroidClient = new MqttAndroidClient(getApplicationContext(), host, clientId);
        String finalHost = host;
        mqttAndroidClient.setCallback(new MqttCallback() {
            @Override
            public void connectionLost(Throwable cause) {
                Log.i(TAG, "连接掉线>host：" + finalHost + "," + cause.getMessage());
                status.setText("未连接>host:" + finalHost + "," + cause.getMessage());
            }

            @Override
            public void messageArrived(String topic, MqttMessage message) throws Exception {
                Log.i(TAG, "topic: " + topic + ", msg: " + new String(message.getPayload()));
                subText.append("topic: " + topic + ", msg: " + new String(message.getPayload()) + "\n\n");
            }

            @Override
            public void deliveryComplete(IMqttDeliveryToken token) {
                Log.i(TAG, "已发送");
            }
        });



        /* 建立MQTT连接。 */
        try {
            mqttAndroidClient.connect(mqttConnectOptions, null, new IMqttActionListener() {
                @Override
                public void onSuccess(IMqttToken asyncActionToken) {
                    Log.i(TAG, "连接成功：" + finalHost);
                    status.setText("已连接：" + finalHost);
//                    subscribeTopic("test");
//                    subscribeTopic("/device_online_status");
//                    subscribeTopic("/read-property");
//                    subscribeTopic("/report-property");
                }

                @Override
                public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
                    Log.i(TAG, "连接失败>host：" + finalHost + "," + exception.getMessage());
                    status.setText("未连接>host:" + finalHost + "," + exception.getMessage());
                    exception.printStackTrace();
                }
            });

        } catch (MqttException e) {
            Log.i(TAG, "连接失败：" + e.getMessage());
            status.setText("未连接：" + e.getMessage());
            e.printStackTrace();
        }
    }

    public void publishMessage(String topic, String payload) {
        try {
            if (mqttAndroidClient.isConnected() == false) {
                mqttAndroidClient.connect();
            }

            MqttMessage message = new MqttMessage();
            message.setPayload(payload.getBytes());
            message.setQos(0);
            mqttAndroidClient.publish(topic, message, null, new IMqttActionListener() {
                @Override
                public void onSuccess(IMqttToken asyncActionToken) {
                    Log.i(TAG, "发布成功>topic:" + topic + ",payload:" + payload);
                    pubText.append("发布成功>topic:" + topic + ",payload:" + payload + "\n\n");
                }

                @Override
                public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
                    Log.i(TAG, "发布失败>topic:" + topic + ",payload:" + payload);
                    pubMsg.setText(exception.getMessage());
                    pubText.append("发布失败>topic:" + topic + ",payload:" + payload + "\n\n");
                    exception.printStackTrace();
                }
            });
        } catch (MqttException e) {
            Log.i(TAG, "发布失败>topic:" + topic + ",payload:" + payload);
            pubMsg.setText(e.getMessage());
            pubText.append("发布失败>topic:" + topic + ",payload:" + payload + "\n\n");
            e.printStackTrace();
        }
    }

    public void subscribeTopic(String topic) {
        try {
            mqttAndroidClient.subscribe(topic, 0, null, new IMqttActionListener() {
                @Override
                public void onSuccess(IMqttToken asyncActionToken) {
                    Log.i(TAG, "订阅成功>topic:" + topic);
                    subTopics.append(topic + "\n");
                }

                @Override
                public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
                    Log.i(TAG, "订阅失败>topic:" + topic);
                    pubMsg.setText(exception.getMessage());
                    exception.printStackTrace();
                }
            });

        } catch (MqttException e) {
            Log.i(TAG, "订阅失败>topic:" + topic);
            subMsg.setText(e.getMessage());
            e.printStackTrace();
        }
    }

    @Override
    public void onDestroy() {
        if (mqttAndroidClient != null) {
            try {
                mqttAndroidClient.disconnect(); //断开连接
            } catch (MqttException e) {
                e.printStackTrace();
            }
        }
        super.onDestroy();
    }

}