当前位置: 首页 > news >正文

Redis 特殊数据类型

目录

1、redis地理空间(GEO)

2、redis基数统计(HyperLogLog)

3、redis位图(bitmap)

4、redis位域bitfield)

5、redis流(Stream)


1、redis地理空间(GEO)

Redis 的地理空间数据结构(GEO)可以用于存储地理位置信息,并支持附近位置搜索等功能。

命令描述
GEOHASH返回一个或多个位置元素的 Geohash 表示
GEOPOS从key里返回所有给定位置元素的位置(经度和纬度)
GEODIST返回两个给定位置之间的距离
GEORADIUS以给定的经纬度为中心, 找出某一半径内的元素
GEOADD将指定的地理空间位置(纬度、经度、名称)添加到指定的key中
GEORADIUSBYMEMBER找出位于指定范围内的元素,中心点是由给定的位置元素决定

 应用场景

  1. 附近的人/店铺搜索:可以使用 GEO 数据结构来存储用户或商店的地理位置信息,然后通过 Redis 提供的命令进行附近的人或店铺搜索,例如查找附近的餐馆、商店或其他服务设施。

  2. 地理围栏监控:通过 GEO 数据结构记录移动物体的实时位置,并结合有序集合(Sorted Set)来实现地理围栏监控,比如在特定区域内的移动车辆或设备监控。

  3. 地理位置标注:将地理位置信息与其他业务数据关联,比如将特定位置的销售点、活动场所等信息与地理位置进行标注,以支持位置相关的业务查询和展示。

2、redis基数统计(HyperLogLog)

Redis 的基数统计(HyperLogLog)数据结构用于估算一个集合中不重复元素的个数,能够在占用较小内存的同时对大数量级的数据进行近似计数。

PFADD 添加元素到 HyperLogLog 中

 示例:PFADD my_hyperloglog user1 user2 user3

 说明:向名为 my_hyperloglog 的 HyperLogLog 结构中添加了三个元

PFCOUNT 获取 HyperLogLog 中的近似基数

 示例:PFCOUNT my_hyperloglog

 说明:返回值为近似的基数,即 HyperLogLog 中不重复元素的数

PFMERGE合并多个 HyperLogLog

 示例:PFMERGE merged_hyperloglog my_hyperloglog1 my_hyperloglog2

 说明:将多个 HyperLogLog 合并为一个新的 HyperLogLo

应用场景

  1. 独立访客统计:可以使用 HyperLogLog 数据结构来进行网站或应用的独立访客数量统计,而不需要存储每个访客的详细信息,节省内存空间。

  2. 活跃用户统计:对于大型在线平台,可以使用 HyperLogLog 计数活跃用户数量,而无需维护每个用户的详细浏览记录。

  3. 广告点击量统计:在广告分析领域,HyperLogLog 可以用于估算独立用户的广告点击数量,而不必存储每次点击的详细信息。

3、redis位图(bitmap)

Redis中的位图(bitmap)是一种特殊的数据结构,它通常用于表示某种状态或者标记,每个比特位可以表示一个状态或者标记的存在与否。

setbit设置位图中的某一位

 示例:SETBIT user:1:online 1001 1

说明:将user 1的在线状态设置为1(在线),偏移量为1001

getbit获取位图中的某一位的值

​​​​​

 示例:GETBIT user:1:online 1001

 说明:返回值为0或1,表示偏移量为1001的位的

strlen统计字节数占用多少示例:user:1:online
bitcount统计位图中值为1的位数

 示例:BITCOUNT user:1:online

 说明:可选参数startend用于指定范围,不指定则统计整个位图中值为1的位

bitop对多个位图进行逻辑运算

 示例:BITOP AND online_users user:1:online user:2:online

 说明:将user 1和user 2的在线状态做与操作,存储到online_users位图

应用场景

  1. 用户在线状态:可以使用位图来表示用户的在线状态,每个比特位代表一个用户,值为1表示在线,值为0表示离线。
  2. 统计用户活跃度:使用位图记录用户每天的活跃情况,以便后续进行活跃度分析和统计。
  3. 标记用户行为:可以用位图来标记用户的某些行为,比如签到、阅读等,每个比特位代表一个行为,值为1表示有该行为,值为0表示没有。

4、redis位域bitfield)

Redis 的位域(Bitfield)数据结构提供了位级别的操作,可以方便地对二进制位进行读取和修改,适用于一些需要对大量位操作的场景。

BITFIELD设置位域中的指定位

示例:BITFIELD mykey SET u8 0 1 GET u4 5

说明:在名为 mykey 的位域中,将第 0 位设置为 1,并获取第 5 位到第 8 位的值

