Rdbs is a robust redis pub/sub wrapper and redis request/reply es6 implementation
npm i -S rdbsconst Rdbs = require('rdbs')Use ioredis configuration
const redisConfig = {
port: 6379, // default
host: '127.0.0.1', // default
password: 'auth',
db: 0 // default
}const ioredis = Rdbs.createRedis(redisConfig)Here is a simple example of the API for publish/subscribe. The following program opens two client connections. It subscribes to a channel with one connection and publishes to that channel with the other under the hood:
const Rdbs = require('rdbs')
const pubSub = Rdbs.createPubSub(redisConfig)
pubSub.on('foo', message => {
console.log('first listener catch foo -> %s', message)
})
pubSub.on('foo', message => {
console.log('second listener catch foo -> %s', message)
})
pubSub.emit('foo', 'bar')
// first listener catched foo -> bar
// second listener catched foo -> barAlso you can send an object (command pattern)
const pubSub = rdbs.createPubSub(redisConfig);
pubSub.on('conect', () => {
// handle connection
})
pubSub.on('error', error => {
// handle error
})
pubSub.on('foo', data => {
console.log('catch foo', data);
});
pubSub.emit('foo', {bar:'bar'});
// catched foo { bar: 'bar' }If you want to get response from another app, you have to use req/rep pattern
const reqRep = Rdbs.createReqRep(redisConfig);
reqRep.on('conect', () => {
// handle connection
})
reqRep.on('error', error => {
// handle error
})
reqRep.on('req', (data, cb) => {
console.log('catch request', data);
//simulate async data processing
setTimeout(() => cb({ response: 'response' }), 2000);
});
reqRep.req('req', { request: 'request' })
.then(response => {
console.log('reply is', response);
}).catch((err) => {
// you own error handler
});
// catch request { request: 'request' }
// reply is { response: 'response' }If you want to join this case by help maintaining something, please don't hesitate to contact.
I'm happy to receive bug reports, fixes, documentation enhancements, and any other improvements.
And since I'm not a native English speaker, if you find any grammar mistakes in the documentation, please also let me know. :)
React
Typescript
Django
Laravel
Facebook
Microsoft
Google
Alibaba
D3
Tencent