close

Messaging le Redis agus NodeJ

Messaging Is é ceann de na feidhmchláir choitianta é Redis nuair a chomhtháthaítear é le NodeJS. Redis soláthraíonn sé struchtúir sonraí sholúbtha amhail Pub/Sub(Publish/Subscribe) agus Message Queue, a chumasaíonn tógáil córas cumarsáide agus malartú sonraí idir comhpháirteanna in fheidhmchlár.

Pub/Sub(Publish/Subscribe)

Pub/Sub ligeann sé do chomhpháirteanna an fheidhmchláir cumarsáid a dhéanamh trí theachtaireachtaí a chlárú agus a chraoladh. Is féidir le comhpháirt feidhmiú mar fhoilsitheoir, teachtaireachtaí a sheoladh chuig cainéal, agus is féidir le comhpháirteanna eile gníomhú mar shíntiúsóirí, ag éisteacht le teachtaireachtaí ar an gcainéal sin.

Sampla de úsáid Pub/Sub le Redis agus NodeJS:

const Redis = require('ioredis');  
const subscriber = new Redis();  
const publisher = new Redis();  
  
// Subscribe and listen for messages on the 'notifications' channel  
subscriber.subscribe('notifications',(err, count) => {  
  console.log(`Subscribed to ${count} channels.`);  
});  
  
// Handle messages when received from the 'notifications' channel  
subscriber.on('message',(channel, message) => {  
  console.log(`Received message from channel '${channel}': ${message}`);  
});  
  
// Publish a message to the 'notifications' channel  
publisher.publish('notifications', 'New notification!');

Message Queue

Redis is féidir é a úsáid mar Message Queue phoist asincrónacha a bhainistiú agus a phróiseáil. Cuidíonn sé seo le latency a laghdú agus méadaíonn sé scalability an iarratais.

Sampla de úsáid Message Queue le Redis agus NodeJS:

const Redis = require('ioredis');  
const client = new Redis();  
  
// Add a task to the 'tasks' queue  
client.rpush('tasks', JSON.stringify({ id: 1, data: 'Task 1' }));  
  
// Process tasks from the 'tasks' queue  
function processTask() {  
  client.lpop('tasks',(err, task) => {  
    if(task) {  
      const parsedTask = JSON.parse(task);  
      console.log('Processing task:', parsedTask);  
      // Process the task here...  
  
      // Continue processing the next tasks  
      processTask();  
    }  
  });  
}  
  
// Start processing tasks from the queue  
processTask();

Nóta: Is samplaí bunúsacha iad seo d'úsáid Redis le Messaging NodeJS. Go praiticiúil, Messaging is féidir le córais cur chun feidhme agus scálaithe a bheith níos casta agus ag brath ar shainriachtanais an fheidhmchláir. Smaoinigh ar shlándáil, láimhseáil earráidí, agus barrfheabhsú feidhmíochta agus tú ag comhtháthú Redis le NodeJS i Messaging gcórais níos casta.