{"id":68,"date":"2014-07-09T19:39:22","date_gmt":"2014-07-09T10:39:22","guid":{"rendered":"https:\/\/appw.jp\/2014\/?p=68"},"modified":"2016-10-28T14:17:18","modified_gmt":"2016-10-28T05:17:18","slug":"mosquitto-publish-%e3%81%a8-server-sent-events-%e3%81%a7-python-%e3%83%81%e3%83%a3%e3%83%83%e3%83%88%e3%82%b5%e3%83%b3%e3%83%97%e3%83%ab%e3%82%92%e6%94%b9%e9%80%a0","status":"publish","type":"post","link":"https:\/\/appw.jp\/2014\/?p=68","title":{"rendered":"Mosquitto Publish \u3068 Server-Sent Events \u3067 Python \u30c1\u30e3\u30c3\u30c8\u30b5\u30f3\u30d7\u30eb\u3092\u6539\u9020"},"content":{"rendered":"

\u524d\u56de\u306e\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\u306e Python WebSocket \u30c1\u30e3\u30c3\u30c8\u30d7\u30ed\u30b0\u30e9\u30e0\u3092\u30d9\u30fc\u30b9\u306b\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\u5927\u6539\u9020\u3092\u3001\u4eca\u56de\u306f\u884c\u3044\u307e\u3059\u3002<\/p>\n

\u524d\u56de\u306f\u3001\u30d5\u30ec\u30fc\u30e0\u30ef\u30fc\u30af\u306b Flask<\/a> \u3092\u5229\u7528\u3057\u307e\u3057\u305f\u304c\u3001\u4eca\u56de\u306f Bottle<\/a> \u3092\u5229\u7528\u3057\u307e\u3059\u3002WSGI Server \u306b gevent<\/a> \u3092\u5229\u7528\u3057\u307e\u3059\u3002<\/p>\n

\u6b21\u306e\u30d7\u30ed\u30b0\u30e9\u30e0\u306f\u3001mqtt-chat.py \u3067\u30bb\u30fc\u30d6\u3057\u307e\u3057\u305f\u3002<\/p>\n

\r\nimport sys,os\r\nimport gevent\r\nfrom gevent import monkey; monkey.patch_all()\r\nfrom gevent.pywsgi import WSGIServer\r\nfrom bottle import get, post, route, view, request, response, redirect, Bottle\r\nimport time\r\nfrom datetime import datetime\r\n\r\nsys.path.append(os.path.dirname(os.path.abspath(__file__)) + '\/..\/model')\r\nfrom mchat import (ChatLog, ConnLog, connecter)\r\nfrom mqttc import (MQTTpub)\r\n\r\napp = Bottle(__name__)\r\n\r\ndef getlist(lastid):\r\n\r\n    wlist = []\r\n    wid = lastid\r\n\r\n    if lastid == '0':\r\n        posts = ChatLog.objects.order_by("-created_at")[:5]\r\n    else:\r\n        posts = ChatLog.objects(created_at__gt = int(lastid)).order_by("-created_at")\r\n\r\n    for post in posts:\r\n        wt = '<p>' + post.text + '<\/p>'\r\n        vt = datetime.fromtimestamp(post.created_at)\r\n        wt = wt + '<p>- ' + vt.strftime('%Y\/%m\/%d %H:%M:%S') + ' -<\/p>'\r\n        wlist.append(wt)\r\n        print 'text=%s' % post.text\r\n        if wid == lastid:\r\n            wid = str(post.created_at)\r\n\r\n    return wid, wlist\r\n\r\n\r\n@app.post('\/post')\r\ndef post():\r\n\r\n    message = request.forms.get('message')\r\n    print "post: %s" % message\r\n    MQTTpub(message)\r\n\r\n@app.get('\/stream')\r\ndef stream():\r\n\r\n    lastid = '0'\r\n\r\n    connid = request.query.id\r\n    conns = ConnLog.objects(connid = int(connid)).order_by("-lastid")\r\n    for conn in conns:\r\n        if lastid == '0':\r\n            lastid = str(conn.lastid)\r\n            break\r\n\r\n    response.content_type  = 'text\/event-stream'\r\n    response.cache_control = 'no-cache'\r\n    \r\n    wlist = []\r\n    wid = lastid\r\n\r\n    wid, wlist = getlist(lastid)\r\n\r\n    if wid != lastid:\r\n        conns.update(set__lastid=int(wid))\r\n\r\n    yield 'event: messages\\n'\r\n    for value in wlist:\r\n        yield 'data: %s\\n' % value\r\n    yield 'id: %s\\n' % wid\r\n    yield 'retry: 10000\\n'\r\n    yield '\\n'\r\n\r\n@app.route('\/')\r\n@view('mqtt-chat')\r\ndef index():\r\n\r\n    lastid = '0'\r\n    wlist = []\r\n    wid = '0'\r\n\r\n    wid, wlist = getlist(lastid)\r\n\r\n    name = 'MQTTC'\r\n    now = int(time.mktime(datetime.now().timetuple()))\r\n    ConnLog(connid=now, lastid=int(wid), user=name).save() \r\n\r\n    return dict(data=wlist, id=str(now), lastid=str(wid))\r\n\r\nif __name__ == '__main__':\r\n    connecter()\r\n    server = WSGIServer(('0.0.0.0', 8080), app)\r\n    server.serve_forever()\r\n<\/pre>\n
Server-Sent Events \u3092\u5229\u7528\u3059\u308b\u306b\u3042\u305f\u3063\u3066\u306f\u3001\u7b2c\uff12\u56de\u306e\u300cMongoDB \u306b\u4fdd\u5b58\u3057\u305f Mosquitto \u306e payload \u3092 Server-Sent Events \u3067\u8868\u793a\u3057\u3066\u307f\u308b<\/a>\u300d\u306e\u65b9\u5f0f\u3092\u524d\u63d0\u3068\u3057\u3066\u3044\u307e\u3059\u3002<\/p>\n
\u6b21\u306f\u30c6\u30f3\u30d7\u30ec\u30fc\u30c8\u3067\u3059\u3002<\/p>\n
mqtt-chat.py \u3092\u30bb\u30fc\u30d6\u3057\u305f\u30c7\u30a3\u30ec\u30af\u30c8\u30ea\u306e\u76f4\u4e0b\u306b views \u30c7\u30a3\u30ec\u30af\u30c8\u30ea\u3092\u4f5c\u6210\u3057\u3066 mqtt-chat.html \u3067\u30bb\u30fc\u30d6\u3057\u307e\u3057\u305f\u3002<\/p>\n
\r\n<!doctype html>\r\n<title>chat<\/title>\r\n<head>\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<h3>Chat<\/h3>\r\n<p>Message: <input id="in" \/><\/p>\r\n<div id="out">\r\n  % for item in data:\r\n    {{!item}}\r\n  % end\r\n<\/div>\r\n<script>\r\n  $('#in').keyup(function(e){\r\n    if (e.keyCode == 13) {\r\n      $.post('\/post', {'message': $(this).val()});\r\n      $(this).val('');\r\n    }\r\n  });\r\n<\/script>\r\n<script>\r\n  var lastid = {{lastid}};\r\n  function sse(){\r\n    var source;\r\n    if (typeof (EventSource) !== 'undefined') {\r\n        source = new EventSource('\/stream?id={{id}}');\r\n\r\n        source.addEventListener('messages', function(event){\r\n          if (event.lastEventId > lastid) {\r\n   \u3000\u3000\u3000\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\u3000\u3000\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
MVC \u306e\u30e2\u30c7\u30eb\u306b\u3042\u305f\u308b mchat.py \u306f\u3001\u6b21\u306e\u3088\u3046\u306b\u3057\u307e\u3057\u305f\u3002<\/p>\n
\r\nfrom mongoengine import *\r\n\r\nclass ChatLog(Document):\r\n    text = StringField(required=True)\r\n    user = StringField(required=True)\r\n    created_at = LongField(required=True)\r\n\r\nclass ConnLog(Document):\r\n    connid = LongField(required=True)\r\n    lastid = LongField(required=True)\r\n    user = StringField(required=True)\r\n \r\ndef connecter():\r\n    con = connect('chattest')\r\n    print con\r\n<\/pre>\n
\u3055\u3089\u306b\u3001Mosquitto \u3078\u306e Publish \u306e\u90e8\u5206\u3082\u5225\u30e2\u30b8\u30e5\u30fc\u30eb\u306b\u3057\u3066\u3001mqttc.py \u3067\u30bb\u30fc\u30d6\u3057\u307e\u3057\u305f\u3002<\/p>\n
\r\nimport paho.mqtt.client as paho\r\n\r\ndef MQTTpub(msg):\r\n    mqttc = paho.Client(client_id="gwclient", clean_session=True, protocol=paho.MQTTv311)\r\n    mqttc.username_pw_set("mqtt", "mqttpasswd")\r\n    mqttc.connect("127.0.0.1", 1883, 60)\r\n    mqttc.publish("test\/chat", msg, 0)\r\n    mqttc.disconnect()\r\n<\/pre>\n
\u30b5\u30fc\u30d0\u30fc\u74b0\u5883\u306f\u3001ConoHa VPS<\/a>\"\" \u3067\u3001CentOS 6.5 \u3067\u3059\u3002<\/p>\n
Android \u306e VNC \u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u30a2\u30d7\u30ea bVNC Pro \u304b\u3089\u78ba\u8a8d\u3092\u884c\u3044\u307e\u3057\u305f\u3002<\/p>\n
\"image\"<\/a><\/p>\n
\u3053\u308c\u307e\u3067\u306e\u6539\u9020\u30b5\u30f3\u30d7\u30eb\u30d7\u30ed\u30b0\u30e9\u30e0\u305d\u306e\u307e\u307e\u3067\u3001\u30b5\u30fc\u30d3\u30b9\u516c\u958b\u3059\u308b\u3088\u3046\u306a\u3053\u3068\u306f\u3001\u30bb\u30ad\u30e5\u30ea\u30c6\u30a3\u306a\u3069\u304b\u3089\u307f\u3066\u3082\u3001\u3042\u308a\u3048\u306a\u3044\u3053\u3068\u3067\u3059\u304c\u3001Server-Sent Events \u306e\u90e8\u5206\u3092\u516c\u958b\u30da\u30fc\u30b8\u306b\u7d44\u307f\u5165\u308c\u3066\u3001\u3072\u3068\u308a\u30bf\u30a4\u30e0\u30e9\u30a4\u30f3\u516c\u958b\u306e\u3088\u3046\u306a\u3053\u3068\u306f\u3067\u304d\u305d\u3046\u3067\u3059\u3002<\/p>\n
\u4eca\u56de\u306e Server-Sent Events \u3067\u306f\u3001\u7d04 10 \u79d2\u9593\u9694\u3067 retry \u518d\u63a5\u7d9a\u3059\u308b\u3088\u3046\u306b\u8a2d\u5b9a\u3057\u3066\u3044\u307e\u3059\u3002\u30d6\u30e9\u30a6\u30b6\u304b\u3089\u30e1\u30c3\u30bb\u30fc\u30b8\u3092 POST \u3057\u3066\u304b\u3089\u3001\u305d\u306e\u30e1\u30c3\u30bb\u30fc\u30b8\u304c\u30d6\u30e9\u30a6\u30b6\u306b\u8868\u793a\u3055\u308c\u308b\u307e\u3067\u3001\u305d\u306e\u3050\u3089\u3044\u306e\u6642\u9593\u304c\u304b\u304b\u308a\u307e\u3059\u3002<\/p>\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
\u7b2c\uff12\u56de\u306e\u300cMongoDB \u306b\u4fdd\u5b58\u3057\u305f Mosquitto \u306e payload \u3092 Server-Sent Events \u3067\u8868\u793a\u3057\u3066\u307f\u308b<\/a>\u300d\u3067\u306f\u3001HTML5 \u306e Server-Sent Events \u3068 PHP \u3067\u30d6\u30e9\u30a6\u30b6\u306b\u8868\u793a\u3057\u307e\u3057\u305f\u3002<\/p>\n
\u7b2c\uff13\u56de\u306e\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\u3067\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\u3057\u305f\u3002<\/p>\n
\u4eca\u56de\u306e\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\u3057\u305f\u3002<\/p>\n
\u307e\u305f\u3001\u300cMosquitto \u3078 SSL \u3067\u63a5\u7d9a\u3057\u3066\u307f\u308b<\/a>\u300d\u3067\u306f\u3001SSL\/TLS \u3067\u306e\u63a5\u7d9a\u306b\u30c8\u30e9\u30a4\u3057\u307e\u3059\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
\u524d\u56de\u306e\u300cPython WebSocket \u306e\u30c1\u30e3\u30c3\u30c8\u30b5\u30f3\u30d7\u30eb\u306b\u3001MongoDB \u4fdd\u5b58\u3092\u4ed8\u3051\u52a0\u3048\u307e\u3057\u305f\u300d\u306e Python WebSocket \u30c1\u30e3\u30c3\u30c8\u30d7\u30ed\u30b0\u30e9\u30e0\u3092\u30d9\u30fc\u30b9\u306b\u3001\u30d6\u30e9\u30a6\u30b6\u304b\u3089 POST \u30e1\u30bd\u30c3\u30c9\u3067 Mosquit […]<\/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-68","post","type-post","status-publish","format-standard","hentry","category-vps"],"_links":{"self":[{"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/posts\/68","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=%2Fwp%2Fv2%2Fcomments&post=68"}],"version-history":[{"count":11,"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/posts\/68\/revisions"}],"predecessor-version":[{"id":164,"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/posts\/68\/revisions\/164"}],"wp:attachment":[{"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=68"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=68"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=68"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}