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é)議的客戶端與消息中間件可傳遞消息，并不受客戶端/中間件不同產(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)用程序中的任何位置訪問(wèn)它們：從插件、組件模型、模塊等。如果有人已經(jīng)解決了類(lèi)似的問(wèn)題并將其設(shè)計(jì)為庫(kù)（甚至更新了它），那就有意義了

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

17 Feb 2025

WordPress 深度依賴第三方 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ò)展。它的其中之一...

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

10 Mar 2025

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

對(duì)于程序員來(lái)說(shuō)，最簡(jiǎn)單的 PHP 表單驗(yàn)證庫(kù)是什么？

17 Oct 2024

最簡(jiǎn)單的 PHP 表單驗(yàn)證庫(kù)問(wèn)題：開(kāi)發(fā)一個(gè)簡(jiǎn)單的 PHP 庫(kù)以進(jìn)行高效的表單驗(yàn)證，其中可以輕松傳遞規(guī)則和字段名稱(chēng)并檢索錯(cuò)誤。答案：一種方法是實(shí)現(xiàn)自己的驗(yàn)證類(lèi)

See all articles