PHP と Thrift を使用したリアルタイムのデータ対話-PHPチュートリアル-php.cn

PHP と Thrift を使用したリアルタイムのデータ対話

WBOY

リリース： 2023-06-28 11:28:01

オリジナル

1114 人が閲覧しました

インターネット技術の継続的な発展に伴い、リアルタイムのデータ対話はあらゆる分野でますます重要になってきています。 PHP と Thrift テクノロジーを使用してリアルタイムのデータ対話を実現することは、非常に実現可能なソリューションになりました。この記事では、PHP と Thrift を使用してリアルタイムのデータ対話を実現する方法と、簡単な例を紹介します。

1.倹約とは何ですか?

Thrift は、Facebook によって開発されたクロスランゲージリモートプロシージャコール (RPC) フレームワークです。 Java、PHP、Python などを含む複数のプログラミング言語をサポートしています。 Thrift は、IDL (インターフェイス定義言語) を使用してデータ型とサービスインターフェイスを定義し、コードジェネレーターを使用してクライアントとサーバーのコードをさまざまなプログラミング言語で生成し、クライアントとサーバーが言語を超えて通信できるようにします。

Thrift の重要な特徴は、XML や JSON の代わりにバイナリプロトコルを使用することです。これにより、Thrift はデータを効率的に送信できるようになり、ユーザーはデータ圧縮アルゴリズムをカスタマイズして送信効率を向上させることができます。

2. Thrift の使用方法は?

Thrift のインストール

Thrift は次のコマンドでインストールできます:

sudo apt-get install thrift-compiler

ログイン後にコピー

または、公式 Web サイトからダウンロードしてインストールできます: https://thrift .apache.org/download

Thrift ファイルの作成

Thrift は IDL を使用してデータ型とサービスインターフェイスを定義します。以下は、サービスインターフェイスとデータ型を含む単純な Thrift ファイルの例です。

namespace php example

struct Person {
    1: required string name,
    2: optional string email,
    3: optional bool gender,
}

service PersonService {
    bool addPerson(1: Person person),
    bool deletePerson(1: string name),
    Person getPerson(1: string name),
}

ログイン後にコピー

この例では、名前、電子メール、性別などの情報を含むデータ構造 person を定義します。また、個人情報の追加、削除、クエリの機能を含む PersonService サービスインターフェイスも定義しました。

コードの生成

次のコマンドを実行して PHP コードを生成します:

thrift --gen php example.thrift

ログイン後にコピー

このコマンドは、Thrift ファイル example.thrift に基づいて PHP コードを生成します。。

サーバー側のコードの作成

サーバー側では、PersonService サービスインターフェイスを実装する必要があります。以下は、簡単な PHP コードの例です。

<?php
namespace example;

require_once 'PersonService.php';

class PersonServiceImpl implements examplePersonServiceIf {

    public function addPerson(examplePerson $person) {
        // 插入数据库等操作
        return true;
    }

    public function deletePerson($name) {
        // 从数据库中删除指定姓名的信息
        return true;
    }

    public function getPerson($name) {
        // 从数据库中查询指定姓名的信息
        return $person;
    }
}

ログイン後にコピー

この例では、PersonServiceIf インターフェイスを実装し、特定のビジネスロジックに従って addperson、deleteperson、および getperson メソッドを記述します。

クライアントコードの記述

クライアント側では、リモートサービスを呼び出すコードを記述する必要があります。 Thrift によって生成されたクライアントコードを使用すると、このプロセスを簡単に実装できます。以下は、単純な PHP クライアントコードの例です。

<?php
namespace example;

require_once 'PersonService.php';

// 连接服务端
$socket = new ThriftTransportTSocket('localhost', 9090);
$transport = new ThriftTransportTBufferedTransport($socket, 1024, 1024);
$protocol = new ThriftProtocolTBinaryProtocol($transport);
$client = new examplePersonServiceClient($protocol);

// 调用addPerson方法
$person = new examplePerson();
$person->name = 'Tom';
$person->email = 'tom@example.com';
$person->gender = true;
$result = $client->addPerson($person);

