Tornado 自定义session，与一致性哈希 ，基于redis 构建分布式 session

        import tornado.ioloop

	import tornado.web

	from myhash import ring

	create_session_id = 'sasd' # 随机生成的 session 函数

	class SessionGen(object):

		container = {}

		def __init__(self,handler):

			self.handler = handler

			random_str = self.handler.get_cookie('session_id')

			if not random_str:

				random_str = create_session_id   # 生成session随机字符串

			else:

				if random_str not in self.container:  # 伪造的session随机字符串

					random_str = create_session_id

					self.container[random_str]={}  # session 字典

			self.random_str = random_str

			self.handler.set_cookie('session_id',random_str,max_age=10)

		def __setitem__(self, key, value):

			# 基于redis 分布式 设置 session

			# import redis

			# result = ring.get_node('ascf')  # 获取分布式 分配的 ip端口  ；split

			# conn = redis.Redis(host='ip',port=232)

			# conn.hset('ascf',key,value)

			self.container[self.random_str][key] = value

		def __getitem__(self, item):

			# 基于redis 分布式 获取 session

			# import redis

			# result = ring.get_node('ascf')  # 获取分布式 分配的 ip端口  ；split

			# conn = redis.Redis(host='ip',port=port)

			# return conn.hget('ascf',item)

			return self.container[self.random_str].get(item)

		def __delitem__(self, key):

			if self.container[self.random_str].get(key):

				del self.container[self.random_str][key]

			# 基于redis 分布式 删除 session

			# import redis

			# ip,port = ring.get_node('ascf').split(':')  # 获取分布式 分配的 ip端口  ；split

			# conn = redis.Redis(host='ip',port=232)

			# conn.hdel('ascf',key)

	class LoginHandler(tornado.web.RequestHandler):

		def initialize(self):

			self.session = SessionGen(self)

		def get(self):

			self.render('login.html',msg='')  # 渲染template

		def post(self):

			username = self.get_argument('username')

			pwd = self.get_argument('pwd')

			if username == 'root' and  pwd == '123':

				self.set_cookie('user',username)

				self.session['user'] = username

				self.redirect('/index')

				return

			self.render('login.html',**{'msg':'用户密码有误'})

	class IndexHandler(tornado.web.RequestHandler):

		def initialize(self):

			self.session = SessionGen(self)

		def get(self):

			if self.session['user']:

				self.write('ojbk')

	settings = {

			'template_path':'templates',

			'static_path':'static',

			'static_url_prefix':'/static/',   # 静态文件 url

			# 'xsrf_cookies':True,   # csrf 

	}

	# 配置模板文件路径

	application = tornado.web.Application([

		(r"/login",LoginHandler),

		(r"/index",IndexHandler),

		],**settings  # 配置文件

		)

	if __name__ == '__main__':

		# 创建socket对象

		application.listen(8000)

		# conn,add = socket.accept()

		tornado.ioloop.IOLoop.instance().start()