Wie entwickle ich eine Nachrichtenwarteschlange in PHP7.0?

Mit der kontinuierlichen Weiterentwicklung und Entwicklung der Internet-Technologie werden ständig verschiedene technische Mittel vorgeschlagen und angewendet, um die Effizienz und Stabilität der Technologie sicherzustellen. Unter diesen ist die Message Queue-Technologie (im Folgenden als MQ bezeichnet) derzeit das beliebteste und am weitesten verbreitete technische Mittel. MQ zielt darauf ab, das Problem der asynchronen Kommunikation zwischen verschiedenen Modulen im System zu lösen und eine lose Kopplung und eine bessere Skalierbarkeit zwischen Anwendungen zu ermöglichen. In diesem Artikel wird vorgestellt, wie man eine Nachrichtenwarteschlange in PHP7.0 entwickelt.

1. MQ-Grundlagen

1. Nachrichtenwarteschlangenkonzept

MQ ist eine Nachrichtenübermittlungs- oder asynchrone Verarbeitungstechnologie. Nachrichtenwarteschlangen ermöglichen eine lose gekoppelte Kommunikation zwischen Sendern und Empfängern und verbessern so die Interkonnektivität und Wartbarkeit zwischen Anwendungen. MQ verwendet Middleware von Drittanbietern, um Nachrichten über Produzenten an die Warteschlange zu senden, und Verbraucher extrahieren Nachrichten aus der Warteschlange für den Verbrauch. MQ kann in verteilten Systemen, Systemen mit hoher Parallelität und Datenrückstandsszenarien verwendet werden.

2. Nachrichtenwarteschlangentyp

MQ umfasst mehrere Typen:

P2P: Der Produzent sendet die Nachricht an eine Warteschlange, die von einem Verbraucher zur Verwendung empfangen wird, was die Zuverlässigkeit der Nachrichtenübermittlung gewährleistet .

Pub/Sub: Publish-Subscribe-Modell. Produzenten veröffentlichen Nachrichten zu Themen, und Abonnenten abonnieren Nachrichten aus den Themen und konsumieren sie, wodurch Elastizität und Skalierbarkeit der Nachrichtenübermittlung erreicht werden können.

3. MQ-Komponenten

MQ besteht hauptsächlich aus den folgenden Komponenten:

Nachricht: die Grundeinheit der Nachrichten

Produzent: der Generator der Nachricht

Verbraucher: der Verbraucher der Nachricht

Warteschlange: die Nachricht Speicherbereich

Exchange: Nachrichtenweiterleitung

Binding: Nachrichtenbindungsbeziehung

2. So entwickeln Sie MQ in PHP7.0

1. Installieren Sie RabbitMQ

RabbitMQ ist eine beliebte MQ-Implementierung, die P2P- und Pub/Sub-Modi unterstützen kann Unterstützt die Entwicklung in mehreren Programmiersprachen und ist äußerst einfach zu verwenden. Die Verwendung von RabbitMQ in PHP7.0 erfordert die Installation der PHP-AMQP-Erweiterung. Die Schritte sind wie folgt:

(1) Laden Sie RabbitMQ herunter und entpacken Sie es. Die offizielle Website-Adresse lautet wie folgt: http://www.rabbitmq.com/

(2) Erlang installieren: RabbitMQ wurde basierend auf der Erlang-Sprache entwickelt. Bitte installieren Sie zuerst die Erlang-Umgebung.

(3) Starten Sie den RabbitMQ-Server:

$ sudo Rabbitmq-Server

(4) Installieren Sie die PHP-AMQP-Erweiterung:

$ pecl install amqp

Nach Abschluss der Installation fügen Sie hinzu Die folgenden Konfigurationselemente in der php.ini-Datei: extension=amqp. (5) Starten Sie den Webserver neu, um sicherzustellen, dass die PHP-AMQP-Erweiterungskonfiguration wirksam wird. Schreiben Sie Code, um RabbitMQ auf PHP zu verwenden Auf der anderen Seite müssen Sie die AMQP-Erweiterung und den Composer installieren und dann das AMQP-Paket installieren.

