django连接redis(文章看着不错)

快来打我* 2023-10-06 11:37 36阅读 0赞

1、首先安装redis，ubuntu下执行以下命令

sudo apt-get install redis-server

2、安装redis库

pip install django-redis

3、配置django中的settings

caches=\{

‘default’：\{

‘backend’：‘redis\_caches.cache.RedisCache’,

'location':127.0.0.1:9999 \#redis服务ip和端口，

‘option’：\{

'client\_class':'redis\_cache.client.DefaultClient',

\},

`REDIS_TIMEOUT``=``7``*``24``*``60``*``60`

`CUBES_REDIS_TIMEOUT``=``60``*``60`

`NEVER_REDIS_TIMEOUT``=``365``*``24``*``60``*``60`

\#其实只是需要CACHES中的那几条就可以了，后面这三句可以不需要的，只是我后面的例子里需要用到，我就在这里配置了。

3、进行读写操作

from django.conf import settings

from django.core.cache import cache

\#read cahce user\_id

def read\_from\_cache(self,username)

key='user\_id\_of'+username

value=cache.get(key)

if value==none:

data=none

else:

date=json.loads(value)

return data

\#write cahche

def write\_to\_cache(self,username)

key='user\_id\_of'+username

cache.set(key,json.dumps(username),settint.NEVER\_REDIS\_TIMEOUT)

4、

通过上面的这两个方法就可以实现对redis的读取操作了，只需要将需要的字段当参数传入到方法中就好了。

那么之前提到的memcached呢？其实也是一样的配置：

<table> 
 <tbody> 
  <tr> 
   <td> <p><code>CACHES&nbsp;</code><code>=</code>&nbsp;<code>{ </code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>'default'</code><code>:&nbsp;{ </code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>'BACKEND'</code><code>:&nbsp;</code><code>'django.core.cache.backends.memcached.MemcachedCache'</code><code>,</code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>'LOCATION'</code><code>:&nbsp;</code><code>'127.0.0.1:11211'</code><code>,</code></p> <p><code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code></p> <p><code>}</code></p> </td> 
  </tr> 
 </tbody> 
</table>

当然用法也是和我上面的例子是一样的了。其实对于redis这样的缓存服务器来说，配置都是很简单的，而具体的使用也不难，官网上面也有很多简单明了的例子可以供我们参考，只有一点需要注意的，那就是对于要将什么样的信息保存到redis才是我们真正需要关心的。

5、使用缓存redis开发博客系统

## [Django开发博客系统redis缓存][Django_redis] ##

Redis 是一个高性能的key-value数据库。redis的出现， 很大程度补偿了memcached这类keyvalue存储的不足，在部分场合可以对关系数据库起到很好的补充作用。 它提供了Python，Ruby，Erlang，PHP客户端，使用很方便。

目前Redis已经发布了3.0版本，正式支持分布式，这个特性太强大，以至于你再不用就对不住自己了。

#### 性能测试 ####

服务器配置：Linux 2.6, Xeon X3320 2.5Ghz

SET操作每秒钟110000次，GET操作每秒钟81000次

stackoverflow网站使用Redis做为缓存服务器。

#### 安装redis ####

服务器安装篇我写了专门文章， 请参阅[redis入门与安装][redis]

#### django中的配置 ####

我们希望在本博客系统中，对于文章点击数、阅览数等数据实现缓存，提高效率。

requirements.txt

添加如下内容，方便以后安装软件依赖，由于在pythonanywhere上面并不能安装redis服务，所以本章只能在本地测试。

<table> 
 <tbody> 
  <tr> 
   <td> <pre>redis==2.10.5
django-redis==4.4.2
APScheduler==3.1.0
</pre> </td> 
  </tr> 
 </tbody> 
</table>

settings.py配置

新增内容

<table> 
 <tbody> 
  <tr> 
   <td> <pre>1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
</pre> </td> 
   <td> <pre>from urllib.parse import urlparse
import dj_database_url

redis_url = urlparse(os.environ.get('REDISTOGO_URL', 'redis://localhost:6959'))
CACHES = {
    'default': {
        'BACKEND': 'redis_cache.cache.RedisCache',
        'LOCATION': '{0}:{1}'.format(redis_url.hostname, redis_url.port),
        'OPTIONS': {
            'DB': 0,
            'PASSWORD': redis_url.password,
            'CLIENT_CLASS': 'redis_cache.client.DefaultClient',
            'PICKLE_VERSION': -1,  # Use the latest protocol version
            'SOCKET_TIMEOUT': 60,  # in seconds
            'IGNORE_EXCEPTIONS': True,
        }
    }
}

SESSION_ENGINE = 'django.contrib.sessions.backends.cache'
SESSION_CACHE_ALIAS = 'default'

# 本地开发配置放在local_settings.py中
try:
    from .local_settings import *
except ImportError:
    pass
</pre> </td> 
  </tr> 
 </tbody> 
</table>

local\_settings.py配置

这个是本地开发时候使用到的配置文件

<table> 
 <tbody> 
  <tr> 
   <td> <pre>1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
</pre> </td> 
   <td> <pre>DEBUG = True

CACHES = {
    'default': {
        'BACKEND': 'redis_cache.cache.RedisCache',
        'LOCATION': '192.168.203.95:6379:1',
        'OPTIONS': {
            'CLIENT_CLASS': 'redis_cache.client.DefaultClient',
            # 'PASSWORD': 'secretpassword',
            'PICKLE_VERSION': -1,  # Use the latest protocol version
            'SOCKET_TIMEOUT': 60,  # in seconds
            'IGNORE_EXCEPTIONS': True,
        }
    }
}
</pre> </td> 
  </tr> 
 </tbody> 
</table>

#### 使用方法 ####

cache\_manager.py缓存管理器

我们新建一个缓存管理器cache\_manager.py，内容如下

<table> 
 <tbody> 
  <tr> 
   <td> <pre>1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
</pre> </td> 
   <td> <pre>#!/usr/bin/env python
# -*- encoding: utf-8 -*-
"""
Topic: redis缓存管理器
"""
from ..models import Post
from redis_cache import get_redis_connection
from apscheduler.schedulers.background import BackgroundScheduler

RUNNING_TIMER = False
REDIS_DB = get_redis_connection('default')

def update_click(post):
    """ 更新点击数 """
    if REDIS_DB.hexists("CLICKS", post.id):
        print('REDIS_DB.hexists...' + str(post.id))
        REDIS_DB.hincrby('CLICKS', post.id)
    else:
        print('REDIS_DB.not_hexists...' + str(post.id))
        REDIS_DB.hset('CLICKS', post.id, post.click + 1)
    run_timer()

def get_click(post):
    """ 获取点击数 """
    if REDIS_DB.hexists("CLICKS", post.id):
        return REDIS_DB.hget('CLICKS', post.id)
    else:
        REDIS_DB.hset('CLICKS', post.id, post.click)
        return post.click

def sync_click():
    """同步文章点击数"""
    print('同步文章点击数start....')
    for k in REDIS_DB.hkeys('CLICKS'):
        try:
            p = Post.objects.get(k)
            print('db_click={0}'.format(p.click))
            cache_click = get_click(p.id)
            print('cache_click={0}'.format(cache_click))
            if cache_click != p.click:
                p.click = get_click(p.id)
                p.save()
        except:
            pass
</pre> </td> 
  </tr> 
 </tbody> 
</table>

views.py修改

然后我们修改view.py，在相应的action里使用这个cache\_manager：

<table> 
 <tbody> 
  <tr> 
   <td> <pre>1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
</pre> </td> 
   <td> <pre>from .commons import cache_manager

def post_list(request):
    """所有已发布文章"""
    posts = Post.objects.annotate(num_comment=Count('comment')).filter(
        published_date__isnull=False).prefetch_related(
        'category').prefetch_related('tags').order_by('-published_date')
    for p in posts:
        p.click = cache_manager.get_click(p)
    return render(request, 'blog/post_list.html', {'posts': posts})

def post_detail(request, pk):
    try:
        pass
    except:
        raise Http404()
    if post.published_date:
        cache_manager.update_click(post)
        post.click = cache_manager.get_click(post)</pre> <p>&nbsp;</p> </td> 
  </tr> 
 </tbody> 
</table>

来源:[https://www.cnblogs.com/lcosima/p/7061666.html][https_www.cnblogs.com_lcosima_p_7061666.html]

[Django_redis]: http://www.cnblogs.com/kuihua/p/5577323.html
[redis]: http://www.pycoding.com/2015/07/01/java/redis01.html
[https_www.cnblogs.com_lcosima_p_7061666.html]: https://www.cnblogs.com/lcosima/p/7061666.html