Erstellen Sie eine einfache Sofortbenachrichtigungsanwendung mit Redis und JavaScript

Erstellen Sie eine einfache Sofortbenachrichtigungsanwendung mit Redis und JavaScript

In der modernen Anwendungsentwicklung ist die Sofortbenachrichtigung zu einer immer häufigeren und wichtigeren Funktion geworden. Es kann Anwendungen dabei helfen, Benutzern schnell und genau Informationen in Echtzeit bereitzustellen und so das Benutzererlebnis und die Interaktivität zu verbessern. In diesem Artikel wird erläutert, wie Sie mithilfe von Redis und JavaScript eine einfache Sofortbenachrichtigungsanwendung erstellen.

Zuerst müssen wir Redis verstehen. Redis ist ein Open-Source-Schlüsselwertspeichersystem, das sich sehr gut für die Verwendung als Cache-Datenbank eignet. Es basiert auf Speicher, bietet leistungsstarke Lese- und Schreibvorgänge und unterstützt eine Vielzahl von Datenstrukturen und Betriebsmethoden. In dieser Anwendung verwenden wir Redis zum Speichern von Benutzerabonnementinformationen und Nachrichtenwarteschlangen.

Stellen Sie vor dem Start sicher, dass Redis im System installiert und der entsprechende Redis-Treiber in die Anwendung importiert wurde.

1. Erstellen Sie eine Nachrichtenveröffentlichung und ein Abonnement.

Zuerst müssen wir einen Herausgeber und einen Abonnenten für die Veröffentlichung bzw. das Abonnement von Benachrichtigungsnachrichten erstellen.

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}`);
});

Mit dem obigen Code erstellen wir einen Redis-Publisher und einen Abonnenten. Der Herausgeber veröffentlicht Nachrichten im angegebenen Kanal notifications über die Methode publisher.publish und der Abonnent abonniert den Kanal über subscriber.subscribe. Wenn eine neue Nachricht im Kanal veröffentlicht wird, löst der Abonnent das Ereignis message aus und druckt die empfangene Nachricht aus. 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

Abonnementinformationen speichern

Der nächste Schritt besteht darin, die Abonnementinformationen des Benutzers zu speichern, damit der Benutzer sofort benachrichtigt werden kann, wenn neue Nachrichten vorliegen. Wir können die Hash-Tabellen-Datenstruktur von Redis verwenden, um Benutzer-IDs und entsprechende Kanalinformationen zu speichern.

rrreee

Im obigen Code verwenden wir die hset-Methode von Redis, um die Benutzer-ID als Schlüssel der Hash-Tabelle und den Kanal als Wert in der subscriptions-Hash-Tabelle zu speichern . Sie können die Abonnementkanalinformationen des Benutzers über die Methode hget abrufen und die Abonnementinformationen des Benutzers über die Methode hdel löschen.

🎜Seitenabonnement und Push implementieren 🎜🎜🎜Der letzte Schritt besteht darin, die Funktion des Benutzerabonnements und des Empfangs von Push-Nachrichten auf der Frontend-Seite zu implementieren. Wir werden die WebSocket-Technologie verwenden, um einen Echtzeit-Push von Nachrichten zu erreichen. 🎜rrreee🎜Im Front-End-Code erstellen wir einen WebSocket-Client und senden eine Anfrage zum Abonnieren der Nachricht über die Methode socket.send. Wenn eine neue Nachricht an den Client gesendet wird, wird das Ereignis socket.onmessage ausgelöst und der empfangene Benachrichtigungsinhalt wird ausgedruckt. 🎜🎜Mit dem obigen Code haben wir eine einfache Sofortbenachrichtigungsanwendung fertiggestellt, die mit Redis und JavaScript erstellt wurde. Es umfasst Nachrichtenveröffentlichungs- und Abonnementfunktionen, mit denen Benutzerabonnementinformationen gespeichert und sofort an den Client übertragen werden können, wenn neue Nachrichten verfügbar sind. Dies ist nur ein einfaches Implementierungsbeispiel. Sie können eine sekundäre Entwicklung und Erweiterung entsprechend Ihren eigenen Anforderungen durchführen. 🎜🎜Zusammenfassung: 🎜🎜Mit Redis und JavaScript können wir ganz einfach eine einfache Sofortbenachrichtigungsanwendung erstellen. Redis bietet leistungsstarke Lese- und Schreibvorgänge zum Speichern von Abonnementinformationen und Nachrichtenwarteschlangen. JavaScript bietet praktische Entwicklungstools und WebSocket-Technologie zur Implementierung von Abonnement- und Push-Funktionen. Diese Anwendung kann häufig in Echtzeitbenachrichtigungen, Chatsystemen, Echtzeitüberwachung und anderen Szenarien eingesetzt werden, um Benutzern ein gutes Erlebnis und Interaktivität zu bieten. 🎜

Das obige ist der detaillierte Inhalt vonErstellen Sie eine einfache Sofortbenachrichtigungsanwendung mit Redis und JavaScript. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!