simps/mqtt-cli 问题修复 & 功能扩展

解决BUG、新增功能、兼容多环境部署,快速响应你的开发需求

邮箱:yvsm@zunyunkeji.com | QQ:316430983 | 微信:yvsm316

simps/mqtt-cli

Composer 安装命令:

composer require simps/mqtt-cli

包简介

PHPMQTT CLI Tools

README 文档

README

  ____  _   _ ____  __  __  ___ _____ _____
 |  _ \| | | |  _ \|  \/  |/ _ \_   _|_   _|
 | |_) | |_| | |_) | |\/| | | | || |   | |
 |  __/|  _  |  __/| |  | | |_| || |   | |
 |_|   |_| |_|_|   |_|  |_|\__\_\|_|   |_|

Install

composer require simps/mqtt-cli

Usage

Publish

$ php vendor/bin/mqtt publish --help
Description:
  Publishing simple messages

Usage:
  publish [options]

Options:
  -H, --host[=HOST]                        Specify the host to connect to [default: "localhost"]
  -P, --port[=PORT]                        Connect to the port specified [default: 1883]
  -t, --topic=TOPIC                        The MQTT topic on which to publish the message
  -m, --message=MESSAGE                    Send a single message from the command line
  -i, --id[=ID]                            The id to use for this client [default: ""]
      --qos[=QOS]                          Specify the quality of service to use for the message, from 0, 1 and 2 [default: 0]
      --dup[=DUP]                          If the DUP flag is set to 0, it indicates that this is the first occasion that the Client or Server has attempted to send this PUBLISH packet [default: 0]
  -r, --retain[=RETAIN]                    If the RETAIN flag is set to 1 in a PUBLISH packet sent by a Client to a Server, the Server MUST replace any existing retained message for this topic and store the Application Message [default: 0]
  -u, --username[=USERNAME]                Provide a username to be used for authenticating with the broker
  -p, --pw[=PW]                            Provide a password to be used for authenticating with the broker
  -c, --clean-session[=CLEAN-SESSION]      Setting the 'clean session' flag [default: true]
  -l, --level=LEVEL                        MQTT Protocol level [default: 4]
  -k, --keepalive[=KEEPALIVE]              The number of seconds between sending PING commands to the broker for the purposes of informing it we are still connected and functioning [default: 0]
      --will-topic[=WILL-TOPIC]            The topic on which to send a Will, in the event that the client disconnects unexpectedly
      --will-message[=WILL-MESSAGE]        Specify a message that will be stored by the broker and sent out if this client disconnects unexpectedly
      --will-qos[=WILL-QOS]                The QoS to use for the Will [default: 0]
      --will-retain[=WILL-RETAIN]          If given, if the client disconnects unexpectedly the message sent out will be treated as a retained message [default: 0]
  -S, --ssl[=SSL]                          Enable SSL encryption [default: false]
      --config-path[=CONFIG-PATH]          Setting the Swoole config file path
      --properties-path[=PROPERTIES-PATH]  Setting the Properties config file path
  -h, --help                               Display help for the given command. When no command is given display help for the list command
  -q, --quiet                              Do not output any message
  -V, --version                            Display this application version
      --ansi                               Force ANSI output
      --no-ansi                            Disable ANSI output
  -n, --no-interaction                     Do not ask any interactive question
  -v|vv|vvv, --verbose                     Increase the verbosity of messages: 1 for normal output, 2 for more verbose output and 3 for debug

Help:
  An MQTT version 3.1/3.1.1/5.0 client for publishing simple messages

Subscribe

$ php vendor/bin/mqtt subscribe --help
Description:
  Subscribing to topics

Usage:
  subscribe [options]