GETBIT获取位域中的指定位

示例:GETBIT mykey 0

返回值为指定偏移处的位的值。

BITOP对位域进行位运算

示例:BITOP AND destkey key1 key2

说明:将多个位域进行指定的位运算(AND/OR/XOR/NOT)后存储到目标位域。

应用场景

  1. 权限管理:位域可以用于表示用户或角色的权限,每一位代表一种权限状态,通过位运算可以方便地进行权限的赋予与撤销。

  2. 实时状态标记:对于实时状态的标记,比如设备状态、用户在线状态等,位域可以高效地存储并更新这些状态信息。

  3. 布隆过滤器:布隆过滤器是一种空间效率很高的概率型数据结构,常用于快速判断一个元素是否存在。在 Redis 中,可以利用位域来实现布隆过滤器。

5、redis流(Stream)

Redis 的流(Stream)数据结构是一个有序、可持久化的消息队列,可以用于实现消息发布订阅系统、事件日志、通知系统等功能。

XADD发布消息到流

示例:XADD mystream * name John age 30

说明:向名为 mystream 的流中添加一条消息,使用 * 作为自动生成的消息ID。

XREAD消费者消费消息

示例:XREAD BLOCK 10000 STREAMS mystream 0

说明:从名为 mystream 的流中读取消息,并阻塞 10 秒等待新消息。

XACK消费者确认消息

示例:XACK mystream mygroup 1606388386385-0 1606388386386-0

说明:消费者组 mygroup 确认处理了特定的消息ID。

XGROUP创建消费者组

示例:XGROUP CREATE mystream mygroup $ MKSTREAM

说明:创建名为 mygroup 的消费者组,并使用 $ 表示从最新的消息开始消费。

应用场景

  1. 消息队列:流可以作为高性能的消息队列使用,允许按照发布的顺序进行消费,支持多个消费者并行处理消息。这种模式非常适合需要处理大量实时消息的业务场景。

  2. 事件日志:流可以用于记录系统的事件日志,包括用户操作、系统状态变化等,以便后续进行分析和故障排查。

  3. 通知系统:流可以用于构建实时的通知系统,例如实时推送用户的消息、提醒和通知。

相关文章:

Redis 特殊数据类型

目录 1、redis地理空间(GEO) 2、redis基数统计(HyperLogLog) 3、redis位图(bitmap) 4、redis位域bitfield) 5、redis流(Stream) 1、redis地理空间(GEO) Redis 的地理空间数据结构(GEO)可以用于存储地理位置信息,并支持附近位置搜索等功能…...

【Windows网络编程】二.TCP套接字编程与主机上线实验

API: socket: 套接字函数创建绑定到特定传输服务提供程序的套接字。 函数原型:SOCKET WSAAPI socket([in] int af,[in] int type,[in] int protocol );参数: af:地址规范系列: AF_INET:IPv4&…...

Qt 事件循环

引出 UI程序之所叫UI程序,是因为需要与用户有交互,用户交互一般是通过鼠标键盘等的输入设备,那UI程序就需要有能随时响应用户交互的能力。 一个C程序的main函数大概是下面这样: int main() {...return 0; } 我们如何使程序能随…...

【趣味随笔】YOLO的“进化史”极简版(YOLO v1-->YOLOP)

📢:如果你也对机器人、人工智能感兴趣,看来我们志同道合✨ 📢:不妨浏览一下我的博客主页【https://blog.csdn.net/weixin_51244852】 📢:文章若有幸对你有帮助,可点赞 👍…...

Leetcode421. 数组中两个数的最大异或值

Every day a Leetcode 题目来源:421. 数组中两个数的最大异或值 解法1:贪心 位运算 初始化答案 ans 0。从最高位 high_bit 开始枚举 i,也就是 max⁡(nums) 的二进制长度减一。设 newAns ans 2i,看能否从数组 nums 中选两个…...

SPRINGBOOT整合CXF发布WEB SERVICE和客户端调用(用户和密码验证)

主要分为客户端和服务端 服务端 pom配置 <parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.4.3</version><relativePath/> <!-- lookup parent fro…...

代码随想录训练营Day5:哈希数组

算是哈希的容器&#xff1a;数组&#xff08;适合连续存放&#xff09;&#xff1b;set&#xff0c;map&#xff08;适合无序存放&#xff09;。所以数组操作就是hash[i];而set,map.insert(元素)&#xff0c;map可以map[]是因为map存放了键值对可以索引查找。关于几个数组相加等…...

腾讯云3年轻量2核2G4M和2核4G5M服务器540元三年

