重新分流

Redis 5 流线 作为 可读可写节点流( W)。 。 。 . 加上命令行接口.

安装

npm install @derhuerst/redis-stream

命令行使用情况

Usage:
    write-into-redis-stream <stream-name>
Examples:
    echo '{"user": "jane", "text": "hey!"}' | write-into-redis-stream chat-msgs

Usage:
    read-from-redis-stream <stream-name> [--history] [--live [--waitTimoout <ms>]] [--limit <n>]
Options:
    --live             Wait for newly added items? Default: true
    --waitTimeout  -t  How long to wait for newly added items. Default: Infinity
    --history          Read all past items from the stream? Default: false
    --limit        -l  Maximum number of items to read. Default: Infinity
Examples:
    read-from-redis-stream chat-msgs --live --limit 1000

使用 Java 脚本

写入 Redis 流

const {createClient} = require('redis')
const createWriter = require('@derhuerst/redis-stream/writer')

const redis = createClient()
const writer = createWriter(redis, 'some-stream-name')
writer.once('finish', () => redis.quit())
writer.on('error', console.error)

writer.write({foo: 'bar'})
writer.end({hey: 'there!'})

从 Redis 流读取

const {createClient} = require('redis')
const createReader = require('@derhuerst/redis-stream/reader')

const redis = createClient()
const reader = createReader(redis, 'some-stream-name')
reader.on('data', console.log)
reader.on('error', console.error)

API 密码

createWriter(redis, streamName)

回返a 可读流 内 对象模式。 。 。 .

createReader(redis, streamName, opt = {})

回返a 可读流 内 对象模式。 。 。 . opt 可能是一个有下列条目的对象:

• live:等待新添加的项目? 默认 : true
• waitTimeout:等待新增加的物品需要多长时间. 默认 : Infinity
• history: 从流中读取所有过去的项目 ? 默认 : false
• limit: 应读项目的最大数量。 默认 : Infinity

许可证

这个项目有双重许可证: 我的捐款是特许的 繁荣公共许可证, (中文(简体) ), 其他人的贡献 许可证为: Apache 2.0 (英语)。 。 。 .

此许可允许您免费使用和共享此软件用于非商业性目的,并允许您为商业目的尝试此软件30天.

为了公众知识、个人学习、私人娱乐、业余爱好项目、业余追求或宗教戒律.

购买商业执照 或阅读更多关于 为什么我卖私人许可证 我的项目。 。 。 .

捐款

如果您有问题或需要支持,请使用 redis-stream请检查您的代码并先设置。 如果您认为找到了错误或想要提出一个特性,请参考 议题页。 。 。 .

通过贡献,你同意 释放你的修改在 Apache 2.0 许可证。 。 。 .