android MQTT使用示例

news2024/11/23 13:23:20

1、导入依赖库：

implementation 'org.eclipse.paho:org.eclipse.paho.android.service:1.1.1'
implementation 'org.eclipse.paho:org.eclipse.paho.client.mqttv3:1.2.5'

2、功能封装：

package com.example.mqttdemo;

import static android.app.Service.START_NOT_STICKY;

import android.app.Service;
import android.content.Context;
import android.content.Intent;
import android.net.ConnectivityManager;
import android.net.NetworkInfo;
import android.os.Handler;
import android.os.IBinder;
import android.util.Log;

import androidx.annotation.Nullable;

import org.eclipse.paho.android.service.MqttAndroidClient;
import org.eclipse.paho.client.mqttv3.*;

public class MyMqttService extends Service {

    public final static String TAG = MyMqttService.class.getSimpleName();
    public static MqttAndroidClient mqttAndroidClient;
    private static MqttConnectOptions mMqttConnectOptions;
    public static String HOST = "tcp://broker.hivemq.com:1883";//服务器地址（协议+地址+端口号）
    public String USERNAME = "";//用户名
    public String PASSWORD = "";//密码
    public static String PUBLISH_TOPIC = "/d";//发布主题
    public static String RESPONSE_TOPIC = "v";//响应主题
    public String CLIENTID = "CLIENTID";//设备唯一标识

    @Override
    public int onStartCommand(Intent intent, int flags, int startId) {
        init();
        return START_NOT_STICKY;//非粘性的 service强制杀死后，不会尝试重新启动service
    }

    @Nullable
    @Override
    public IBinder onBind(Intent intent) {
        return null;
    }

    /**
     * 开启服务
     */
    public static void startService(Context mContext) {
        mContext.startService(new Intent(mContext, MyMqttService.class));
    }

