Redis と JavaScript を使用したリアルタイムメッセージングアプリケーションの構築: ユーザー接続の処理方法-Redis-php.cn

Redis と JavaScript を使用したリアルタイムメッセージングアプリケーションの構築: ユーザー接続の処理方法

王林

リリース： 2023-07-31 17:17:08

オリジナル

826 人が閲覧しました

Redis と JavaScript を使用したリアルタイム通信アプリケーションの構築: ユーザー接続の処理方法

インターネットの急速な発展に伴い、リアルタイム通信アプリケーションの需要が高まっています。 Redis と JavaScript を使用してリアルタイム通信アプリケーションを適切に構築し、リアルタイムメッセージの送受信やオンラインユーザー管理などの機能を実装できます。この記事では、Redis と JavaScript を使用してユーザー接続を処理し、リアルタイム通信アプリケーションを実装する方法を紹介します。

Redis のインストールと構成

まず、Redis サーバーをインストールして構成する必要があります。 Redis の公式 Web サイト (https://redis.io/download) からオペレーティングシステムに適した Redis インストールパッケージをダウンロードし、公式ドキュメントに従ってインストールして構成できます。

JavaScript ファイルの作成

次に、ユーザー接続を処理するための JavaScript ファイルを作成します。バックエンド環境として Node.js を使用するため、最初に Node.js (https://nodejs.org/) をインストールする必要があります。

作成した JavaScript ファイルに、まず必要なモジュールを導入します:

const express = require('express');
const http = require('http');
const socketio = require('socket.io');

ログイン後にコピー

次に、HTTP リクエストを処理するための Express アプリケーションを作成します:

const app = express();
const server = http.createServer(app);
const io = socketio(server);

ログイン後にコピー

ユーザー接続の処理

次に、ユーザー接続を処理する必要があります。ユーザーがアプリに接続すると、一連のアクションを実行する必要があります。

まず、ユーザー接続イベントをリッスンします:

io.on('connection', (socket) => {
  // 处理连接逻辑
});

ログイン後にコピー

次に、接続ロジックを処理します。これには、ユーザーの参加/脱退イベント、メッセージングなどが含まれます。この例では、簡単なチャットルーム機能を追加します。

// 存储在线用户的列表
let onlineUsers = [];

// 监听用户加入事件
socket.on('join', (user) => {
  onlineUsers.push(user);
  io.emit('userJoined', onlineUsers);
});

// 监听用户离开事件
socket.on('disconnect', () => {
  onlineUsers = onlineUsers.filter((user) => user.id !== socket.id);
  io.emit('userLeft', onlineUsers);
});

// 监听消息发送事件
socket.on('sendMessage', (message) => {
  io.emit('newMessage', message);
});

ログイン後にコピー

上記のコードでは、ユーザーが発行したイベントをリッスンすることで接続ロジックを処理します。ユーザーが参加すると、オンラインユーザーリストに追加してすべてのユーザーに通知します。ユーザーが退会すると、オンラインユーザーリストから削除してすべてのユーザーに通知します。ユーザーがメッセージを送信すると、すべてのユーザーにメッセージを送信します。。

Redis を使用してオンラインユーザーを保存する

オンラインユーザーの管理を容易にするために、Redis を使用してオンラインユーザーリストを保存できます。接続ロジックでは、オンラインユーザーリストを Redis に保存し、オンラインユーザーリストの更新を Redis を通じてすべてのユーザーにブロードキャストします。

まず、Redis モジュールをインストールします:

npm install redis

ログイン後にコピー

次に、接続ロジックの先頭に Redis 接続コードを追加します:

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

client.on('error', (err) => {
  console.error(err);
});

// 连接Redis服务器后执行的操作
client.on('connect', () => {
  // 从Redis中获取在线用户列表
  client.smembers('onlineUsers', (err, reply) => {
    if (err) throw err;
    onlineUsers = reply;
    io.emit('userJoined', onlineUsers);
  });
});

// 监听用户加入事件
socket.on('join', (user) => {
  onlineUsers.push(user);
  // 将在线用户列表保存到Redis中
  client.sadd('onlineUsers', user, (err, reply) => {
    if (err) throw err;
    io.emit('userJoined', onlineUsers);
  });
});

// 监听用户离开事件
socket.on('disconnect', () => {
  onlineUsers = onlineUsers.filter((user) => user.id !== socket.id);
  // 从Redis中删除离线用户
  client.srem('onlineUsers', socket.id, (err, reply) => {
    if (err) throw err;
    io.emit('userLeft', onlineUsers);
  });
});

ログイン後にコピー

このようにして、とを追加できます。ユーザーが参加するときに退席するとき、オンラインユーザーリストを Redis に保存し、Redis を通じてオンラインユーザーリストを取得します。