{"id":96,"date":"2014-07-31T10:30:38","date_gmt":"2014-07-31T01:30:38","guid":{"rendered":"http:\/\/appw.jp\/2014\/?p=96"},"modified":"2014-12-13T05:57:58","modified_gmt":"2014-12-12T20:57:58","slug":"mosquitto-%e3%81%b8-ssl-%e3%81%a7%e6%8e%a5%e7%b6%9a%e3%81%97%e3%81%a6%e3%81%bf%e3%82%8b","status":"publish","type":"post","link":"https:\/\/appw.jp\/2014\/?p=96","title":{"rendered":"Mosquitto \u3078 SSL \u3067\u63a5\u7d9a\u3057\u3066\u307f\u308b"},"content":{"rendered":"<p>\u300c<a href=\"http:\/\/appw.jp\/2014\/?p=91\">Mosquitto \u306e SSL \u5bfe\u5fdc\u3092\u8a66\u3057\u3066\u307f\u308b<\/a>\u300d\u3067 SSL \u5bfe\u5fdc\u3057\u307e\u3057\u305f\u3002\u305d\u3053\u3067\u4f5c\u6210\u3057\u305f\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u7528\u306e\u30ad\u30fc\u3068\u8a3c\u660e\u66f8\u3092\u4f7f\u7528\u3057\u3066\u3001\u4eca\u56de\u306f\u3001\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u304b\u3089\u306e\u63a5\u7d9a\u3092\u8a66\u307f\u307e\u3059\u3002<\/p>\n<p>\u3053\u308c\u307e\u3067\u306b\u3044\u304f\u3064\u304b Python \u3067 MQTT \u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u30d7\u30ed\u30b0\u30e9\u30e0\u3092\u4f5c\u6210\u3057\u3066\u3044\u307e\u3059\u304c\u3001\u3053\u308c\u3089\u3092\u6539\u9020\u3057\u3066\u5229\u7528\u3057\u307e\u3059\u3002<\/p>\n<p>\u6700\u521d\u306b\u300c<a href=\"http:\/\/appw.jp\/2014\/?p=47\">Mosquitto \u306e payload \u3092 MongoDB \u306b\u4fdd\u5b58\u3057\u3066\u307f\u308b<\/a>\u300d\u306e\u30d7\u30ed\u30b0\u30e9\u30e0\u3067\u3059\u3002<\/p>\n<pre class=\"brush: python; title: ; notranslate\" title=\"\">\r\nimport os, sys\r\nimport time\r\nfrom datetime import datetime\r\nimport paho.mqtt.client as paho\r\n\r\nsys.path.append(os.path.dirname(os.path.abspath(__file__)) + '\/..\/model')\r\nfrom mchat import (connecter, ChatLog)\r\n\r\ndef on_connect(mosq, obj, rc):\r\n    print(&quot;on connect &#x5B;rc]:&quot; + str(rc))\r\n\r\ndef on_message(mosq, obj, msg):\r\n    now = int(time.mktime(datetime.now().timetuple()))\r\n    ChatLog(text=msg.payload, user='MQTT', created_at=now).save() \r\n    print(&quot;on message &#x5B;topic]:&quot;+msg.topic + &quot;  &#x5B;qos]:&quot; + str(msg.qos) + &quot;  &#x5B;payload]:&quot; + str(msg.payload))\r\n\r\ndef on_publish(mosq, obj, mid):\r\n    print(&quot;on publish &#x5B;mid]:&quot; + str(mid))\r\n\r\ndef on_subscribe(mosq, obj, mid, granted_qos):\r\n    print(&quot;on subscribe &#x5B;mid]:&quot; + str(mid) + &quot; &#x5B;qos]:&quot; + str(granted_qos))\r\n\r\ndef on_disconnect(mosq, obj, rc):\r\n    print(&quot;on disconnect &#x5B;rc]:&quot; + str(rc))\r\n\r\ndef on_log(mosq, obj, level, string):\r\n    print(string)\r\n\r\nmqttc = paho.Client()\r\n\r\nmqttc.on_message = on_message\r\nmqttc.on_connect = on_connect\r\nmqttc.on_publish = on_publish\r\nmqttc.on_subscribe = on_subscribe\r\nmqttc.on_disconnect = on_disconnect\r\n\r\nmqttc.username_pw_set(&quot;mqtt&quot;, &quot;mqttpasswd&quot;)\r\n\r\nca_certs = &quot;\/etc\/mosquitto\/ca\/ca.crt&quot;\r\ncertfile = &quot;\/etc\/mosquitto\/tls\/client.crt&quot;\r\nkeyfile = &quot;\/etc\/mosquitto\/tls\/client.key&quot;\r\nmqttc.tls_set(ca_certs, certfile, keyfile, cert_reqs=paho.ssl.CERT_REQUIRED, tls_version=paho.ssl.PROTOCOL_TLSv1, ciphers=None)\r\nmqttc.connect(&quot;www.hoge.jp&quot;, 8883, 60)\r\n\r\nconnecter()\r\n\r\nmqttc.subscribe(&quot;test\/chat&quot;, 0)\r\n\r\nmqttc.publish(&quot;test\/chat&quot;, &quot;conected mqtt subscribe&quot;)\r\n\r\nmqttc.loop_forever()\r\n<\/pre>\n<p>\u7d9a\u3044\u3066\u300c<a href=\"http:\/\/appw.jp\/2014\/?p=68\">Mosquitto Publish \u3068 Server-Sent Events \u3067 Python \u30c1\u30e3\u30c3\u30c8\u30b5\u30f3\u30d7\u30eb\u3092\u6539\u9020<\/a>\u300d\u306e mqttc.py \u3067\u3059\u3002<\/p>\n<pre class=\"brush: python; title: ; notranslate\" title=\"\">\r\nimport paho.mqtt.client as paho\r\n\r\ndef MQTTpub(msg):\r\n    mqttc = paho.Client(client_id=&quot;gwclient&quot;, clean_session=True, protocol=paho.MQTTv311)\r\n    mqttc.username_pw_set(&quot;mqtt&quot;, &quot;mqttpasswd&quot;)\r\n\r\n    ca_certs = &quot;\/etc\/mosquitto\/ca\/ca.crt&quot;\r\n    certfile = &quot;\/etc\/mosquitto\/tls\/client.crt&quot;\r\n    keyfile = &quot;\/etc\/mosquitto\/tls\/client.key&quot;\r\n    mqttc.tls_set(ca_certs, certfile, keyfile, cert_reqs=paho.ssl.CERT_REQUIRED, tls_version=paho.ssl.PROTOCOL_TLSv1, ciphers=None)\r\n\r\n    mqttc.connect(&quot;www.hoge.jp&quot;, 8883, 60)\r\n    mqttc.publish(&quot;test\/chat&quot;, msg, 0)\r\n    mqttc.disconnect()\r\n<\/pre>\n<p>\u306a\u304a\u3001\u4f7f\u7528\u3057\u3066\u3044\u308b paho-mqtt \u30d1\u30c3\u30b1\u30fc\u30b8\u306f\u3001SSL\/TLS \u306e\u30b5\u30dd\u30fc\u30c8\u304c Python 2.7 \u304b\u3089\u3068\u306a\u3063\u3066\u3044\u308b\u3088\u3046\u3067\u3059\u3002<\/p>\n<p>\u308f\u305f\u3057\u306e\u74b0\u5883\u306f\u3001CentOS 6.5\u3001Python 2.6.6 \u3067\u3059\u306e\u3067\u3001Python 2.7 \u3092\u8ffd\u52a0\u3057\u306a\u3051\u308c\u3070\u78ba\u8a8d\u3067\u304d\u307e\u305b\u3093\u3067\u3057\u305f\u3002<\/p>\n<p>\u3068\u308a\u3042\u3048\u305a\u78ba\u8a8d\u3059\u308b\u305f\u3081\u306b\u3001\u3053\u306e\u8a18\u4e8b\u6642\u70b9\u3067\u6700\u65b0\u30d0\u30fc\u30b8\u30e7\u30f3\u306e Python 2.7.8 \u3092\u8ffd\u52a0\u3057\u307e\u3057\u305f\u3002<\/p>\n<p>\u30a4\u30f3\u30b9\u30c8\u30fc\u30eb\u5148\u3067\u3059\u3002<\/p>\n<pre class=\"brush: bash; title: ; notranslate\" title=\"\">\r\nmkdir \/opt\/local\r\ncd \/opt\/local\r\n<\/pre>\n<p>Development tools \u3092\u30a4\u30f3\u30b9\u30c8\u30fc\u30eb\u3057\u307e\u3059\u3002<\/p>\n<pre class=\"brush: bash; title: ; notranslate\" title=\"\">\r\nyum groupinstall &quot;Development tools&quot;\r\nyum install zlib-devel bzip2-devel openssl-devel ncurses-devel sqlite-devel readline-devel tk-deve\r\n<\/pre>\n<p>Python 2.7.8 \u3092\u30c0\u30a6\u30f3\u30ed\u30fc\u30c9\u3057\u307e\u3059\u3002<\/p>\n<pre class=\"brush: bash; title: ; notranslate\" title=\"\">\r\ncurl -O https:\/\/www.python.org\/ftp\/python\/2.7.8\/Python-2.7.8.tgz\r\ntar zxf Python-2.7.8.tgz\r\n<\/pre>\n<p>Python 2.7.8 \u3092\u30a4\u30f3\u30b9\u30c8\u30fc\u30eb\u3057\u307e\u3059\u3002<\/p>\n<pre class=\"brush: bash; title: ; notranslate\" title=\"\">\r\ncd Python-2.7.8\r\n.\/configure --prefix=\/opt\/local\r\nmake &amp;&amp; make altinstall\r\n<\/pre>\n<p>easy_install \u3092\u30a4\u30f3\u30b9\u30c8\u30fc\u30eb\u3057\u307e\u3059\u3002<\/p>\n<pre class=\"brush: bash; title: ; notranslate\" title=\"\">\r\ncurl -O http:\/\/python-distribute.org\/distribute_setup.py\r\n\/opt\/local\/bin\/python2.7 .\/distribute_setup.py\r\n<\/pre>\n<p>virtualenv \u3092\u30a4\u30f3\u30b9\u30c8\u30fc\u30eb\u3057\u307e\u3059\u3002<\/p>\n<pre class=\"brush: bash; title: ; notranslate\" title=\"\">\r\n\/opt\/local\/bin\/easy_install-2.7 virtualenv\r\n<\/pre>\n<p>easy_install-2.7 \u3092\u4f7f\u7528\u3057\u3066\u5fc5\u8981\u306a\u30d1\u30c3\u30b1\u30fc\u30b8\u3092\u3059\u3079\u3066\u30a4\u30f3\u30b9\u30c8\u30fc\u30eb\u3057\u307e\u3059\u3002<\/p>\n<pre class=\"brush: bash; title: ; notranslate\" title=\"\">\r\neasy_install-2.7 gevent bottle pytz mongoengine paho-mqtt supervisor\r\n<\/pre>\n<p>\u305d\u3057\u3066\u3001python2.7 \u3067\u5b9f\u884c\u3057\u307e\u3059\u3002<\/p>\n<p><a href=\"http:\/\/appw.jp\/2014\/files\/2014\/07\/Screenshot_2014-07-31-10-38-0201.png\"><img loading=\"lazy\" decoding=\"async\" src=\"http:\/\/appw.jp\/2014\/files\/2014\/07\/Screenshot_2014-07-31-10-38-0201-300x300.png\" alt=\"Screenshot_2014-07-31-10-38-02~01\" width=\"300\" height=\"300\" class=\"aligncenter size-medium wp-image-98\" srcset=\"https:\/\/appw.jp\/2014\/files\/2014\/07\/Screenshot_2014-07-31-10-38-0201-300x300.png 300w, https:\/\/appw.jp\/2014\/files\/2014\/07\/Screenshot_2014-07-31-10-38-0201-150x150.png 150w, https:\/\/appw.jp\/2014\/files\/2014\/07\/Screenshot_2014-07-31-10-38-0201.png 640w\" sizes=\"auto, (max-width: 300px) 100vw, 300px\" \/><\/a><\/p>\n<div class=\"float-clear\">&nbsp;<\/div>\n","protected":false},"excerpt":{"rendered":"<p>\u300cMosquitto \u306e SSL \u5bfe\u5fdc\u3092\u8a66\u3057\u3066\u307f\u308b\u300d\u3067 SSL \u5bfe\u5fdc\u3057\u307e\u3057\u305f\u3002\u305d\u3053\u3067\u4f5c\u6210\u3057\u305f\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u7528\u306e\u30ad\u30fc\u3068\u8a3c\u660e\u66f8\u3092\u4f7f\u7528\u3057\u3066\u3001\u4eca\u56de\u306f\u3001\u30af\u30e9\u30a4\u30a2\u30f3\u30c8\u304b\u3089\u306e\u63a5\u7d9a\u3092\u8a66\u307f\u307e\u3059\u3002 \u3053\u308c\u307e\u3067\u306b\u3044\u304f\u3064\u304b Python \u3067 MQT [&hellip;]<\/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-96","post","type-post","status-publish","format-standard","hentry","category-vps"],"_links":{"self":[{"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/posts\/96","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=96"}],"version-history":[{"count":3,"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/posts\/96\/revisions"}],"predecessor-version":[{"id":138,"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=\/wp\/v2\/posts\/96\/revisions\/138"}],"wp:attachment":[{"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=%2Fwp%2Fv2%2Fmedia&parent=96"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=%2Fwp%2Fv2%2Fcategories&post=96"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/appw.jp\/2014\/index.php?rest_route=%2Fwp%2Fv2%2Ftags&post=96"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}