【消息中间件】原生PHP对接Uni H5、APP、微信小程序实时通讯消息服务

系统管理员 2024-04-20 22:25 20阅读 0赞

#### 文章目录 ####

*  视频演示效果
 *  前言
 *  一、分析
 *  二、全局注入MQTT连接
 *   *  1.引入库
     *  2.写入全局连接代码
 *  二、PHP环境建立
 *  总结

--------------------

## 视频演示效果 ##

![c049b9a3442e44b8b325b6ef6e1da990-00002.jpg_auth_key_4844121640-0-0-f39fd41ef906d4ab4c5a048d3262d3b6][]

【uniapp】实现买定离手小游戏

--------------------

## 前言 ##

> Mqtt不同环境问题太多，新手可以看下

1.  [《【MQTT】Esp32数据上传采集：最新mqtt插件（支持掉线、真机调试错误等问题》][MQTT_Esp32_mqtt]
2.  [《一篇就够:uniapp-Mqtt系列问题详细攻略(解决掉线、真机调试错误等问题)》][uniapp-Mqtt]
3.  [《解决微信小程序MQTT真机连接问题与合法域名配置SSL问题》][MQTT_SSL]
4.  [《解决微信小程序MQTT通讯真机调试失败的问题附加可用代码》][MQTT]
5.  [《Esp8266-01s、51单片机实现连接MQTT踩坑：附加烧录安信可固件+宝塔搭建MQTT服务器 全套攻略》][Esp8266-01s_51_MQTT_MQTT_]

以上的就是我所有的Mqtt踩坑记录，相信看完应该能解决了，今天这一篇文章，主要是记录`升级Mqtt5.0以及如何适配安卓端`，如果不想看，也可以直接去下载插件：[【uniapp】【5.0协议】最完整Mqtt示例代码（解决掉线、真机调试错误等问题）][uniapp_5.0_Mqtt]  
`注意：`插件代码不含如果要用在app端，请留意评论区的消息，换协议  
![在这里插入图片描述][12b36f93906b449fb81c20b3de748817.png]

![在这里插入图片描述][3873d3316b08446f9502d337bda1a1d3.png]

--------------------

## 一、分析 ##

将原APP接入实时通讯，采用MQTT，有很多优点，这里就不列举了。这次对接的是我的打卡平台，  
分为三个端：H5、APP、微信小程序  
要保证三个端都通，我这里也不绕圈子了，协议我会放在本节底部，通过uniapp中的app.vue文件，将mqtt连接为全局状态，无论哪个页面都不会掉线，那么如何一对一接收呢？这里我做的思路是将客户端的订阅号订阅名改为自己的登陆账号，也就是说，用户未登录时不连接，检测到用户登录后将账户结合一些制定字符串作为onTopic，服务端指定发送过去即可，分析完之后我们开始实现客户端的连接。  
![在这里插入图片描述][e21e2c6f0fc54e0f83cd51154b3a4c76.png_pic_center]

连接案例：

var hosts = '';
    // #ifdef APP-PLUS
    hosts = 'wx://' + that.globalData.serve.host + ':443/mqtt';
    // #endif
    
    // #ifdef H5
    hosts = 'wss://' + that.globalData.serve.host + ':443/mqtt';
    // hosts = 'wss://' + that.globalData.serve.host + ':443/mqtt';
    
    // hosts = 'tcp://' + this.globalData.serve.host + ':' + this.globalData.serve.wsport + this.globalData.serve.path;
    //#endif
    // #ifdef MP-WEIXIN
    // wx仅仅可以使用体验版
    hosts = 'wxs://' + that.globalData.serve.host + ':443/mqtt';
    //#endif

## 二、全局注入MQTT连接 ##

### 1.引入库 ###

import mqtt from '@/utils/mqtt3.0.0.js'; // 导入MQTT库

![在这里插入图片描述][9e93d9424ab34f6496525e9636ef353a.png]

库直接在插件中下载即可用：  
[【uniapp】【5.0协议】最完整Mqtt示例代码（解决掉线、真机调试错误等问题）][uniapp_5.0_Mqtt]

### 2.写入全局连接代码 ###