腾讯云轻量应用服务器特价是有新用户限制的&#xff0c;所以阿腾云建议大家选择3年期轻量应用服务器&#xff0c;一劳永逸&#xff0c;免去续费困扰。腾讯云轻量应用服务器3年可以选择2核2G4M和2核4G5M带宽&#xff0c;3年轻量2核2G4M服务器540元&#xff0c;2核4G5M轻量应用服…...

程序员的护城河:职业发展的关键元素

目录 1. 技术深度与广度 2. 项目经验与实际操作 3. 沟通与团队协作 4. 持续学习与自我更新 5. 社区参与与开源贡献 6. 创新思维与解决问题的能力 7. 职业规划与自我管理 结语 在科技日新月异的今天&#xff0c;程序员的竞争已经不再仅仅依赖于技术水平&#xff0c;而是…...

基于SpringBoot+Vue的在线学习平台系统

基于SpringBootVue的在线学习平台系统的设计与实现~ 开发语言&#xff1a;Java数据库&#xff1a;MySQL技术&#xff1a;SpringBootMyBatisVue工具&#xff1a;IDEA/Ecilpse、Navicat、Maven 系统展示 主页 用户界面 登录界面 管理员界面 摘要 本文设计并实现了一套基于Spri…...

Kafka+redis分布式锁结合使用心得总结

#kafka部分 KafkaListener(topics "#{${vsmart_alert_detection_tms_send_message_topic}.split(,)}", groupId "${vsmart.alert.detection.consumer.group}") public void vsmartAlertDetectionTmsSendMessage(ConsumerRecord<?, ?> record, A…...

cmd打开idea

当我们用idea打开一个项目的时候&#xff0c;有时候这个项目目录是有的&#xff0c;但是用idea的open却找不到&#xff0c;有时候我要重新关闭窗口&#xff0c;再open好多次才有 于是我现在使用命令打开&#xff0c;先把idea安装路径的bin目录放在path里面 然后cd到项目路径&…...

javaScript爬虫程序抓取评论

由于评论区目前没有开放的API接口&#xff0c;所以我们不能直接通过编程获取到评论区的内容。但是&#xff0c;我们可以通过模拟浏览器的行为来实现这个功能。以下是一个使用Python的requests库和BeautifulSoup库来实现这个功能的基本思路&#xff1a; import requests from bs…...

RT-DETR 应用 CARAFE:特征内容感知重新组装

特征上采样是现代卷积神经网络架构中的关键操作,例如特征金字塔。其设计对于密集预测任务,如目标检测和语义/实例分割至关重要。在本研究中,我们提出了一种称为内容感知特征重组(CARAFE)的通用、轻量级且高效的操作符,以实现这一目标。CARAFE具有以下几个优点:(1)大的…...

Git Commit 之道:规范化 Commit Message 写作指南

1 commit message 规范 commit message格式都包括三部分&#xff1a;Header&#xff0c;Body和Footer <type>(<scope>): <subject><body><footer>Header是必需的&#xff0c;Body和Footer则可以省略 1.1 Header Type&#xff08;必需&#xf…...

【机试题】LazyIterator迭代器懒加载问题

将下面这个未完成的Java工具类补充完成&#xff0c;实现懒加载的功能&#xff0c;该类需要实现Iterable接口&#xff0c;能够遍历所有数据。具体要求如下&#xff1a; 工具类提供了一个ValueLoader接口&#xff0c;用于获取数据&#xff0c;其中ValueLoader的接口定义为&#x…...

【面试经典150 | 位运算】位1的个数

文章目录 写在前面Tag题目来源题目解读解题思路方法一&#xff1a;循环检查二进制位方法二&#xff1a;位运算优化方法三&#xff1a;__builtin_popcount() 写在最后 写在前面 本专栏专注于分析与讲解【面试经典150】算法&#xff0c;两到三天更新一篇文章&#xff0c;欢迎催更…...

vue中数据代理和事件处理

数据代理 直接在对象下可直接修改属性的值&#xff0c;而Object提供defineProperty()对属性进行控制 <script>let perosn {name: 小蜜,sex: 男,//age: 19 }Object.defineProperty(perosn,age,{value: 19//enumerable: true ,添加enumerable将默认值改为true&#xff0c…...

Unity之NetCode多人网络游戏联机对战教程(8)--玩家位置同步

文章目录 前言添加相机玩家添加对应组件服务端权威&#xff08;server authoritative&#xff09;客户端权威&#xff08;client authoritative&#xff09;服务端同步位置阅读与理解PlayerTransformSync.csNetworkVariableUploadTransformSyncTransform 后话 前言 承接上篇&a…...

