您的位置:首页 > 汽车 > 新车 > 南通模板网建站_珠海今日头条新闻_快速排名程序_淘宝流量助手平台

南通模板网建站_珠海今日头条新闻_快速排名程序_淘宝流量助手平台

2025/1/23 11:47:36 来源:https://blog.csdn.net/Wuxiaoming135/article/details/144202131  浏览:    关键词:南通模板网建站_珠海今日头条新闻_快速排名程序_淘宝流量助手平台
南通模板网建站_珠海今日头条新闻_快速排名程序_淘宝流量助手平台

1. 使用mosquitto

这是一个mqtt服务器,用于广播数据

安装过程省略(有很多教程),安装完成后,可以在终端输入mosquitto,接下来就可以模拟这个一对多的发布者订阅模式了

订阅(topic1是订阅的主题,也可以是别的):mosquitto_sub -v -t topic1

发布:mosquitto_pub -t topic1 -m 消息内容

如下,是一个模拟过程:

首先,打开三个终端,这三个终端都输入“mosquitto_sub -v -t t1”表示这三个终端都订阅了这个主题:(图片放错啦,请将下面的topic1换成t1)

接着,再来一个终端,输入

mosquitto_pub -t t1 -m "Hello, MQTT!"

 消息内容,去发布消息(接着这三个订阅这个主题的终端都可以接受到这个消息):

2. mosquitto设置局域网可访问

在mosquitto的安装目录,如“C:\Program Files\mosquitto”下,找到“mosquitto.conf”文件,插入两行:(分别表示端口和局域网可访问)

接下来,我们换一种方式去使用mosquitto,在“C:\Program Files\mosquitto”下打开终端,输入:

mosquitto -c mosquitto.conf -v

这就表示按照配置去运行mosquitto服务器啦,接着我们来换一种方式模拟,开几个终端,输入如下:(实际上还应该输入-h mosquitto服务器的ip,但是现在是在一台电脑上的操作,就省事儿了)

接着我们再起一个终端,用于发布消息,如下:(输入:“mosquitto_pub -t t334 -p 8889 -m 这是给t334QQQQQQQ的消息!”等消息)

3. flutter使用mqtt

话不多说,安装:

mqtt_client: ^10.3.0

使用:(运行,服务端会检测到)

【注】:如果是真机有问题(貌似需要配置ssl)目前只能电脑本地模拟器运行,等评论区大佬解决😂(等作者解决估计要很久)

import 'package:flutter/material.dart';
import 'package:mqtt_client/mqtt_client.dart';
import 'package:mqtt_client/mqtt_server_client.dart';main(){runApp(const MaterialApp(home: H(),));}
class H extends StatefulWidget {const H({super.key});@overrideState<H> createState() => _HState();
}class _HState extends State<H> {final client = MqttServerClient.withPort('192.168.101.21', "small_sun", 8889);String _resStr = "";Future<void> initClient() async {client.logging(on: false); //是否开启日志,这里就不看看日志了client.keepAlivePeriod = 20; //设置超时时间try {// await client.connect(username, password); //开始连接await client.connect();// 一般需要输入密码,如:client.connect(username, password);print('mqtt连接啦');} catch (e) {client.disconnect();}if (client.connectionStatus?.state == MqttConnectionState.connected) {} else {client.disconnect();}client.subscribe("t1", MqttQos.atMostOnce);// 订阅的主题1client.subscribe("t2", MqttQos.atMostOnce);// 订阅的主题2//监听服务器发来的信息client.updates?.listen((List<MqttReceivedMessage<MqttMessage>> c) {final MqttPublishMessage recMess = c[0].payload as MqttPublishMessage;// 返回的数据final String pt = MqttPublishPayload.bytesToStringAsString(recMess.payload.message);print('订阅的主题:${c[0].topic}');print('服务器返回的数据信息:$pt');setState(() {_resStr = pt;});});}@overridevoid initState() {super.initState();initClient();}@overrideWidget build(BuildContext context) {return Scaffold(appBar: AppBar(title:const  Text("MQTT test",),backgroundColor: Colors.green,),body: Center(child: Text(_resStr,style: const TextStyle(fontSize: 40)),),);}
}

显示:

模仿第二点,向mosquitto发送代理后,手机显示:

本文参考资料:(感谢这位大佬!)Flutter框架高阶——使用MQTT协议进行信息传输_flutter mqtt-CSDN博客

版权声明:

本网仅为发布的内容提供存储空间,不对发表、转载的内容提供任何形式的保证。凡本网注明“来源:XXX网络”的作品,均转载自其它媒体,著作权归作者所有,商业转载请联系作者获得授权,非商业转载请注明出处。

我们尊重并感谢每一位作者,均已注明文章来源和作者。如因作品内容、版权或其它问题,请及时与我们联系,联系邮箱:809451989@qq.com,投稿邮箱:809451989@qq.com