App.vue是uni-app的主组件，所有页面都是在App.vue下进行切换的，是页面入口文件。但App.vue本身不是页面，这里不能编写视图元素，也就是没有。

这个文件的作用包括：调用应用生命周期函数、配置全局样式、配置全局的存储globalData

所以我们的代码：

**`注意：`**  
App.vue和其他页面不一样，我也是弄了好久才弄清楚，另外使用了全局globalData才编译成小程序时最新版本会报错，获取不到，应该时BUG，我当时用的是基础组件2.33版本就解决了

## 二、PHP环境建立 ##

下载文章顶部的配套资源到服务器  
![在这里插入图片描述][4f51310867c44e9ab1f43ad04c838a3e.png]  
修改封装的代码里面的连接信息，以及数据持久化

<?php
    require_once("php_mqtt/mqtt.class.php");//基础组件
    function send_mqtt_message($receiver, $content,$conn,$type)
    {
        $server = "mqtt.taila.club";  // 服务代理地址(mqtt服务端地址)
        $port = 1883;                // 通信端口
        $username = "";              // 用户名(如果需要)
        $password = "";              // 密码(如果需要)
        $client_id = "clientx9293670xxctr_492344"; // 设置你的连接客户端id
    
        $mqtt = new Mqtt($server, $port, $client_id); // 实例化MQTT类
        if ($mqtt->connect(true, NULL, $username, $password)) {
            // 如果创建链接成功
            $message = array(
                'message_id' => uniqid(), // 使用uniqid生成唯一的消息ID
                'sender' => '153***9', // 消息的发送者，可以是用户ID或用户名
                'receiver' => $receiver, // 消息的接收者，可以是用户ID或用户名
                'content' => $content, // 消息的内容，可以是文本、图片、文件等
                'timestamp' => time(), // 消息的时间戳，记录消息的发送时间
                'type' => $type, // 消息的类型，用于区分不同类型的消息0系统消息
                'status' => '0'//0未读1已读
            );
    
            $json_message = json_encode($message); // 将PHP数组转换为JSON字符串
    
            $mqtt->publish("$receiver", $json_message, 2); // 发送JSON消息到主题 "gg"
            //持久化
           // $sql="INSERT INTO `message` (`message_id`, `sender`, `receiver`, `content`, `type`, `status`, `create_time`) VALUES (NULL, '15368666279', '$receiver', '$content', '$type', '0', CURRENT_TIMESTAMP)";
           // $conn->query($sql);
            $mqtt->close(); // 发送后关闭链接
        } else {
            echo "Time out!\n";
        }
    }
    ?>

调用方式非常简单，新建index.php

<?php
    include '../../api/conn.php';//连接数据库根据你情况来定
    require_once("../../api/Message_push/mqtt_sender.php");
    
    //消息发送
    $receiver = $_GET["openid"];//发送手机号
    $content = $_GET["msg"];//发送的消息
    send_mqtt_message($receiver, $content,$conn,'1');
    ?>

## 总结 ##

以上就是今天要讲的内容，本文仅仅简单介绍了【MQTT5】原生PHP对接Uni H5、APP、微信小程序实时通讯消息服务的使用

?希望你能喜欢我的其他作品  
[《记一次云之家签到抓包》][Link 1]  
[《记一次视频抓包m3u8解密过程》][m3u8]  
[《抓包部分软件时无网络+过代理检测 解决办法 安卓黄鸟httpcanary+vmos》][_ _httpcanary_vmos]  
[《Python】记录抓包分析自动领取芝麻HTTP每日免费IP（成品+教程）》][Python_HTTP_IP]  
[《某课抓包视频 安卓手机：黄鸟+某课app+VirtualXposed虚拟框架》][_app_VirtualXposed]

推荐专栏：

[《Python爬虫脚本项目实战》][Python]

该专栏往期文章：  
[《【Python爬虫项目实战一】获取Chatgpt3.5免费接口文末付代码（过Authorization认证）》][Python_Chatgpt3.5_Authorization]

