Linux-Tutorial: Tutorial zur manuellen Kompilierung der PHP-AMQP-Erweiterung unter Ubuntu

Ist Shenma amqp? Die Einführung ist hier. Einfach ausgedrückt handelt es sich um das erweiterte Warteschlangen-Protokoll. Diese Erweiterung soll es PHP erm?glichen, das amqp-Protokoll und die zugeh?rige Warteschlange-Dienstkommunikation zu unterstützen.

Vorteile: Es kann das Parallelit?tsproblem der Serververarbeitung l?sen.
Das Advanced Messaging Queuing Protocol (AMQP) ist eine Protokollspezifikation auf Anwendungsebene, die für asynchrone Nachrichtenübermittlung verwendet wird. Als Wire-Layer-Protokoll und nicht als API (wie JMS) k?nnen AMQP-Clients Nachrichten unabh?ngig von ihrer Quelle beliebig senden und empfangen. Mittlerweile gibt es bereits eine ganze Reihe von Servern und Clients für verschiedene Plattformen, die zum Einsatz kommen k?nnen.

(1) Grundkonzepte

RabbitMQ ist ein beliebtes Open-Source-Messaging-

Warteschlangensystem

, das in Erlang-Sprache entwickelt wurde. RabbitMQ ist eine Standardimplementierung von AMQP (Advanced Message Queuing Protocol). Wenn Sie mit AMQP nicht vertraut sind, wird es schwierig sein, die RabbitMQ-Dokumentation direkt zu lesen. Allerdings gibt es nur wenige Schlüsselkonzepte, die hier kurz vorgestellt werden. Ein paar Konzepterkl?rungen:

Broker: Einfach ausgedrückt handelt es sich um eine Nachrichten-

Warteschlange

Server-Entit?t.

• Austausch: Nachrichtenaustausch, der die Regeln festlegt und an welche Warteschlange die Nachricht weitergeleitet wird.
• Warteschlange: Nachrichten-Warteschlange Tr?ger, jede Nachricht wird in eine oder mehrere
Warteschlangen
• gestellt. Bindung: Bindung, ihre Funktion besteht darin, Austausch und Warteschlange gem?? Routing-Regeln zu binden. Routing-Schlüssel: Routing-Schlüsselwort, Exchange übermittelt Nachrichten basierend auf diesem Schlüsselwort.
• vhost: virtueller Host k?nnen in einem Broker ge?ffnet werden, um die Berechtigungen für verschiedene Benutzer zu trennen.
• Produzent: Nachrichtenproduzent ist das Programm, das Nachrichten übermittelt.
• Verbraucher: Nachrichtenkonsument ist das Programm, das Nachrichten akzeptiert.
• Kanal: Nachrichtenkanal In jeder Verbindung des Clients k?nnen mehrere Kan?le eingerichtet werden, und jeder Kanal stellt eine Sitzungsaufgabe dar.
• (2) Nutzungsprozess
• Das hei?t, Client – ??AMQP-Server – Client

Der Client auf der linken Seite sendet eine Nachricht an den Client auf der rechten Seite. Der Vorgang ist:

Verbindung abrufen

Kanal abrufen

• Austausch definieren, Warteschlange
• verwendet einen RoutingKey, der die Warteschlange an einen Exchange bindet
• Senden Sie die Nachricht an die entsprechende Warteschlange, indem Sie einen Exchange und einen RoutingKey angeben
• Der Empf?nger erh?lt dann auch die Verbindung, wenn er sie empf?ngt Ruft den Kanal ab und gibt dann eine Warteschlange an, um Nachrichten direkt aus der Warteschlange abzurufen, um die es sich handelt. Es ist egal, wie Exchange, RoutingKey und die Bindung erfolgen. Es ist in Ordnung, Nachrichten aus der entsprechenden Warteschlange abzurufen ??>Aufgrund der Standardquelle von Ubuntu gibt es kein php5-amqp-Paket, daher müssen Sie es manuell kompilieren, um amqp verwenden zu k?nnen.
• Vorbereitungsarbeiten
• :

PHP-Kompilierungstools installieren

Rabbitmq-Bibliothek installieren

