redis_pubsub_subscriber_publisher_channel_messaging_quickstart.ts

1import { createClient } from 'redis';
2
3async function run() {
4  const subscriber = createClient();
5  const publisher = createClient();
6
7  subscriber.on('error', (err) => console.error('Subscriber Error', err));
8  publisher.on('error', (err) => console.error('Publisher Error', err));
9
10  await subscriber.connect();
11  await publisher.connect();
12
13  // Subscribe to a channel
14  await subscriber.subscribe('article-updates', (message) => {
15    console.log(`Received message: ${message}`);
16  });
17
18  // Publish a message to the same channel
19  await publisher.publish('article-updates', 'New article published!');
20
21  // Optional: Unsubscribe and disconnect after a delay
22  setTimeout(async () => {
23    await subscriber.unsubscribe('article-updates');
24    await subscriber.quit();
25    await publisher.quit();
26  }, 5000);
27}
28
29run().catch(console.error);