tornadoはredisを使用してセッション分散ストレージを実現する
前言:
tornadoをc 10に近づける能力を提供するためには、tornadoがあまり得意ではない静的ファイルをnginxで処理し、マルチappスキームで負荷能力を向上させるしかない.
私は怠け者で、インタフェースとプラットフォームのページをpyにして、upstreamで負荷を作るのはよくありません.もしあなたがip_を使うならば.hash、あるいはinsertクッキーの方式は、バックエンドサーバに対するヒットを保証しているが、兄はまだヒットしたくない.
私はまだrr輪訓を考えています.どうしてですか.ページに大量の時間を費やすioと計算要求のため、この時私はいつも1台のサーバーに命中してスケジューリングして、それでは私はずっと待っていて、後ろにはまだたくさんの任務が同期して詰まっています.の痛快すぎて、この時rr輪訓が必要で、sessionがどのように一致しているか、この時はsession cookieの記憶を保証するために迅速な記憶が必要です.
アラームプラットフォームではredis、mongodbなどのnosqlデータベースが使用されているため、memcachedを構成する必要はありません.今度は私の大好きなredisを使いました.
関連するクラスとライブラリ、login_をインポートしました.requiredは装飾器で、ユーザーがログインしたかどうかを判断するために、なければアクセスをloginに投げます.htmlページ.
関連付けられた2つのクラス:
セッションのファイルを処理します!
tornado各コントローラ関連class~
ログイン登録セッションの場合:
ログインを終了するには、次の手順に従います.
実はNoneに変えればいいのですが、マッチングは装飾器のほうでできました.
原文:http://rfyiamcool.blog.51cto.com/1030776/1406378
私、これでいいです.前に関連するコンポーネントを構成します!
pip install ujson redis
pip install tornado
session.pyコード:
この外国人は少し粗末で、説明はほとんどありませんが、tornado redis session自体は難しくないもので、見てみればできます.
単一tornado私は今すでに1500個の長い接続まで崩壊しないことができて、もしngixnを加えてtornadoの配布負荷をするならば、接続は6 kで問題がないと推定します.すべての業務にアクセスするメール転送の問題も大きくなく、メールゲートウェイに問題があると推定されています.
本文は「峰雲、彼女だけだ」から出た.ブログ、転載お断り!
tornadoをc 10に近づける能力を提供するためには、tornadoがあまり得意ではない静的ファイルをnginxで処理し、マルチappスキームで負荷能力を向上させるしかない.
私は怠け者で、インタフェースとプラットフォームのページをpyにして、upstreamで負荷を作るのはよくありません.もしあなたがip_を使うならば.hash、あるいはinsertクッキーの方式は、バックエンドサーバに対するヒットを保証しているが、兄はまだヒットしたくない.
私はまだrr輪訓を考えています.どうしてですか.ページに大量の時間を費やすioと計算要求のため、この時私はいつも1台のサーバーに命中してスケジューリングして、それでは私はずっと待っていて、後ろにはまだたくさんの任務が同期して詰まっています.の痛快すぎて、この時rr輪訓が必要で、sessionがどのように一致しているか、この時はsession cookieの記憶を保証するために迅速な記憶が必要です.
アラームプラットフォームではredis、mongodbなどのnosqlデータベースが使用されているため、memcachedを構成する必要はありません.今度は私の大好きなredisを使いました.
関連するクラスとライブラリ、login_をインポートしました.requiredは装飾器で、ユーザーがログインしたかどうかを判断するために、なければアクセスをloginに投げます.htmlページ.
#xiaorui.cc
from base import BaseHandler
from tornado.web import HTTPError
def login_required(f):
def _wrapper(self,*args, **kwargs):
print self.get_current_user()
logged = self.get_current_user()
if logged == None:
self.write('no login')
self.finish()
else:
ret = f(self,*args, **kwargs)
return _wrapper
class Application(tornado.web.Application):
def __init__(self):
settings = dict(
cookie_secret = "e446976943b4e8442f099fed1f3fea28462d5832f483a0ed9a3d5d3859f==78d",
session_secret = "3cdcb1f00803b6e78ab50b466a40b9977db396840c28307f428b25e2277f1bcc",
session_timeout = 60,
store_options = {
'redis_host': 'localhost',
'redis_port': 6379,
'redis_pass': '',
},
)
handlers = [
(r"/", MainHandler),
(r"", MainHandler),
(r"/login", LoginHandler)
]
tornado.web.Application.__init__(self, handlers, **settings)
self.session_manager = session.SessionManager(settings["session_secret"], settings["store_options"], settings["session_timeout"])関連付けられた2つのクラス:
class MainHandler(BaseHandler):
@login_required
def get(self):
username = self.get_current_user()
print 'start..'
print username
print self.session['nima']
if username==None:
self.write('nima')
else:
self.write("What's up, " + username + "?")
class LoginHandler(BaseHandler):
def get(self):
self.session["user_name"] = self.get_argument("name")
self.session["nima"] = 'xiaorui.cc'
self.session.save()
self.write(' session ')セッションのファイルを処理します!
#/usr/bin/python
# coding: utf-8
import uuid
import hmac
import ujson
import hashlib
import redis
class SessionData(dict):
def __init__(self, session_id, hmac_key):
self.session_id = session_id
self.hmac_key = hmac_key
# @property
# def sid(self):
# return self.session_id
# @x.setter
# def sid(self, value):
# self.session_id = value
class Session(SessionData):
def __init__(self, session_manager, request_handler):
self.session_manager = session_manager
self.request_handler = request_handler
try:
current_session = session_manager.get(request_handler)
except InvalidSessionException:
current_session = session_manager.get()
for key, data in current_session.iteritems():
self[key] = data
self.session_id = current_session.session_id
self.hmac_key = current_session.hmac_key
def save(self):
self.session_manager.set(self.request_handler, self)
class SessionManager(object):
def __init__(self, secret, store_options, session_timeout):
self.secret = secret
self.session_timeout = session_timeout
try:
if store_options['redis_pass']:
self.redis = redis.StrictRedis(host=store_options['redis_host'], port=store_options['redis_port'], password=store_options['redis_pass'])
else:
self.redis = redis.StrictRedis(host=store_options['redis_host'], port=store_options['redis_port'])
except Exception as e:
print e
def _fetch(self, session_id):
try:
session_data = raw_data = self.redis.get(session_id)
if raw_data != None:
self.redis.setex(session_id, self.session_timeout, raw_data)
session_data = ujson.loads(raw_data)
if type(session_data) == type({}):
return session_data
else:
return {}
except IOError:
return {}
def get(self, request_handler = None):
if (request_handler == None):
session_id = None
hmac_key = None
else:
session_id = request_handler.get_secure_cookie("session_id")
hmac_key = request_handler.get_secure_cookie("verification")
if session_id == None:
session_exists = False
session_id = self._generate_id()
hmac_key = self._generate_hmac(session_id)
else:
session_exists = True
check_hmac = self._generate_hmac(session_id)
if hmac_key != check_hmac:
raise InvalidSessionException()
session = SessionData(session_id, hmac_key)
if session_exists:
session_data = self._fetch(session_id)
for key, data in session_data.iteritems():
session[key] = data
return session
def set(self, request_handler, session):
request_handler.set_secure_cookie("session_id", session.session_id)
request_handler.set_secure_cookie("verification", session.hmac_key)
session_data = ujson.dumps(dict(session.items()))
self.redis.setex(session.session_id, self.session_timeout, session_data)
def _generate_id(self):
new_id = hashlib.sha256(self.secret + str(uuid.uuid4()))
return new_id.hexdigest()
def _generate_hmac(self, session_id):
return hmac.new(session_id, self.secret, hashlib.sha256).hexdigest()
class InvalidSessionException(Exception):
passtornado各コントローラ関連class~
import tornado.web
import sys
import session
class BaseHandler(tornado.web.RequestHandler):
def __init__(self, *argc, **argkw):
super(BaseHandler, self).__init__(*argc, **argkw)
self.session = session.Session(self.application.session_manager, self)
def get_current_user(self):
return self.session.get("user_name")ログイン登録セッションの場合:
self.session["user_name"] = self.get_argument("name")
self.session["nima"] = 'xiaorui.cc'
self.session.save()ログインを終了するには、次の手順に従います.
self.session["nima"] =None
self.session.save()実はNoneに変えればいいのですが、マッチングは装飾器のほうでできました.
原文:http://rfyiamcool.blog.51cto.com/1030776/1406378
私、これでいいです.前に関連するコンポーネントを構成します!
pip install ujson redis
pip install tornado
session.pyコード:
git clone https://github.com/zs1621/tornado-redis-sessionこの外国人は少し粗末で、説明はほとんどありませんが、tornado redis session自体は難しくないもので、見てみればできます.
単一tornado私は今すでに1500個の長い接続まで崩壊しないことができて、もしngixnを加えてtornadoの配布負荷をするならば、接続は6 kで問題がないと推定します.すべての業務にアクセスするメール転送の問題も大きくなく、メールゲートウェイに問題があると推定されています.
本文は「峰雲、彼女だけだ」から出た.ブログ、転載お断り!