百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术教程 > 正文

适用于Node.js的健壮、注重性能的全功能Redis客户端——ioredis

mhr18 2024-10-11 12:56 28 浏览 0 评论

介绍

ioredis是一个适用于Nodejs的Redis全功能客户端,健壮性以及高性能是它的亮点,支持Redis> = 2.6.12和(Node.js> = 6),ioredis是一个功能强大的功能强大的Redis客户,已被阿里巴巴和许多其他了不起的公司所使用。







Github

https://github.com/luin/ioredis

特性

  • 功能齐全。它支持Cluster,Sentinel,Pipelining,当然还支持Lua脚本和Pub / Sub(具有二进制消息的支持)
  • 高性能
  • 易于使用的API。它与Node回调和本机Promise一起使用
  • 命令参数和回复的转换
  • 透明键前缀
  • Lua脚本的抽象,允许您定义自定义命令
  • 支持二进制数据
  • 支持TLS
  • 支持脱机队列和就绪检查
  • 支持ES6类型,例如Map和Set
  • 支持GEO命令(Redis 3.2不稳定)
  • 复杂的错误处理策略
  • 支持NAT映射
  • 安装

    npm install ioredis

    基本使用

    var Redis = require("ioredis");
    var redis = new Redis();
    
    redis.set("foo", "bar");
    redis.get("foo", function(err, result) {
     console.log(result);
    });
    redis.del("foo");
    
    // 或者如果最后一个参数不是函数,则使用Promise
    redis.get("foo").then(function(result) {
     console.log(result);
    });
    
    
    redis.sadd("set", 1, 3, 5, 7);
    redis.sadd("set", [1, 3, 5, 7]);
    
    // 所有参数都直接传递给redis服务器:
    redis.set("key", 100, "EX", 10);

    连接到Redis

    创建新的Redis实例后,将同时创建到Redis的连接。可以通过以下方式指定要连接的Redis:

    new Redis(); // Connect to 127.0.0.1:6379
    new Redis(6380); // 127.0.0.1:6380
    new Redis(6379, "192.168.1.1"); // 192.168.1.1:6379
    new Redis("/tmp/redis.sock");
    new Redis({
     port: 6379, // Redis port
     host: "127.0.0.1", // Redis host
     family: 4, // 4 (IPv4) or 6 (IPv6)
     password: "auth",
     db: 0
    });

    使用TLS加密时,还可以将连接选项指定为redis:// URL或rediss:// URL:

    new Redis("redis://:authpassword@127.0.0.1:6380/4");

    发布/订阅

    这是发布/订阅API的简单示例。以下程序将打开两个客户端连接。它订阅一个连接的频道,然后发布另一个连接:

    var Redis = require("ioredis");
    var redis = new Redis();
    var pub = new Redis();
    redis.subscribe("news", "music", function(err, count) {
     // 现在我们都订阅了“新闻”和“音乐”频道。
     // `count` 代表我们当前订阅的频道数。
    
     pub.publish("news", "Hello world!");
     pub.publish("music", "Hello again!");
    });
    
    redis.on("message", function(channel, message) {
     // 从新闻频道,收到消息Hello world!
     // 从音乐频道再次收到消息Hello!
     console.log("Receive message %s from channel %s", message, channel);
    });
    
    //还有一个称为“ messageBuffer”的事件,与“ message”相同,除了//返回缓冲区buffer而不是字符串。
    redis.on("messageBuffer", function(channel, message) {
     
    });

    还以类似方式支持PSUBSCRIBE:

    redis.psubscribe("pat?ern", function(err, count) {});
    redis.on("pmessage", function(pattern, channel, message) {});
    redis.on("pmessageBuffer", function(pattern, channel, message) {});

    当客户端发出SUBSCRIBE或PSUBSCRIBE时,该连接将进入“订阅者”模式。那时,只有修改订阅集的命令才有效。当订阅集为空时,连接将恢复为常规模式。如果需要在订阅者模式下向Redis发送常规命令,只需打开另一个连接即可。

    处理二进制数据

    redis.set("foo", Buffer.from("bar"));

    每个命令都有一个返回Buffer的方法(通过在命令名后添加“ Buffer”后缀)。获取缓冲区buffer:

    redis.getBuffer("foo", function(err, result) {
     // result is a buffer.
    });

    Pipelining

    如果要发送一批命令(例如> 5),则可以使用流水线将命令在内存中排队,然后将它们一次全部发送到Redis。这样,性能提高了50%?300%。redis.pipeline()创建一个Pipeline实例。您可以像Redis实例一样在其上调用任何Redis命令。这些命令在内存中排队,并通过调用exec方法刷新到Redis:

    var pipeline = redis.pipeline();
    pipeline.set("foo", "bar");
    pipeline.del("cc");
    pipeline.exec(function(err, results) {
     
    });
    
    
    redis
     .pipeline()
     .set("foo", "bar")
     .del("cc")
     .exec(function(err, results) {});
    
    
    var promise = redis
     .pipeline()
     .set("foo", "bar")
     .get("foo")
     .exec();
    promise.then(function(result) {
    });

    每个链接的命令还可以具有一个回调,该回调将在命令得到答复时被调用:

    redis
     .pipeline()
     .set("foo", "bar")
     .get("foo", function(err, result) {
     // result === 'bar'
     })
     .exec(function(err, result) {
     // result[1][1] === 'bar'
     });

    除了将命令分别添加到管道队列之外,还可以将命令和参数数组传递给构造函数:

    redis.pipeline([["set", "foo", "bar"], ["get", "foo"]]).exec(function() {
     /* ... */
    });

    length属性显示管道中有多少个命令:

    const length = redis
     .pipeline()
     .set("foo", "bar")
     .get("foo").length;
    // length === 2

    。。。。。。

    以上是借鉴Github上介绍的部分功能,如果需要详细了解它的所有功能,则可以直接参考Github上提供的文档API,非常详细,本文篇幅有限就不在此展示!

    https://github.com/luin/ioredis

    Redis可视化客户端

    之前的文章中介绍了很多Redis的可视化管理客户端,今天就在介绍一个跨平台的Redis GUI——Medis。Medis是一个漂亮的,易于使用的Redis管理应用程序,它基于Electron,React和Redux构建在现代网络上。它由许多很棒的Node.js模块提供支持,尤其是ioredis和ssh2。







    特性:

  • 按键查看/编辑
  • SSH隧道,用于连接远程服务器
  • 执行自定义命令的终端
  • 配置查看/编辑
  • 高级:

  • JSON / MessagePack格式查看/编辑和内置高亮显示/验证
  • 在不阻止Redis服务器的情况下使用数百万个键和键成员
  • 模式管理器,可轻松选择子键组。
  • https://github.com/luin/medis

    总结

    如果你正愁在Nodejs下没有找到一个好用的Redis客户端,那么ioredis则是你可以选择的一个选项,好不好用还得试试才知道,Enjoy it!

    相关推荐

    订单超时自动取消业务的 N 种实现方案,从原理到落地全解析

    在分布式系统架构中,订单超时自动取消机制是保障业务一致性的关键组件。某电商平台曾因超时处理机制缺陷导致日均3000+订单库存锁定异常,直接损失超50万元/天。本文将从技术原理、实现细节、...

    使用Spring Boot 3开发时,如何选择合适的分布式技术?

    作为互联网大厂的后端开发人员,当你满怀期待地用上SpringBoot3,准备在项目中大显身手时,却发现一个棘手的问题摆在面前:面对众多分布式技术,究竟该如何选择,才能让SpringBoot...

    数据库内存爆满怎么办?99%的程序员都踩过这个坑!

    你的数据库是不是又双叒叕内存爆满了?!服务器监控一片红色警告,老板在群里@所有人,运维同事的电话打爆了手机...这种场景是不是特别熟悉?别慌!作为一个在数据库优化这条路上摸爬滚打了10年的老司机,今天...

    springboot利用Redisson 实现缓存与数据库双写不一致问题

    使用了Redisson来操作Redis分布式锁,主要功能是从缓存和数据库中获取商品信息,以下是针对并发时更新缓存和数据库带来不一致问题的解决方案1.基于读写锁和删除缓存策略在并发更新场景下,...

    外贸独立站数据库炸了?对象缓存让你起死回生

    上周黑五,一个客户眼睁睁看着服务器CPU飙到100%——每次页面加载要查87次数据库。这让我想起2024年Pantheon的测试:Redis缓存能把WooCommerce查询速度提升20倍。跨境电商最...

    手把手教你在 Spring Boot3 里纯编码实现自定义分布式锁

    为什么要自己实现分布式锁?你是不是早就受够了引入各种第三方依赖时的繁琐?尤其是分布式锁这块,每次集成Redisson或者Zookeeper,都得额外维护一堆配置,有时候还会因为版本兼容问题头疼半...

    如何设计一个支持百万级实时数据推送的WebSocket集群架构?

    面试解答:要设计一个支持百万级实时数据推送的WebSocket集群架构,需从**连接管理、负载均衡、水平扩展、容灾恢复**四个维度切入:连接层设计-**长连接优化**:采用Netty或Und...

    Redis数据结构总结——面试最常问到的知识点

    Redis作为主流的nosql存储,面试时经常会问到。其主要场景是用作缓存,分布式锁,分布式session,消息队列,发布订阅等等。其存储结构主要有String,List,Set,Hash,Sort...

    skynet服务的缺陷 lua死循环

    服务端高级架构—云风的skynet这边有一个关于云风skynet的视频推荐给大家观看点击就可以观看了!skynet是一套多人在线游戏的轻量级服务端框架,使用C+Lua开发。skynet的显著优点是,...

    七年Java开发的一路辛酸史:分享面试京东、阿里、美团后的心得

    前言我觉得有一个能够找一份大厂的offer的想法,这是很正常的,这并不是我们的饭后谈资而是每个技术人的追求。像阿里、腾讯、美团、字节跳动、京东等等的技术氛围与技术规范度还是要明显优于一些创业型公司...

    mysql mogodb es redis数据库之间的区别

    1.MySQL应用场景概念:关系型数据库,基于关系模型,使用表和行存储数据。优点:支持ACID事务,数据具有很高的一致性和完整性。缺点:垂直扩展能力有限,需要分库分表等方式扩展。对于复杂的查询和大量的...

    redis,memcached,nginx网络组件

    1.理解阻塞io,非阻塞io,同步io,异步io的区别2.理解BIO和AIO的区别io多路复用只负责io检测,不负责io操作阻塞io中的write,能写多少是多少,只要写成功就返回,譬如准备写500字...

    SpringBoot+Vue+Redis实现验证码功能

    一个小时只允许发三次验证码。一次验证码有效期二分钟。SpringBoot整合Redis...

    AWS MemoryDB 可观测最佳实践

    AWSMemoryDB介绍AmazonMemoryDB是一种完全托管的、内存中数据存储服务,专为需要极低延迟和高吞吐量的应用程序而设计。它与Redis和Memcached相似,但具有更...

    从0构建大型AI推荐系统:实时化引擎从工具到生态的演进

    在AI浪潮席卷各行各业的今天,推荐系统正从幕后走向前台,成为用户体验的核心驱动力。本文将带你深入探索一个大型AI推荐系统从零起步的全过程,揭示实时化引擎如何从单一工具演进为复杂生态的关键路径。无论你是...

    取消回复欢迎 发表评论: