漫话Redis源码之一百零五

2024-02-06 09:32
文章标签 源码 redis 漫话 一百零五

本文主要是介绍漫话Redis源码之一百零五，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

fsl相关的代码，都是一些基本的操作：

void fsl_rdb_save(RedisModuleIO *rdb, void *value) {fsl_t *fsl = value;RedisModule_SaveUnsigned(rdb,fsl->length);for (long long i = 0; i < fsl->length; i++)RedisModule_SaveSigned(rdb, fsl->list[i]);
}void fsl_aofrw(RedisModuleIO *aof, RedisModuleString *key, void *value) {fsl_t *fsl = value;for (long long i = 0; i < fsl->length; i++)RedisModule_EmitAOF(aof, "FSL.PUSH","sl", key, fsl->list[i]);
}void fsl_free(void *value) {fsl_type_free(value);
}/* ========================== helper methods ======================= */int get_fsl(RedisModuleCtx *ctx, RedisModuleString *keyname, int mode, int create, fsl_t **fsl, int reply_on_failure) {RedisModuleKey *key = RedisModule_OpenKey(ctx, keyname, mode);int type = RedisModule_KeyType(key);if (type != REDISMODULE_KEYTYPE_EMPTY && RedisModule_ModuleTypeGetType(key) != fsltype) {RedisModule_CloseKey(key);if (reply_on_failure)RedisModule_ReplyWithError(ctx, REDISMODULE_ERRORMSG_WRONGTYPE);RedisModuleCallReply *reply = RedisModule_Call(ctx, "INCR", "c", "fsl_wrong_type");RedisModule_FreeCallReply(reply);return 0;}/* Create an empty value object if the key is currently empty. */if (type == REDISMODULE_KEYTYPE_EMPTY) {if (!create) {/* Key is empty but we cannot create */RedisModule_CloseKey(key);*fsl = NULL;return 1;}*fsl = fsl_type_create();RedisModule_ModuleTypeSetValue(key, fsltype, *fsl);} else {*fsl = RedisModule_ModuleTypeGetValue(key);}RedisModule_CloseKey(key);return 1;
}/* ========================== commands ======================= *//* FSL.PUSH <key> <int> - Push an integer to the fixed-size list (to the right).* It must be greater than the element in the head of the list. */
int fsl_push(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {if (argc != 3)return RedisModule_WrongArity(ctx);long long ele;if (RedisModule_StringToLongLong(argv[2],&ele) != REDISMODULE_OK)return RedisModule_ReplyWithError(ctx,"ERR invalid integer");fsl_t *fsl;if (!get_fsl(ctx, argv[1], REDISMODULE_WRITE, 1, &fsl, 1))return REDISMODULE_OK;if (fsl->length == LIST_SIZE)return RedisModule_ReplyWithError(ctx,"ERR list is full");if (fsl->length != 0 && fsl->list[fsl->length-1] >= ele)return RedisModule_ReplyWithError(ctx,"ERR new element has to be greater than the head element");fsl->list[fsl->length++] = ele;RedisModule_SignalKeyAsReady(ctx, argv[1]);return RedisModule_ReplyWithSimpleString(ctx, "OK");
}int bpop_reply_callback(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {REDISMODULE_NOT_USED(argv);REDISMODULE_NOT_USED(argc);RedisModuleString *keyname = RedisModule_GetBlockedClientReadyKey(ctx);fsl_t *fsl;if (!get_fsl(ctx, keyname, REDISMODULE_READ, 0, &fsl, 0) || !fsl)return REDISMODULE_ERR;RedisModule_ReplyWithLongLong(ctx, fsl->list[--fsl->length]);return REDISMODULE_OK;
}int bpop_timeout_callback(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {REDISMODULE_NOT_USED(argv);REDISMODULE_NOT_USED(argc);return RedisModule_ReplyWithSimpleString(ctx, "Request timedout");
}/* FSL.BPOP <key> <timeout> - Block clients until list has two or more elements.* When that happens, unblock client and pop the last two elements (from the right). */
int fsl_bpop(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {if (argc != 3)return RedisModule_WrongArity(ctx);long long timeout;if (RedisModule_StringToLongLong(argv[2],&timeout) != REDISMODULE_OK || timeout < 0)return RedisModule_ReplyWithError(ctx,"ERR invalid timeout");fsl_t *fsl;if (!get_fsl(ctx, argv[1], REDISMODULE_READ, 0, &fsl, 1))return REDISMODULE_OK;if (!fsl) {RedisModule_BlockClientOnKeys(ctx, bpop_reply_callback, bpop_timeout_callback,NULL, timeout, &argv[1], 1, NULL);} else {RedisModule_ReplyWithLongLong(ctx, fsl->list[--fsl->length]);}return REDISMODULE_OK;
}int bpopgt_reply_callback(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {REDISMODULE_NOT_USED(argv);REDISMODULE_NOT_USED(argc);RedisModuleString *keyname = RedisModule_GetBlockedClientReadyKey(ctx);long long *pgt = RedisModule_GetBlockedClientPrivateData(ctx);fsl_t *fsl;if (!get_fsl(ctx, keyname, REDISMODULE_READ, 0, &fsl, 0) || !fsl)return REDISMODULE_ERR;if (fsl->list[fsl->length-1] <= *pgt)return REDISMODULE_ERR;RedisModule_ReplyWithLongLong(ctx, fsl->list[--fsl->length]);return REDISMODULE_OK;
}int bpopgt_timeout_callback(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {REDISMODULE_NOT_USED(argv);REDISMODULE_NOT_USED(argc);return RedisModule_ReplyWithSimpleString(ctx, "Request timedout");
}void bpopgt_free_privdata(RedisModuleCtx *ctx, void *privdata) {REDISMODULE_NOT_USED(ctx);RedisModule_Free(privdata);
}/* FSL.BPOPGT <key> <gt> <timeout> - Block clients until list has an element greater than <gt>.* When that happens, unblock client and pop the last element (from the right). */
int fsl_bpopgt(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {if (argc != 4)return RedisModule_WrongArity(ctx);long long gt;if (RedisModule_StringToLongLong(argv[2],&gt) != REDISMODULE_OK)return RedisModule_ReplyWithError(ctx,"ERR invalid integer");long long timeout;if (RedisModule_StringToLongLong(argv[3],&timeout) != REDISMODULE_OK || timeout < 0)return RedisModule_ReplyWithError(ctx,"ERR invalid timeout");fsl_t *fsl;if (!get_fsl(ctx, argv[1], REDISMODULE_READ, 0, &fsl, 1))return REDISMODULE_OK;if (!fsl || fsl->list[fsl->length-1] <= gt) {/* We use malloc so the tests in blockedonkeys.tcl can check for memory leaks */long long *pgt = RedisModule_Alloc(sizeof(long long));*pgt = gt;RedisModule_BlockClientOnKeys(ctx, bpopgt_reply_callback, bpopgt_timeout_callback,bpopgt_free_privdata, timeout, &argv[1], 1, pgt);} else {RedisModule_ReplyWithLongLong(ctx, fsl->list[--fsl->length]);}return REDISMODULE_OK;
}int bpoppush_reply_callback(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {REDISMODULE_NOT_USED(argv);REDISMODULE_NOT_USED(argc);RedisModuleString *src_keyname = RedisModule_GetBlockedClientReadyKey(ctx);RedisModuleString *dst_keyname = RedisModule_GetBlockedClientPrivateData(ctx);fsl_t *src;if (!get_fsl(ctx, src_keyname, REDISMODULE_READ, 0, &src, 0) || !src)return REDISMODULE_ERR;fsl_t *dst;if (!get_fsl(ctx, dst_keyname, REDISMODULE_WRITE, 1, &dst, 0) || !dst)return REDISMODULE_ERR;long long ele = src->list[--src->length];dst->list[dst->length++] = ele;RedisModule_SignalKeyAsReady(ctx, dst_keyname);return RedisModule_ReplyWithLongLong(ctx, ele);
}int bpoppush_timeout_callback(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {REDISMODULE_NOT_USED(argv);REDISMODULE_NOT_USED(argc);return RedisModule_ReplyWithSimpleString(ctx, "Request timedout");
}void bpoppush_free_privdata(RedisModuleCtx *ctx, void *privdata) {RedisModule_FreeString(ctx, privdata);
}/* FSL.BPOPPUSH <src> <dst> <timeout> - Block clients until <src> has an element.* When that happens, unblock client, pop the last element from <src> and push it to <dst>* (from the right). */
int fsl_bpoppush(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {if (argc != 4)return RedisModule_WrongArity(ctx);long long timeout;if (RedisModule_StringToLongLong(argv[3],&timeout) != REDISMODULE_OK || timeout < 0)return RedisModule_ReplyWithError(ctx,"ERR invalid timeout");fsl_t *src;if (!get_fsl(ctx, argv[1], REDISMODULE_READ, 0, &src, 1))return REDISMODULE_OK;if (!src) {/* Retain string for reply callback */RedisModule_RetainString(ctx, argv[2]);/* Key is empty, we must block */RedisModule_BlockClientOnKeys(ctx, bpoppush_reply_callback, bpoppush_timeout_callback,bpoppush_free_privdata, timeout, &argv[1], 1, argv[2]);} else {fsl_t *dst;if (!get_fsl(ctx, argv[2], REDISMODULE_WRITE, 1, &dst, 1))return REDISMODULE_OK;long long ele = src->list[--src->length];dst->list[dst->length++] = ele;RedisModule_SignalKeyAsReady(ctx, argv[2]);RedisModule_ReplyWithLongLong(ctx, ele);}return REDISMODULE_OK;
}/* FSL.GETALL <key> - Reply with an array containing all elements. */
int fsl_getall(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {if (argc != 2)return RedisModule_WrongArity(ctx);fsl_t *fsl;if (!get_fsl(ctx, argv[1], REDISMODULE_READ, 0, &fsl, 1))return REDISMODULE_OK;if (!fsl)return RedisModule_ReplyWithArray(ctx, 0);RedisModule_ReplyWithArray(ctx, fsl->length);for (int i = 0; i < fsl->length; i++)RedisModule_ReplyWithLongLong(ctx, fsl->list[i]);return REDISMODULE_OK;
}/* Callback for blockonkeys_popall */
int blockonkeys_popall_reply_callback(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {REDISMODULE_NOT_USED(argc);RedisModuleKey *key = RedisModule_OpenKey(ctx, argv[1], REDISMODULE_WRITE);if (RedisModule_KeyType(key) == REDISMODULE_KEYTYPE_LIST) {RedisModuleString *elem;long len = 0;RedisModule_ReplyWithArray(ctx, REDISMODULE_POSTPONED_ARRAY_LEN);while ((elem = RedisModule_ListPop(key, REDISMODULE_LIST_HEAD)) != NULL) {len++;RedisModule_ReplyWithString(ctx, elem);RedisModule_FreeString(ctx, elem);}RedisModule_ReplySetArrayLength(ctx, len);} else {RedisModule_ReplyWithError(ctx, "ERR Not a list");}RedisModule_CloseKey(key);return REDISMODULE_OK;
}int blockonkeys_popall_timeout_callback(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {REDISMODULE_NOT_USED(argv);REDISMODULE_NOT_USED(argc);return RedisModule_ReplyWithError(ctx, "ERR Timeout");
}/* BLOCKONKEYS.POPALL key** Blocks on an empty key for up to 3 seconds. When unblocked by a list* operation like LPUSH, all the elements are popped and returned. Fails with an* error on timeout. */
int blockonkeys_popall(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {if (argc != 2)return RedisModule_WrongArity(ctx);RedisModuleKey *key = RedisModule_OpenKey(ctx, argv[1], REDISMODULE_READ);if (RedisModule_KeyType(key) == REDISMODULE_KEYTYPE_EMPTY) {RedisModule_BlockClientOnKeys(ctx, blockonkeys_popall_reply_callback,blockonkeys_popall_timeout_callback,NULL, 3000, &argv[1], 1, NULL);} else {RedisModule_ReplyWithError(ctx, "ERR Key not empty");}RedisModule_CloseKey(key);return REDISMODULE_OK;
}/* BLOCKONKEYS.LPUSH key val [val ..]* BLOCKONKEYS.LPUSH_UNBLOCK key val [val ..]** A module equivalent of LPUSH. If the name LPUSH_UNBLOCK is used,* RM_SignalKeyAsReady() is also called. */
int blockonkeys_lpush(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {if (argc < 3)return RedisModule_WrongArity(ctx);RedisModuleKey *key = RedisModule_OpenKey(ctx, argv[1], REDISMODULE_WRITE);if (RedisModule_KeyType(key) != REDISMODULE_KEYTYPE_EMPTY &&RedisModule_KeyType(key) != REDISMODULE_KEYTYPE_LIST) {RedisModule_ReplyWithError(ctx, REDISMODULE_ERRORMSG_WRONGTYPE);} else {for (int i = 2; i < argc; i++) {if (RedisModule_ListPush(key, REDISMODULE_LIST_HEAD,argv[i]) != REDISMODULE_OK) {RedisModule_CloseKey(key);return RedisModule_ReplyWithError(ctx, "ERR Push failed");}}}RedisModule_CloseKey(key);/* signal key as ready if the command is lpush_unblock */size_t len;const char *str = RedisModule_StringPtrLen(argv[0], &len);if (!strncasecmp(str, "blockonkeys.lpush_unblock", len)) {RedisModule_SignalKeyAsReady(ctx, argv[1]);}return RedisModule_ReplyWithSimpleString(ctx, "OK");
}/* Callback for the BLOCKONKEYS.BLPOPN command */
int blockonkeys_blpopn_reply_callback(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {REDISMODULE_NOT_USED(argc);long long n;RedisModule_StringToLongLong(argv[2], &n);RedisModuleKey *key = RedisModule_OpenKey(ctx, argv[1], REDISMODULE_WRITE);int result;if (RedisModule_KeyType(key) == REDISMODULE_KEYTYPE_LIST &&RedisModule_ValueLength(key) >= (size_t)n) {RedisModule_ReplyWithArray(ctx, n);for (long i = 0; i < n; i++) {RedisModuleString *elem = RedisModule_ListPop(key, REDISMODULE_LIST_HEAD);RedisModule_ReplyWithString(ctx, elem);RedisModule_FreeString(ctx, elem);}result = REDISMODULE_OK;} else if (RedisModule_KeyType(key) == REDISMODULE_KEYTYPE_LIST ||RedisModule_KeyType(key) == REDISMODULE_KEYTYPE_EMPTY) {/* continue blocking */result = REDISMODULE_ERR;} else {result = RedisModule_ReplyWithError(ctx, REDISMODULE_ERRORMSG_WRONGTYPE);}RedisModule_CloseKey(key);return result;
}int blockonkeys_blpopn_timeout_callback(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {REDISMODULE_NOT_USED(argv);REDISMODULE_NOT_USED(argc);return RedisModule_ReplyWithError(ctx, "ERR Timeout");
}/* BLOCKONKEYS.BLPOPN key N** Blocks until key has N elements and then pops them or fails after 3 seconds.*/
int blockonkeys_blpopn(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {if (argc < 3) return RedisModule_WrongArity(ctx);long long n;if (RedisModule_StringToLongLong(argv[2], &n) != REDISMODULE_OK) {return RedisModule_ReplyWithError(ctx, "ERR Invalid N");}RedisModuleKey *key = RedisModule_OpenKey(ctx, argv[1], REDISMODULE_WRITE);int keytype = RedisModule_KeyType(key);if (keytype != REDISMODULE_KEYTYPE_EMPTY &&keytype != REDISMODULE_KEYTYPE_LIST) {RedisModule_ReplyWithError(ctx, REDISMODULE_ERRORMSG_WRONGTYPE);} else if (keytype == REDISMODULE_KEYTYPE_LIST &&RedisModule_ValueLength(key) >= (size_t)n) {RedisModule_ReplyWithArray(ctx, n);for (long i = 0; i < n; i++) {RedisModuleString *elem = RedisModule_ListPop(key, REDISMODULE_LIST_HEAD);RedisModule_ReplyWithString(ctx, elem);RedisModule_FreeString(ctx, elem);}} else {RedisModule_BlockClientOnKeys(ctx, blockonkeys_blpopn_reply_callback,blockonkeys_blpopn_timeout_callback,NULL, 3000, &argv[1], 1, NULL);}RedisModule_CloseKey(key);return REDISMODULE_OK;
}int RedisModule_OnLoad(RedisModuleCtx *ctx, RedisModuleString **argv, int argc) {REDISMODULE_NOT_USED(argv);REDISMODULE_NOT_USED(argc);if (RedisModule_Init(ctx, "blockonkeys", 1, REDISMODULE_APIVER_1)== REDISMODULE_ERR)return REDISMODULE_ERR;RedisModuleTypeMethods tm = {.version = REDISMODULE_TYPE_METHOD_VERSION,.rdb_load = fsl_rdb_load,.rdb_save = fsl_rdb_save,.aof_rewrite = fsl_aofrw,.mem_usage = NULL,.free = fsl_free,.digest = NULL};fsltype = RedisModule_CreateDataType(ctx, "fsltype_t", 0, &tm);if (fsltype == NULL)return REDISMODULE_ERR;if (RedisModule_CreateCommand(ctx,"fsl.push",fsl_push,"",0,0,0) == REDISMODULE_ERR)return REDISMODULE_ERR;if (RedisModule_CreateCommand(ctx,"fsl.bpop",fsl_bpop,"",0,0,0) == REDISMODULE_ERR)return REDISMODULE_ERR;if (RedisModule_CreateCommand(ctx,"fsl.bpopgt",fsl_bpopgt,"",0,0,0) == REDISMODULE_ERR)return REDISMODULE_ERR;if (RedisModule_CreateCommand(ctx,"fsl.bpoppush",fsl_bpoppush,"",0,0,0) == REDISMODULE_ERR)return REDISMODULE_ERR;if (RedisModule_CreateCommand(ctx,"fsl.getall",fsl_getall,"",0,0,0) == REDISMODULE_ERR)return REDISMODULE_ERR;if (RedisModule_CreateCommand(ctx, "blockonkeys.popall", blockonkeys_popall,"", 1, 1, 1) == REDISMODULE_ERR)return REDISMODULE_ERR;if (RedisModule_CreateCommand(ctx, "blockonkeys.lpush", blockonkeys_lpush,"", 1, 1, 1) == REDISMODULE_ERR)return REDISMODULE_ERR;if (RedisModule_CreateCommand(ctx, "blockonkeys.lpush_unblock", blockonkeys_lpush,"", 1, 1, 1) == REDISMODULE_ERR)return REDISMODULE_ERR;if (RedisModule_CreateCommand(ctx, "blockonkeys.blpopn", blockonkeys_blpopn,"", 1, 1, 1) == REDISMODULE_ERR)return REDISMODULE_ERR;return REDISMODULE_OK;
}

这篇关于漫话Redis源码之一百零五的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/683859。

相关文章

JAVA智听未来一站式有声阅读平台听书系统小程序源码

JAVA智听未来一站式有声阅读平台听书系统小程序源码

智听未来，一站式有声阅读平台听书系统 🌟&nbsp;开篇：遇见未来，从“智听”开始 在这个快节奏的时代，你是否渴望在忙碌的间隙，找到一片属于自己的宁静角落？是否梦想着能随时随地，沉浸在知识的海洋，或是故事的奇幻世界里？今天，就让我带你一起探索“智听未来”——这一站式有声阅读平台听书系统，它正悄悄改变着我们的阅读方式，让未来触手可及！ 📚&nbsp;第一站：海量资源，应有尽有 走进“智听
阅读更多...
零基础学习Redis(10) -- zset类型命令使用

零基础学习Redis(10) -- zset类型命令使用

zset是有序集合，内部除了存储元素外，还会存储一个score，存储在zset中的元素会按照score的大小升序排列，不同元素的score可以重复，score相同的元素会按照元素的字典序排列。 1. zset常用命令 1.1 zadd  zadd key [NX | XX] [GT | LT]   [CH] [INCR] score member [score member ...]
阅读更多...
Java ArrayList扩容机制 （源码解读）

Java ArrayList扩容机制 （源码解读）

结论：初始长度为10，若所需长度小于1.5倍原长度，则按照1.5倍扩容。若不够用则按照所需长度扩容。 一. 明确类内部重要变量含义         1：数组默认长度         2:这是一个共享的空数组实例，用于明确创建长度为0时的ArrayList ，比如通过 new ArrayList<>(0)，ArrayList 内部的数组 elementData 会指向这个 EMPTY_EL
阅读更多...
如何在Visual Studio中调试.NET源码

如何在Visual Studio中调试.NET源码

今天偶然在看别人代码时，发现在他的代码里使用了Any判断List<T>是否为空。 我一般的做法是先判断是否为null，再判断Count。 看了一下Count的源码如下： 1 [__DynamicallyInvokable]2 public int Count3 {4 [__DynamicallyInvokable]5 get
阅读更多...
工厂ERP管理系统实现源码（JAVA）

工厂ERP管理系统实现源码（JAVA）

工厂进销存管理系统是一个集采购管理、仓库管理、生产管理和销售管理于一体的综合解决方案。该系统旨在帮助企业优化流程、提高效率、降低成本，并实时掌握各环节的运营状况。 在采购管理方面，系统能够处理采购订单、供应商管理和采购入库等流程，确保采购过程的透明和高效。仓库管理方面，实现库存的精准管理，包括入库、出库、盘点等操作，确保库存数据的准确性和实时性。 生产管理模块则涵盖了生产计划制定、物料需求计划、
阅读更多...
Spring 源码解读：自定义实现Bean定义的注册与解析

Spring 源码解读：自定义实现Bean定义的注册与解析

引言 在Spring框架中，Bean的注册与解析是整个依赖注入流程的核心步骤。通过Bean定义，Spring容器知道如何创建、配置和管理每个Bean实例。本篇文章将通过实现一个简化版的Bean定义注册与解析机制，帮助你理解Spring框架背后的设计逻辑。我们还将对比Spring中的BeanDefinition和BeanDefinitionRegistry，以全面掌握Bean注册和解析的核心原理。
阅读更多...
音视频入门基础：WAV专题（10）——FFmpeg源码中计算WAV音频文件每个packet的pts、dts的实现

音视频入门基础：WAV专题（10）——FFmpeg源码中计算WAV音频文件每个packet的pts、dts的实现

一、引言 从文章《音视频入门基础：WAV专题（6）——通过FFprobe显示WAV音频文件每个数据包的信息》中我们可以知道，通过FFprobe命令可以打印WAV音频文件每个packet（也称为数据包或多媒体包）的信息，这些信息包含该packet的pts、dts： 打印出来的“pts”实际是AVPacket结构体中的成员变量pts，是以AVStream->time_base为单位的显
阅读更多...
kubelet组件的启动流程源码分析

kubelet组件的启动流程源码分析

概述 摘要: 本文将总结kubelet的作用以及原理，在有一定基础认识的前提下，通过阅读kubelet源码，对kubelet组件的启动流程进行分析。 正文 kubelet的作用 这里对kubelet的作用做一个简单总结。 节点管理 节点的注册 节点状态更新 容器管理(pod生命周期管理) 监听apiserver的容器事件 容器的创建、删除(CRI) 容器的网络的创建与删除
阅读更多...
Redis中使用布隆过滤器解决缓存穿透问题

Redis中使用布隆过滤器解决缓存穿透问题

一、缓存穿透(失效)问题 缓存穿透是指查询一个一定不存在的数据，由于缓存中没有命中，会去数据库中查询，而数据库中也没有该数据，并且每次查询都不会命中缓存，从而每次请求都直接打到了数据库上，这会给数据库带来巨大压力。 二、布隆过滤器原理 布隆过滤器（Bloom Filter）是一种空间效率很高的随机数据结构，它利用多个不同的哈希函数将一个元素映射到一个位数组中的多个位置，并将这些位置的值置
阅读更多...
red5-server源码

red5-server源码

red5-server源码：https://github.com/Red5/red5-server
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2