概述
- 首先我们通过hiredis 向redis 中写入了数据，这里我们主要以测试为目的，所以，Key 值设定为毫秒级时间戳。
- 但是当我们测试完成之后，需要验证实际情况，这里我们直接使用redis-cli 登录数据库看看。
- 本次测试完成，接下来要结合业务开始测试，需要清理数据库，但是一条一条的删除太慢了。这里给出lua 脚本，以及使用方式。
接下来为具体实际内容。
详述
通过消息队列接收数据，并向redis中存储。
使用技术栈：ZeroMQ、redis
简述：通过消息队列接收转发的消息内容，存储到缓存数据库中。
key-value： 毫秒级时间戳-消息内容
/*
* @Author : Zry && 978524088@qq.com
* @Date : 2023-07-05 15:31:34
* @LastEditors : Zry && 978524088@qq.com
* @LastEditTime : 2023-07-05 15:46:04
* @FilePath : /zryTest/src/include/redis/redis_zmq/receiver.c
* @Description :
*
* Copyright (c) 2023 by 978524088@qq.com, All Rights Reserved.
*/
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <time.h>
#include <zmq.h>
#include <hiredis/hiredis.h>
// 定义Redis服务器的地址和端口
#define REDIS_HOST "127.0.0.1"
#define REDIS_PORT 6379
// 定义消息的最大长度
#define MAX_MESSAGE_SIZE 1024
long long current_timestamp()
{
struct timespec ts;
clock_gettime(CLOCK_MONOTONIC, &ts);
return ts.tv_sec * 1000LL + ts.tv_nsec / 1000000LL;
}
int main()
{
// 创建zmq的上下文和socket，用于接收路由消息
void *context = zmq_ctx_new();
void *socket = zmq_socket(context, ZMQ_ROUTER);
zmq_bind(socket, "tcp://*:5566");
while (1)
{
// 接收路由消息的各个部分
zmq_msg_t identity;
zmq_msg_init(&identity);
zmq_msg_recv(&identity, socket, 0);
zmq_msg_t empty;
zmq_msg_init(&empty);
zmq_msg_recv(&empty, socket, 0);
zmq_msg_t message;
zmq_msg_init(&message);
zmq_msg_recv(&message, socket, 0);
// 获取消息内容和类型
char *content = (char *)zmq_msg_data(&message);
size_t content_size = zmq_msg_size(&message);
char *type = (char *)zmq_msg_data(&empty);
size_t type_size = zmq_msg_size(&empty);
// 获取当前时间戳
long long timestamp = current_timestamp();
// 将消息存储到Redis缓存中
redisContext *redis = redisConnect(REDIS_HOST, REDIS_PORT);
if (redis != NULL && redis->err == 0)
{
// 构造Key
char key[256];
snprintf(key, sizeof(key), "%lld:%.*s", timestamp, (int)type_size, type);
// 存储消息内容到Redis
redisReply *reply = (redisReply *)redisCommand(redis, "SET %s %b", key, content, content_size);
freeReplyObject(reply);
// 打印存储结果
printf("Stored message: %s\n", key);
// 断开与Redis服务器的连接
redisFree(redis);
}
else
{
printf("Failed to connect to Redis server\n");
}
// 释放消息
zmq_msg_close(&identity);
zmq_msg_close(&empty);
zmq_msg_close(&message);
}
// 关闭zmq的socket和上下文
zmq_close(socket);
zmq_ctx_destroy(context);
return 0;
}
通过 redis-cli 登录数据库查看具体的数据内容。
要通过Redis直接查看数据内容，你可以使用Redis的命令行工具redis-cli来连接到Redis服务器，并执行相应的命令来查看数据。
以下是一些常用的Redis命令，可以帮助你查看数据内容：
查看所有键：使用KEYS *命令可以列出所有的键。KEYS *
获取键的值：使用GET命令可以获取指定键的值。GET key
将key替换为你要查看的键的名称。
获取哈希表的字段和值：使用HGETALL命令可以获取指定哈希表的所有字段和值。HGETALL hash
将hash替换为你要查看的哈希表的名称。
获取列表的元素：使用LRANGE命令可以获取指定列表的指定范围内的元素。LRANGE list start stop
将list替换为你要查看的列表的名称，start和stop分别替换为范围的起始和结束索引。
获取集合的元素：使用SMEMBERS命令可以获取指定集合的所有元素。SMEMBERS set
将set替换为你要查看的集合的名称。
获取有序集合的元素：使用ZRANGE命令可以获取指定有序集合的指定范围内的元素。ZRANGE zset start stop
将zset替换为你要查看的有序集合的名称，start和stop分别替换为范围的起始和结束索引。
这里我使用 KEYS *查看，因为现在只有我存储的少量数据
127.0.0.1:6379> KEYS *
.......
1054) "3673007893:Hello, world!"
1055) "3673008590:"
1056) "3673009630:test"
1057) "3673010538:"
1058) "3673008562:"
1059) "3673010512:client"
1060) "3673008640:Hello, world!"
1061) "3673009571:client"
1062) "3673010513:Hello, world!"
1063) "3673006965:Hello, world!"
1064) "3673008613:Hello, world!"
1065) "3673006999:Hello, world!"
至此可以确认，数据已经从消息队列读取出，并保存到数据库中了。
使用lua 脚本 清理数据内容。
接下来，将设计具体消息内容，key 键种类、过期时间、为了数据干净，现在先要把当前存在的数据清理掉。
因为redis 我没找到直接形如 DEL * 的方式删掉全部，所以干脆通过lua 脚本 来批量删除
使用以下 的Lua脚本来批量删除键：
local keys = redis.call('KEYS', ARGV[1])
for i, key in ipairs(keys) do
redis.call('DEL', key)
end
将这个修正后的Lua脚本保存到一个文件中，例如delete_keys.lua。
然后，使用以下命令来执行Lua脚本并批量删除键：
redis-cli EVAL "$(cat delete_keys.lua)" 0 prefix:*
将prefix:*替换为实际的键的模式。
这个命令使用了Redis的EVAL命令和Lua脚本。它通过EVAL命令执行Lua脚本，并将键的模式作为参数传递给Lua脚本。Lua脚本使用KEYS命令获取匹配模式的键的列表，并使用DEL命令多次调用来删除每个键。文章来源：https://www.toymoban.com/news/detail-541232.html
请注意，使用DEL命令删除键是不可逆的操作，一旦删除就无法恢复。在执行删除操作之前，请确保你已经备份了需要保留的数据。文章来源地址https://www.toymoban.com/news/detail-541232.html
到了这里，关于【实战】使用Lua脚本怎么清理redis中的数据【实战】使用Lua脚本怎么清理redis中的数据的文章就介绍完了。如果您还想了解更多内容，请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章，希望大家以后多多支持TOY模板网！
