AMQP oder Advanced Message Queuing Protocol ist ein Standard-Message-Queuing-Protokoll der Anwendungsschicht, das einheitliche Messaging-Dienste bereitstellt. Es ist ein offener Standard für Protokolle der Anwendungsschicht und wurde für nachrichtenorientierte Middleware entwickelt. Auf diesem Protokoll basierende Clients und Nachrichten-Middleware k?nnen Nachrichten übertragen und sind nicht durch unterschiedliche Client-/Middleware-Produkte, unterschiedliche Entwicklungssprachen usw. eingeschr?nkt. Zu den Implementierungen in Erlang geh?ren RabbitMQ usw.

abstract class AbstractChannel
{
    const PROTOCOL_080 = '0.8';
    const PROTOCOL_091 = '0.9.1';
    public static $PROTOCOL_CONSTANTS_CLASS;
    public function __construct(AbstractConnection $connection, $channel_id)
    {
        $this->connection = $connection;
        $this->channel_id = $channel_id;
        $connection->channels[$channel_id] = $this;
        $this->frame_queue = array(); // Lower level queue for frames
        $this->method_queue = array(); // Higher level queue for methods
        $this->auto_decode = false;
        $this->msg_property_reader = new AMQPReader(null);
        $this->wait_content_reader = new AMQPReader(null);
        $this->dispatch_reader = new AMQPReader(null);
        $this->protocolVersion = self::getProtocolVersion();
        switch ($this->protocolVersion) {
            case self::PROTOCOL_091:
                self::$PROTOCOL_CONSTANTS_CLASS = 'PhpAmqpLib\Wire\Constants091';
                $c = self::$PROTOCOL_CONSTANTS_CLASS;
                $this->debug = new DebugHelper($c);
                $this->amqp_protocol_header = $c::$AMQP_PROTOCOL_HEADER;
                $this->protocolWriter = new Protocol091();
                $this->waitHelper = new Wait091();
                $this->methodMap = new MethodMap091();
                break;
            case self::PROTOCOL_080:
                self::$PROTOCOL_CONSTANTS_CLASS = 'PhpAmqpLib\Wire\Constants080';
                $c = self::$PROTOCOL_CONSTANTS_CLASS;
                $this->debug = new DebugHelper($c);
                $this->amqp_protocol_header = $c::$AMQP_PROTOCOL_HEADER;
                $this->protocolWriter = new Protocol080();
                $this->waitHelper = new Wait080();
                $this->methodMap = new MethodMap080();
                break;
            default:
                throw new AMQPRuntimeException(sprintf(
                    'Protocol: %s not implemented.',
                    $this->protocolVersion
                ));
        }
    }

Verwandter Artikel

Memcache vs. Memcached: Welche PHP-Bibliothek sollten Sie w?hlen?

09 Nov 2024

Unterscheidung zwischen ?Memcache“ und ?Memcached“ in PHPPHP bietet zwei Memcached-Bibliotheken: Memcache und Memcached. Das Verst?ndnis ihrer Unterschiede hilft...

Memcache vs. Memcached: Welche PHP-Memcached-Bibliothek sollten Sie w?hlen?

19 Nov 2024

Memcache vs. Memcached: Auswahl der richtigen PHP-Memcached-BibliothekEinführungPHP bietet zwei scheinbar ?hnliche Memcached-Bibliotheken: Memcache und...

Memcache vs. Memcached: Welche PHP-Caching-Bibliothek sollten Sie w?hlen?

12 Nov 2024

Memcache vs. Memcached: Auswahl der richtigen PHP-Bibliothek für Ihre Cache-AnforderungenIm Bereich der PHP-Caching-Bibliotheken stechen Memcache und Memcached hervor ...

Welche PHP-Bibliothek passt am besten zu Ihren Anforderungen an die Validierung von E-Mail-Adressen?

18 Nov 2024

PHP-Bibliotheken zur E-Mail-Adressvalidierung aufgedecktE-Mail-Adressvalidierung spielt eine entscheidende Rolle bei der Datenvalidierung, aber die Erstellung einer...

Welche PHP-ORM-Bibliothek eignet sich am besten zum Abstrahieren von Datenbankanbietern und zum Zuordnen von dom?nen-/relationalen Modellen?

05 Jan 2025

Empfehlungen zur PHP-ORM-BibliothekWenn es um objektrelationales Mapping (ORM) für PHP geht, stechen mehrere Bibliotheken hervor. Zur Adressierung...

Wie benutze ich die GD -Bibliothek in PHP, um die Gr??e der Gr??e, Ernte und Wasserzeichen zu erfassen und zu Wasserzeichen?

21 Jun 2025

Die GD -Bibliothek von PHP unterstützt Bildverarbeitungsvorg?nge ohne zus?tzliche Abh?ngigkeiten. 1. Die Gr??e der Gr??e: Verwenden Sie ImagecreateFromjpeg (), um das Bild zu laden, eine neue Gr??e zu erstellen, skalieren Sie und speichern Sie es durch imageCopyresampled (); 2. Ernte: Erstellen Sie nach dem Laden des Originalbildes eine neue Leinwand der Zielgr??e und kopieren Sie den angegebenen Bereich. 3. Fügen Sie ein Wasserzeichen hinzu: Verwenden Sie ImagettFtext (), um Text hinzuzufügen, oder verwenden Sie imageCopy (), um das transparente PNG -Logo zu überlagern. Die grundlegenden Funktionen sind einfach und effektiv, und andere Bibliotheken k?nnen für komplexe Anforderungen berücksichtigt werden.

See all articles