    /**
     * 发布 （模拟其他客户端发布消息）
     *
     * @param message 消息
     */
    public static void publish(String message) {
        String topic = PUBLISH_TOPIC;
        Integer qos = 1;
        Boolean retained = false;
        try {
            //参数分别为：主题、消息的字节数组、服务质量、是否在服务器保留断开连接后的最后一条消息
            mqttAndroidClient.publish(topic, message.getBytes(), qos.intValue(), retained.booleanValue());
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }

    /**
     * 响应 （收到其他客户端的消息后，响应给对方告知消息已到达或者消息有问题等）
     *
     * @param message 消息
     */
    public static void response(String message) {
        String topic = RESPONSE_TOPIC;
        Integer qos = 1;
        Boolean retained = false;
        try {
            //参数分别为：主题、消息的字节数组、服务质量、是否在服务器保留断开连接后的最后一条消息
            mqttAndroidClient.publish(topic, message.getBytes(), qos.intValue(), retained.booleanValue());
        } catch (MqttException e) {
            e.printStackTrace();
        }
    }

    /**
     * 初始化
     */
    private void init() {
        String serverURI = HOST; //服务器地址（协议+地址+端口号）
        Log.i(TAG, "初始化MQ" + serverURI);
        if (mqttAndroidClient == null) {
            mqttAndroidClient = new MqttAndroidClient(this, serverURI, CLIENTID);
            mqttAndroidClient.setCallback(mqttCallback); //设置监听订阅消息的回调
        }
        if (mMqttConnectOptions == null) {
            mMqttConnectOptions = new MqttConnectOptions();
            mMqttConnectOptions.setCleanSession(true); //设置是否清除缓存
            mMqttConnectOptions.setConnectionTimeout(10); //设置超时时间，单位：秒
            mMqttConnectOptions.setKeepAliveInterval(20); //设置心跳包发送间隔，单位：秒
            mMqttConnectOptions.setUserName(USERNAME); //设置用户名
            mMqttConnectOptions.setPassword(PASSWORD.toCharArray()); //设置密码
        }
        // last will message
        boolean doConnect = true;
        String message = "{\"terminal_uid\":\"" + CLIENTID + "\"}";
        String topic = PUBLISH_TOPIC;
        Integer qos = 1;
        Boolean retained = true;
        if ((!message.equals("")) || (!topic.equals(""))) {
            // 最后的遗嘱
            try {
                mMqttConnectOptions.setWill(topic, message.getBytes(), qos.intValue(), retained.booleanValue());
            } catch (Exception e) {
                Log.i(TAG, "Exception Occured");
                doConnect = false;
                iMqttActionListener.onFailure(null, e);
            }
        }
        if (doConnect) {
            doClientConnection();
        }
    }

    /**
     * 连接MQTT服务器
     */
    private static void doClientConnection() {
        try {
            if (!mqttAndroidClient.isConnected() && isConnectIsNomarl()) {
                Log.i(TAG, "连接MQTT服务器" + HOST);
                mqttAndroidClient.connect(mMqttConnectOptions, null, iMqttActionListener);
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    /**
     * 判断网络是否连接
     */
    private static boolean isConnectIsNomarl() {
        return true;
//        ConnectivityManager connectivityManager = (ConnectivityManager) BaseApplication.getInstance().getSystemService(Context.CONNECTIVITY_SERVICE);
//        NetworkInfo info = connectivityManager.getActiveNetworkInfo();
//        if (info != null && info.isAvailable()) {
//            String name = info.getTypeName();
//            Log.i(TAG, "当前网络名称：" + name);
//            return true;
//        } else {
//            Log.i(TAG, "没有可用网络");
//            /*没有可用网络的时候，延迟3秒再尝试重连*/
//            new Handler().postDelayed(new Runnable() {
//                @Override
//                public void run() {
//                    Log.i(TAG, "没有可用网络doClientConnection");
//                    doClientConnection();
//                }
//            }, 3000);
//            return false;
//        }
    }

    //MQTT是否连接成功的监听
    private static IMqttActionListener iMqttActionListener = new IMqttActionListener() {

        @Override
        public void onSuccess(IMqttToken arg0) {
            Log.i(TAG, "连接成功 " + HOST);
            try {
                if (mqttAndroidClient != null) {
                    mqttAndroidClient.subscribe(PUBLISH_TOPIC, 1);//订阅主题，参数：主题、服务质量
                }
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

        @Override
        public void onFailure(IMqttToken arg0, Throwable arg1) {
            arg1.printStackTrace();
            Log.i(TAG, "连接失败 ");
            doClientConnection();//连接失败，重连（可关闭服务器进行模拟）
        }
    };

    //订阅主题的回调
    private MqttCallback mqttCallback = new MqttCallback() {

        @Override
        public void messageArrived(String topic, MqttMessage msgStr) throws Exception {

            try {
                String enCodeMsg = new String(msgStr.getPayload());
                Log.i(TAG, "收到消息： " + enCodeMsg);
                //收到消息，这里弹出Toast表示。如果需要更新UI，可以使用广播或者EventBus进行发送
                //收到其他客户端的消息后，响应给对方告知消息已到达或者消息有问题等
                response("message arrived");
            } catch (Exception e) {
                e.printStackTrace();
            }
        }

        @Override
        public void deliveryComplete(IMqttDeliveryToken arg0) {

        }

        @Override
        public void connectionLost(Throwable arg0) {
            Log.i(TAG, "连接断开 ");
            doClientConnection();//连接断开，重连
        }
    };

    public static void disconnect(Context context) {
        try {
            if (mqttAndroidClient != null && mqttAndroidClient.isConnected()) {
                mqttAndroidClient.unsubscribe(PUBLISH_TOPIC);
                mqttAndroidClient.unregisterResources();
                mqttAndroidClient.disconnect(0); //断开连接
                mqttAndroidClient = null;
                context.stopService(new Intent(context, MyMqttService.class));
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/2246030.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

算法日记 32 day 动态规划（完全背包）

算法日记 32 day 动态规划（完全背包）

同样是背包问题，但01背包和完全背包是两个类型的问题。 完全背包： 完全背包与01背包的区别在于物品的个数是否是无限的。除此之外，在解决01背包的时候dp的背包遍历的顺利是倒序，为的是保证物品只被添加一次，而完全背包…
阅读更多...
实用功能，觊觎（Edge）浏览器的内置截（长）图功能

实用功能，觊觎（Edge）浏览器的内置截（长）图功能

Edge浏览器内置截图功能 近年来，Edge浏览器不断更新和完善，也提供了长截图功能。在Edge中，只需点击右上角的“...”，然后选择“网页捕获”->“捕获整页”，即可实现长截图。这一功能的简单易用，使其成为…
阅读更多...
计算机网络：应用层知识点概述及习题

计算机网络：应用层知识点概述及习题

网课资源： 湖科大教书匠 1、概述 习题1 1 在计算机网络体系结构中，应用层的主要功能是 A. 实现进程之间基于网络的通信 B. 通过进程之间的交互来实现特定网络应用 C. 实现分组在多个网络上传输 D. 透明传输比特流 2 以下不属于TCP/IP体系结构应用层范畴…
阅读更多...
【LSTM实战】跨越千年，赋诗成文：用LSTM重现唐诗的韵律与情感

【LSTM实战】跨越千年，赋诗成文：用LSTM重现唐诗的韵律与情感

本文将介绍如何使用LSTM训练一个能够创作诗歌的模型。为了训练出效果优秀的模型，我整理了来自网络的4万首诗歌数据集。我们的模型可以直接使用预先训练好的参数，这意味着您无需从头开始训练，即可在自己的电脑上体验AI作诗的乐趣。我已经为您准…
阅读更多...
鸿蒙网络编程系列50-仓颉版TCP回声服务器示例

鸿蒙网络编程系列50-仓颉版TCP回声服务器示例

1. TCP服务端简介 TCP服务端是基于TCP协议构建的一种网络服务模式，它为HTTP（超文本传输协议）、SMTP（简单邮件传输协议）等高层协议的应用程序提供了可靠的底层支持。在TCP服务端中，服务器启动后会监听一个或…
阅读更多...
基于 SpringBoot 的作业管理系统【附源码】

基于 SpringBoot 的作业管理系统【附源码】

基于 SpringBoot 的作业管理系统 效果如下： 系统注册页面 学生管理页面 作业管理页面 作业提交页面 系统管理员主页面 研究背景 随着社会的快速发展，信息技术的广泛应用已经渗透到各个行业。在教育领域，课程作业管理是学校教学活动中的重要…
阅读更多...
怎么只提取视频中的声音？从视频中提取纯音频技巧

怎么只提取视频中的声音？从视频中提取纯音频技巧

在数字媒体的广泛应用中，提取视频中的声音已成为一项常见且重要的操作。无论是为了学习、娱乐、创作还是法律用途，提取声音都能为我们带来诸多便利。怎么只提取视频中的声音？本文将详细介绍提取声音的原因、工具、方法以及注意事项。 一、为什…
阅读更多...
Java多态的优势和弊端

Java多态的优势和弊端

1. public class text {public static void main(String[] args) {animal dnew dog();d.eat();// dog a (dog) d;//类似强制转换//a.lookhome();/* if(d instanceof dog){dog a(dog)d;a.lookhome();}else if(d instanceof cat){cat c(cat) d;c.work();}else{System.out.print…
阅读更多...
FPGA 14 ，硬件开发板分类详解，FPGA开发板与普通开发板烧录的区别

FPGA 14 ，硬件开发板分类详解，FPGA开发板与普通开发板烧录的区别

目录 前言 在嵌入式系统开发中，硬件开发板是工程师常用的工具之一。不同类型的开发板有不同的特点和用途，其中最常见的两大类是普通开发板和FPGA开发板。这里分享记录，这两类开发板的分类，并深入探讨它们在烧录过程中的具体区别…
阅读更多...
冲破AI 浪潮冲击下的 迷茫与焦虑

冲破AI 浪潮冲击下的 迷茫与焦虑

在这个科技日新月异的时代，人工智能如汹涌浪潮般席卷而来，不断改变我们的生活。你是否对 AI 充满好奇，却不知它将如何改变你的工作与生活？又是否会在 AI 浪潮的冲击下陷入迷茫与焦虑？《AI 时代：弯道超车新思…
阅读更多...
时序论文23｜ICML24谷歌开源零样本时序大模型TimesFM

时序论文23｜ICML24谷歌开源零样本时序大模型TimesFM

论文标题：A DECODER - ONLY FOUNDATION MODEL FOR TIME - SERIES FORECASTING 论文链接：https://arxiv.org/abs/2310.10688 论文链接：https://github.com/google-research/timesfm 前言 谷歌这篇时间序列大模型很早之前就在关注&#xff…
阅读更多...
Redis的基本使用命令（GET,SET,KEYS,EXISTS,DEL,EXPIRE,TTL,TYPE）

Redis的基本使用命令（GET,SET,KEYS,EXISTS,DEL,EXPIRE,TTL,TYPE）

目录 SET GET KEYS EXISTS DEL EXPIRE TTL redis中的过期策略是怎么实现的（面试） 上文介绍reids的安装以及基本概念，本章节主要介绍 Redis的基本使用命令的使用 Redis 是一个基于键值对（KEY - VALUE）存储的…
阅读更多...
大疆上云api开发

大疆上云api开发

目前很多公司希望使用上云api开发自己的无人机平台,但是官网资料不是特别全,下面浅谈一下本人开发过程中遇到的一系列问题。 本人使用机场为大疆机场2，飞机为M3TD，纯内网使用 部署 链接: 上云api代码. 首先从github上面拉去代码 上云api代码github. 后…
阅读更多...
实现管易云到金蝶云星空的数据无缝集成

实现管易云到金蝶云星空的数据无缝集成

管易云数据集成到金蝶云星空：案例分享 在企业信息化系统中，数据的高效流动和准确对接是业务顺利运行的关键。本文将聚焦于一个具体的系统对接集成案例——通过轻易云数据集成平台实现管易云数据到金蝶云星空的无缝迁移，方案名称为“wk_店铺_…
阅读更多...
Ubuntu上安装MySQL并且实现远程登录

Ubuntu上安装MySQL并且实现远程登录

目录 下载网络工具 查看网络连接 更新系统软件包； 安装mysql数据库 查看mysql数据库状态 以数字ip形式显示mysql的监听状态。（默认监听端口是3306） 查看安装mysql数据库时系统创建的目录信息。 根据查询到的系统用户名以及随机密码&a…
阅读更多...
卷积神经网络各层介绍

卷积神经网络各层介绍

目录 1 卷积层 2 BN层 3 激活层 3.1 ReLU（Rectified Linear Unit） 3.2 sigmoid 3.3 tanh（双曲正切） 3.4 Softmax 4 池化层 5 全连接层 6 模型例子 1 卷积层 卷积是使用一个卷积核（滤波器）对矩阵进…
阅读更多...
LVS

LVS

一、 lvs简介 LVS:Linux Virtual Server ，负载调度器，内核集成，章文嵩，阿里的四层 SLB(Server LoadBalance) 是基 于 LVSkeepalived 实现 LVS 官网 : http://www.linuxvirtualserver.org/ LVS 相关术语 VS: Virtual Serve…
阅读更多...
使用 Elastic AI Assistant for Search 和 Azure OpenAI 实现从 0 到 60 的转变

使用 Elastic AI Assistant for Search 和 Azure OpenAI 实现从 0 到 60 的转变

作者：来自 Elastic Greg Crist Elasticsearch 推出了一项新功能：Elastic AI Assistant for Search。你可以将其视为 Elasticsearch 和 Kibana 开发人员的内置指南，旨在回答问题、引导你了解功能并让你的生活更轻松。在 Microsoft AI Services…
阅读更多...
掺铒光纤激光器

掺铒光纤激光器

一、光纤激光器的特点 实现灵活的激光光源（窄线宽、可调谐、多波长、超短光脉冲源）易获得高功率、高的光脉冲能量激光波长与光纤通信传输窗口相匹配采用激光器泵浦形式（半导体激光器泵浦）热稳定性、价格低廉、易小型化 二、放大…
阅读更多...
AP+AC组网——STA接入

AP+AC组网——STA接入

扫描 主动扫描：STA发送Probe Request帧，AP收到回复Probe Response 可以带着SSID扫描寻找指定WIFI，也可以带着空SSID扫描进入周围可用WLAN 被动扫描： 客户端通过侦听AP定期发送的Beacon帧（100TUs，1TU1024…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023