{"id":54,"date":"2014-07-09T12:23:54","date_gmt":"2014-07-09T03:23:54","guid":{"rendered":"http:\/\/appw.jp\/2014\/?p=54"},"modified":"2016-10-28T14:16:08","modified_gmt":"2016-10-28T05:16:08","slug":"mongodb-%e3%81%ab%e4%bf%9d%e5%ad%98%e3%81%97%e3%81%9f-mosquitto-%e3%81%ae-payload-%e3%82%92-server-sent-events-%e3%81%a7%e8%a1%a8%e7%a4%ba%e3%81%97%e3%81%a6%e3%81%bf%e3%82%8b","status":"publish","type":"post","link":"http:\/\/appw.jp\/2014\/?p=54","title":{"rendered":"MongoDB \u306b\u4fdd\u5b58\u3057\u305f Mosquitto \u306e payload \u3092 Server-Sent Events \u3067\u8868\u793a\u3057\u3066\u307f\u308b"},"content":{"rendered":"

\u524d\u56de\u306e\u300cMosquitto \u306e payload \u3092 MongoDB \u306b\u4fdd\u5b58\u3057\u3066\u307f\u308b<\/a>\u300d\u306e\u7d9a\u7bc7\u3067\u3059\u3002<\/p>\n

\u4eca\u56de\u306f\u3001\u305d\u306e MongoDB \u304b\u3089\u53d6\u308a\u51fa\u3057\u3066\u3001HTML5 \u306e Server-Sent Events\uff08EventSource\uff09\u3092\u5229\u7528\u3057\u3066\u30d6\u30e9\u30a6\u30b6\u306b\u8868\u793a\u3057\u3066\u3044\u304f\u30d7\u30ed\u30b0\u30e9\u30e0\u3092 PHP \u3067\u4f5c\u6210\u3057\u307e\u3059\u3002Server-Sent Events \u306b\u3064\u3044\u3066\u306f\u3001\u4ee5\u524d\u306e\u8a18\u4e8b\u300cServer-Sent Events\uff08EventSource\uff09\u3092\u8a66\u3057\u3066\u307f\u307e\u3059<\/a>\u300d\u304c\u30d9\u30fc\u30b9\u3068\u306a\u308a\u307e\u3059\u3002<\/p>\n

\u307e\u305a\u3001ConoHa VPS<\/a>\"\" \u306e CentOS 6.5 \u306e\u74b0\u5883\u3067\u3001PHP \u304b\u3089 MongoDB \u306b\u30a2\u30af\u30bb\u30b9\u3059\u308b\u305f\u3081\u3001MongoDB PHP \u30c9\u30e9\u30a4\u30d0\u3092\u30a4\u30f3\u30b9\u30c8\u30fc\u30eb\u3057\u307e\u3059\u3002<\/p>\n

\r\nsudo pecl install mongo\r\n<\/pre>\n
\u305d\u3057\u3066\u3001php.ini \u306b\u6b21\u306e\u884c\u3092\u8ffd\u52a0\u3057\u307e\u3059\u3002<\/p>\n
\r\nextension=mongo.so\r\n<\/pre>\n
\u6b21\u306f\u3001\u30d6\u30e9\u30a6\u30b6\u5074\u306e HTML \u3067\u3059\u3002<\/p>\n
\r\n<!DOCTYPE html>\r\n<html>\r\n<head>\r\n<meta http-equiv="Content-Type" content="text\/html; charset=utf-8">\r\n<script src="http:\/\/ajax.googleapis.com\/ajax\/libs\/jquery\/1.11.1\/jquery.min.js"><\/script>\r\n<\/head>\r\n<body>\r\n<div id="out">\r\n<?php\r\n\/\/ DB\u3078\u63a5\u7d9a\r\n$mongo = new Mongo();\r\n\/\/ \u30c7\u30fc\u30bf\u30d9\u30fc\u30b9\u3092\u6307\u5b9a\r\n$db = $mongo->selectDB("chattest");\r\n\/\/ \u30b3\u30ec\u30af\u30b7\u30e7\u30f3\u3092\u6307\u5b9a\r\n$con = $db->selectCollection("conn_log");\r\n$col = $db->selectCollection("chat_log");\r\n\/\/ \u30b3\u30ec\u30af\u30b7\u30e7\u30f3\u306e\u30c9\u30ad\u30e5\u30e1\u30f3\u30c8\u3092\u53d6\u5f97\r\n$connid = time();\r\n$lastid = 0;\r\n$wid = $lastid;\r\n$cursor = $col->find()->sort(array('created_at'=>-1))->limit(5);\r\nforeach ($cursor as $doc) {\r\n  echo '<p>' . $doc["text"] . '<\/p>';\r\n  $wt = date('Y\/m\/d H:i:s', $doc["created_at"]);\r\n  echo '<p>- ' . $wt . ' -<\/p>';\r\n  if ($wid == $lastid) {\r\n    $wid = $doc["created_at"];\r\n  }\r\n}\r\n$con->insert(array('connid' => $connid, 'lastid' => $wid, 'user' => 'php'));\r\n\/\/\u00a0\u63a5\u7d9a\u306e\u5207\u65ad\r\n$mongo->close();\r\n?>\r\n<\/div>\r\n<script>\r\n<?php\r\n  echo "  var lastid = '" . $wid . "';" . PHP_EOL;\r\n?>\r\n  function sse(){\r\n    if (typeof (EventSource) !== 'undefined') {\r\n<?php\r\n  echo "      sv = 'sse.php?id=" . $connid . "';" . PHP_EOL;\r\n?>\r\n      source = new EventSource(sv);\r\n\r\n      source.addEventListener('messages', function(event){\r\n        if (event.lastEventId > lastid) {\r\n   \u3000     document.getElementById('out').innerHTML = event.data + document.getElementById('out').innerHTML ;\r\n          lastid = event.lastEventId;\r\n        }\r\n      },false);\r\n         \r\n      source.addEventListener('end', function(event){\r\n        if (event.lastEventId > lastid) {\r\n   \u3000     document.getElementById('out').innerHTML = event.data + document.getElementById('out').innerHTML ;\r\n          lastid = event.lastEventId;\r\n        }\r\n        source.close();\r\n      },false);\r\n\r\n      source.onerror = function (event) {\r\n        if (source.readyState === EventSource.CLOSED) {\r\n          document.getElementById('out').innerHTML = '<p>\u7d42\u4e86\u3057\u3066\u3044\u307e\u3059\u3002<\/p>' + document.getElementById('out').innerHTML ;\r\n        }\r\n        else if (source.readyState === EventSource.OPEN) {\r\n          document.getElementById('out').innerHTML = '<p>\u7d42\u4e86\u3057\u307e\u3059\u3002<\/p>' + document.getElementById('out').innerHTML ;\r\n          source.close();\r\n        }\r\n        else if (source.readyState === EventSource.CONNECTING) {\r\n        }\r\n      }\r\n    } else {\r\n      document.getElementById('out').innerHTML = '<p>Server-Sent Events \u306f\u30b5\u30dd\u30fc\u30c8\u3055\u308c\u3066\u3044\u307e\u305b\u3093\u3002<\/p>' ;\r\n    }\r\n  }\r\n  window.onload = sse;\r\n<\/script>\r\n<\/body>\r\n<\/html>\r\n<\/pre>\n
\u521d\u671f\u8868\u793a\u306b\u6700\u65b0\u306e\uff15\u4ef6\u3092\u8868\u793a\u3059\u308b\u305f\u3081\u3001PHP \u3067 MongoDB \u306b\u30a2\u30af\u30bb\u30b9\u3059\u308b\u30b3\u30fc\u30c9\u304c\u542b\u307e\u308c\u3066\u3044\u307e\u3059\u3002<\/p>\n
\u3055\u3089\u306b\u3001HTML5 \u306e Server-Sent Events \u306e\u5b9f\u969b\u306e\u3057\u304f\u307f\u3092\u8003\u616e\u3057\u3066\u3001\u63a5\u7d9a\u3054\u3068\u306b Server-Sent Events \u3067\u9001\u4fe1\u3057\u305f\u6700\u7d42\u30c9\u30ad\u30e5\u30e1\u30f3\u30c8\u306e created_at \u3092\u7ba1\u7406\u3057\u3066\u3001\u6b21\u56de\u306e\u9001\u4fe1\u30c7\u30fc\u30bf\u306e\u5224\u5b9a\u306b\u4f7f\u7528\u3059\u308b\u3057\u304f\u307f\u3092\u8ffd\u52a0\u3057\u3066\u3044\u307e\u3059\u3002<\/p>\n
\u3044\u304f\u3064\u304b\u65b9\u5f0f\u3092\u8003\u3048\u3066\u8a66\u3057\u305f\u75d5\u8de1\u304c\u3046\u3063\u3059\u3089\u3068\u30b3\u30fc\u30c9\u306b\u6b8b\u3063\u3066\u3057\u307e\u3044\u307e\u3057\u305f\u304c\u3001\u6700\u7d42\u7684\u306b\u306f\u3001EventSource \u306b\u8a2d\u5b9a\u3057\u305f url \u306e sse.php \u306b GET \u30e1\u30bd\u30c3\u30c9\u3067 \u8b58\u5225\u60c5\u5831\u3092\u6e21\u3059\u3053\u3068\u306b\u3057\u3066\u3001\u305d\u306e\u5185\u5bb9\u306b\u306f\u3001\u6700\u521d\u306b\u30d6\u30e9\u30a6\u30b6\u304b\u3089\u63a5\u7d9a\u3057\u305f UNIXTIME \u3092\u30bb\u30c3\u30c8\u3059\u308b\u3053\u3068\u306b\u3057\u307e\u3057\u305f\u3002<\/p>\n
\u3053\u306e\u60c5\u5831\u3068\u6700\u7d42\u30c9\u30ad\u30e5\u30e1\u30f3\u30c8\u306e created_at \u3092 conn_log \u30b3\u30ec\u30af\u30b7\u30e7\u30f3\u306b\u4fdd\u5b58\u3057\u3066\u3001\u9001\u4fe1\u30c7\u30fc\u30bf\u306e\u30c0\u30d6\u308a\u3084\u30e2\u30ec\u3092\u56de\u907f\u3059\u308b\u3088\u3046\u306b\u3057\u307e\u3057\u305f\u3002\u5927\u91cf\u30a2\u30af\u30bb\u30b9\u306b\u306f\u5411\u304b\u306a\u3044\u65b9\u6cd5\u3067\u3059\u306e\u3067\u691c\u8a0e\u306e\u4f59\u5730\u304c\u3042\u308a\u307e\u3059\u304c\u3001\u5148\u306b\u9032\u307f\u307e\u3059\u3002<\/p>\n
\u7d9a\u3044\u3066\u3001\u30b5\u30fc\u30d0\u30fc\u5074\u3067\u3059\u3002<\/p>\n
\u524d\u56de\u9001\u4fe1\u3057\u305f\u30c9\u30ad\u30e5\u30e1\u30f3\u30c8\u4ee5\u964d\u3092\u691c\u7d22\u3057\u3066\u3044\u307e\u3059\u3002<\/p>\n
\r\n<?php\r\nheader('Content-Type: text\/event-stream');\r\nheader('Cache-Control: no-cache');\r\n\r\n$lastid = 0;\r\n$connid = 0;\r\nif (isset($_GET['id'])) {\r\n   $connid = intval($_GET['id']);\r\n}\r\n\r\n\/\/ DB\u3078\u63a5\u7d9a\r\n$mongo = new Mongo();\r\n\/\/ \u30c7\u30fc\u30bf\u30d9\u30fc\u30b9\u3092\u6307\u5b9a\r\n$db = $mongo->selectDB("chattest");\r\n\/\/ \u30b3\u30ec\u30af\u30b7\u30e7\u30f3\u3092\u6307\u5b9a\r\n$con = $db->selectCollection("conn_log");\r\n$col = $db->selectCollection("chat_log");\r\n\/\/ \u30b3\u30ec\u30af\u30b7\u30e7\u30f3\u306e\u30c9\u30ad\u30e5\u30e1\u30f3\u30c8\u3092\u53d6\u5f97\r\n$curcon = $con->findOne(array('connid' => $connid));\r\n$lastid = $curcon["lastid"];\r\n$wid = $lastid;\r\n$cursor = $col->find(array('created_at' => array('$gt' => $lastid)))->sort(array('created_at' => -1));\r\necho 'event: ' . 'messages' . PHP_EOL;\r\nforeach ($cursor as $doc) {\r\n  if ($wid == $lastid) {\r\n    $wid = $doc["created_at"];\r\n  }\r\n  echo 'data: <p>' . $doc["text"] . '<\/p>' . PHP_EOL ;\r\n  $wt = date('Y\/m\/d H:i:s', $doc["created_at"]);\r\n  echo 'data: <p>- ' . $wt . ' -<\/p>' . PHP_EOL ;\r\n}\r\necho 'id: ' . strval($wid) . PHP_EOL;\r\n\r\n$curcon["lastid"] = $wid;\r\n$con->save($curcon);\r\n\/\/\u00a0\u63a5\u7d9a\u306e\u5207\u65ad\r\n$mongo->close();\r\n\r\n$retry = 10000;\r\nif ( $retry == 0 ) {\r\n  echo 'event: ' . 'end' . PHP_EOL;\r\n} else {\r\n  echo 'retry: ' . $retry . '' . PHP_EOL;\r\n}\r\necho PHP_EOL;\r\nob_flush();\r\nflush();\r\n\r\n?>\r\n<\/pre>\n<\/svg>\n
\u7b2c\uff11\u56de\u306e\u300cMosquitto \u306e payload \u3092 MongoDB \u306b\u4fdd\u5b58\u3057\u3066\u307f\u308b<\/a>\u300d\u3067\u306f\u3001Mosquitto \u306e payload \u3092 MongoDB \u306b\u4fdd\u5b58\u3057\u307e\u3057\u305f\u3002<\/p>\n
\u4eca\u56de\u306e\u7b2c\uff12\u56de\u306f\u3001HTML5 \u306e Server-Sent Events \u3068 PHP \u3067\u30d6\u30e9\u30a6\u30b6\u306b\u8868\u793a\u3057\u307e\u3057\u305f\u3002<\/p>\n
\u6b21\u56de\u306e\u7b2c\uff13\u56de\u306f\u3001Python \u3067 WebSocket \u3092\u5229\u7528\u3057\u305f\u7c21\u5358\u306a\u30c1\u30e3\u30c3\u30c8\u30d7\u30ed\u30b0\u30e9\u30e0\u3092\u53c2\u8003\u306b MongoDB \u30a2\u30af\u30bb\u30b9\u3092\u66f8\u304d\u52a0\u3048\u3066\u307f\u307e\u3059\u3002
\n\u300cPython WebSocket \u306e\u30c1\u30e3\u30c3\u30c8\u30b5\u30f3\u30d7\u30eb\u306b\u3001MongoDB \u4fdd\u5b58\u3092\u4ed8\u3051\u52a0\u3048\u307e\u3057\u305f<\/a>\u300d<\/p>\n
\u7b2c\uff14\u56de\u306f\u3001\u7b2c\uff13\u56de\u306e Python \u306e WebSocket \u30c1\u30e3\u30c3\u30c8\u30d7\u30ed\u30b0\u30e9\u30e0\u3092\u53c2\u8003\u306b\u3057\u3064\u3064\u3001\u30d6\u30e9\u30a6\u30b6\u304b\u3089 POST \u30e1\u30bd\u30c3\u30c9\u3067 Mosquitto \u3078 Publish \u3057\u3001\u307e\u305f\u3001Server-Sent Events \u3067\u30d6\u30e9\u30a6\u30b6\u306b\u8868\u793a\u3059\u308b\u65b9\u5f0f\u3092 Python \u3067\u8a66\u3057\u3066\u307f\u307e\u3059\u3002
\n\u300cMosquitto Publish \u3068 Server-Sent Events \u3067 Python \u30c1\u30e3\u30c3\u30c8\u30b5\u30f3\u30d7\u30eb\u3092\u6539\u9020<\/a>\u300d<\/p>\n","protected":false},"excerpt":{"rendered":"
\u524d\u56de\u306e\u300cMosquitto \u306e payload \u3092 MongoDB \u306b\u4fdd\u5b58\u3057\u3066\u307f\u308b\u300d\u306e\u7d9a\u7bc7\u3067\u3059\u3002 \u4eca\u56de\u306f\u3001\u305d\u306e MongoDB \u304b\u3089\u53d6\u308a\u51fa\u3057\u3066\u3001HTML5 \u306e Server-Sent Events\uff08EventSource […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"closed","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[2],"tags":[],"class_list":["post-54","post","type-post","status-publish","format-standard","hentry","category-vps"],"_links":{"self":[{"href":"http:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/posts\/54","targetHints":{"allow":["GET"]}}],"collection":[{"href":"http:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"http:\/\/appw.jp\/2014\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=54"}],"version-history":[{"count":9,"href":"http:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/posts\/54\/revisions"}],"predecessor-version":[{"id":162,"href":"http:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/posts\/54\/revisions\/162"}],"wp:attachment":[{"href":"http:\/\/appw.jp\/2014\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=54"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/appw.jp\/2014\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=54"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/appw.jp\/2014\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=54"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}