[root@fgedu101 ~]# cat > /memcached/app/scripts/product_cache_optimize.py << 'EOF'
> #!/usr/bin/env python3
> # product_cache_optimize.py
> # from:www.itpux.com.qq113257174.wx:itpux-com
> # web: http://www.fgedu.net.cn
>
> import memcache
> import json
>
> class ProductCacheOptimizer:
> def __init__(self, servers=[‘192.168.1.101:11211’]):
> self.mc = memcache.Client(servers, debug=0)
> self.page_size = 50 # 每页50条
>
> def set_product_list(self, category_id, products):
> “””分页存储商品列表，避免大Key”””
> total = len(products)
> page_count = (total + self.page_size – 1) // self.page_size
>
> # 存储元数据
> meta = {
> ‘category_id’: category_id,
> ‘total’: total,
> ‘page_count’: page_count,
> ‘page_size’: self.page_size
> }
> self.mc.set(f”fgedu:product:meta:{category_id}”, meta, time=3600)
>
> # 分页存储
> for page in range(page_count):
> start = page * self.page_size
> end = min((page + 1) * self.page_size, total)
> page_products = products[start:end]
> self.mc.set(f”fgedu:product:page:{category_id}:{page}”, page_products, time=3600)
>
> print(f”商品列表分页存储完成: category_id={category_id}, 总数={total}, 页数={page_count}”)
>
> def get_product_list(self, category_id, page=0):
> “””获取指定页的商品列表”””
> meta = self.mc.get(f”fgedu:product:meta:{category_id}”)
> if not meta:
> return None
>
> page_data = self.mc.get(f”fgedu:product:page:{category_id}:{page}”)
> return {
> ‘total’: meta[‘total’],
> ‘page’: page,
> ‘page_size’: meta[‘page_size’],
> ‘products’: page_data
> }
>
> def set_product_detail(self, product_id, detail):
> “””存储商品详情，使用压缩”””
> import gzip
> import base64
>
> detail_str = json.dumps(detail)
> detail_bytes = detail_str.encode(‘utf-8’)
>
> if len(detail_bytes) > 10240: # 大于10KB压缩
> compressed = gzip.compress(detail_bytes)
> data = {
> ‘compressed’: True,
> ‘data’: base64.b64encode(compressed).decode(‘utf-8’)
> }
> print(f”商品详情压缩存储: product_id={product_id}, 原始={len(detail_bytes)}B, 压缩后={len(compressed)}B”)
> else:
> data = detail
>
> self.mc.set(f”fgedu:product:detail:{product_id}”, data, time=3600)
>
> def get_product_detail(self, product_id):
> “””获取商品详情”””
> import gzip
> import base64
>
> data = self.mc.get(f”fgedu:product:detail:{product_id}”)
> if not data:
> return None
>
> if isinstance(data, dict) and data.get(‘compressed’):
> compressed = base64.b64decode(data[‘data’])
> detail_bytes = gzip.decompress(compressed)
> return json.loads(detail_bytes.decode(‘utf-8’))
> return data
>
> if __name__ == “__main__”:
> optimizer = ProductCacheOptimizer()
>
> # 测试商品列表分页存储
> products = [{“id”: i, “name”: f”商品{i}”, “price”: i * 10} for i in range(500)]
> optimizer.set_product_list(1001, products)
>
> # 获取第一页数据
> result = optimizer.get_product_list(1001, page=0)
> print(f”获取第1页数据，商品数: {len(result[‘products’])}”)
>
> # 测试商品详情压缩存储
> detail = {
> “id”: 10001,
> “name”: “测试商品”,
> “description”: “x” * 50000, # 大文本
> “specs”: {“color”: “red”, “size”: “L”}
> }
> optimizer.set_product_detail(10001, detail)
> result = optimizer.get_product_detail(10001)
> print(f”获取商品详情成功: {result[‘name’]}”)
> EOF

[root@fgedu101 ~]# chmod +x /memcached/app/scripts/product_cache_optimize.py