RedisJSON模块详解

# 设置一个JSON文档
JSON.SET user:1 $ '{"name":"Alice","age":30,"address":{"city":"New York","country":"USA"},"hobbies":["reading","swimming"]}'

# 获取整个JSON文档
JSON.GET user:1

# 获取特定字段
JSON.GET user:1 $.name

# 获取嵌套字段
JSON.GET user:1 $.address.city

# 获取数组元素
JSON.GET user:1 $.hobbies[0]

# 更新特定字段
JSON.SET user:1 $.age '31'

# 删除字段
JSON.DEL user:1 $.address.country

# 获取字段类型
JSON.TYPE user:1 $.name

# 根元素
$

# 子元素
$.name

# 嵌套子元素
$.address.city

# 数组所有元素
$.hobbies[*]

# 数组特定元素
$.hobbies[0]

# 过滤器（获取年龄大于30的用户）
$[?(@.age > 30)]

# 递归搜索（查找所有price属性）
$..price

# 多个路径（同时获取name和age）
$.name, $.age

操作类型         | RedisJSON (ops/sec) | 字符串方式 (ops/sec) | 性能提升
----------------|---------------------|---------------------|---------
完整文档读取    | 120,000             | 100,000             | 1.2x
完整文档写入    | 80,000              | 60,000              | 1.3x
部分字段读取    | 150,000             | 30,000              | 5.0x
部分字段更新    | 100,000             | 10,000              | 10.0x
嵌套查询        | 90,000              | 5,000               | 18.0x

# 存储用户配置文件
JSON.SET user:1001 $ '{
  "id": 1001,
  "name": "张三",
  "email": "zhangsan@example.com",
  "preferences": {
    "language": "zh-CN",
    "theme": "dark",
    "notifications": {
      "email": true,
      "sms": false
    }
  },
  "permissions": ["read", "write"],
  "lastLogin": "2023-05-15T10:30:00Z"
}'

# 更新用户偏好设置
JSON.SET user:1001 $.preferences.theme '"light"'

# 添加新权限
JSON.ARRAPPEND user:1001 $.permissions '"admin"'

# 获取用户通知设置
JSON.GET user:1001 $.preferences.notifications

# 存储产品信息
JSON.SET product:2001 $ '{
  "id": 2001,
  "name": "智能手机",
  "category": "电子产品",
  "price": 2999,
  "specs": {
    "screen": "6.5英寸",
    "memory": "8GB",
    "storage": "128GB"
  },
  "inventory": {
    "total": 100,
    "available": 85
  },
  "tags": ["新品", "热卖"]
}'

# 更新库存
JSON.SET product:2001 $.inventory.available '80'

# 增加价格
JSON.NUMINCRBY product:2001 $.price -200

# 查询特定规格
JSON.GET product:2001 $.specs.screen

# 存储事件数据
JSON.SET event:analytics:001 $ '{
  "eventId": "001",
  "timestamp": "2023-05-15T10:30:00Z",
  "userId": 1001,
  "action": "purchase",
  "details": {
    "productId": 2001,
    "quantity": 1,
    "price": 2999
  },
  "metadata": {
    "source": "web",
    "campaign": "summer_sale"
  }
}'

# 查询特定用户的所有购买事件
JSON.GET event:analytics:* $[?(@.userId == 1001 && @.action == "purchase")]

# 更新事件元数据
JSON.SET event:analytics:001 $.metadata.campaign '"flash_sale"'

# 存储应用配置
JSON.SET config:app $ '{
  "version": "1.0.0",
  "database": {
    "host": "localhost",
    "port": 5432,
    "poolSize": 10
  },
  "cache": {
    "enabled": true,
    "ttl": 3600
  },
  "features": {
    "newUI": true,
    "betaFeatures": false
  }
}'

# 更新数据库配置
JSON.SET config:app $.database.host '"db.example.com"'

# 启用测试功能
JSON.SET config:app $.features.betaFeatures 'true'

# 获取缓存配置
JSON.GET config:app $.cache

# 存储传感器数据
JSON.SET sensor:device:001 $ '{
  "deviceId": "001",
  "timestamp": "2023-05-15T10:30:00Z",
  "location": {
    "building": "A",
    "floor": 3,
    "room": "305"
  },
  "readings": {
    "temperature": 23.5,
    "humidity": 45,
    "pressure": 1013
  },
  "status": "active"
}'

# 更新传感器读数
JSON.SET sensor:device:001 $.readings.temperature '24.0'

# 查询特定建筑的所有设备
JSON.GET sensor:device:* $[?(@.location.building == "A")]

# 拉取Redis Stack镜像
docker pull redis/redis-stack-server:latest

# 运行Redis Stack容器
docker run -d --name redis-stack -p 6379:6379 redis/redis-stack-server:latest

# 下载RedisJSON模块
wget https://github.com/RedisJSON/RedisJSON/releases/download/v2.6.0/ReJSON-2.6.0-linux-x64.zip
unzip ReJSON-2.6.0-linux-x64.zip

# 启动Redis并加载模块
redis-server --loadmodule /path/to/rejson.so

# 连接到Redis
redis-cli

# 设置JSON值
127.0.0.1:6379> JSON.SET user:1 $ '{"name":"Alice","age":30}'

# 获取JSON值
127.0.0.1:6379> JSON.GET user:1
"{\"name\":\"Alice\",\"age\":30}"

# 获取特定字段
127.0.0.1:6379> JSON.GET user:1 $.name
"\"Alice\""

# 更新字段
127.0.0.1:6379> JSON.SET user:1 $.age '31'
OK

# 安装Redis Python客户端
pip install redis

# 使用示例
import redis
import json

# 连接到Redis
r = redis.Redis(host='localhost', port=6379, db=0)

# 设置JSON值
user_data = {
    "name": "Alice",
    "age": 30,
    "address": {
        "city": "New York",
        "country": "USA"
    }
}
r.execute_command('JSON.SET', 'user:1', '.', json.dumps(user_data))

# 获取JSON值
result = r.execute_command('JSON.GET', 'user:1')
print(json.loads(result))

# 获取特定字段
name = r.execute_command('JSON.GET', 'user:1', '$.name')
print(json.loads(name)[0])  # 输出: Alice

# 更新字段
r.execute_command('JSON.SET', 'user:1', '$.age', '31')

// 安装Redis Node.js客户端
npm install redis

// 使用示例
const { createClient } = require('redis');

async function main() {
  // 连接到Redis
  const client = createClient();
  await client.connect();
  
  // 设置JSON值
  const userData = {
    name: "Alice",
    age: 30,
    address: {
      city: "New York",
      country: "USA"
    }
  };
  await client.sendCommand(['JSON.SET', 'user:1', '.', JSON.stringify(userData)]);
  
  // 获取JSON值
  const result = await client.sendCommand(['JSON.GET', 'user:1']);
  console.log(JSON.parse(result));
  
  // 获取特定字段
  const name = await client.sendCommand(['JSON.GET', 'user:1', '$.name']);
  console.log(JSON.parse(name)[0]);  // 输出: Alice
  
  // 更新字段
  await client.sendCommand(['JSON.SET', 'user:1', '$.age', '31']);
  
  // 关闭连接
  await client.quit();
}

main().catch(console.error);