Options:
  -H, --host[=HOST]                        Specify the host to connect to [default: "localhost"]
  -P, --port[=PORT]                        Connect to the port specified [default: 1883]
  -i, --id[=ID]                            The id to use for this client [default: ""]
      --qos=QOS                            Specify the quality of service to use for the message, from 0, 1 and 2 (multiple values allowed)
  -t, --topic=TOPIC                        The MQTT topic to subscribe to (multiple values allowed)
  -u, --username[=USERNAME]                Provide a username to be used for authenticating with the broker
  -p, --pw[=PW]                            Provide a password to be used for authenticating with the broker
  -c, --clean-session[=CLEAN-SESSION]      Setting the 'clean session' flag [default: true]
  -l, --level=LEVEL                        MQTT Protocol level [default: 4]
  -k, --keepalive[=KEEPALIVE]              The number of seconds between sending PING commands to the broker for the purposes of informing it we are still connected and functioning [default: 0]
      --will-topic[=WILL-TOPIC]            The topic on which to send a Will, in the event that the client disconnects unexpectedly
      --will-message[=WILL-MESSAGE]        Specify a message that will be stored by the broker and sent out if this client disconnects unexpectedly
      --will-qos[=WILL-QOS]                The QoS to use for the Will [default: 0]
      --will-retain[=WILL-RETAIN]          If given, if the client disconnects unexpectedly the message sent out will be treated as a retained message [default: 0]
  -S, --ssl[=SSL]                          Enable SSL encryption [default: false]
      --config-path[=CONFIG-PATH]          Setting the Swoole config file path
      --properties-path[=PROPERTIES-PATH]  Setting the Properties config file path
  -U, --unsubscribe[=UNSUBSCRIBE]          Topics that need to be unsubscribed (multiple values allowed)
  -e, --event[=EVENT]                      Subscribed EventDispatcher [default: ""]
  -h, --help                               Display help for the given command. When no command is given display help for the list command
  -q, --quiet                              Do not output any message
  -V, --version                            Display this application version
      --ansi                               Force ANSI output
      --no-ansi                            Disable ANSI output
  -n, --no-interaction                     Do not ask any interactive question
  -v|vv|vvv, --verbose                     Increase the verbosity of messages: 1 for normal output, 2 for more verbose output and 3 for debug

Help:
  An MQTT version 3.1/3.1.1/5.0 client for subscribing to topics

Path

There are two config: --config-path and --properties-path, you need to specify the path to the config file.

  • --config-path
// config.php

return [
    'open_mqtt_protocol' => true,
    'package_max_length' => 2 * 1024 * 1024,
];
  • --properties-path
// properties.php

return [
    'publish' => [
        'topic_alias' => 1,
        'message_expiry_interval' => 12,
    ],
    'will' => [
        'will_delay_interval' => 60,
        'message_expiry_interval' => 60,
    ],
];

simps/mqtt-cli 适用场景与选型建议

simps/mqtt-cli 是一款 基于 PHP 开发的 Composer 扩展包,目前已累计 60.76k 次下载、GitHub Stars 达 7, 最近一次更新时间为 2021 年 03 月 17 日, 在 PHP 生态内属于活跃度较高的组件。

它主要适用于以下技术方向: 「php」 「client」 「coroutine」 「swoole」 「mqtt」 「simps」 等业务场景。在实际项目中,围绕这些方向常见需要落地的问题包括:接口对接、性能调优、并发安全、与既有框架(Laravel / ThinkPHP / Yii / Webman 等)的兼容适配,以及生产环境的日志埋点与稳定性保障。

我们在过去多个企业项目中使用过 simps/mqtt-cli 或与其功能相近的方案,如果你在选型或落地过程中遇到问题,例如 版本兼容、二次改造、私有化封装、与内部系统对接、生产 BUG 排查,欢迎联系我们协助评估。

围绕 simps/mqtt-cli 我们能提供哪些服务?
定制开发 / 二次开发

基于 simps/mqtt-cli 在你已有业务上做功能扩展、字段裁剪、UI 适配、与内部账号 / 权限 / 日志系统的深度对接。

BUG 修复 & 性能优化

线上偶发问题、内存泄漏、慢查询、并发异常等排查修复;针对高流量场景做缓存、队列、索引层面的调优。

项目外包 & 长期维护

承接完整的项目从需求 → 设计 → 开发 → 上线 → 长期运维;也可按月提供技术保姆服务。

yvsm@zunyunkeji.com QQ:316430983 微信:yvsm316 西安尊云信息科技 · 专注 PHP / Go / 分布式系统研发

统计信息

  • 总下载量: 60.76k
  • 月度下载量: 0
  • 日度下载量: 0
  • 收藏数: 8
  • 点击次数: 23
  • 依赖项目数: 2
  • 推荐数: 0

GitHub 信息

  • Stars: 7
  • Watchers: 2
  • Forks: 1
  • 开发语言: PHP

其他信息

  • 授权协议: Apache-2.0
  • 更新时间: 2021-03-17