spring boot 中@Value读取中文配置时乱码

1.spring boot 读取application.properties 该文件是iso8859编码 如果是直接写中文 读取时会乱码 显示成?? 必须得转ascii码才能正常显示 其他方法测试也不行 Value("${apig.order.tiaokong.qianzi}") private String apigOrderTiaokongQianzi;...

基于距离变化能量开销动态调整的WSN低功耗拓扑控制开销算法matlab仿真

目录 1.程序功能描述 2.测试软件版本以及运行结果展示 3.核心程序 4.算法仿真参数 5.算法理论概述 6.参考文献 7.完整程序 1.程序功能描述 通过动态调整节点通信的能量开销&#xff0c;平衡网络负载&#xff0c;延长WSN生命周期。具体通过建立基于距离的能量消耗模型&am…...

解决本地部署 SmolVLM2 大语言模型运行 flash-attn 报错

出现的问题 安装 flash-attn 会一直卡在 build 那一步或者运行报错 解决办法 是因为你安装的 flash-attn 版本没有对应上&#xff0c;所以报错&#xff0c;到 https://github.com/Dao-AILab/flash-attention/releases 下载对应版本&#xff0c;cu、torch、cp 的版本一定要对…...

爬虫基础学习day2

# 爬虫设计领域 工商&#xff1a;企查查、天眼查短视频&#xff1a;抖音、快手、西瓜 ---> 飞瓜电商&#xff1a;京东、淘宝、聚美优品、亚马逊 ---> 分析店铺经营决策标题、排名航空&#xff1a;抓取所有航空公司价格 ---> 去哪儿自媒体&#xff1a;采集自媒体数据进…...

rnn判断string中第一次出现a的下标

# coding:utf8 import torch import torch.nn as nn import numpy as np import random import json""" 基于pytorch的网络编写 实现一个RNN网络完成多分类任务 判断字符 a 第一次出现在字符串中的位置 """class TorchModel(nn.Module):def __in…...

基于SpringBoot在线拍卖系统的设计和实现

摘 要 随着社会的发展&#xff0c;社会的各行各业都在利用信息化时代的优势。计算机的优势和普及使得各种信息系统的开发成为必需。 在线拍卖系统&#xff0c;主要的模块包括管理员&#xff1b;首页、个人中心、用户管理、商品类型管理、拍卖商品管理、历史竞拍管理、竞拍订单…...

虚拟电厂发展三大趋势:市场化、技术主导、车网互联

市场化&#xff1a;从政策驱动到多元盈利 政策全面赋能 2025年4月&#xff0c;国家发改委、能源局发布《关于加快推进虚拟电厂发展的指导意见》&#xff0c;首次明确虚拟电厂为“独立市场主体”&#xff0c;提出硬性目标&#xff1a;2027年全国调节能力≥2000万千瓦&#xff0…...

从 GreenPlum 到镜舟数据库:杭银消费金融湖仓一体转型实践

作者&#xff1a;吴岐诗&#xff0c;杭银消费金融大数据应用开发工程师 本文整理自杭银消费金融大数据应用开发工程师在StarRocks Summit Asia 2024的分享 引言&#xff1a;融合数据湖与数仓的创新之路 在数字金融时代&#xff0c;数据已成为金融机构的核心竞争力。杭银消费金…...

0x-3-Oracle 23 ai-sqlcl 25.1 集成安装-配置和优化

是不是受够了安装了oracle database之后sqlplus的简陋&#xff0c;无法删除无法上下翻页的苦恼。 可以安装readline和rlwrap插件的话&#xff0c;配置.bahs_profile后也能解决上下翻页这些&#xff0c;但是很多生产环境无法安装rpm包。 oracle提供了sqlcl免费许可&#xff0c…...

QT开发技术【ffmpeg + QAudioOutput】音乐播放器

一、 介绍 使用ffmpeg 4.2.2 在数字化浪潮席卷全球的当下&#xff0c;音视频内容犹如璀璨繁星&#xff0c;点亮了人们的生活与工作。从短视频平台上令人捧腹的搞笑视频&#xff0c;到在线课堂中知识渊博的专家授课&#xff0c;再到影视平台上扣人心弦的高清大片&#xff0c;音…...

LeetCode - 148. 排序链表

目录 题目 思路 基本情况检查 复杂度分析 执行示例 读者可能出的错误 正确的写法 题目 148. 排序链表 - 力扣&#xff08;LeetCode&#xff09; 思路 链表归并排序采用"分治"的策略&#xff0c;主要分为三个步骤&#xff1a; 分割&#xff1a;将链表从中间…...