纯PHP AMQP库

AMQP，即Advanced Message Queuing Protocol,一个提供统一消息服务的应用层标准高级消息队列协议,是应用层协议的一个开放标准,为面向消息的中间件设计。基于此协议的客户端与消息中间件可传递消息，并不受客户端/中间件不同产品，不同的开发语言等条件的限制。Erlang中的实现有 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
                ));
        }
    }

相关文章

Go 库可以作为纯二进制包分发吗？

22Dec2024

直接在 Go 中使用二进制包在分发 Go 库时，许多开发人员希望保留源代码。然而，一个常见的...

如何将 MySQL 数据库转储为纯文本 (CSV) 备份？

01Nov2024

使用 SQL 将 MySQL 数据库转储为纯文本 (CSV) 备份，而不是使用 mysqldump，后者以主要设计用于...的格式输出数据。

ORM 或纯 SQL：哪种数据库方法适合您的项目？

15Jan2025

使用 ORM 还是纯 SQL？当开发需要数据库支持的应用程序时，选择使用 ORM（对象关系映射）还是纯 SQL...

如何使用纯 PHP 创建 API？

04Nov2024

在这个项目中，我们将在任何框架中仅使用 PHP 创建一个简单的 API。我们所需要的只是： PHP - 必备 作曲家 - 必备 编辑器/IDE，如 VScode 或 PHPStorm Docker - 首选但不是必需的 邮差 - 预

ORM 或纯 SQL：哪种数据库方法适合您的应用程序？

15Jan2025

使用 ORM 还是普通 SQL？开发应用程序时，决定是使用对象关系映射 (ORM) 工具还是……非常重要。

如何用 PHP 逐行读取纯文本文件？

27Oct2024

使用 PHP 读取纯文本文件问题：您在服务器上有一个包含数据行的纯文本文件。您如何才能读取来自...的所有信息？

See all articles