Interaksi data masa nyata menggunakan PHP dan Thrift

Dengan perkembangan berterusan teknologi Internet, interaksi data masa nyata menjadi semakin penting dalam semua lapisan masyarakat. Menggunakan teknologi PHP dan Thrift untuk mencapai interaksi data masa nyata telah menjadi penyelesaian yang sangat boleh dilaksanakan. Artikel ini akan memperkenalkan cara menggunakan PHP dan Thrift untuk mencapai interaksi data masa nyata, dan memberikan contoh mudah.

1. Apakah itu Jimat?

Thrift ialah rangka kerja panggilan prosedur jauh (RPC) merentas bahasa yang dibangunkan oleh Facebook. Ia menyokong pelbagai bahasa pengaturcaraan, termasuk Java, PHP, Python, dll. Thrift menggunakan IDL (Interface Definition Language) untuk mentakrifkan jenis data dan antara muka perkhidmatan, dan kemudian menggunakan penjana kod untuk menjana kod klien dan pelayan dalam bahasa pengaturcaraan yang berbeza, membolehkan klien dan pelayan berkomunikasi merentas bahasa.

Ciri penting Thrift ialah ia menggunakan protokol binari dan bukannya XML atau JSON. Ini membolehkan Thrift menghantar data dengan cekap dan membolehkan pengguna menyesuaikan algoritma pemampatan data untuk meningkatkan kecekapan penghantaran.

2. Bagaimana cara menggunakan Jimat?

1. Pasang Thrift

Kita boleh memasang Thrift melalui arahan berikut:

sudo apt-get install thrift-compiler

atau muat turun dan pasang melalui laman web rasmi: https://thrift.apache.org/download

2. Menulis fail Thrift

menggunakan IDL Tentukan jenis data dan antara muka perkhidmatan. Berikut ialah contoh fail Thrift yang mudah, termasuk antara muka perkhidmatan dan jenis data:

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),
}

Dalam contoh ini, kami mentakrifkan struktur data Orang, yang mengandungi maklumat seperti nama, e-mel dan jantina. Kami juga menentukan antara muka perkhidmatan PersonService, yang merangkumi fungsi menambah, memadam dan menanya maklumat peribadi.

Jana kod

Laksanakan arahan berikut untuk menjana kod PHP:

thrift --gen php example.thrift

Arahan ini akan menjana kod PHP berdasarkan contoh fail Thrift.thrift.

Tulis kod bahagian pelayan

Di bahagian pelayan, kita perlu melaksanakan antara muka perkhidmatan PersonService. Berikut ialah contoh kod PHP mudah:

<?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;
    }
}

Dalam contoh ini, kami melaksanakan antara muka PersonServiceIf dan menulis kaedah addPerson, deletePerson dan getPerson mengikut logik perniagaan tertentu.

Menulis kod pelanggan

Di pihak pelanggan, kita perlu menulis kod untuk memanggil perkhidmatan jauh. Menggunakan kod klien yang dijana oleh Thrift, kami boleh melaksanakan proses ini dengan mudah. Berikut ialah contoh kod klien PHP mudah:

<?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);

Dalam contoh ini, kami mula-mula menggunakan kelas Pengangkutan dan Protokol yang disediakan oleh Thrift untuk menyambung ke pelayan dan membuat instantiate objek klien. Kemudian kami memanggil kaedah addPerson, kaedah deletePerson dan kaedah getPerson untuk merealisasikan interaksi data masa nyata antara klien dan pelayan melalui penghantaran rangkaian.

3. Contoh merealisasikan interaksi data masa nyata

Berikut ialah contoh mudah yang menunjukkan cara menggunakan PHP dan Thrift untuk merealisasikan interaksi data masa nyata. Katakan kita mempunyai ruang sembang dalam talian di mana pengguna boleh menghantar mesej dan pengguna lain boleh melihat mesej tersebut. Kita boleh menggunakan Thrift untuk menentukan struktur mesej dan antara muka perkhidmatan sembang, dan menggunakan PHP untuk melaksanakan pelayan dan klien.

Tentukan fail Jimat

Kami mentakrifkan kelas Mesej, yang mengandungi maklumat seperti penghantar, penerima, masa penghantaran dan kandungan mesej mesej. Kami juga menentukan antara muka perkhidmatan ChatService, yang merangkumi fungsi menghantar mesej dan mendapatkan semua mesej.

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(),
}

Jana kod

Laksanakan arahan berikut untuk menjana kod PHP:

thrift --gen php example.thrift

Kod yang dijana termasuk fail seperti Person.php, PersonService.php, PersonServiceClient.php dan Thrift.

Menulis kod sebelah pelayan

Di bahagian pelayan, kita perlu melaksanakan antara muka perkhidmatan ChatService Berikut ialah contoh kod PHP yang mudah:

<?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;
    }
}

Dalam contoh ini, kami melaksanakan antara muka ChatServiceIf dan menggunakan tatasusunan untuk. simpannya Semua mesej diterima. Apabila pelayan menerima mesej, kami menyimpannya dalam tatasusunan. Apabila pelanggan memanggil kaedah getAllMessages, kami mengembalikan semua mesej yang disimpan.

Menulis kod pelanggan

Di pihak pelanggan, kita perlu menulis kod untuk memanggil perkhidmatan jauh. Berikut ialah contoh kod klien PHP mudah:

<?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}
";
}

Dalam contoh ini, kami mula-mula mencipta objek klien dan menyambung ke pelayan menggunakan kelas yang disediakan oleh Thrift. Kemudian kami menghantar mesej, memanggil kaedah sendMessage dan menggunakan kaedah getAllMessages untuk mendapatkan semua mesej dan mengeluarkannya.

5 Kesimpulan

Dengan menggunakan PHP dan Jimat untuk mencapai interaksi data masa nyata, kami boleh mencapai komunikasi merentas bahasa dengan mudah, menjadikan interaksi data antara platform berbeza lebih cekap dan boleh dipercayai. Pada masa yang sama, ciri merentas bahasa Thrift juga menjadikan pengembangan dan penyelenggaraan aplikasi lebih mudah dan lebih fleksibel.

Atas ialah kandungan terperinci Interaksi data masa nyata menggunakan PHP dan Thrift. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!