AMQP，即Advanced Message Queuing Protocol,一個(gè)提供統(tǒng)一消息服務(wù)的應(yīng)用層標(biāo)準(zhǔn)高級(jí)消息隊(duì)列協(xié)議,是應(yīng)用層協(xié)議的一個(gè)開(kāi)放標(biāo)準(zhǔn),為面向消息的中間件設(shè)計(jì)?；诖藚f(xié)議的客戶(hù)端與消息中間件可傳遞消息，并不受客戶(hù)端/中間件不同產(chǎn)品，不同的開(kāi)發(fā)語(yǔ)言等條件的限制。Erlang中的實(shí)現(xiàn)有 RabbitMQ等。

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
                ));
        }
    }

相關(guān)文章

在 Joomla 中連接第三方 PHP 庫(kù)

28 Dec 2024

PHP 庫(kù)很方便，因?yàn)榭梢詮膽?yīng)用程序中的任何位置訪(fǎng)問(wèn)它們：從插件、組件模型、模塊等。如果有人已經(jīng)解決了類(lèi)似的問(wèn)題并將其設(shè)計(jì)為庫(kù)（甚至更新了它），那就有意義了

WordPress使用的JavaScript和PHP庫(kù)

17 Feb 2025

WordPress 深度依賴(lài)第三方 JavaScript 和 PHP 庫(kù)，其中 jQuery 是使用最廣泛的 JavaScript 庫(kù)，PHP 庫(kù)主要由單個(gè)類(lèi)文件組成。其他使用的 JavaScript 庫(kù)包括 jQuery Masonry、jQuery Hotkeys、jQuery Suggest、jQuery Form、jQuery Color、jQuery Migrate、jQuery Schedule、jQuery UI、Backbone、colorpicker、hoverIntent、S

PHP可以使用PDO創(chuàng)建數(shù)據(jù)庫(kù)嗎？

08 Nov 2024

在 PHP 中使用 PDO 創(chuàng)建數(shù)據(jù)庫(kù)在 PHP 中，PDO（PHP 數(shù)據(jù)對(duì)象）是廣泛使用的與數(shù)據(jù)庫(kù)交互的擴(kuò)展。它的其中之一...

重點(diǎn)介紹PHP數(shù)據(jù)庫(kù)查詢(xún)語(yǔ)句

06 Apr 2023

PHP作為一種流行的服務(wù)器端腳本語(yǔ)言，可以匯集許多不同的數(shù)據(jù)類(lèi)型和數(shù)據(jù)庫(kù)。尤其是在web應(yīng)用程序的開(kāi)發(fā)中，它經(jīng)常需要訪(fǎng)問(wèn)數(shù)據(jù)庫(kù)來(lái)檢索和操作數(shù)據(jù)。本文將重點(diǎn)介紹PHP數(shù)據(jù)庫(kù)查詢(xún)語(yǔ)句。一、什么是數(shù)據(jù)庫(kù)查詢(xún)語(yǔ)句在對(duì)數(shù)據(jù)庫(kù)進(jìn)行操作的過(guò)程中，我們常常需要從數(shù)據(jù)庫(kù)中獲取數(shù)據(jù)。這時(shí)，我們需要使用查詢(xún)語(yǔ)句。數(shù)據(jù)庫(kù)查詢(xún)（SQL Query）是從數(shù)據(jù)庫(kù)中檢索數(shù)據(jù)的指令集。SQL是Structure

如何優(yōu)化PHP 7中的數(shù)據(jù)庫(kù)查詢(xún)？

10 Mar 2025

本文探討了PHP 7中的優(yōu)化數(shù)據(jù)庫(kù)查詢(xún)。它解決了源于效率低下的查詢(xún)，網(wǎng)絡(luò)延遲和數(shù)據(jù)庫(kù)服務(wù)器負(fù)載的性能瓶頸。策略包括使用適當(dāng)?shù)臄?shù)據(jù)類(lèi)型，索引，查詢(xún)優(yōu)化

如何根據(jù)數(shù)據(jù)庫(kù)類(lèi)型字符串動(dòng)態(tài)創(chuàng)建PHP對(duì)象？

20 Nov 2024

從數(shù)據(jù)庫(kù)類(lèi)型字符串動(dòng)態(tài)創(chuàng)建 PHP 對(duì)象根據(jù) MySQL 數(shù)據(jù)庫(kù)中的類(lèi)型定義創(chuàng)建 PHP 對(duì)象需要?jiǎng)討B(tài)...

See all articles