// 调用deletePerson方法
$name = 'Tom';
$result = $client->deletePerson($name);

// 调用getPerson方法
$name = 'Tom';
$person = $client->getPerson($name);

ログイン後にコピー

この例では、まず Thrift が提供する Transport クラスと Protocol クラスを使用してサーバーに接続し、クライアントオブジェクトをインスタンス化します。次に、addperson メソッド、deleteperson メソッド、getperson メソッドを呼び出して、ネットワーク送信を介したクライアントとサーバー間のリアルタイムのデータ対話を実現しました。

3. リアルタイムデータインタラクションの実現例

次は、PHP と Thrift を使用してリアルタイムデータインタラクションを実現する方法を示す簡単な例です。ユーザーがメッセージを送信でき、他のユーザーがそのメッセージを見ることができるオンラインチャットルームがあるとします。 Thrift を使用してメッセージ構造とチャットサービスインターフェイスを定義し、PHP を使用してサーバーとクライアントを実装できます。

Thrift ファイルの定義

メッセージの送信者、受信者、送信時刻、メッセージ内容などの情報を含む Message クラスを定義します。また、メッセージの送信とすべてのメッセージの取得の機能を含む ChatService サービスインターフェイスも定義しました。

namespace php example

struct Message {
    1: required string from,
    2: required string to,
    3: required i32 timestamp,
    4: required string content,
}

service ChatService {
    bool sendMessage(1: Message message),
    list<Message> getAllMessages(),
}

ログイン後にコピー

コードの生成

次のコマンドを実行して PHP コードを生成します:

thrift --gen php example.thrift

ログイン後にコピー

生成されたコードには、Person.php、PersonService.php、PersonServiceClient が含まれます.php や Thrift などのファイル。

サーバー側のコードを記述する

サーバー側では、ChatService サービスインターフェイスを実装する必要があります。以下は簡単な PHP コードの例です:

<?php
namespace example;

require_once 'ChatService.php';

class ChatServiceImpl implements exampleChatServiceIf {
    
    private $messages = [];

    public function sendMessage(exampleMessage $message) {
        $this->messages[] = $message;
        return true;
    }

    public function getAllMessages() {
        return $this->messages;
    }
}

ログイン後にコピー

この例では、ChatServiceIf インターフェイスを実装し、配列を使用して受信したすべてのメッセージを保存します。サーバーがメッセージを受信すると、それを配列に保存します。クライアントが getAllMessages メソッドを呼び出すと、保存されているすべてのメッセージが返されます。

クライアントコードの記述

クライアント側では、リモートサービスを呼び出すコードを記述する必要があります。以下は、単純な PHP クライアントコードの例です。

<?php
namespace example;

require_once 'ChatService.php';

// 连接服务端
$socket = new ThriftTransportTSocket('localhost', 9090);
$transport = new ThriftTransportTBufferedTransport($socket, 1024, 1024);
$protocol = new ThriftProtocolTBinaryProtocol($transport);
$client = new exampleChatServiceClient($protocol);

// 发送消息
$message = new exampleMessage();
$message->from = 'Tom';
$message->to = 'Jerry';
$message->timestamp = time();
$message->content = 'Hello, Jerry!';
$client->sendMessage($message);

// 获取所有消息并输出
$messages = $client->getAllMessages();
foreach ($messages as $message) {
    echo "{$message->from} to {$message->to} at {$message->timestamp}: {$message->content}
";
}

ログイン後にコピー

この例では、最初にクライアントオブジェクトを作成し、Thrift が提供するクラスを使用してサーバーに接続します。次に、メッセージを送信し、sendMessage メソッドを呼び出し、getAllMessages メソッドを使用してすべてのメッセージを取得して出力します。

5. 結論

PHP と Thrift を使用してリアルタイムのデータインタラクションを実現することで、言語を超えたコミュニケーションを簡単に実現でき、異なるプラットフォーム間のデータインタラクションがより効率的かつ信頼性の高いものになります。同時に、Thrift のクロスランゲージ機能により、アプリケーションの拡張とメンテナンスがより簡単かつ柔軟になります。

以上がPHP と Thrift を使用したリアルタイムのデータ対話の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。