\u6b21\u306e\u30d7\u30ed\u30b0\u30e9\u30e0\u306f\u3001ws-chat.py \u3067\u30bb\u30fc\u30d6\u3057\u307e\u3057\u305f\u3002<\/p>\n
\r\nimport os,sys\r\nimport gevent\r\nfrom gevent import monkey; monkey.patch_all()\r\nfrom geventwebsocket.handler import WebSocketHandler\r\nfrom gevent.pywsgi import WSGIServer\r\nfrom flask import Flask, render_template, request\r\nimport time\r\nfrom datetime import datetime\r\n\r\nsys.path.append(os.path.dirname(os.path.abspath(__file__)) + '\/..\/model')\r\n\r\nfrom mchat import (ChatLog, connecter)\r\n\r\n\r\napp = Flask(__name__)\r\n\r\n\r\nparticipants = set()\r\n\r\n@app.route('\/chat')\r\ndef chat():\r\n\r\n ws = request.environ.get('wsgi.websocket')\r\n participants.add(ws)\r\n try:\r\n wlist = []\r\n posts = ChatLog.objects.order_by("-id" , "-datetime")[:5]\r\n for post in posts:\r\n wlist.append(post.text)\r\n for value in reversed(wlist):\r\n ws.send(value)\r\n while True:\r\n m = ws.receive()\r\n print "recv message %s" % m\r\n if m is None:\r\n break\r\n for p in participants:\r\n print "send message %s" % m\r\n p.send(m)\r\n now = int(time.mktime(datetime.now().timetuple()))\r\n ChatLog(text=m, user='WS', created_at=now).save()\r\n finally:\r\n participants.remove(ws)\r\n\r\n return ""\r\n\r\n@app.route('\/')\r\ndef index():\r\n return render_template('ws-chat.html')\r\n \r\nif __name__ == "__main__":\r\n connecter()\r\n server = WSGIServer(('0.0.0.0',8080), app, handler_class=WebSocketHandler)\r\n server.serve_forever()\r\n<\/pre>\n\u305d\u3057\u3066\u3001\u30c6\u30f3\u30d7\u30ec\u30fc\u30c8\u3092\u5229\u7528\u3057\u307e\u3059\u3002<\/p>\n
ws-chat.py \u3092\u30bb\u30fc\u30d6\u3057\u305f\u30c7\u30a3\u30ec\u30af\u30c8\u30ea\u306e\u76f4\u4e0b\u306b templates \u30c7\u30a3\u30ec\u30af\u30c8\u30ea\u3092\u4f5c\u6210\u3057\u3066 ws-chat.html \u3067\u30bb\u30fc\u30d6\u3057\u307e\u3057\u305f\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<script>\r\nwindow.onload = function() {\r\n var data = {};\r\n var s = new WebSocket("ws:\/\/127.0.0.1:8080\/chat");\r\n s.onopen = function() {\r\n s.send('New participant joined');\r\n };\r\n s.onmessage = function(e) {\r\n $("#out").prepend("<p>" + e.data + "<\/p>");\r\n };\r\n $('#in').keyup(function(e){\r\n if (e.keyCode == 13) {\r\n var line = $(this).val();\r\n $(this).val('');\r\n s.send(line);\r\n return false;\r\n }\r\n });\r\n};\r\n<\/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<\/div>\r\n<\/body>\r\n<\/html>\r\n<\/pre>\nMongoDB \u30a2\u30af\u30bb\u30b9\u306f\u5225\u306e\u30e2\u30b8\u30e5\u30fc\u30eb\u3067\u300cMosquitto \u306e payload \u3092 MongoDB \u306b\u4fdd\u5b58\u3057\u3066\u307f\u308b<\/a>\u300d\u3067\u4f5c\u6210\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\ndef connecter():\r\n con = connect('chattest')\r\n print con\r\n<\/pre>\n\u5b9f\u884c\u3057\u307e\u3059\u3002<\/p>\n
\r\npython ws-chat.py\r\n<\/pre>\n
![\"\"](\"http:\/\/www19.a8.net\/0.gif?a8mat=25TTDR+2BY85U+50+4ATZKY\")
\u3067\u3001CentOS 6.5 \u3067\u3059\u3002<\/p>\n![\"image\"](\"http:\/\/appw.jp\/2014\/files\/2014\/07\/wpid-wp-1404894122849.png\" "\\"wp-1404894122849\\"")
<\/a>