Wenn Sie Linux verwenden Die Distribution verfügt nicht über ein vorgefertigtes librabbitmq-dev-Paket, Sie k?nnen es also kompilieren und installieren, indem Sie den Quellcode herunterladen

Wenn Sie Git dann nicht installiert haben, installieren Sie bitte Git, da wir das erhalten müssen Quellcode aus dem offiziellen Repository

<code>sudo apt<span>-get</span> install php5<span>-dev</span></code>

Klonen Sie den Quellcode und kompilieren Sie

<code>sudo apt<span>-get</span> install librabbitmq<span>-dev</span></code>

Kompilieren Sie die Bibliothek

Dann müssen wir den Quellcode der PHP-Erweiterung herunterladen , die Adresse ist hier:

http ://pecl.php.net/package/amqp

<code>git <span>clone</span> git:<span>//<strong>github</strong>.com/alanxz/rabbitmq-c.git</span>
cd rabbitmq-c
git submodule init
git submodule update</code>

Die neueste Version ist 1.4.0

<code>autoreconf -i && ./configure && <span>make</span> && sudo <span>make</span> install</code>

Erstellen Sie die Konfiguration Datei

Dann starten Sie Ihren Webserver oder PHP-FPM neu und drucken Sie phpinfo. Wenn Sie den folgenden Inhalt sehen, bedeutet dies, dass die Erweiterung installiert ist

Beispiel

<code>wget http://pecl<span>.php</span><span>.net</span>/get/amqp-<span>1.4</span><span>.0</span><span>.tgz</span>tar zxf amqp-<span>1.4</span><span>.0</span><span>.tgz</span>
cd amqp-<span>1.4</span><span>.0</span>/

phpize && ./configure --with-amqp && make && sudo make install</code>

Produktion Seite

<code><span>sudo</span><span>echo</span><span>"extension = amqp.so"</span> > /etc/php5/conf.d/amqp.ini</code>

Verbraucherseite

Das Obige stellt die manuelle Kompilierung des PHP-AMQP-Erweiterungs-Tutorials unter Linux unter Ubuntu vor, einschlie?lich der relevanten Inhalte. Ich hoffe, es wird für Freunde hilfreich sein, die sich für PHP-Tutorials interessieren.

<code><span>/**
 * PHP amqp(RabbitMQ) Demo - publisher
 * 生產(chǎn)者：發(fā)送消息
 * 邏輯：創(chuàng)建連接-->創(chuàng)建channel-->創(chuàng)建交換機<strong>對象</strong>-->發(fā)送消息* 
 */</span><span>//配置信息</span><span>$conn_args</span> = <span>array</span>(
    <span>'host'</span> => <span>'localhost'</span>,
    <span>'port'</span> => <span>'5672'</span>,
    <span>'login'</span> => <span>'guest'</span>,
    <span>'password'</span> => <span>'guest'</span>,
    <span>'vhost'</span>=><span>'/'</span>
);
<span>$e_name</span> = <span>'e_lamp'</span>; <span>//交換機名</span><span>$k_route</span> = <span>'key_1'</span>; <span>//路由key</span><span>//創(chuàng)建連接和channel</span><span>$conn</span> = <span>new</span> AMQPConnection(<span>$conn_args</span>);
<span>if</span> (!<span>$conn</span>->connect()) {
    <span>die</span>(<span>"Cannot connect to the broker!\n"</span>);
}
<span>$channel</span> = <span>new</span> AMQPChannel(<span>$conn</span>);

<span>//消息內容</span><span>$message</span> = <span>"TEST MESSAGE! 測試消息！"</span>;

<span>//創(chuàng)建交換機<strong>對象</strong></span><span>$ex</span> = <span>new</span> AMQPExchange(<span>$channel</span>);
<span>$ex</span>->setName(<span>$e_name</span>);

<span>//發(fā)送消息</span><span>//$channel->startTransaction(); //開始事務</span><span>for</span>(<span>$i</span>=<span>0</span>; <span>$i</span><<span>5</span>; ++<span>$i</span>){
    <span>echo</span><span>"Send Message:"</span>.<span>$ex</span>->publish(<span>$message</span>, <span>$k_route</span>).<span>"\n"</span>;
}
<span>//$channel->commitTransaction(); //提交事務</span><span>$conn</span>->disconnect();</code>