使用swoole作为MQTT客户端并接收实现即时消息推送

环境准备首先需要安装 swoole 可以使用 pecl 进行安装，如 pecl install swool, 注意加上版本号

或者使用构建好的 docker 镜像，这里使用构建好的 zacksleo/php:7.1-alpine-fpm-swoole 镜像

使用 compose 安装依赖库

composer require jesusslim/mqttclient

<?phpnamespace console\controllers;use yii;
use console\components\mqtt\Logger;
use console\components\mqtt\Store;
use yii\console\Controller;
use mqttclient\src\swoole\MqttClient;
use mqttclient\src\subscribe\Topic;class MqttController extends Controller
{public function actionClient(){$r = new MqttClient(getenv('TOKEN_MQTT_HOST'), getenv('TOKEN_MQTT_PORT'), 'push-server-client');$r->setAuth(getenv('TOKEN_MQTT_USERNAME'), getenv('TOKEN_MQTT_PASSWORD'));$r->setKeepAlive(60);$r->setLogger(new Logger());$r->setStore(new Store());$r->setTopics([//消息回执new Topic('user-auth/create', function (MqttClient $client, $msg) {//$msg 为获取到的消息体}),//消息打开new Topic('user-auth/delete', function (MqttClient $client, $msg) {//$msg 为获取到的消息体})]);$r->connect();}
}
复制代码

阅读原文请访问

www.zxb8.cc/?p=515

使用swoole作为MQTT客户端并接收实现即时消息推送相关推荐

Gin + gRPC双向流模式 + sse实现grpc客户端到前端界面的消息推送
Gin + gRPC + sse实现grpc客户端到前端界面的消息推送功能需求工厂客户端与服务端通过gRPC连接突破工厂防火墙(不需要额外开启端口) 前端可以控制数据推送的开启和停止前端数据大 ...
xmpp关于后台挂起的消息接收，后台消息推送，本地发送通知
想问下,在xmpp即时通讯的项目中,我程序如果挂起了,后台有消息过来,我这边的推送不过来,所以我的通知就会收不到消息,当我重新唤醒应用的时候,他才会接收到通知,消息就会推送过来,我在plist哪里设置 ...
苹果的消息是从服务器接收数据,iOS 消息推送原理及简单实现
从图中可以很清楚的看出来推送的原理主要分为以下几步: 1.由App向iOS设备发送一个注册通知,用户需要同意系统发送推送. 2.iOS向APNs远程推送服务器发送App的Bundle Id和设备的UD ...
使用swoole进行消息推送通知，配合vb.net进行客户端开发一样爽[开发篇]
在以前的项目中,就曾听说过swoole的大名,想用来进行消息推送,但是当时只是有了初步的了解,并不敢大胆的运用到线上产品.所谓识不足则多虑,威不足则多怒.所以就是怕,只能跟领导说了运用极光的推送功能 ...
Android MQTT实现消息推送
飞哥语录:编程说白了就是发送数据,接收数据,处理数据. 1.概述 MQTT(Message Queuing Telemetry Transport,消息队列遥测传输)是IBM开发的一个即时通讯协议,有 ...
Android 二维码被扫后接收通知(使用MQTT协议实现消息推送)
现如今扫码付款和收款已经很便利了,比如超市买完东西付款时有两种方式 : 顾客可以出示付款码给收银员扫码收款,也可以由顾客扫描超市的收款码进行付款 .两种方式在付款完成后超市端会进行语音播报收到xx元. ...
Activemq MQTT 简单消息推送示例
Activemq MQTT 简单消息推送示例简介简单使用 MQTT 连接 Activemq 进行消息推送的示例代码编写详情环境准备使用docker启动Activemq,查看M ...
spring实现mqtt服务端_SpringBoot--实战开发--MQTT消息推送(六十)
一.MQTT简介 MQTT(Message Queuing Telemetry Transport,消息队列遥测传输)是IBM开发的一个即时通讯协议,有可能成为物联网的重要组成部分.该协议支持所有平台 ...
MQTT+ActiveMQ实现消息推送（移动端）
这个小程序是我导师给我布置的一个任务,网上教程不是很多,遇到的一些困难都是自己解决的,所以写出来分享一下,有什么问题大家可以留言,尽力帮大家解决. 首先,我们需要先下载activeMQ (官网:htt ...

使用swoole作为MQTT客户端并接收实现即时消息推送

使用swoole作为MQTT客户端并接收实现即时消息推送相关推荐

最新文章

热门文章