使用Redis实现购物车后端处理

本文中心思想：实现购物车的后端处理逻辑。

本文将教会你掌握：1．存储商品信息，2．存储购物车信息，3．获取购物车信息。

存储商品信息

商品包含多个属性，例如：名字，价格，描述等等。使用哈希能够将商品的所有信息存储在一个键 item:*:info，其中 * 是商品 ID，例如，商品 ID 为 1 的哈希键 item:1:info 中的内容为：

{
"name": "儿童棉马甲加厚",
"price": 14.9
}

我们可以使用 hmset() 方法一次性存入商品信息：

item_info_key = 'item:' + str(item_id) + ':info'
conn.hmset(item_info_key, {"name": "儿童棉马甲加厚", "price": 14.9})

同时，商品并不是永久存在的，是有有效期的，在到达有效期后应该从 Redis 中删除，避免用户继续购买或者加入到购物车中。

由于一个商品的全部信息都存储在同一个键中，所以我们可以使用键的过期时间来设置商品信息哈希键 item:*:info 在指定的时间后过期：

conn.expire(item_info_key, 30 * 24 * 60 * 60)

上述例子中，我们设置商品信息在 30 天后过期。

将这些过程写入方法 add_item() 中：

def add_item(name, price):
item_id = conn.incr('item_id') #设置item_id键自增
item_info_key = 'item:' + item_id + ':info'
conn.hmset(item_info_key, {"name": name, "price": price})
conn.expire(item_info_key, 30 * 24 * 60 * 60)

存储购物车信息

购物车的定义十分简单，我们可以将每个用户的购物车都看作是一个哈希，这个哈希存储着商品 ID 与加入购物车的数量之间的映射关系，由于购物车与用户相关，所以购物车的哈希键名为 cart:*，其中*是用户ID。

在本关卡中，我们只处理商品加入/移出购物车时对购物车进行更新：

• 当用户将某件商品加入到购物车时
  • 应该将该商品 ID 和加入购物车的数量添加到哈希中
  • 如果购物车中已有该商品，则应该根据新的数量更新哈希
• 如果用户将某件商品移出购物车时
  • 应该从哈希中删除该商品 ID 对应的域

通过上述规则，可以将加入和移出购物车合并编写一个方法：

def add_to_cart(user_id, item, count):
if count > 0:
conn.hset('cart:' + user_id, item, count)
else:
conn.hrem('cart:' + user_id, item)

获取购物车信息

实现了更新购物车的方法，但还需要一个方法来展示用户当前购物车中有什么商品，我们可以直接使用 hgetall() 方法获取到 cart:*（其中*为用户ID）键中所有域-值对：

def get_cart_info(user_id):
return conn.hgetall('cart:' + user_id)

最后我们将整个哈希返回，以便后续处理。

代码007普通

打赏 收藏 海报 链接