(1) Amqp-Paket installieren

$ Composer benötigt php-amqplib/php-amqplib

(2) Produzentencode

Das Folgende ist ein PHP-Produzentencode zum Senden von Nachrichten an die Warteschlange:

Zunächst benötigen Sie Instantiate den Client wie folgt:

$connection = new AMQPConnection();

$connection->setHost('localhost');

$connection->setPort('5672');

$connection-> guest');

$connection->setPassword('guest');

$connection->connect();

Implementierung des Nachrichtenversands:

$exchange = 'test-exchange';
$ queue = ' test-queue';
$message = 'Hello World';

try {

$channel = new AMQPChannel($connection);
$exchange = new AMQPExchange($channel);
$exchange->setName($exchange);
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->declareExchange();
$queue = new AMQPQueue($channel);
$queue->setName($queue);
$queue->setFlags(AMQP_DURABLE);
$queue->declareQueue();
$queue->bind($exchange->getName(), $queue->getName());
$exchange->publish($message, $queue->getName());

}

catch (AMQPException $e) {

var_dump($e);

}
$connection->disconnect();

Den obigen Code erstellen eine Warteschlange Test-Warteschlange und ein Austauscher Test-Austausch, binden Sie dann die Warteschlange und den Austausch und senden Sie dann die Nachricht.

(3) Verbrauchercode

Das Folgende ist ein Verbrauchercode zum Konsumieren von Nachrichten aus der Warteschlange:

Instanziieren Sie zunächst den Client wie folgt:

$connection = new AMQPConnection();

$connection ->setHost( 'localhost');

$connection->setPort('5672');

$connection->setLogin('guest');

$connection->setPassword('guest');

$connection-> connect();

Implementierung des Nachrichtenverbrauchs:

$exchange = 'test-exchange';
$queue = 'test-queue';
try {

$channel = new AMQPChannel($connection);
$exchange = new AMQPExchange($channel);
$exchange->setName($exchange);
$exchange->setType(AMQP_EX_TYPE_DIRECT);
$exchange->declareExchange();
$queue = new AMQPQueue($channel);
$queue->setName($queue);
$queue->setFlags(AMQP_DURABLE);
$queue->declareQueue();
$queue->bind($exchange->getName(), $queue->getName());
$queue->consume(function(AMQPEnvelope $message, AMQPQueue $queue) {
    echo $message->getBody();
    $queue->ack($message->getDeliveryTag());
});

}

catch (AMQPException $e ) {

var_dump($e);

}
$connection->disconnect();

Im obigen Code werden eine Warteschlangen-Testwarteschlange und ein Austauscher-Testaustausch erstellt, und dann werden die Warteschlange und der Austauscher gebunden, und dann wird der Verbraucher die Nachricht abrufen Bearbeiten Sie die Warteschlange, geben Sie sie an die Konsole aus und bestätigen Sie, dass die Nachricht über die Methode $queue->ack() verarbeitet wird.

3. Zusammenfassung

Dieser Artikel stellt vor, wie man MQ in PHP7.0 entwickelt. Erstens müssen Sie die RabbitMQ- und PHP-AMQP-Erweiterungen installieren; zweitens müssen Sie Composer und das amqp-Paket installieren und schließlich Code schreiben, um das Senden und Konsumieren von Nachrichten zu implementieren. Das Aufkommen der MQ-Technologie bietet eine bequemere und effizientere Messaging-Methode für Internetanwendungen. Insbesondere in Szenarien mit hoher Parallelität und verteilten Systemen ist MQ ein unverzichtbarer Bestandteil. Ich hoffe, dass die Leser durch das Studium dieses Artikels die spezifischen Schritte und Implementierungsmethoden der MQ-Entwicklung in PHP7.0 verstehen und eine Referenz für das Ausprobieren der MQ-Technologie in ihren eigenen Geschäftsanwendungen bereitstellen können.

Das obige ist der detaillierte Inhalt vonWie entwickle ich eine Nachrichtenwarteschlange in PHP7.0?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!