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
));
}
}? ???? ?? ???? ???? ????? ?? ???? ????? ????????. ?????? ???? ?? ??????! ? ???? ?? ???? ?? ?????? ?????. ??? ???? ???? ??? ????. ??? ??? ?? ??? ?? ??? ???? ????! ??? ?? ?? ??? ???? ????? ????. ???: admin@php.cn
?? ??
?? ????? ?? ?? C/C? ?? ???? ?? BMP ???? ??? ??? ??????
29 Nov 2024
?? ????? ?? ?? C/C? BMP ??? ???? ??? ??? ????? ??? ? ??? ?????.
?? ????? ?? ?? C/C? ?? ???? ?? BMP ???? ??? ??? ??????
03 Dec 2024
?? ????? ?? ?? C/C? BMP ??? ?? ?? ?? ?????? ??? ??? ???? ?? ?? ??? ???? ? ????.
??? ?? ??? ?? ?? ????? ??? ?? ???? (1)
29 Jul 2016
??? ?? ??? ?? ?? ?????: ??? ?? ??? ?? ?? ????? ??? ?? ????(1): ? ??? ?????? ???? ??? ??? ??: # ------ --- --------------------- # # ??? ??? ?? 'author' # CREATE TABLE ??? ( author_id int (6) DEFAULT '0' NOT NULL auto_increment, first_name varchar(20)
???? ?? ??, ?? ??? ?? ?? ???? ??? ???? ???? PHP ?? ??
25 Jul 2016
???? ?? ??, ?? ??? ?? ?? ???? ??? ???? ???? PHP ?? ??
??? ??
??? ?? ????? PHP ?????
??? ?? ????? PHP ?????
50?? ??? ??? PHP ???? ??
??? PHP ????, ??? ????? ??? ???? ?????
??? ???? ?? ?? PHP ?????
??? ???? ?? ?? PHP ?????