Bina aplikasi pemberitahuan segera yang ringkas menggunakan Redis dan JavaScript

Bina aplikasi pemberitahuan segera yang ringkas menggunakan Redis dan JavaScript

Dalam pembangunan aplikasi moden, pemberitahuan segera telah menjadi ciri yang semakin biasa dan penting. Ia boleh membantu aplikasi menyampaikan maklumat masa nyata kepada pengguna dengan cepat dan tepat, meningkatkan pengalaman pengguna dan interaktiviti. Artikel ini akan memperkenalkan cara membina aplikasi pemberitahuan segera yang ringkas menggunakan Redis dan JavaScript.

Pertama, kita perlu memahami Redis. Redis ialah sistem storan nilai kunci sumber terbuka, yang sangat sesuai digunakan sebagai pangkalan data cache. Ia berdasarkan ingatan, menyediakan operasi baca dan tulis berprestasi tinggi, dan menyokong pelbagai struktur data dan kaedah operasi. Dalam aplikasi ini, kami akan menggunakan Redis untuk menyimpan maklumat langganan pengguna dan baris gilir mesej.

Sebelum bermula, pastikan Redis telah dipasang dalam sistem dan pemacu Redis yang sepadan telah diimport ke dalam aplikasi.

1. Buat penerbitan dan langganan mesej

Pertama, kita perlu mencipta penerbit dan pelanggan masing-masing untuk menerbitkan dan melanggan mesej pemberitahuan.

const redis = require('redis');
const publisher = redis.createClient();
const subscriber = redis.createClient();

// 发布消息
publisher.publish('notifications', '您有新的通知消息');

// 订阅消息
subscriber.subscribe('notifications');
subscriber.on('message', (channel, message) => {
  console.log(`收到来自 ${channel} 的消息: ${message}`);
});

Dengan kod di atas, kami mencipta penerbit Redis dan pelanggan. Penerbit menerbitkan mesej kepada saluran pemberitahuan yang ditentukan melalui kaedah publisher.publish dan pelanggan melanggan saluran melalui subscriber.subscribe. Apabila mesej baharu diterbitkan ke saluran, pelanggan akan mencetuskan acara mesej dan mencetak mesej yang diterima. publisher.publish 方法发布消息到指定频道 notifications，而订阅者通过 subscriber.subscribe 订阅该频道。当有新的消息发布到频道时，订阅者会触发 message 事件，并打印出收到的消息。

2. 存储订阅信息

下一步是存储用户的订阅信息，以便在有新消息时能够即时通知到用户。我们可以使用 Redis 的哈希表数据结构来存储用户ID和对应的频道信息。

const redis = require('redis');
const client = redis.createClient();

// 存储订阅信息
function subscribeUser(userId, channel) {
  client.hset('subscriptions', userId, channel);
}

// 获取订阅信息
function getUserSubscription(userId) {
  return new Promise((resolve, reject) => {
    client.hget('subscriptions', userId, (err, channel) => {
      if (err) {
        reject(err);
      } else {
        resolve(channel);
      }
    });
  });
}

// 删除订阅信息
function unsubscribeUser(userId) {
  client.hdel('subscriptions', userId);
}

上述代码中，我们使用 Redis 的 hset 方法将用户ID作为哈希表的键，频道作为值，存储到 subscriptions 哈希表中。可以通过 hget 方法获取用户的订阅频道信息，并通过 hdel 方法删除用户的订阅信息。

3. 实现页面订阅和推送

最后一步是在前端页面实现用户的订阅和接收推送消息的功能。我们将使用 WebSocket 技术来实现消息的实时推送。

const socket = new WebSocket('ws://localhost:3000');

// 订阅通知
function subscribeNotifications(userId) {
  socket.send(JSON.stringify({
    event: 'subscribe',
    userId
  }));
}

// 接收消息
socket.onmessage = (event) => {
  const message = JSON.parse(event.data);
  if (message.event === 'notification') {
    console.log(`收到新的通知: ${message.content}`);
  }
};

在前端代码中，我们创建了一个 WebSocket 客户端，并通过 socket.send 方法发送订阅消息的请求。当有新的消息推送到客户端时，会触发 socket.onmessage

Maklumat langganan storan

Langkah seterusnya ialah menyimpan maklumat langganan pengguna supaya pengguna boleh dimaklumkan dengan segera apabila terdapat mesej baharu. Kami boleh menggunakan struktur data jadual cincang Redis untuk menyimpan ID pengguna dan maklumat saluran yang sepadan.

rrreee

Dalam kod di atas, kami menggunakan kaedah hset Redis untuk menyimpan ID pengguna sebagai kunci jadual cincang dan saluran sebagai nilai ke dalam jadual cincang langganan . Anda boleh mendapatkan maklumat saluran langganan pengguna melalui kaedah hget dan memadam maklumat langganan pengguna melalui kaedah hdel.

🎜Laksanakan langganan halaman dan tolak 🎜🎜🎜Langkah terakhir ialah melaksanakan fungsi langganan pengguna dan menerima mesej tolak pada halaman hadapan. Kami akan menggunakan teknologi WebSocket untuk mencapai tolakan mesej masa nyata. 🎜rrreee🎜Dalam kod bahagian hadapan, kami mencipta klien WebSocket dan menghantar permintaan untuk melanggan mesej melalui kaedah socket.send. Apabila mesej baharu ditolak kepada klien, acara socket.onmessage akan dicetuskan dan kandungan pemberitahuan yang diterima akan dicetak. 🎜🎜Dengan kod di atas, kami telah melengkapkan aplikasi pemberitahuan segera ringkas yang dibina dengan Redis dan JavaScript. Ia termasuk fungsi penerbitan dan langganan mesej, yang boleh menyimpan maklumat langganan pengguna dan menolaknya kepada pelanggan serta-merta apabila mesej baharu tersedia. Ini hanyalah contoh pelaksanaan asas, anda boleh menjalankan pembangunan dan pengembangan sekunder mengikut keperluan anda sendiri. 🎜🎜Ringkasan: 🎜🎜Menggunakan Redis dan JavaScript, kami boleh membina aplikasi pemberitahuan segera yang ringkas dengan mudah. Redis menyediakan operasi baca dan tulis berprestasi tinggi untuk menyimpan maklumat langganan dan baris gilir mesej JavaScript menyediakan alat pembangunan yang mudah dan teknologi WebSocket untuk melaksanakan fungsi langganan dan tolak. Aplikasi ini boleh digunakan secara meluas dalam pemberitahuan masa nyata, sistem sembang, pemantauan masa nyata dan senario lain untuk memberikan pengguna pengalaman dan interaktiviti yang baik. 🎜

Atas ialah kandungan terperinci Bina aplikasi pemberitahuan segera yang ringkas menggunakan Redis dan JavaScript. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!