PHP code example of nashgao / mqtt

1. Go to this page and download the library: Download nashgao/mqtt library. Choose the download type require.

2. Extract the ZIP file and open the index.php.

3. Add this code to the index.php.

    
        
<?php
require_once('vendor/autoload.php');

/* Start to develop here. Best regards https://php-download.com/ */

nashgao / mqtt example snippets


      use Hyperf\Context\ApplicationContext;
      use Nashgao\MQTT\Config\TopicConfig;
      use Nashgao\MQTT\Event\SubscribeEvent;
      use Psr\EventDispatcher\EventDispatcherInterface;  
    
      $event = new SubscribeEvent(topicConfigs: [
          new TopicConfig([
             'topic' => 'topic/test',
             'qos' => 2
          ])
      ]);
      $dispatcher = ApplicationContext::getContainer()->get(EventDispatcherInterface::class);
      $dispatcher->dispatch($event);

 
      use Nashgao\MQTT\Client;

      $client = make(Client::class);
      $client->subscribe([
          'topic/test' => [
              'qos' => 2
          ]
      ]);

 
    use Hyperf\Event\EventDispatcher;
    use Hyperf\Context\ApplicationContext;
    use Nashgao\MQTT\Event\PublishEvent;
    use Psr\EventDispatcher\EventDispatcherInterface;
    
    $dispatcher = ApplicationContext::getContainer()->get(EventDispatcherInterface::class);
    $dispatcher->dispatch(new PublishEvent('topic/test', 'hi mqtt', 2));


    use Nashgao\MQTT\Client;
    
    $client = make(Client::class);
    $client->publish('topic/test', 'hi_mqtt', 2);

bash
php bin/hyperf.php vendor:publish nashgao/mqtt

config/autoload/mqtt.php