Download the PHP package nashgao/mqtt without Composer
On this page you can find all versions of the php package nashgao/mqtt. It is possible to download/install these versions without Composer. Possible dependencies are resolved automatically.
FAQ
Example:
In general, it is recommended to use always a project to download your libraries. In an application normally there is more than one library needed.
- Some hosting areas are not accessible by a terminal or SSH. Then it is not possible to use Composer.
- To use Composer is sometimes complicated. Especially for beginners.
- Composer needs much resources. Sometimes they are not available on a simple webspace.
- If you are using private repositories you don't need to share your credentials. You can set up everything on our site and then you provide a simple download link to your team member.
- Simplify your Composer build process. Use our own command line tool to download the vendor folder as binary. This makes your build process faster and you don't need to expose your credentials for private repositories.
Informations about the package mqtt
Nashgao/MQTT
A PHP MQTT client library for Hyperf framework with MQTT 5 shared subscription support.
Installation
Publish the configuration file:
Quick Start
Publishing Messages
Subscribing to Topics
Project Overview
Nashgao/MQTT is a PHP MQTT client library that provides coroutine-based MQTT 5 functionality integrated with the Hyperf framework. Built on top of simps/mqtt, this library focuses on enabling MQTT 5's shared subscription feature for load-balanced message consumption across multiple subscribers.
Design Philosophy
The library was specifically designed to leverage MQTT 5's Shared Subscription feature, which allows multiple subscribers to subscribe to the same topic while ensuring only one subscriber receives each message (load balancing). This is particularly useful for:
- Queue Topics:
$queue/topic- Simple load balancing - Shared Topics:
$share/group/topic- Group-based load balancing with custom group names
Architecture Overview
Core Components
Client Layer
Client(src/Client.php): Main facade providing proxy methods for all MQTT operationsClientFactory(src/ClientFactory.php): Factory for creating client instances with proper pool managementClientProxy(src/ClientProxy.php): Proxy implementation handling method delegation and connection management
Connection Management
MQTTConnection(src/MQTTConnection.php): Wrapper around simps/mqtt client with Hyperf coroutine integrationMQTTPool(src/Pool/MQTTPool.php): Connection pool implementation for efficient resource managementPoolFactory(src/Pool/PoolFactory.php): Factory for creating and managing connection pools
Configuration System
ClientConfig(src/Config/ClientConfig.php): Connection configuration (broker, credentials, timeouts)TopicConfig(src/Config/TopicConfig.php): Topic-specific configuration for subscriptions and publishingConfigProvider(src/ConfigProvider.php): Hyperf service provider for dependency injection and event listeners
Event-Driven Architecture
The library uses Hyperf's event system for decoupled MQTT operations:
Command Events (trigger actions):
PublishEvent: Dispatch to publish messagesSubscribeEvent: Dispatch to subscribe to topics
Notification Events (reactions to MQTT events):
OnReceiveEvent: Triggered when messages are receivedOnPublishEvent: Triggered when messages are publishedOnSubscribeEvent: Triggered when subscriptions are establishedOnDisconnectEvent: Triggered on connection loss
Listeners
PublishListener: Handles PublishEvent dispatchingSubscribeListener: Handles SubscribeEvent dispatchingAfterWorkerStartListener: Handles auto-subscription on server startupOnReceiveListener: Handles incoming message processingServerIdListener: Manages server identification for clustering
Multi-Subscription Support
The library supports multiple subscription patterns:
- Auto-subscription: Configure topics in
mqtt.phpwithauto_subscribe: true - Multi-subscriber: Use
enable_multisub: trueto create multiple clients for the same topic - Shared subscriptions: Configure
enable_share_topic: truewith group names - Queue subscriptions: Enable
enable_queue_topic: truefor simple load balancing
Configuration
MQTT Broker Configuration
Key environment variables:
MQTT_HOST: MQTT broker host (default: localhost)MQTT_PORT: MQTT broker port (default: 1883)MQTT_USERNAME: MQTT username (default: admin)MQTT_PASSWORD: MQTT password (default: public)MQTT_PROTOCOL_LEVEL: MQTT protocol level (default: 5)
Connection Pool Configuration
Located in config/autoload/mqtt.php:
min_connections: Minimum pool connectionsmax_connections: Maximum pool connectionsconnect_timeout: Connection timeoutwait_timeout: Wait timeout for pool exhaustion
Usage Patterns
Publishing Messages
Subscribing to Topics
Auto-subscription
Configure topics in config/autoload/mqtt.php with auto_subscribe: true to automatically subscribe when the Hyperf server starts.
Dependencies
- PHP >= 8.3
- Hyperf Framework ~3.1
- simps/mqtt ~2.0
- Swoole >= 5.0 or Swow >= 1.5 (extensions)
Testing Requirements
The test suite requires:
- PHPUnit with co-phpunit for coroutine testing
- Hyperf testing framework
- Redis for integration tests (optional)
- MQTT broker running for integration tests
All versions of mqtt with dependencies
hyperf/di Version ~3.1
hyperf/framework Version ~3.1
hyperf/event Version ~3.1
hyperf/pool Version ~3.1
hyperf/logger Version ~3.1
hyperf/config Version ~3.1
hyperf/utils Version ~3.1
simps/mqtt Version ~2.0