?如果感觉看完文章还不过瘾，欢迎查看我的其它专栏  
?作者对python有很大的兴趣，完成过很多独立的项目：例如滇医通等等脚本，但是由于版权的原因下架了，爬虫这一类审核比较严谨，稍有不慎就侵权违规了，所以在保证质量的同时会对文章进行筛选

如果您对爬虫感兴趣请收藏或者订阅该专栏哦[《Python爬虫脚本项目实战》][Python]，如果你有项目欢迎联系我，我会同步教程到本专栏！

[?**Python爬虫项目实战系列文章**][Python 1]！！  
⭐⭐欢迎订阅⭐⭐

[`【Python爬虫项目实战一】获取Chatgpt3.5免费接口文末付代码（过Authorization认证）`][Python_Chatgpt3.5_Authorization 1]  
[`【Python爬虫项目实战二】Chatgpt还原验证算法-解密某宝伪知网数据接口`][Python_Chatgpt_-]

⭐⭐欢迎订阅⭐⭐  
![在这里插入图片描述][818388c859c04a719ff9c282527b08e6.png]

**[Python爬虫脚本项目实战][Python 2]**  
![在这里插入图片描述][508ce3f3ee894fa7b33136db7bbecc7a.png]

[c049b9a3442e44b8b325b6ef6e1da990-00002.jpg_auth_key_4844121640-0-0-f39fd41ef906d4ab4c5a048d3262d3b6]: https://video-community.csdnimg.cn/vod-84deb4/7a4fd5102d0671ee813e0674a2ce0102/snapshots/c049b9a3442e44b8b325b6ef6e1da990-00002.jpg?auth_key=4844121640-0-0-f39fd41ef906d4ab4c5a048d3262d3b6
[MQTT_Esp32_mqtt]: https://taila.blog.csdn.net/article/details/131629933
[uniapp-Mqtt]: https://taila.blog.csdn.net/article/details/130383845
[MQTT_SSL]: https://taila.blog.csdn.net/article/details/124960889
[MQTT]: https://taila.blog.csdn.net/article/details/124911845
[Esp8266-01s_51_MQTT_MQTT_]: https://taila.blog.csdn.net/article/details/124901610
[uniapp_5.0_Mqtt]: https://ext.dcloud.net.cn/plugin?id=12014
[12b36f93906b449fb81c20b3de748817.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/20/be645778587c49449fc930ac2fae875b.png
[3873d3316b08446f9502d337bda1a1d3.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/20/0ac6a8244c6841c2a9db0cb3d3e77ff9.png
[e21e2c6f0fc54e0f83cd51154b3a4c76.png_pic_center]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/20/fb1bf377e8904b6b86447c88b2861140.png
[9e93d9424ab34f6496525e9636ef353a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/20/07558dccccbc4268957c206d771edd2e.png
[4f51310867c44e9ab1f43ad04c838a3e.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/20/59019cbd7b024311a3c033c561e14194.png
[Link 1]: https://blog.csdn.net/qq_35230125/article/details/113903423
[m3u8]: https://blog.csdn.net/qq_35230125/article/details/121647199
[_ _httpcanary_vmos]: https://blog.csdn.net/qq_35230125/article/details/121696563
[Python_HTTP_IP]: https://blog.csdn.net/qq_35230125/article/details/122890424
[_app_VirtualXposed]: https://blog.csdn.net/qq_35230125/article/details/121643395
[Python]: http://t.csdn.cn/gGn4P
[Python_Chatgpt3.5_Authorization]: https://blog.csdn.net/qq_35230125/article/details/130199605
[Python 1]: http://t.csdn.cn/iv7Xl
[Python_Chatgpt3.5_Authorization 1]: https://taila.blog.csdn.net/article/details/130199605
[Python_Chatgpt_-]: https://taila.blog.csdn.net/article/details/130240841
[818388c859c04a719ff9c282527b08e6.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/20/55ffbca8f9ac43e5b4ef4aea3365c83c.png
[Python 2]: http://t.csdn.cn/aUa9g
[508ce3f3ee894fa7b33136db7bbecc7a.png]: https://image.dandelioncloud.cn/pgy_files/images/2024/04/20/ae0c8d0a94584b12a03d5e058346b9f7.png