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

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-

, 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:

Warteschlange

• 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

Verbindung 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
• :

Rabbitmq-Bibliothek installieren

<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

<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

<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
 * 生产者：发送消息
 * 逻辑：创建连接-->创建channel-->创建交换机<strong>对象</strong>-->发送消息* 
 */</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>//创建连接和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>//创建交换机<strong>对象</strong></span><span>$ex</span> = <span>new</span> AMQPExchange(<span>$channel</span>);
<span>$ex</span>->setName(<span>$e_name</span>);

<span>//发送消息</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>