Memcache と PHP を使用した高パフォーマンスのサーバー側プッシュ サービスを実装する

インターネット技術の継続的な発展に伴い、ネットワーク アプリケーションに対するパフォーマンス要件はますます高くなっています。この前提の下、サーバー側のプッシュ サービスは、リアルタイム通信ソリューションとして、ますます多くのアプリケーションに採用されています。この記事では、Memcache と PHP を使用して、高パフォーマンスのサーバーサイド プッシュ サービスを実装する方法を紹介します。

1.サーバーサイドプッシュサービスとは何ですか?

サーバー側プッシュ サービスとは、クライアントが積極的にデータを要求することなく、サーバーがクライアントに積極的にデータを送信することを意味します。たとえば、チャット ルームでは、ユーザーがメッセージを送信した後、各ユーザーがリクエストしなくても、すべてのオンライン ユーザーがメッセージを受信できます。これにより、リアルタイム パフォーマンスが大幅に向上し、サーバーへの負荷も軽減されます。

2. Memcache の役割

Memcache はデータをキャッシュするためのツールです。その機能は、データの読み取りと書き込みを高速化するためにデータをメモリに保存することです。サーバー側のプッシュ サービスでは、Memcache の役割は、サーバーとデータベースへの負荷を軽減するために送信する必要があるメッセージをキャッシュすることです。

3. PHP を使用してサーバーサイド プッシュ サービスを実装する

次に、PHP を使用してサーバーサイド プッシュ サービスを実装します。この記事では、次の 3 つの部分で構成されるチャット ルーム システムがすでにあることを前提とします。

1. オンライン ユーザー リスト

オンライン ユーザー リストは、現在のチャットを指します。 room ルーム内のユーザーのリスト。すぐにアクセスできるように、オンライン ユーザー リストを Memcache にキャッシュする必要があります。

2. メッセージ リスト

メッセージ リストとは、すべてのユーザーによって送信されたメッセージのリストを指します。すぐにアクセスできるように、メッセージ リストを Memcache にキャッシュする必要があります。同時に、クライアントが新しいメッセージがあるかどうかを判断しやすくするために、メッセージ リストにタイムスタンプ フィールドを追加する必要があります。

3. プッシュ サービス

プッシュ サービスは、クライアントにプッシュする必要があるメッセージをアクティブに送信するサービスを指します。私たちのシステムでは、WebSocket を使用してプッシュ サービスを実装します。

以下は詳細な実装手順です:

1. オンライン ユーザー リストのキャッシュ

ユーザーがログに記録するときに、オンライン ユーザー リストにユーザーを追加できます。で。その後、ユーザーがログアウトすると、オンライン ユーザーのリストから削除されます。オンライン ユーザー リストは次のようにキャッシュされます:

$memcache = new Memcache;
$memcache->addServer('localhost', 11211);

// オンライン ユーザーを追加しますlist Cache
$onlineUsers = array('user1', 'user2', 'user3');
$memcache->set('online_users', $onlineUsers, 0, 0);

// キャッシュからオンライン ユーザー リストを取得します
$onlineUsers = $memcache->get('online_users');

2. キャッシュ メッセージ リスト

ユーザーがメッセージを送信すると、そのメッセージをメッセージ リストに追加できます。次に、プッシュ サービスでメッセージ リストをクライアントに送信します。クライアントが新しいメッセージがあるかどうかを判断しやすくするために、メッセージ リストにタイムスタンプ フィールドを追加する必要があります。メッセージ リストは次のようにキャッシュされます:

$memcache = new Memcache;
$memcache->addServer('localhost', 11211);

// メッセージ リストを次のように追加します。キャッシュ
$messages = array(

array('user' => 'user1', 'message' => 'hello', 'timestamp' => time()),
array('user' => 'user2', 'message' => 'world', 'timestamp' => time())

);
$memcache->set('messages', $messages, 0, 0);

// Getキャッシュからのメッセージ リスト
$messages = $memcache->get('messages');

3. プッシュ サービスの実装

WebSocket を使用してプッシュを実装します。サービス。 WebSocket は、最新のブラウザで使用できるリアルタイム通信プロトコルです。 PHP では、Ratchet を使用して WebSocket を実装できます。プッシュ サービスの実装方法は次のとおりです。

//Ratchet ライブラリの紹介
require __DIR__.'/vendor/autoload.php';

use RatchetMessageComponentInterface;
use RatchetConnectionInterface;

// WebSocket プッシュ サービス
class Chat は MessageComponentInterface を実装します
{

protected $clients;

public function __construct() 
{
    $this->clients = new SplObjectStorage;
}

public function onOpen(ConnectionInterface $conn) 
{
    $this->clients->attach($conn);
}

public function onMessage(ConnectionInterface $from, $msg) 
{
    $memcache = new Memcache;
    $memcache->addServer('localhost', 11211);

    // 获取在线用户列表和消息列表
    $onlineUsers = $memcache->get('online_users');
    $messages = $memcache->get('messages');

    // 发送消息给所有客户端
    foreach ($this->clients as $client) 
    {
        $client->send(json_encode(array(
            'type' => 'message',
            'online_users' => $onlineUsers,
            'messages' => $messages
        )));
    }
}

public function onClose(ConnectionInterface $conn) 
{
    $this->clients->detach($conn);
}

public function onError(ConnectionInterface $conn, Exception $e) 
{
    $conn->close();
}

}

// WebSocket サーバーを作成して
$app を起動します= new RatchetApp ('localhost', 8080);
$app->route('/chat', new Chat);
$app->run();

4.クライアントの実装

クライアントは、最新のブラウザを使用して実装できます。クライアントの HTML および JavaScript コードは次のとおりです:

<title>WebSocket Chat</title>

<ul id="messages"></ul>

<form action="">
    <input id="message" type="text">
    <button>Send</button>
</form>

<script>
    var ws = new WebSocket("ws://localhost:8080/chat");

    ws.onmessage = function(event) {
        var data = JSON.parse(event.data);

        // 更新在线用户列表
        var onlineUsers = data.online_users;
        for (var i = 0; i < onlineUsers.length; i++) {
            // add online user to list
        }

        // 更新消息列表
        var messages = data.messages;
        for (var i = 0; i < messages.length; i++) {
            // add message to list
        }
    };

    document.querySelector("form").addEventListener("submit", function(event) {
        event.preventDefault();
        var input = document.querySelector("input#message");
        ws.send(input.value);
        input.value = "";
    });
</script>

5. まとめ

この記事では、Memcache と PHP を使用して高パフォーマンスのサーバー側プッシュ サービスを実装する方法を紹介します。オンライン ユーザー リストとメッセージ リストをメモリにキャッシュすることにより、サーバーとデータベースへの負荷を大幅に軽減できます。同時に、WebSocket プロトコルを使用してリアルタイム通信を実現できるため、リアルタイム パフォーマンスが向上します。

以上がMemcache と PHP を使用した高パフォーマンスのサーバー側プッシュ サービスを実装するの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。