PHP非同期通信およびメッセージキューの実装ガイド：SOAPおよびRabbitMQ実際の戦闘

M66 2025-10-07

導入

最新のインターネットアプリケーションでは、非同期通信とメッセージキューは、効率的なシステムを実現するための重要な手段です。広く使用されているサーバー側の言語として、PHPはこれらの機能をサポートするための豊富なライブラリと拡張機能を提供します。この記事では、PHPとSOAPを使用して非同期通信を実装する方法と、RabbitMQを介してメッセージキューを実装し、完全なコードの例を提供する方法を詳細に説明します。

石鹸とは何ですか

SOAP（Simple Object Access Protocol）は、分散システムのアプリケーション間の通信に使用されるXMLベースのメッセージングプロトコルです。 HTTP、SMTP、およびその他のプロトコルを介した送信をサポートし、非同期コミュニケーションとメッセージキューイング機能を実現するためにWebサービスでよく使用されます。

PHPとSOAPを使用して、非同期通信を実装します

SOAP拡張機能のインストールと構成最初に、PHP環境でSOAP拡張機能をインストールして有効にする必要があります。 PHP.iniファイルでSOAP拡張機能を有効にして、構成を完了します。特定の手順については、公式のPHPドキュメントを参照してください。

SOAPサーバーを作成します

<?php
require_once('lib/nusoap.php');

$server = new soap_server();
$server->configurewsdl（ &#39;asyncserver&#39;、 &#39;urn：asyncserver&#39;）;

関数my_async_function（$ parameter）
{
    //非同期操作を実行するためのロジック// ...
    「成功」を戻るします。
}

$ server->レジスタ（ &#39;my_async_function&#39;、
    array（ &#39;parameter&#39; => &#39;xsd：string&#39;）、
    array（ &#39;return&#39; => &#39;xsd：string&#39;）、
    &#39;urn：asyncserver&#39;、
    &#39;urn：asyncserver＃my_async_function&#39;、
    「RPC」、
    「エンコード」、
    「私の非同期機能」
）;

$ server-> service（file_get_contents（ &#39;php：// input&#39;））;
？>

SOAPクライアントを作成します

<?php
require_once('lib/nusoap.php');

$client = new nusoap_client('http://localhost/async_server.php?wsdl', 'wsdl');
$response = $client-> call（ &#39;my_async_function&#39;、array（ &#39;parameter&#39; => &#39;hello&#39;））;

print_r（$ response）;
？>

上記のコードは、NUSOAP_CLIENTを介してSOAPクライアントを作成し、サーバーの非同期関数を呼び出してPHPの非同期通信を実現します。

PHPとSOAPを使用してメッセージキューを実装します

メッセージキューは、アプリケーション間でメッセージを渡すメカニズムであり、システムデカップリングと非同期処理を実装するためによく使用されます。 PHPでは、RabbitMQなどのサードパーティライブラリを使用してメッセージキューを実装できます。

rabbitmqをインストールして構成します

PHP環境でRabbitMQをインストールして構成するには、インストールと構成については、公式のRabbitMQドキュメントを参照してください。

生産者と消費者を作成します

<?php
require_once('vendor/autoload.php');

use PhpAmqpLib\Connection\AMQPStreamConnection;
use PhpAmqpLib\Message\AMQPMessage;

$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->チャネル（）;

$ queue = &#39;async_queue&#39;;
$ channel-> queue_declare（$ queue、false、true、false、false）;

$ message = new amqpmessage（ &#39;hello、message！&#39;）;
$ channel-> basic_publish（$ message、 &#39;&#39;、$ queue）;

$ channel-> close（）;
$ connection-> close（）;
？>

<?php
require_once('vendor/autoload.php');

use PhpAmqpLib\Connection\AMQPStreamConnection;

$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->チャネル（）;

$ queue = &#39;async_queue&#39;;
$ channel-> queue_declare（$ queue、false、true、false、false）;

$ channel-> basic_consume（$ queue、 &#39;&#39;、false、false、false、false、function（$ msg）{
    エコー「受信：」。 $ msg-> body。 "\ n";
    $ msg-> ack（）;
}）;

while（$ channel-> is_consuming（））{
    $ channel-> wait（）;
}

$ channel-> close（）;
$ connection-> close（）;
？>

phpamqplibライブラリを介してrabbitmq接続を作成し、キューを定義します。プロデューサーはbasic_publishを介してメッセージを送信し、消費者はbasic_consumeを介してキュー内のメッセージを聴いて処理します。

結論は

PHPとSOAPを組み合わせると、非同期通信を簡単に実現できますが、RabbitMQなどのメッセージキューツールを使用して、非同期タスクを効率的に管理できます。この記事では、開発者が実際のプロジェクトで非同期処理とメッセージキューイング機能を迅速に実装するのに役立つ完全なサンプルコードを提供します。さまざまなプロジェクトのニーズに応じて、システムアーキテクチャとパフォーマンスを最適化するために、他のサードパーティライブラリを選択することもできます。