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

?? ??

?? ????? ?? ?? C/C? ?? ???? ?? BMP ???? ??? ??? ??????

29 Nov 2024

?? ????? ?? ?? C/C? BMP ??? ???? ??? ??? ????? ??? ? ??? ?????.

?? ????? ?? ?? C/C? ?? ???? ?? BMP ???? ??? ??? ??????

03 Dec 2024

?? ????? ?? ?? C/C? BMP ??? ?? ?? ?? ?????? ??? ??? ???? ?? ?? ??? ???? ? ????.

?? ?? - PHP CLI ?????

17 Feb 2025

? ??? Symfony Console, HOA Console ? WebMozart ??? 3 ?? PHP ?? ?? ?????? ?????. ??? ??? ???? ??? ??? ???? ?? ?? ? ??? ?????. ?? ??? : Symfony Console : ???? ????

Joomla?? ?? PHP ????? ??

28 Dec 2024

PHP ?????? ????, ?? ?? ??, ?? ? ?? ????? ?? ???? ???? ? ?? ??? ?????. ??? ?? ??? ??? ???? ?????? ?????(??? ??????) ??? ????.

??? PHP QR ?? ?????

15 Jan 2025

HeroQR: ??? ?? PHP QR ?? ?? ????? ??? PHP?? QR ?? ??? ??????? ? ?? ???? ???! ?QR ?? ??? ?? ???? ???? ???? ??? ?? ?? ?? PHP ?????? HeroQR? ???? ?? ??? ?????. HeroQR? ???? ??? ?????? HeroQR? ??? ?? ???? ?? ???? ?????. ??? QR ?? ???? ?? ????? ?? ??? ??? ??? ????? HeroQR? ??? ?? ?? ??? ????. HeroQR? ?? ?? HeroQR? ????? QR ??? ???? ??? ??? ? ?? ??? ??? ????? ???????. ??? ??? ?? ??? ??? ??? ????. ?? ??? ??? ?? ??? ?? ??? ??? ??

WordPress?? ???? JavaScript ? PHP ?????

17 Feb 2025

WordPress? ?? JavaScript ? PHP ?????? ?? ????, ? ? jQuery? ?? ?? ???? JavaScript ??????? PHP ?????? ?? ?? ??? ??? ?????. ?? ? ?? JavaScript ??????? jQuery Masonry, JQuery Hotkeys, JQuery ??, jQuery ??, jQuery ??, jQuery Migrate, JQuery Schedule, JQuery UI, Backbone, ColorPicker, Hoverintent, S? ????.

See all articles