--<\/p>\n
--<\/p>\n
PHP \u7684\u61c9\u7528\u5834\u666f\u53ef\u80fd\u767c\u751f\u5728\u9700\u8981\u5f9e\u7db2\u9801\u767c\u51fa publish \u63a7\u5236\u9700\u6c42\uff0cHoyo \u5c1a\u672a\u5728 PHP \u4e0a\u64b0\u5beb\u5e38\u99d0\u7a0b\u5f0f<\/p>\n
\u5b89\u88dd\uff0c\u8df3\u904e PHP \u7248\u672c\u9700\u6c42<\/p>\n
> composer require php-mqtt\/client --ignore-platform-reqs<\/pre>\n\u7a0b\u5f0f\u7bc4\u4f8b<\/p>\n
<?php\r\nspl_autoload_register(function ($class_name) {\r\n $load_FileName = str_replace('\\\\', '\/', $class_name);\r\n $file_name = __DIR__ .\"\/php\/\". $load_FileName .\".php\";\r\n if ( is_file($file_name) === true ) {\r\n require_once( $file_name );\r\n }\r\n});\r\n\r\n$server = 'test.mosquitto.org';\r\n$port = 1883;\r\n$clientId = 'test-publisher';\r\n\r\n$mqtt = new \\PhpMqtt\\Client\\MQTTClient($server, $port, $clientId);\r\n$mqtt->connect();\r\n$mqtt->publish('aa\/Get\/DemandRange', 'Hello World!', 0);\r\n$mqtt->close();<\/pre>\n--<\/p>\n
Python<\/h2>\n
\u4f7f\u7528\u8b49\u66f8\u9023\u63a5 SSL<\/p>\n
client = mqtt.Client()\r\nclient.tls_set(ca_certs=\"my_root_ca.pem\", certfile=\"client.pem\", keyfile=\"client.key\")<\/pre>\n\u4e0d\u4f7f\u7528\u8b49\u66f8\u9023\u63a5<\/p>\n
client.tls_set(cert_reqs=ssl.CERT_NONE)\r\nclient.tls_insecure_set(True)<\/pre>\n\u5b8c\u6574\u7bc4\u4f8b<\/p>\n
import paho.mqtt.client as mqtt\r\n\r\n# \u7576\u5730\u7aef\u7a0b\u5f0f\u9023\u7dda\u4f3a\u670d\u5668\u5f97\u5230\u56de\u61c9\u6642\uff0c\u8981\u505a\u7684\u52d5\u4f5c\r\ndef on_connect(client, userdata, flags, rc):\r\n logging.info(\"Connected with result code %s\", str(rc))\r\n client.subscribe(\"v1\/devices\/me\/rpc\/request\/+\")\r\n\r\n# \u7576\u63a5\u6536\u5230\u5f9e\u4f3a\u670d\u5668\u767c\u9001\u7684\u8a0a\u606f\u6642\u8981\u9032\u884c\u7684\u52d5\u4f5c\r\ndef on_message(client, userdata, msg):\r\n # logging.info(userdata)\r\n # \u8f49\u63db\u7de8\u78bcutf-8\u624d\u770b\u5f97\u61c2\u4e2d\u6587\r\n\r\n# \u8a2d\u5b9a\u9023\u7dda\u7684\u52d5\u4f5c\r\nclient.on_connect = on_connect\r\n\r\n# \u8a2d\u5b9a\u63a5\u6536\u8a0a\u606f\u7684\u52d5\u4f5c\r\nclient.on_message = on_message\r\n\r\n# \u8a2d\u5b9a\u767b\u5165\u5e33\u865f\u5bc6\u78bc\r\nclient.username_pw_set(mqtt_username, mqtt_password)\r\n\r\n# \u8a2d\u5b9a\u9023\u7dda\u8cc7\u8a0a(IP, Port, \u9023\u7dda\u6642\u9593)\r\ntry:\r\n client.connect(mqtt_broker, int(mqtt_port), 60)\r\nexcept Exception as e:\r\n logging.info(e)\r\n\r\n#\r\ndef loop_forever():\r\n client.loop_forever()\r\n\r\nm = threading.Thread(target=loop_forever)\r\nm.start()<\/pre>\n<\/p>\n
--<\/p>\n
CLI<\/h2>\n
CLI \u57f7\u884c\u65b9\u5f0f\u9664\u4e86\u53ef\u4ee5\u6eff\u8db3\u55ae\u6a5f\u57f7\u884c\u5916\uff0c\u8b93 PHP \u76f4\u63a5\u547c\u53eb\u57f7\u884c\u61c9\u8a72\u662f\u66f4\u4f73\u7684\u65b9\u5f0f\uff0c\u5c24\u5176\u662f\u525b\u525b\u4e0a\u8ff0\u7684 PHP Publish \u6548\u80fd\u4e0d\u5f70\u7684\u60c5\u6cc1<\/p>\n