安装 ：pip install redis
#coding=utf-8
#导入
import redis
#隐式链接
r = redis.StrictRedis()
#显式链接
# r = redis.StrictRedis(host='127.0.0.1',port=6379,db=0)
#get 和set设置
r.set('color','red')
r.get('color')
#HMSET 和 HGETALL 使用
r.hmset('dict',{'name':'anaf'})
people = r.hgetall('dict')
print people #显示出字典{'name':'anaf'}
#管道的使用方式和事务相同，但是创建的时候需要加上参数transaction=False
pipe = r.pipeline(transaction=False)
#事务和管道还支持链式调用
result = r.pipeline().set('color','red'),.get('color').execute()
在线好友
online_user.py
#coding=utf-8
'''
实现在线用户的统计 源自http://flask.pocoo.org/snippets/71/
只是显示了统计ip 并没有显示个数 还没有count个数
time：2017-06-19
author：anaf
'''
from app import redis_store
from datetime import datetime
import time
from flask import current_app
def mark_online(user_id):
now = int(time.time())
expires = now + (current_app.config['ONLINE_LAST_MINUTES'] * 60) + 10
all_users_key = 'online-users/%d' % (now // 60)
user_key = 'user-activity/%s' % user_id
p = redis_store.pipeline()
p.sadd(all_users_key, user_id)
p.set(user_key, now)
p.expireat(all_users_key, expires)
p.expireat(user_key, expires)
p.execute()
def get_user_last_activity(user_id):
last_active = redis_store.get('user-activity/%s' % user_id)
if last_active is None:
return None
return datetime.utcfromtimestamp(int(last_active))
def get_online_users():
current = int(time.time()) // 60
minutes = xrange(current_app.config['ONLINE_LAST_MINUTES'])
return redis_store.sunion(['online-users/%d' % (current - x) for x in minutes])
main.py
@main.route('/online')
def online():
return Response('Online: %s' % ', '.join(get_online_users()),mimetype='text/plain')
效果：Online: 192.168.2.17, 127.0.0.1
