Redis Pub/Sub
Redis Pub/Sub implements the messaging system where the publishers sends the messages while the subscribers receive them.
Aside from data storage, Redis can be used as a Publisher/Subscriber platform. In this pattern, publishers can issue messages to any number of subscribers on a channel. These messages are fire-and-forget, in that if a message is published and no subscribers exists, the message evaporates and cannot be recovered.
Before the usage remember to install required packages.
$ yarn add redis
microservice.ts
client.ts
import { createMicroservice, Transport } from '@marblejs/messaging';
const microservice = createMicroservice({
transport: Transport.REDIS
options: {
host: 'redis://127.0.0.1:6379',
channel: 'hello_channel',
},
// ...
});
import { MessagingClient, createMicroservice, Transport } from '@marblejs/messaging';
const client = MessagingClient({
transport: Transport.REDIS
options: {
host: 'redis://127.0.0.1:6379',
channel: 'hello_channel',
},
// ...
});
The
options property is specific to the chosen transport layer. REDIS exposes the following properties:Attribute | description |
host | Host address of the Redis server |
channel | Channel name which your microservice will listen to |
timeout | Timeout for RPC-like communication. Defaults to 120 seconds |
port | Port of the Redis server |
password | If set, client will run Redis auth command on connect. |
Last modified 2yr ago