\u3055\u3066\u3001\u524d\u56de\u30bb\u30c3\u30c8\u30a2\u30c3\u30d7\u3057\u305fVerneMQ\u3092\u52d5\u304b\u3057\u3066\u307f\u307e\u3057\u3087\u3046\u3002MQTT\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u306fphp\u3067\u5b9f\u88c5\u3057\u307e\u3059\u3002\u30e9\u30a4\u30d6\u30e9\u30ea\u306f\u3001phpMQTT\u3092\u4f7f\u3063\u3066\u307f\u307e\u3059\u3002
\n<\/p>\n
\u305d\u308c\u3067\u306f\u3001\u307e\u305a\u6700\u521d\u306bvernemq\u30b5\u30fc\u30d3\u30b9\u306e\u8d77\u52d5\u3092\u3057\u307e\u3059\u3002\u30d5\u30a1\u30a4\u30eb\u30c7\u30a3\u30b9\u30af\u30ea\u30d7\u30bf\u4e0a\u9650\u6570\u3092\u63a8\u5968\u306e65536\u306b\u5909\u3048\u3066\u3044\u306a\u3044\u3068\u3001\u4ee5\u4e0b\u306e\u3088\u3046\u306b\u8b66\u544a\u304c\u51fa\u307e\u3059\u3002\u500b\u4eba\u7684\u306b\u306f\u89aa\u5207\u306a\u8a2d\u8a08\u3060\u3068\u601d\u3044\u307e\u3059\u3002<\/p>\n
$ sudo service vernemq start\nStarting vernemq: !!!!\n!!!! WARNING: ulimit -n is 1024; 65536 is the recommended minimum.\n!!!!\n [ OK ]\n<\/code><\/pre>\nMQTT\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u306e\u4f5c\u6210<\/h2>\n
MQTT\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u3092\u5b9f\u88c5\u3057\u3066\u3044\u304d\u307e\u3059\u3002phpMQTT<\/a>\u306e\u30bd\u30fc\u30b9\u30b3\u30fc\u30c9\u306fgithub\u3067\u516c\u958b\u3055\u308c\u3066\u3044\u308b\u306e\u3067\u3001\u30c0\u30a6\u30f3\u30ed\u30fc\u30c9\u3057\u3066\u304a\u597d\u304d\u306a\u30c7\u30a3\u30ec\u30af\u30c8\u30ea\u306b\u914d\u7f6e\u3057\u3066\u304f\u3060\u3055\u3044\u3002<\/p>\npublisher<\/h3>\n
\u307e\u305a\u306f\u3001publisher\u304b\u3089\u3002phpMQTT.php\u3092require\u3057\u3001phpMQTT\u30af\u30e9\u30b9\u3092\u751f\u6210\u3001\u8a8d\u8a3c\u60c5\u5831\u3092\u30bb\u30c3\u30c8\u3057\u3066Broker\u3078\u63a5\u7d9a\u3001\u305d\u306e\u5f8cpublish\u3068\u3044\u3046\u6d41\u308c\u306b\u306a\u308a\u307e\u3059\u3002<\/p>\n
\u63a5\u7d9a\u3059\u308b\u5404\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u306f\u3001user\/(\u30e6\u30fc\u30b6\u540d) \u3068\u3044\u3046\u30c8\u30d4\u30c3\u30af\u3092 subscribe\u3057\u3066\u3044\u308b\u3082\u306e\u3068\u3057\u3001publisher\u306f\u3001\u30e6\u30fc\u30b6\u540d\u306e\u307f\u3092\u6307\u5b9a\u3057\u3066\u3001\u7279\u5b9a\u306esubscriber\u306e\u307f\u306b\u4efb\u610f\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u9001\u308b\u4ed5\u69d8\u3068\u3057\u307e\u3059\u3002<\/p>\n
\u5f15\u6570\u306f2\u3064\u3067\u30011\u3064\u76ee\u306ftopic\u30012\u3064\u76ee\u306f\u30e1\u30c3\u30bb\u30fc\u30b8\u3067\u3059\u3002\u30d5\u30a1\u30a4\u30eb\u540d\u306f\u3001publisher.php\u3068\u3057\u307e\u3059\u3002<\/p>\n
<?php\n\n require(\"phpMQTT\/phpMQTT.php\");\n\n $username = \"pub\";\n $password = \"password\";\n\n $target = isset($argv[1]) ? $argv[1] : null;\n $message = isset($argv[2]) ? $argv[2] : null;\n if ($target === null || $message === null){\n die(\"invalid parameter\\n\\n\");\n }\n\n $mqtt = new phpMQTT(\"localhost\", 1883, \"ClientID\".rand());\n if (!$mqtt->connect(true, null, $username, $password)){\n exit;\n }\n\n $mqtt->publish(\"user\/{$target}\", $message, 0);\n print \"send: 'user\/{$target}' -> '{$message}'\\n\\n\";\n\n $mqtt->close();\n\n<\/code><\/pre>\nsubscriber<\/h3>\n
\u6b21\u306f\u3001subscriber\u3067\u3059\u3002\u5f15\u6570\u306f2\u3064\u3067\u3001 Broker\u306b\u63a5\u7d9a\u3059\u308b\u30e6\u30fc\u30b6\u540d\u3068\u30d1\u30b9\u30ef\u30fc\u30c9\u3067\u3059\u3002\u81ea\u5206\u5b9b\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u53d7\u4fe1\u3059\u308b\u3068\u3001\u30c8\u30d4\u30c3\u30af\u3068\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u6a19\u6e96\u51fa\u529b\u3078\u51fa\u3059\u4ed5\u69d8\u3068\u3057\u307e\u3059\u3002\u30d5\u30a1\u30a4\u30eb\u540d\u306f\u3001subscriber.php\u3067\u3059\u3002<\/p>\n
<?php\n\n require(\"phpMQTT\/phpMQTT.php\");\n\n $username = isset($argv[1]) ? $argv[1] : null;\n $password = isset($argv[2]) ? $argv[2] : null;\n\n $mqtt = new phpMQTT(\"localhost\", 1883, \"ClientID\".rand());\n if (!$mqtt->connect(true, null, $username, $password)){\n exit;\n }\n $topics = array();\n $topics[\"user\/{$username}\"] = array(\"qos\" => 1, \"function\" => \"procmsg\");\n print \"subscribe 'user\/{$username}'\\n\";\n\n $mqtt->subscribe($topics, 1);\n while ($mqtt->proc()){\n \/\/ receive loop\n }\n $mqtt->close();\n\n function procmsg($topic, $msg){\n print \"Msg Recieved: \".date(\"r\").\"\\nTopic:{$topic}\\n$msg\\n\";\n }\n<\/code><\/pre>\n\u5b9f\u884c<\/h3>\n
\u307e\u305a\u306fsubscriber\u30922\u3064\u8d77\u52d5\u3057\u307e\u3059\u3002<\/p>\n
$ php subscriber.php sub1 password\nsubscribe 'user\/sub1'\n<\/code><\/pre>\n$ php subscriber.php sub2 password\nsubscribe 'user\/sub2'\n<\/code><\/pre>\n\u3053\u306e\u72b6\u614b\u3067\u3001publisher\u3092\u8d77\u52d5\u3057\u307e\u3059\u3002sub1\u306b\u30e1\u30c3\u30bb\u30fc\u30b8\u3092\u9001\u3063\u3066\u307f\u307e\u3057\u3087\u3046\u3002<\/p>\n
$ php publisher.php sub1 \"Hello MQTT\"\nsend: 'user\/sub1' -> 'Hello MQTT'\n<\/code><\/pre>\n$ php subscriber.php sub1 password\nsubscribe 'user\/sub1'\nMsg Recieved: Mon, 17 Jul 2017 21:20:59 +0900\nTopic:user\/sub1\nHello MQTT\n<\/code><\/pre>\n\u4e00\u898b\u4e0a\u624b\u304f\u3044\u3063\u3066\u3044\u308b\u3088\u3046\u3067\u3059\u304c\u3001\/var\/log\/vernemq\/console.log \u3092\u307f\u308b\u3068<\/p>\n
[warning] <0.2273.0>@vmq_ranch:teardown:127 session stopped abnormally due to '{error,unexpected_message,{error,cant_parse_variable_header}}'\n<\/code><\/pre>\nsubscriber\u304c\u30a8\u30e9\u30fc\u3067\u5207\u65ad\u3055\u308c\u3066\u3057\u307e\u3044\u307e\u3059\u3002\u3093\u30fc\u3001\u306a\u3093\u3067\u3060\u308d\u3046\u3068\u8abf\u3079\u3066\u3044\u305f\u306e\u3067\u3059\u304c\u3001\u4e00\u70b9\u602a\u3057\u3044\u3068\u3053\u308d\u304c\u3002phpMQTT.php \u306e function subsucribe()<\/code> \u306b\u3066\u3001MQTT\u306esubscribe\u30b3\u30de\u30f3\u30c9\u3092\u751f\u6210\u3057\u3066\u3044\u308b\u3068\u3053\u308d\u3067\u3001<\/p>\n$cmd = 0x80;\n<\/code><\/pre>\n