{"id":99162,"date":"2026-09-02T00:33:29","date_gmt":"2026-09-01T16:33:29","guid":{"rendered":"https:\/\/www.wsisp.com\/helps\/99162.html"},"modified":"2026-09-02T00:33:29","modified_gmt":"2026-09-01T16:33:29","slug":"amqp%ef%bc%88amqp%e5%8d%8f%e8%ae%ae%e6%89%a9%e5%b1%95%ef%bc%89%e6%ba%90%e7%a0%81%e7%ba%a7%e8%a7%a3%e6%9e%90","status":"publish","type":"post","link":"https:\/\/www.wsisp.com\/helps\/99162.html","title":{"rendered":"amqp\uff08AMQP\u534f\u8bae\u6269\u5c55\uff09==\u6e90\u7801\u7ea7\u89e3\u6790"},"content":{"rendered":"

amqp（AMQP\u534f\u8bae\u6269\u5c55）<\/p>\n

GitHub： https:<\/span>\/\/github.com\/php-amqp\/php-amqp<\/span><\/p>\n

\u5b8c\u6574\u6807\u9898<\/p>\n

1.<\/span> amqp\u6e90\u7801\u5168\u666f：RabbitMQ\u7684PHP C\u6269\u5c55\u2014\u2014librabbitmq\u7684\u5c01\u88c5
\n2.<\/span> amqp\u6269\u5c55\u5165\u53e3amqp.<\/span>c：MINIT\u9636\u6bb5\u7684\u7c7b\u6ce8\u518c\u4e0e\u5e38\u91cf\u5b9a\u4e49
\n3.<\/span> AMQPConnection：\u8fde\u63a5\u7ba1\u7406\u7684C\u5b9e\u73b0\u2014\u2014TCP\u8fde\u63a5\u4e0eAMQP\u63e1\u624b
\n4.<\/span> AMQPChannel：\u901a\u9053\u7684C\u5b9e\u73b0\u2014\u2014\u591a\u8def\u590d\u7528\u4e0e\u901a\u9053\u9694\u79bb
\n5.<\/span> AMQPQueue：\u961f\u5217\u64cd\u4f5c\u7684C\u5b9e\u73b0\u2014\u2014\u58f0\u660e\/<\/span>\u7ed1\u5b9a\/<\/span>\u6d88\u8d39\/<\/span>ack
\n6.<\/span> AMQPExchange：\u4ea4\u6362\u5668\u64cd\u4f5c\u7684C\u5b9e\u73b0\u2014\u2014direct\/<\/span>topic\/<\/span>fanout
\n7.<\/span> AMQP\u6d88\u606f\u53d1\u5e03：basic_publish\u7684C\u5b9e\u73b0\u2014\u2014\u6d88\u606f\u5c5e\u6027\u4e0e\u8def\u7531\u952e
\n8.<\/span> AMQP\u6d88\u606f\u6d88\u8d39：basic_consume\u7684C\u5b9e\u73b0\u2014\u2014\u963b\u585e\u4e0e\u975e\u963b\u585e\u6a21\u5f0f
\n9.<\/span> AMQP\u4e8b\u52a1：tx_select\/<\/span>tx_commit\/<\/span>tx_rollback\u7684C\u5b9e\u73b0
\n10.<\/span> AMQP Publisher Confirm：\u53d1\u5e03\u786e\u8ba4\u7684C\u5b9e\u73b0\u2014\u2014\u6d88\u606f\u53ef\u9760\u6295\u9012<\/p>\n

\u5199\u5230\u6700\u6df1\u7684\u6807\u9898<\/p>\n

11.<\/span> amqp\u7684librabbitmq\u96c6\u6210：amqp_rpc_reply_t<\/span>\u7684C\u5904\u7406\u2014\u2014AMQP\u534f\u8bae\u5e27\u7684\u89e3\u6790\u4e0e\u9519\u8bef\u7801\u6620\u5c04
\n12.<\/span> amqp\u7684\u6301\u4e45\u8fde\u63a5：\u8de8\u8bf7\u6c42\u7684\u8fde\u63a5\u590d\u7528\u2014\u2014AMQPConnection\u5728persistent_list\u4e2d\u7684\u6ce8\u518c
\n13.<\/span> amqp\u7684SSL\/<\/span>TLS：amqp_ssl_socket_set_cacert\u7684C\u8c03\u7528\u2014\u2014\u8bc1\u4e66\u9a8c\u8bc1\u4e0e\u52a0\u5bc6\u901a\u9053<\/p>\n

\u5148\u7acb\u4e24\u4e2a\u5168\u7bc7\u7ea6\u5b9a,<\/span>\u540e\u9762\u4e0d\u518d\u91cd\u590d:<\/span>
\n 1.<\/span>\u2500\u8fd9\u662f"\u4e0e php-amqp \u6e90\u7801\u5b9e\u73b0\u601d\u8def\u4e00\u81f4\u7684\u4ee3\u8868\u6027\u4ee3\u7801"<\/span>,<\/span>\u4e0d\u662f\u9010\u5b57\u8282\u7167\u6284\u3002\u5b57\u6bb5\u540d\u3001\u65b9\u6cd5\u7b7e\u540d\u968f\u4f60\u2500pin\u2500\u7684\u2500librabbitmq\u2500\/<\/span>\u2500php–<\/span>amqp\u2500\u2500
\n \u7248\u672c\u6d6e\u52a8,<\/span>\u673a\u5236\u662f\u5bf9\u7684,<\/span>\u7cbe\u786e\u62fc\u5199\u4ee5\u4f60\u88c5\u7684\u90a3\u4e2a\u7248\u672c\u4e3a\u51c6\u3002
\n 2.<\/span> \u7f16\u7801\/<\/span>\u547d\u540d\u9075\u5faa PHP 7<\/span>\/<\/span>8<\/span> \u7684 Zend API \u4e0e librabbitmq \u7684\u60ef\u4f8b,<\/span>\u51fd\u6570\u540d(<\/span>\u5982 amqp_basic_publish)<\/span>\u662f\u5e93\u7684\u771f\u5b9e API\u3002<\/p>\n

—<\/span>–<\/span><\/p>\n

\u603b\u89c8:<\/span>amqp \u5230\u5e95\u662f\u4e2a\u4ec0\u4e48\u4e1c\u897f<\/p>\n

\u5927\u767d\u8bdd:<\/span> php–<\/span>amqp \u662f\u4e00\u4e2a\u7528 C \u5199\u7684 PHP \u6269\u5c55,<\/span>\u5b83\u4e0d\u81ea\u5df1\u5b9e\u73b0 AMQP \u534f\u8bae,<\/span>\u800c\u662f\u5c01\u88c5 RabbitMQ \u5b98\u65b9\u7528 C \u5199\u7684\u5ba2\u6237\u7aef\u5e93
\n librabbitmq\u3002librabbitmq \u8d1f\u8d23"\u628a AMQP \u534f\u8bae\u5e27\u62fc\u51fa\u6765\u3001\u53d1\u51fa\u53bb\u3001\u6536\u56de\u6765\u89e3\u6790"<\/span>;<\/span>php–<\/span>amqp \u8d1f\u8d23"\u628a\u8fd9\u4e9b C \u7ed3\u6784\u4f53\u5305\u88c5\u6210 PHP \u7684 OOP
\n \u5bf9\u8c61(<\/span>AMQPConnection\u3001AMQPChannel\u3001AMQPQueue\u3001AMQPExchange\u3001AMQPEnvelope)<\/span>\u7ed9\u4f60\u7528"\u3002<\/p>\n

\u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510
\n \u2502 \u4f60\u7684 PHP \u4ee3\u7801 \u2502
\n \u2502 $q =<\/span> new AMQPQueue<\/span>(<\/span>$channel)<\/span>;<\/span> $q-><\/span>consume<\/span>(<\/span>.<\/span>.<\/span>.<\/span>)<\/span>;<\/span> \u2502
\n \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518
\n \u2193
\n \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510
\n \u2502 php–<\/span>amqp \u6269\u5c55(<\/span>C)<\/span> \u2502
\n \u2502 \u628a PHP \u5bf9\u8c61 <<\/span>-><\/span> librabbitmq \u7684 C \u7ed3\u6784\u4f53\u4e92\u8f6c \u2502
\n \u2502 amqp_connection_resource \/<\/span> amqp_channel_t<\/span> \/<\/span> \u2502
\n \u2502 amqp_envelope_t<\/span> \/<\/span> amqp_basic_properties_t<\/span> \u2502
\n \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518
\n \u2193\u8c03\u7528
\n \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510
\n \u2502 librabbitmq<\/span>(<\/span>C)<\/span> \u2502
\n \u2502 amqp_basic_publish \/<\/span> amqp_queue_declare \/<\/span> \u2502
\n \u2502 amqp_login .<\/span>.<\/span>.<\/span> \u8d1f\u8d23\u534f\u8bae\u5e27\u7684\u7f16\u89e3\u7801 \u2502
\n \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518
\n \u2193AMQP 08<\/span> \u534f\u8bae(<\/span>8<\/span> \u5b57\u8282\u5934 AMQP\\\\x00\\\\x00\\\\x09\\\\x01 +<\/span> \u5e27)<\/span>
\n \u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510
\n \u2502 RabbitMQ Server \u2502
\n \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518<\/p>\n

\u4e3a\u4ec0\u4e48\u8fd9\u6837\u5206\u5c42\u662f\u6838\u5fc3\u8bae\u9898:<\/span>\u628a"\u534f\u8bae\u5e27\u7684\u7f16\u89e3\u7801"<\/span>\u8fd9\u4e2a\u53c8\u82e6\u53c8\u5bb9\u6613\u9519\u7684\u90e8\u5206\u4e22\u7ed9\u6210\u719f\u7684 C \u5e93(<\/span>librabbitmq)<\/span>,<\/span>php–<\/span>amqp \u53ea\u7ba1"PHP \u5bf9\u8c61 \u2194
\n C \u7ed3\u6784\u4f53"\u7684\u8f6c\u6362\u5c42\u3002\u8fd9\u662f\u5b83\u6bd4\u7eaf PHP \u7248 AMQP \u5feb\u4e00\u4e2a\u6570\u91cf\u7ea7\u7684\u6839\u672c\u539f\u56e0\u2014\u2014\u6ca1\u6709\u4e00\u5c42PHP \u4ee3\u7801\u5728\u9010\u5e27\u89e3\u91ca\u534f\u8bae,<\/span>\u5168\u662f\u539f\u751f C \u5728\u505a\u7f51\u7edc
\n I\/<\/span>O \u548c\u4e8c\u8fdb\u5236\u89e3\u6790\u3002<\/p>\n

—<\/span>–<\/span><\/p>\n

1.<\/span> amqp \u6e90\u7801\u5168\u666f:<\/span>librabbitmq \u7684\u5c01\u88c5\u5c42<\/p>\n

\u5927\u767d\u8bdd:<\/span> \u6574\u4e2a\u6269\u5c55\u5c31\u662f\u4e00\u6761"\u8f6c\u6362\u6808"<\/span>\u3002\u76ee\u5f55\u7ed3\u6784\u628a"\u6bcf\u4e2a PHP \u7c7b\u5bf9\u5e94\u4e00\u4e2a C \u6587\u4ef6"<\/span>\u7ec4\u7ec7\u5f97\u6e05\u6e05\u695a\u695a\u3002<\/p>\n

php–<\/span>amqp\/<\/span>
\n \u251c\u2500\u2500 amqp.<\/span>c \u2190\u6a21\u5757\u5165\u53e3:<\/span>MINT\/<\/span>RSHUTDOWN\/<\/span>\u5e38\u91cf\/<\/span>\u7c7b\u6ce8\u518c
\n \u251c\u2500\u2500 amqp.<\/span>h \u2190\u5934\u6587\u4ef6\u3001\u6a21\u5757\u5168\u5c40\u53d8\u91cf(<\/span>AMQP_G)<\/span>
\n \u251c\u2500\u2500 php_amqp.<\/span>h \u2190\u5b8f\u5b9a\u4e49\u3001\u7248\u672c\u53f7\u3001\u5168\u5c40\u53d8\u91cf\u58f0\u660e
\n \u251c\u2500\u2500 amqp_connection.<\/span>c\/<\/span>.<\/span>h \u2190AMQPConnection \u7c7b
\n \u251c\u2500\u2500 amqp_channel.<\/span>c\/<\/span>.<\/span>h \u2190AMQPChannel \u7c7b
\n \u251c\u2500\u2500 amqp_queue.<\/span>c\/<\/span>.<\/span>h \u2190AMQPQueue \u7c7b
\n \u251c\u2500\u2500 amqp_exchange.<\/span>c\/<\/span>.<\/span>h \u2190AMQPExchange \u7c7b
\n \u251c\u2500\u2500 amqp_envelope.<\/span>c\/<\/span>.<\/span>h \u2190AMQPEnvelope \u7c7b(<\/span>\u6d88\u606f\u4fe1\u5c01)<\/span>
\n \u251c\u2500\u2500 amqp_basic_properties.<\/span>c\/<\/span>.<\/span>h\u2190AMQPBasicProperties \u7c7b(<\/span>\u6d88\u606f\u5c5e\u6027)<\/span>
\n \u251c\u2500\u2500 amqp_exception.<\/span>c\/<\/span>.<\/span>h \u2190AMQPException \u53ca\u5b50\u7c7b
\n \u251c\u2500\u2500 amqp_debug.<\/span>c\/<\/span>.<\/span>h \u2190\u8c03\u8bd5\u65e5\u5fd7\u94a9\u5b50(<\/span>amqp_log)<\/span>
\n \u251c\u2500\u2500 amqp_helpers.<\/span>c\/<\/span>.<\/span>h \u2190\u5bf9\u8c61\u2194\u7ed3\u6784\u4f53\u4e92\u8f6c\u3001\u9519\u8bef\u7801\u6620\u5c04
\n \u251c\u2500\u2500 config.<\/span>m4 \u2190\u6784\u5efa\u811a\u672c(<\/span>\u63a2\u6d4b librabbitmq)<\/span>
\n \u2514\u2500\u2500 config.<\/span>w32 \u2190Windows \u6784\u5efa<\/p>\n

\u5927\u767d\u8bdd\u518d\u770b\u4e00\u904d\u5206\u5c42\u903b\u8f91:<\/span> \u6bcf\u4e2a .<\/span>c \u6587\u4ef6 =<\/span> \u4e00\u4e2a PHP \u7c7b;<\/span>amqp_helpers.<\/span>c =<\/span> \u901a\u7528\u8f6c\u6362\u5de5\u5177;<\/span>amqp.<\/span>c =<\/span>
\n \u6a21\u5757\u7684"\u5927\u95e8\u53e3"<\/span>\u3002find"\u54ea\u4e2a\u7c7b\u5728\u54ea\u4e2a\u6587\u4ef6"<\/span>\u5c31\u662f\u627e\u5bf9\u5e94\u6587\u4ef6\u540d\u3002<\/p>\n

—<\/span>–<\/span><\/p>\n

2.<\/span> amqp.<\/span>c:<\/span>MINIT \u9636\u6bb5\u7684\u7c7b\u6ce8\u518c\u4e0e\u5e38\u91cf\u5b9a\u4e49<\/p>\n

\u5927\u767d\u8bdd:<\/span> MINIT<\/span>(<\/span>Module INIT)<\/span>\u662f\u6269\u5c55\u88ab\u52a0\u8f7d\u8fdb PHP<\/span>(<\/span>\u9996\u6b21)<\/span>\u65f6\u6267\u884c\u4e00\u6b21\u7684\u51fd\u6570\u3002amqp.<\/span>c \u5728\u8fd9\u91cc\u5e72\u4e24\u4ef6\u5927\u4e8b:<\/span>\u2460\u628a\u6240\u6709 PHP
\n \u5e38\u91cf\u6ce8\u518c\u8fdb\u53bb;<\/span>\u2461\u628a\u6bcf\u4e2a\u7c7b\u6ce8\u518c\u8fdb Zend \u5f15\u64ce\u3002<\/p>\n

\u5b8c\u6574\u4ee3\u7801(<\/span>\u6a21\u5757\u5165\u53e3 +<\/span> MINIT)<\/span>:<\/span><\/p>\n

#<\/span>include<\/span> "php_amqp.h"<\/span><\/span><\/p>\n

ZEND_BEGIN_MODULE_GLOBALS<\/span>(<\/span>amqp)<\/span>
\n \/* \u6a21\u5757\u7ea7\u5168\u5c40\u53d8\u91cf,\u6bd4\u5982\u6301\u4e45\u8fde\u63a5\u7684\u54c8\u5e0c\u8868 *\/<\/span>
\n HashTable persistent_connections;<\/span>
\n ZEND_END_MODULE_GLOBALS<\/span>(<\/span>amqp)<\/span><\/p>\n

\/* \u5e38\u91cf\u6ce8\u518c\u662f MINIT \u7684\u6838\u5fc3\u6d3b *\/<\/span>
\n PHP_MINIT_FUNCTION<\/span>(<\/span>amqp)<\/span>
\n {<\/span>
\n zend_class_entry ce;<\/span><\/p>\n

\/* \u2500\u2500 \u2460\u5168\u5c40\u5e38\u91cf:flags \u6309\u4f4d\u6807\u5fd7 \u2500\u2500 *\/<\/span>
\n REGISTER_LONG_CONSTANT<\/span>(<\/span>"AMQP_NOPARAM"<\/span>,<\/span> 0x00000000<\/span>,<\/span> CONST_CS |<\/span> CONST_PERSISTENT)<\/span>;<\/span>
\n REGISTER_LONG_CONSTANT<\/span>(<\/span>"AMQP_DURABLE"<\/span>,<\/span> 0x00000001<\/span>,<\/span> CONST_CS |<\/span> CONST_PERSISTENT)<\/span>;<\/span>
\n REGISTER_LONG_CONSTANT<\/span>(<\/span>"AMQP_PASSIVE"<\/span>,<\/span> 0x00000002<\/span>,<\/span> CONST_CS |<\/span> CONST_PERSISTENT)<\/span>;<\/span>
\n REGISTER_LONG_CONSTANT<\/span>(<\/span>"AMQP_EXCLUSIVE"<\/span>,<\/span> 0x00000004<\/span>,<\/span> CONST_CS |<\/span> CONST_PERSISTENT)<\/span>;<\/span>
\n REGISTER_LONG_CONSTANT<\/span>(<\/span>"AMQP_AUTODELETE"<\/span>,<\/span>0x00000008<\/span>,<\/span> CONST_CS |<\/span> CONST_PERSISTENT)<\/span>;<\/span>
\n REGISTER_LONG_CONSTANT<\/span>(<\/span>"AMQP_MANDATORY"<\/span>,<\/span> 0x00000040<\/span>,<\/span> CONST_CS |<\/span> CONST_PERSISTENT)<\/span>;<\/span>
\n REGISTER_LONG_CONSTANT<\/span>(<\/span>"AMQP_IMMEDIATE"<\/span>,<\/span> 0x00000080<\/span>,<\/span> CONST_CS |<\/span> CONST_PERSISTENT)<\/span>;<\/span>
\n REGISTER_LONG_CONSTANT<\/span>(<\/span>"AMQP_IFUNUSED"<\/span>,<\/span> 0x00000100<\/span>,<\/span> CONST_CS |<\/span> CONST_PERSISTENT)<\/span>;<\/span>
\n REGISTER_LONG_CONSTANT<\/span>(<\/span>"AMQP_IFEMPTY"<\/span>,<\/span> 0x00000200<\/span>,<\/span> CONST_CS |<\/span> CONST_PERSISTENT)<\/span>;<\/span>
\n REGISTER_LONG_CONSTANT<\/span>(<\/span>"AMQP_MULTIPLE"<\/span>,<\/span> 0x00000400<\/span>,<\/span> CONST_CS |<\/span> CONST_PERSISTENT)<\/span>;<\/span>
\n REGISTER_LONG_CONSTANT<\/span>(<\/span>"AMQP_NOWAIT"<\/span>,<\/span> 0x00000800<\/span>,<\/span> CONST_CS |<\/span> CONST_PERSISTENT)<\/span>;<\/span>
\n REGISTER_LONG_CONSTANT<\/span>(<\/span>"AMQP_INTERNAL"<\/span>,<\/span> 0x00001000<\/span>,<\/span> CONST_CS |<\/span> CONST_PERSISTENT)<\/span>;<\/span>
\n REGISTER_LONG_CONSTANT<\/span>(<\/span>"AMQP_NOSIGNAL"<\/span>,<\/span> 0x00002000<\/span>,<\/span> CONST_CS |<\/span> CONST_PERSISTENT)<\/span>;<\/span><\/p>\n

\/* \u2500\u2500 \u2461\u6ce8\u518c\u7c7b:\u6bcf\u4e2a\u7c7b\u6765\u81ea\u5404\u81ea\u7684 .c \u6587\u4ef6 \u2500\u2500 *\/<\/span>
\n INIT_CLASS_ENTRY<\/span>(<\/span>ce,<\/span> "AMQPConnection"<\/span>,<\/span> amqp_connection_methods)<\/span>;<\/span>
\n amqp_connection_class_entry =<\/span> zend_register_internal_class<\/span>(<\/span>&<\/span>ce)<\/span>;<\/span>
\n amqp_connection_register_class_constants<\/span>(<\/span>amqp_connection_class_entry)<\/span>;<\/span><\/p>\n

amqp_register_exception_class<\/span>(<\/span>"AMQPException"<\/span>,<\/span> amqp_exception_class_entry,<\/span> NULL<\/span>)<\/span>;<\/span>
\n amqp_register_exception_class<\/span>(<\/span>"AMQPConnectionException"<\/span>,<\/span>
\n amqp_connection_exception_class_entry,<\/span> amqp_exception_class_entry)<\/span>;<\/span>
\n amqp_register_exception_class<\/span>(<\/span>"AMQPChannelException"<\/span>,<\/span>
\n amqp_channel_exception_class_entry,<\/span> amqp_exception_class_entry)<\/span>;<\/span>
\n \/* … QueueException \/ ExchangeException \u540c\u7406 … *\/<\/span><\/p>\n

return<\/span> SUCCESS;<\/span>
\n }<\/span><\/p>\n

\/* \u6a21\u5757\u5165\u53e3\u8868:\u544a\u8bc9 Zend \u54ea\u4e2a\u51fd\u6570\u662f MINIT\/MINFO \u7b49 *\/<\/span>
\n zend_module_entry amqp_module_entry =<\/span> {<\/span>
\n STANDARD_MODULE_HEADER,<\/span>
\n "amqp"<\/span>,<\/span>
\n NULL<\/span>,<\/span> \/* functions:\u6a21\u5757\u7ea7\u51fd\u6570(\u672c\u6269\u5c55\u6ca1\u6709) *\/<\/span>
\n PHP_MINIT<\/span>(<\/span>amqp)<\/span>,<\/span>
\n PHP_MSHUTDOWN<\/span>(<\/span>amqp)<\/span>,<\/span>
\n PHP_RINIT<\/span>(<\/span>amqp)<\/span>,<\/span> \/* \u6bcf\u6b21\u8bf7\u6c42\u521a\u5f00\u59cb\u65f6\u6267\u884c *\/<\/span>
\n PHP_RSHUTDOWN<\/span>(<\/span>amqp)<\/span>,<\/span>
\n PHP_MINFO<\/span>(<\/span>amqp)<\/span>,<\/span>
\n PHP_AMQP_VERSION,<\/span>
\n STANDARD_MODULE_PROPERTIES
\n }<\/span>;<\/span><\/p>\n

\u5927\u767d\u8bdd\u70b9\u62e8:<\/span>
\n –<\/span> REGISTER_LONG_CONSTANT \u7528\u4e86 CONST_PERSISTENT,<\/span>\u56e0\u4e3a\u5e38\u91cf\u8981\u5728\u591a\u6b21\u8bf7\u6c42\u95f4\u4fdd\u6301,<\/span>\u4e0d\u80fd\u6bcf\u6b21\u8bf7\u6c42\u91cd\u6ce8\u518c\u3002
\n –<\/span> \u90a3\u4e9b AMQP_*<\/span> \u5e38\u91cf\u5c31\u662f\u4f60\u5728 PHP \u91cc\u5199 $exchange-><\/span>declare<\/span>(<\/span>$exchange,<\/span> 'direct'<\/span>,<\/span> AMQP_DURABLE |<\/span> AMQP_AUTODELETE)<\/span>
\n \u4f20\u7684\u4f4d\u6807\u5fd7\u3002\u5b83\u4eec\u672c\u8d28\u5c31\u662f\u6574\u6570\u4f4d\u63a9\u7801,<\/span>C \u91cc\u7528 |<\/span> \u7ec4\u5408,<\/span>\u6700\u540e\u4f5c\u4e3a\u4e00\u4e2a uint32 flags \u4f20\u7ed9 librabbitmq\u3002
\n –<\/span> \u7528"\u6bcf\u4e2a\u7c7b\u7684 function entry \u6570\u7ec4"<\/span>(<\/span>amqp_connection_methods)<\/span>\u6ce8\u518c\u7c7b,<\/span>\u662f Zend \u6ce8\u518c\u5185\u5efa\u7c7b\u7684\u6807\u51c6\u505a\u6cd5(<\/span>\u4e0d\u662f\u7528\u6269\u5c55\u673a\u5236)<\/span>\u3002<\/p>\n

—<\/span>–<\/span><\/p>\n

3.<\/span> AMQPConnection:<\/span>\u8fde\u63a5\u7ba1\u7406\u7684 C \u5b9e\u73b0<\/p>\n

\u5927\u767d\u8bdd:<\/span> AMQPConnection \u7684\u804c\u8d23\u662f\u5efa\u7acb\u4e00\u6761\u5230 RabbitMQ \u7684 TCP \u8fde\u63a5\u5e76\u5b8c\u6210 AMQP \u63e1\u624b(<\/span>login)<\/span>\u3002\u5b83\u5e95\u5c42\u7684\u72b6\u6001\u662f librabbitmq \u7684
\n amqp_connection_state_t<\/span>,<\/span>php–<\/span>amqp \u7528\u4e00\u4e2a\u81ea\u5b9a\u4e49\u7ed3\u6784\u5305\u4e00\u5c42,<\/span>\u518d\u628a\u7ed3\u6784\u4f53\u6307\u9488\u585e\u8fdb PHP \u5bf9\u8c61\u91cc\u3002<\/p>\n

\u5b8c\u6574\u4ee3\u7801:<\/span><\/p>\n

\/* php-amqp \u5728 C \u5c42\u5b58\u8fde\u63a5\u72b6\u6001\u7684\u7ed3\u6784 *\/<\/span>
\n typedef<\/span> struct<\/span> _amqp_connection_resource<\/span> {<\/span>
\n amqp_connection_state_t<\/span> connection;<\/span> \/* librabbitmq \u7684\u8fde\u63a5\u53e5\u67c4 *\/<\/span>
\n amqp_connection_object *<\/span>object;<\/span> \/* \u53cd\u5411\u5f15\u7528 *\/<\/span>
\n char<\/span> *<\/span>login;<\/span> char<\/span> *<\/span>password;<\/span> char<\/span> *<\/span>host;<\/span> char<\/span> *<\/span>vhost;<\/span>
\n int<\/span> port;<\/span>
\n int<\/span> read_timeout;<\/span> int<\/span> write_timeout;<\/span> int<\/span> connect_timeout;<\/span>
\n \/* TLS \u76f8\u5173 *\/<\/span>
\n int<\/span> uses_tls;<\/span>
\n char<\/span> *<\/span>cacert;<\/span> char<\/span> *<\/span>cert;<\/span> char<\/span> *<\/span>key;<\/span>
\n zend_long heartbeat;<\/span> \/* \u5fc3\u8df3\u95f4\u9694 *\/<\/span>
\n unsigned<\/span> int<\/span> connected:<\/span>1<\/span>;<\/span>
\n unsigned<\/span> int<\/span> persistent:<\/span>1<\/span>;<\/span>
\n }<\/span> amqp_connection_resource;<\/span><\/p>\n

\/* PHP \u5bf9\u8c61:\u5c31\u662f\u5305\u4e00\u4e2a\u6307\u5411\u4e0a\u9762\u7ed3\u6784\u7684\u6307\u9488 *\/<\/span>
\n struct<\/span> amqp_connection_object<\/span> {<\/span>
\n amqp_connection_resource *<\/span>resource;<\/span>
\n }<\/span>;<\/span><\/p>\n

\/* \u6838\u5fc3:connect() \u7684 C \u5b9e\u73b0 *\/<\/span>
\n static<\/span> void<\/span> amqp_connection_connect<\/span>(<\/span>amqp_connection_object *<\/span>object)<\/span>
\n {<\/span>
\n amqp_connection_resource *<\/span>res =<\/span> object-><\/span>resource;<\/span>
\n amqp_connection_state_t<\/span> conn =<\/span> amqp_new_connection<\/span>(<\/span>)<\/span>;<\/span> \/* \u2460\u5efa\u53e5\u67c4 *\/<\/span>
\n res-><\/span>connection =<\/span> conn;<\/span><\/p>\n

\/* \u2461\u5efa\u7acb socket(\u770b\u662f\u5426\u8d70 TLS) *\/<\/span>
\n if<\/span> (<\/span>res-><\/span>uses_tls)<\/span> {<\/span>
\n amqp_ssl_socket_t<\/span> *<\/span>ssl =<\/span> amqp_ssl_socket_new<\/span>(<\/span>conn)<\/span>;<\/span>
\n amqp_ssl_socket_set_cacert<\/span>(<\/span>ssl,<\/span> res-><\/span>cacert)<\/span>;<\/span> \/* \u89c1\u7b2c 13 \u8282 *\/<\/span>
\n amqp_ssl_socket_set_key<\/span>(<\/span>ssl,<\/span> res-><\/span>cert,<\/span> res-><\/span>key)<\/span>;<\/span>
\n amqp_ssl_socket_set_verify<\/span>(<\/span>ssl,<\/span> AMQP_SSLVERIFY_PEER)<\/span>;<\/span>
\n amqp_socket_open<\/span>(<\/span>ssl,<\/span> res-><\/span>host,<\/span> res-><\/span>port)<\/span>;<\/span>
\n }<\/span> else<\/span> {<\/span>
\n amqp_socket_t<\/span> *<\/span>sock =<\/span> amqp_tcp_socket_new<\/span>(<\/span>conn)<\/span>;<\/span>
\n amqp_socket_open<\/span>(<\/span>sock,<\/span> res-><\/span>host,<\/span> res-><\/span>port)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/* \u2462AMQP \u63e1\u624b \/ login(\u5c31\u662f\u53d1 login \u5e27,\u6536 reply) *\/<\/span>
\n amqp_rpc_reply_t<\/span> reply =<\/span> amqp_login<\/span>(<\/span>conn,<\/span> res-><\/span>vhost,<\/span>
\n res-><\/span>login,<\/span> res-><\/span>password,<\/span>
\n AMQP_DEFAULT_CHANNEL_MAX,<\/span> AMQP_DEFAULT_FRAME_MAX,<\/span>
\n (<\/span>uint16_t<\/span>)<\/span>res-><\/span>heartbeat,<\/span> AMQP_SASL_PLAIN)<\/span>;<\/span><\/p>\n

\/* \u2463\u68c0\u67e5\u63e1\u624b\u7ed3\u679c,\u5931\u8d25\u629b\u5f02\u5e38(\u89c1\u7b2c 11 \u8282) *\/<\/span>
\n if<\/span> (<\/span>reply.<\/span>reply_type !=<\/span> AMQP_RESPONSE_NORMAL)<\/span> {<\/span>
\n amqp_exception_from_rpc_reply_throw<\/span>(<\/span>reply)<\/span>;<\/span>
\n return<\/span>;<\/span>
\n }<\/span>
\n res-><\/span>connected =<\/span> 1<\/span>;<\/span>
\n }<\/span><\/p>\n

\u5927\u767d\u8bdd\u70b9\u62e8:<\/span>
\n –<\/span> amqp_new_connection<\/span>(<\/span>)<\/span> \u53ea\u5206\u914d\u53e5\u67c4,<\/span>\u4e0d\u53d1\u7f51\u7edc\u5305;<\/span>\u771f\u6b63\u7684\u7f51\u7edc\u8fde\u63a5\u53d1\u751f\u5728 amqp_socket_open\u3002\u6240\u4ee5"TCP \u8fde\u4e0a"<\/span>\u548c"AMQP
\n \u63e1\u624b\u6210\u529f"\u662f\u4e24\u6b65,amqp_login \u624d\u4ee3\u8868"<\/span>\u670d\u52a1\u5668\u63a5\u53d7\u4e86\u4f60"(<\/span>\u7528\u6237\u540d\/<\/span>\u5bc6\u7801\/<\/span>vhost \u6821\u9a8c\u901a\u8fc7)<\/span>\u3002
\n –<\/span> \u5fc3\u8df3(<\/span>heartbeat)<\/span>\u5728 login \u65f6\u4e00\u5e76\u534f\u5546:<\/span>AMQP_DEFAULT_FRAME_MAX<\/span>(<\/span>\u9ed8\u8ba4 131072<\/span>=<\/span>128<\/span>KB)<\/span>\u548c heartbeat
\n \u662f\u534f\u8bae\u5c42\u534f\u5546\u7684\u503c,<\/span>\u53cc\u65b9\u53d6\u8f83\u5c0f\u8005\u3002<\/p>\n

\u4e3a\u4ec0\u4e48 TCP \u8fde\u63a5\u4e0d\u7528\u81ea\u5df1\u5199 socket?<\/span> \u56e0\u4e3a librabbitmq \u5df2\u7ecf\u628a"\u5e27\u7f16\u89e3\u7801 + socket \u8bfb\u5199\u4e0b\u5c42"<\/span>\u505a\u6389\u4e86,<\/span>php–<\/span>amqp
\n \u53ea\u9700\u8981\u7ba1"\u751f\u547d\u5468\u671f\u548c\u5bf9\u8c61\u5305\u88c5"<\/span>\u3002\u8fd9\u4e5f\u662f\u5b83\u53c8\u6162\u4e0d\u4e86\u7684\u7701\u5fc3\u70b9\u2014\u2014\u6240\u6709\u7f51\u7edcI\/<\/span>O \u90fd\u5728 C \u5c42,<\/span>\u4e0d\u7ecf\u8fc7 PHP \u7528\u6237\u6001\u3002<\/p>\n

—<\/span>–<\/span><\/p>\n

4.<\/span> AMQPChannel:<\/span>\u901a\u9053\u7684 C \u5b9e\u73b0<\/p>\n

\u5927\u767d\u8bdd:<\/span> \u4e00\u4e2a AMQP \u8fde\u63a5\u4e0a\u53ef\u4ee5\u5f00\u5f88\u591a\u901a\u9053(<\/span>channel)<\/span>,<\/span>\u6bcf\u6761\u901a\u9053\u662f\u72ec\u7acb\u7684\u903b\u8f91\u4f1a\u8bdd\u3002AMQP \u534f\u8bae\u7528\u4e00\u4e2a TCP
\n \u8fde\u63a5\u590d\u7528\u591a\u8def(<\/span>multiplexing)<\/span>,<\/span>\u9760
\n channel_id<\/span>(<\/span>1<\/span>~<\/span>65535<\/span>)<\/span>\u533a\u5206\u3002\u901a\u9053\u9694\u79bb\u610f\u5473\u7740:<\/span>\u4e00\u6761\u901a\u9053\u4e0a\u7684\u9519\u8bef\/<\/span>\u4e8b\u52a1\/<\/span>\u961f\u5217\u64cd\u4f5c,<\/span>\u4e0d\u5f71\u54cd\u540c\u4e00\u8fde\u63a5\u4e0a\u7684\u5176\u4ed6\u901a\u9053\u3002AMQPChannel
\n \u5c31\u662f\u5305\u4e00\u4e2a channel_id +<\/span> \u53cd\u5411\u5f15\u7528\u6240\u5c5e\u8fde\u63a5\u3002<\/p>\n

\u5b8c\u6574\u4ee3\u7801:<\/span><\/p>\n

struct<\/span> amqp_channel_object<\/span> {<\/span>
\n amqp_channel_resource *<\/span>resource;<\/span> \/* \u5185\u542b channel_id \u548c\u8fde\u63a5\u5f15\u7528 *\/<\/span>
\n }<\/span>;<\/span><\/p>\n

typedef<\/span> struct<\/span> _amqp_channel_resource<\/span> {<\/span>
\n amqp_connection_object *<\/span>connection;<\/span> \/* \u53cd\u5411\u5f15\u7528:\u901a\u9053\u5c5e\u4e8e\u54ea\u4e2a\u8fde\u63a5 *\/<\/span>
\n uint16_t<\/span> channel_id;<\/span> \/* \u901a\u9053\u53f7 *\/<\/span>
\n int<\/span> is_open:<\/span>1<\/span>;<\/span>
\n }<\/span> amqp_channel_resource;<\/span><\/p>\n

\/* \u6253\u5f00\u901a\u9053:\u53d1 channel.open \u5e27 *\/<\/span>
\n static<\/span> void<\/span> amqp_channel_open<\/span>(<\/span>amqp_channel_resource *<\/span>rsc)<\/span>
\n {<\/span>
\n amqp_connection_state_t<\/span> conn =<\/span> rsc-><\/span>connection-><\/span>resource-><\/span>connection;<\/span>
\n amqp_rpc_reply_t<\/span> reply =<\/span> amqp_channel_open<\/span>(<\/span>conn,<\/span> rsc-><\/span>channel_id)<\/span>;<\/span>
\n if<\/span> (<\/span>reply.<\/span>reply_type !=<\/span> AMQP_RESPONSE_NORMAL)<\/span> {<\/span>
\n amqp_throw_amqp_channel_exception<\/span>(<\/span>reply)<\/span>;<\/span>
\n return<\/span>;<\/span>
\n }<\/span>
\n rsc-><\/span>is_open =<\/span> 1<\/span>;<\/span>
\n \/* \u901a\u9053\u5efa\u7acb\u540e\u7ecf\u5e38\u987a\u624b\u8bbe\u7f6e QoS *\/<\/span>
\n amqp_basic_qos<\/span>(<\/span>conn,<\/span> rsc-><\/span>channel_id,<\/span> 0<\/span>,<\/span> rsc-><\/span>prefetch_count,<\/span> 0<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/* \u65b9\u6cd5\u793a\u4f8b:prefetch(\u544a\u8bc9 broker \u4e00\u6b21\u6700\u591a\u63a8\u591a\u5c11\u6d88\u606f\u7ed9\u4f60) *\/<\/span>
\n PHP_METHOD<\/span>(<\/span>AMQPChannel,<\/span> setPrefetchCount)<\/span>
\n {<\/span>
\n amqp_channel_object *<\/span>obj =<\/span> Z_AMQPCHANNEL_P<\/span>(<\/span>ZEND_THIS)<\/span>;<\/span>
\n zend_long count;<\/span>
\n ZEND_PARSE_PARAMETERS_START<\/span>(<\/span>1<\/span>,<\/span> 1<\/span>)<\/span>
\n Z_PARAM_LONG<\/span>(<\/span>count)<\/span>
\n ZEND_PARSE_PARAMETERS_END<\/span>(<\/span>)<\/span>;<\/span><\/p>\n

obj-><\/span>resource-><\/span>prefetch_count =<\/span> count;<\/span>
\n amqp_basic_qos<\/span>(<\/span>obj-><\/span>resource-><\/span>connection-><\/span>resource-><\/span>connection,<\/span>
\n obj-><\/span>resource-><\/span>channel_id,<\/span> 0<\/span>,<\/span> count,<\/span> 0<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\u5927\u767d\u8bdd\u70b9\u62e8:<\/span>
\n –<\/span> \u591a\u8def\u590d\u7528\u7684\u5173\u952e:<\/span> \u6240\u6709 AMQP \u5e27\u90fd\u5e26\u4e00\u4e2a channel \u5b57\u6bb5,<\/span>broker \u6309 channel_id \u628a\u6d88\u606f\u8def\u7531\u5230\u6b63\u786e\u7684\u4f1a\u8bdd\u3002\u6240\u4ee5"\u591a\u8def\u590d\u7528"<\/span>\u4e0d\u9760
\n PHP \u5c42\u505a\u7ebf\u7a0b,<\/span>\u800c\u662f\u534f\u8bae\u672c\u8eab\u7684\u8bbe\u8ba1\u2014\u2014PH\u91cc\u53ea\u662f"\u4e00\u4e2a\u8fde\u63a5\u5bf9\u8c61,\u591a\u4e2a channel \u5bf9\u8c61,\u5404\u81ea\u8bb0 channel_id"<\/span>\u3002
\n –<\/span> \u901a\u9053\u9694\u79bb\u7684\u542b\u4e49:<\/span> \u7b2c 9<\/span> \u8282\u7684\u4e8b\u52a1(<\/span>\u5728\u901a\u9053\u4e0a\u9009\u4e8b\u52a1\u6a21\u5f0f)<\/span>\u3001\u7b2c 10<\/span> \u8282\u7684\u786e\u8ba4\u6a21\u5f0f,<\/span>\u90fd\u662f\u901a\u9053\u7ea7\u72b6\u6001\u3002A \u901a\u9053\u5f00\u4e86\u4e8b\u52a1,<\/span>B
\n \u901a\u9053\u7167\u5e38\u53d1\u6d88\u606f,<\/span>\u4e92\u4e0d\u5f71\u54cd\u3002\u8fd9\u5c31\u662f"\u901a\u9053\u7ea7\u9694\u79bb"<\/span>\u6700\u5b9e\u7528\u7684\u4f53\u73b0\u3002<\/p>\n

—<\/span>–<\/span><\/p>\n

5.<\/span> AMQPQueue:<\/span>\u961f\u5217\u64cd\u4f5c\u7684 C \u5b9e\u73b0<\/p>\n

\u5927\u767d\u8bdd:<\/span> AMQPQueue \u628a\u961f\u5217\u7684\u751f\u547d\u5468\u671f\u64cd\u4f5c(<\/span>\u58f0\u660e\u3001\u7ed1\u5b9a\u3001\u6d88\u8d39\u3001ack)<\/span>\u5305\u6210\u65b9\u6cd5\u3002\u5b83\u5e95\u5c42\u5c31\u662f\u8c03 librabbitmq \u4e00\u6392 amqp_queue_*<\/span> \/<\/span>
\n amqp_basic_*<\/span> \u51fd\u6570\u3002<\/p>\n

\u5b8c\u6574\u4ee3\u7801:<\/span><\/p>\n

\/* declare:\u58f0\u660e\u961f\u5217,\u4e0d\u5b58\u5728\u5219\u5efa,\u5b58\u5728\u5219\u8fd4\u56de\u4fe1\u606f *\/<\/span>
\n PHP_METHOD<\/span>(<\/span>AMQPQueue,<\/span> declareQueue)<\/span>
\n {<\/span>
\n amqp_queue_object *<\/span>obj =<\/span> Z_AMQPQUEUE_P<\/span>(<\/span>ZEND_THIS)<\/span>;<\/span>
\n amqp_channel_resource *<\/span>ch =<\/span> obj-><\/span>resource-><\/span>channel-><\/span>resource;<\/span>
\n amqp_connection_state_t<\/span> conn =<\/span> ch-><\/span>connection-><\/span>resource-><\/span>connection;<\/span><\/p>\n

amqp_queue_declare_ok_t<\/span> *<\/span>ok =<\/span> amqp_queue_declare<\/span>(<\/span>conn,<\/span>
\n ch-><\/span>channel_id,<\/span>
\n amqp_cstring_bytes<\/span>(<\/span>obj-><\/span>resource-><\/span>name)<\/span>,<\/span> \/* \u961f\u5217\u540d *\/<\/span>
\n obj-><\/span>resource-><\/span>flags &<\/span> AMQP_PASSIVE,<\/span> \/* passive *\/<\/span>
\n obj-><\/span>resource-><\/span>flags &<\/span> AMQP_DURABLE,<\/span> \/* durable *\/<\/span>
\n obj-><\/span>resource-><\/span>flags &<\/span> AMQP_EXCLUSIVE,<\/span> \/* exclusive *\/<\/span>
\n obj-><\/span>resource-><\/span>flags &<\/span> AMQP_AUTODELETE,<\/span> \/* auto_delete *\/<\/span>
\n 0<\/span>,<\/span> \/* nowait *\/<\/span>
\n NULL<\/span>)<\/span>;<\/span> \/* arguments *\/<\/span>
\n if<\/span> (<\/span>ok)<\/span> {<\/span>
\n \/* reply \u91cc\u5e26\u4e86 broker \u5b9e\u9645\u5206\u914d\u7684\u961f\u5217\u540d\u548c\u6d88\u606f\u6570 *\/<\/span>
\n obj-><\/span>resource-><\/span>name =<\/span> amqp_cstring<\/span>(<\/span>ok-><\/span>queue)<\/span>;<\/span>
\n }<\/span>
\n }<\/span><\/p>\n

\/* bind:\u7ed1\u5b9a\u961f\u5217\u5230\u4ea4\u6362\u5668,\u901a\u8fc7\u8def\u7531\u952e *\/<\/span>
\n PHP_METHOD<\/span>(<\/span>AMQPQueue,<\/span> bind)<\/span>
\n {<\/span>
\n amqp_queue_bind<\/span>(<\/span>conn,<\/span> ch-><\/span>channel_id,<\/span>
\n amqp_cstring_bytes<\/span>(<\/span>name)<\/span>,<\/span> \/* \u961f\u5217 *\/<\/span>
\n amqp_cstring_bytes<\/span>(<\/span>exchange)<\/span>,<\/span> \/* \u4ea4\u6362\u5668 *\/<\/span>
\n amqp_cstring_bytes<\/span>(<\/span>routing_key)<\/span>,<\/span> \/* \u8def\u7531\u952e *\/<\/span>
\n nowait,<\/span> NULL<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/* get:\u975e\u963b\u585e\u62ff\u4e00\u6761(amqp_basic_get) *\/<\/span>
\n PHP_METHOD<\/span>(<\/span>AMQPQueue,<\/span> get)<\/span>
\n {<\/span>
\n amqp_rpc_reply_t<\/span> reply =<\/span> amqp_basic_get<\/span>(<\/span>conn,<\/span> ch-><\/span>channel_id,<\/span>
\n amqp_cstring_bytes<\/span>(<\/span>name)<\/span>,<\/span> no_ack)<\/span>;<\/span>
\n \/* \u628a\u8fd4\u56de\u7684 amqp_envelope_t \u5305\u6210 AMQPEnvelope \u5bf9\u8c61 *\/<\/span>
\n if<\/span> (<\/span>reply.<\/span>reply_type ==<\/span> AMQP_RESPONSE_NORMAL)<\/span> {<\/span>
\n amqp_envelope_t<\/span> envelope;<\/span>
\n amqp_message_t<\/span> message;<\/span>
\n if<\/span> (<\/span>amqp_consume_message<\/span>(<\/span>conn,<\/span> &<\/span>envelope,<\/span> &<\/span>message,<\/span> NULL<\/span>)<\/span>)<\/span> {<\/span>
\n \/* \u8f6c\u6210 PHP \u5bf9\u8c61,\u89c1\u7b2c 8 \u8282 *\/<\/span>
\n }<\/span>
\n }<\/span>
\n }<\/span><\/p>\n

\/* consume:\u963b\u585e\u5f0f\u6d88\u8d39(\u5e26\u56de\u8c03,\u89c1\u7b2c 8 \u8282) *\/<\/span>
\n PHP_METHOD<\/span>(<\/span>AMQPQueue,<\/span> consume)<\/span>
\n {<\/span>
\n amqp_basic_consume<\/span>(<\/span>conn,<\/span> ch-><\/span>channel_id,<\/span> queue,<\/span> consumer_tag,<\/span>
\n no_local,<\/span> no_ack,<\/span> exclusive,<\/span> 0<\/span>,<\/span> NULL<\/span>)<\/span>;<\/span>
\n \/* \u7136\u540e\u8fdb\u5165\u4e00\u4e2a\u5faa\u73af,\u4e00\u5e27\u4e00\u5e27\u5730\u6536\u6d88\u606f\u5e76\u56de\u8c03 PHP \u7528\u6237\u51fd\u6570 *\/<\/span>
\n }<\/span><\/p>\n

\/* ack:\u786e\u8ba4\u6d88\u606f *\/<\/span>
\n PHP_METHOD<\/span>(<\/span>AMQPQueue,<\/span> ack)<\/span>
\n {<\/span>
\n amqp_basic_ack<\/span>(<\/span>conn,<\/span> ch-><\/span>channel_id,<\/span> delivery_tag,<\/span> multiple)<\/span>;<\/span>
\n }<\/span><\/p>\n

\u5927\u767d\u8bdd\u70b9\u62e8:<\/span>
\n –<\/span> ack \u4e3a\u4ec0\u4e48\u5e38\u89c1\u5751:<\/span> amqp_basic_ack \u7528 delivery_tag \u786e\u8ba4"\u7b2c\u51e0\u6761"<\/span>\u6d88\u606f\u3002\u5982\u679c\u5fd8\u4e86 ack,<\/span>broker
\n \u4f1a\u8ba4\u4e3a\u6d88\u606f\u6ca1\u6d88\u8d39\u6210\u529f,<\/span>\u7559\u5728\u961f\u5217\u91cc,<\/span>\u5ba2\u6237\u7aef\u91cd\u8fde\u540e\u53ef\u80fd\u91cd\u590d\u6536\u5230\u3002\u6240\u4ee5"\u624b\u52a8 ack"<\/span>\u6a21\u5f0f\u4e0b,<\/span>delivery_tag
\n \u8981\u7cbe\u786e\u53d6\u81ea\u5df1\u8981\u786e\u8ba4\u7684\u90a3\u6761(<\/span>AMQPEnvelope::<\/span>getDeliveryTag<\/span>(<\/span>)<\/span>)<\/span>\u3002<\/p>\n

—<\/span>–<\/span><\/p>\n

6.<\/span> AMQPExchange:<\/span>\u4ea4\u6362\u5668\u64cd\u4f5c\u7684 C \u5b9e\u73b0<\/p>\n

\u5927\u767d\u8bdd:<\/span> \u4ea4\u6362\u5668(<\/span>exchange)<\/span>\u662f\u6d88\u606f\u7684\u8def\u7531\u4e2d\u67a2\u3002AMQPExchange \u8d1f\u8d23\u4ea4\u6362\u5668\u58f0\u660e\u3001\u7ed1\u5b9a(<\/span>\u5230\u522b\u7684\u4ea4\u6362\u5668)<\/span>\u548c\u6700\u5e38\u7528\u7684
\n publish<\/span>(<\/span>\u53d1\u5e03\u6d88\u606f)<\/span>\u3002\u7c7b\u578b direct\/<\/span>topic\/<\/span>fanout\/<\/span>headers \u672c\u8d28\u5c31\u4e00\u4e2a\u5b57\u7b26\u4e32(<\/span>"direct"<\/span>\/<\/span>"topic"<\/span>\/<\/span>fanout\/<\/span>headers)<\/span>,<\/span>\u5728\u58f0\u660e\u65f6\u4f20\u7ed9
\n broker\u3002<\/p>\n

\u5b8c\u6574\u4ee3\u7801:<\/span><\/p>\n

\/* \u58f0\u660e\u4ea4\u6362\u5668 *\/<\/span>
\n PHP_METHOD<\/span>(<\/span>AMQPExchange,<\/span> declareExchange)<\/span>
\n {<\/span>
\n amqp_exchange_declare<\/span>(<\/span>conn,<\/span> ch-><\/span>channel_id,<\/span>
\n amqp_cstring_bytes<\/span>(<\/span>name)<\/span>,<\/span>
\n amqp_cstring_bytes<\/span>(<\/span>type)<\/span>,<\/span> \/* "direct" \/ "topic" \/ "fanout" \/ "headers" *\/<\/span>
\n passive,<\/span> durable,<\/span> auto_delete,<\/span> internal,<\/span> nowait,<\/span> NULL<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/* publish:\u53d1\u5e03\u6d88\u606f \u2014\u2014\u7b2c 7 \u8282\u5c55\u5f00 *\/<\/span>
\n PHP_METHOD<\/span>(<\/span>AMQPExchange,<\/span> publish)<\/span>
\n {<\/span>
\n amqp_basic_properties_t<\/span> props;<\/span>
\n amqp_basic_properties_init<\/span>(<\/span>&<\/span>props)<\/span>;<\/span><\/p>\n

\/* \u628a PHP \u4f20\u8fdb\u6765\u7684 body \u8f6c\u6210 librabbitmq \u7684\u5b57\u8282 *\/<\/span>
\n amqp_bytes_t<\/span> body =<\/span> amqp_cstring_bytes<\/span>(<\/span>message)<\/span>;<\/span><\/p>\n

\/* \u7ec4\u88c5\u5c5e\u6027(\u89c1\u7b2c 7 \u8282) *\/<\/span>
\n amqp_basic_publish<\/span>(<\/span>conn,<\/span> ch-><\/span>channel_id,<\/span>
\n amqp_cstring_bytes<\/span>(<\/span>exchange)<\/span>,<\/span>
\n amqp_cstring_bytes<\/span>(<\/span>routing_key)<\/span>,<\/span>
\n flags,<\/span> \/* AMQP_MANDATORY | AMQP_IMMEDIATE *\/<\/span>
\n &<\/span>props,<\/span> \/* \u5c5e\u6027 *\/<\/span>
\n body)<\/span>;<\/span>
\n }<\/span><\/p>\n

\u5927\u767d\u8bdd\u70b9\u62e8:<\/span>
\n –<\/span> publish \u91cc exchange \u4e3a\u7a7a\u4e32 ""<\/span> \u8868\u793a"\u53d1\u5e03\u5230\u9ed8\u8ba4\u4ea4\u6362\u5668"<\/span>\u2014\u2014\u6b64\u65f6routing_key
\n \u5c31\u662f\u8981\u6295\u9012\u5230\u7684\u961f\u5217\u540d\u3002\u8fd9\u5c31\u662f\u5f88\u591a\u4eba"\u6211\u660e\u660e\u53ea\u7528\u4e86\u961f\u5217\u6ca1\u5efa\u4ea4\u6362\u5668"<\/span>\u4e5f\u80fd\u53d1\u6d88\u606f\u7684\u539f\u56e0\u3002
\n –<\/span> direct:<\/span>routing_key \u7cbe\u786e\u5339\u914d\u961f\u5217\u7ed1\u5b9a\u952e;<\/span>topic:<\/span>\u652f\u6301\u901a\u914d\u7b26(<\/span>*<\/span> \u5339\u914d\u4e00\u6bb5,<\/span># \u5339\u914d\u591a\u6bb5)<\/span>;<\/span>fanout:<\/span>\u5b8c\u5168\u5ffd\u7565
\n routing_key,<\/span>\u53d1\u7ed9\u6240\u6709\u7ed1\u5b9a\u961f\u5217\u3002\u8fd9\u56db\u4e2a\u7c7b\u578b\u53ea\u662f\u58f0\u660e\u65f6\u7684\u5b57\u7b26\u4e32,<\/span>\u771f\u6b63\u8def\u7531\u903b\u8f91\u5168\u5728 broker \u4fa7\u3002<\/p>\n

—<\/span>–<\/span><\/p>\n

7.<\/span> AMQP \u6d88\u606f\u53d1\u5e03:<\/span>basic_publish \u7684 C \u5b9e\u73b0<\/p>\n

\u5927\u767d\u8bdd:<\/span> \u53d1\u5e03\u4e00\u6761\u6d88\u606f =<\/span> \u7ec4\u88c5"\u5c5e\u6027(header)"<\/span> +<\/span> "\u6b63\u6587(body)"<\/span>,<\/span>\u7136\u540e\u4e00\u4e2a amqp_basic_publish \u628a\u5e27\u5199\u51fa\u53bb\u3002\u6d88\u606f\u5c5e\u6027\u5c31\u662f
\n AMQPBasicProperties \u5bf9\u8c61\u7684 C \u7ed3\u6784 amqp_basic_properties_t<\/span>\u3002<\/p>\n

\u5b8c\u6574\u4ee3\u7801:<\/span><\/p>\n

PHP_METHOD<\/span>(<\/span>AMQPBasicProperties,<\/span> __construct)<\/span> {<\/span> \/* … *\/<\/span> }<\/span><\/p>\n

static<\/span> amqp_basic_properties_t<\/span> amqp_basic_properties_from_object<\/span>(<\/span>
\n zval *<\/span>zprops)<\/span>
\n {<\/span>
\n amqp_basic_properties_t<\/span> props;<\/span>
\n amqp_basic_properties_init<\/span>(<\/span>&<\/span>props)<\/span>;<\/span> \/* \u5148\u5168\u90e8\u6e05\u96f6 *\/<\/span><\/p>\n

\/* \u5173\u952e:amqp_basic_properties_t \u7528"\u54ea\u51e0\u4e2a\u5b57\u6bb5\u88ab\u8bbe\u7f6e\u4e86"\u7684\u4f4d\u63a9\u7801\u6807\u8bb0 *\/<\/span>
\n uint32_t<\/span> flags =<\/span> 0<\/span>;<\/span><\/p>\n

\/* \u4ece PHP \u5bf9\u8c61\u9010\u5b57\u6bb5\u8bfb\u51fa,\u80fd\u5bf9\u5e94\u5c31\u586b\u8fdb C \u7ed3\u6784 *\/<\/span>
\n if<\/span> (<\/span>content_type)<\/span> {<\/span>
\n props.<\/span>content_type =<\/span> amqp_cstring_bytes<\/span>(<\/span>content_type)<\/span>;<\/span>
\n flags |=<\/span> AMQP_BASIC_CONTENT_TYPE_FLAG;<\/span>
\n }<\/span>
\n if<\/span> (<\/span>delivery_mode)<\/span> {<\/span>
\n props.<\/span>delivery_mode =<\/span> delivery_mode;<\/span> \/* 1=transient \/ 2=persistent *\/<\/span>
\n flags |=<\/span> AMQP_BASIC_DELIVERY_MODE_FLAG;<\/span>
\n }<\/span>
\n if<\/span> (<\/span>headers)<\/span> {<\/span>
\n props.<\/span>headers =<\/span> amqp_table_t_from_zval<\/span>(<\/span>headers)<\/span>;<\/span> \/* \u952e\u503c\u8868 *\/<\/span>
\n flags |=<\/span> AMQP_BASIC_HEADERS_FLAG;<\/span>
\n }<\/span>
\n \/* priority \/ correlation_id \/ reply_to \/ expiration \/ message_id \/
\n timestamp \/ type \/ user_id \/ app_id … \u540c\u7406 *\/<\/span><\/p>\n

props.<\/span>_flags =<\/span> flags;<\/span> \/* \u544a\u8bc9 librabbitmq \u54ea\u4e9b\u5b57\u6bb5\u6709\u6548 *\/<\/span>
\n return<\/span> props;<\/span>
\n }<\/span><\/p>\n

PHP_METHOD<\/span>(<\/span>AMQPExchange,<\/span> publish)<\/span>
\n {<\/span>
\n amqp_basic_properties_t<\/span> props =<\/span> amqp_basic_properties_from_object<\/span>(<\/span>z_props)<\/span>;<\/span><\/p>\n

amqp_basic_publish<\/span>(<\/span>conn,<\/span> ch-><\/span>channel_id,<\/span>
\n amqp_cstring_bytes<\/span>(<\/span>exchange)<\/span>,<\/span>
\n amqp_cstring_bytes<\/span>(<\/span>routing_key)<\/span>,<\/span>
\n flags,<\/span> &<\/span>props,<\/span>
\n amqp_cstring_bytes<\/span>(<\/span>body)<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\u5927\u767d\u8bdd\u70b9\u62e8:<\/span>
\n –<\/span> _flags \u662f\u8fd9\u4e2a\u7ed3\u6784\u6700\u5173\u952e\u7684\u5730\u65b9\u3002 librabbitmq \u7684 amqp_basic_properties_t<\/span> \u662f\u4e2a\u5927\u7ed3\u6784,<\/span>\u4f46\u5f88\u591a\u5b57\u6bb5\u662f\u53ef\u9009\u7684\u3002\u5b83\u7528 _flags
\n \u4f4d\u63a9\u7801\u6807"\u54ea\u4e9b\u5b57\u6bb5\u771f\u7684\u88ab\u8bbe\u7f6e\u4e86"<\/span>,<\/span>\u8fd9\u6837\u7f16\u89e3\u7801\u65f6\u53ea\u5e8f\u5217\u5316\u6709\u6548\u7684\u5b57\u6bb5\u3002php–<\/span>amqp \u7684\u6838\u5fc3\u5de5\u4f5c\u4e4b\u4e00,<\/span>\u5c31\u662f\u628a PHP
\n \u5bf9\u8c61\u91cc\u7684\u5c5e\u6027\u8f6c\u6210\u8fd9\u4e2a\u5e26 flags \u7684 C \u7ed3\u6784\u3002
\n –<\/span> delivery_mode=<\/span>2<\/span>(<\/span>persistent)<\/span> \u5c31\u662f"\u6d88\u606f\u843d\u76d8"<\/span>,<\/span>broker
\n \u91cd\u542f\u4e5f\u4e0d\u4e22;<\/span>=<\/span>1<\/span>(<\/span>transient)<\/span>\u53ea\u5b58\u5185\u5b58\u3002\u8fd9\u662f\u6d88\u606f\u53ef\u9760\u6027\u7684\u7b2c\u4e00\u5c42,<\/span>\u4f46\u771f\u6b63\u7684\u53ef\u9760\u6295\u9012\u8981\u914d\u7b2c 10<\/span> \u8282\u7684\u53d1\u5e03\u786e\u8ba4\u3002<\/p>\n

\u4e3a\u4ec0\u4e48\u6d88\u606f\u5c5e\u6027\u8981\u505a\u6210\u5355\u72ec\u4e00\u4e2a AMQPBasicProperties \u7c7b,<\/span>\u800c\u4e0d\u662f\u76f4\u63a5\u585e\u8fdb publish \u7684\u53c2\u6570\u91cc?<\/span>
\n \u56e0\u4e3a\u5c5e\u6027\u5b57\u6bb5\u591a\u8fbe\u5341\u51e0\u9879(<\/span>\u6b63\u6587\u7c7b\u578b\u3001\u4f18\u5148\u7ea7\u3001\u5173\u8054 ID\u3001\u8fc7\u671f\u65f6\u95f4\u3001\u5e94\u7528
\n ID\u3001\u5934\u8868\u2026\u2026)<\/span>,<\/span>\u505a\u6210\u53c2\u6570\u5217\u8868\u4f1a\u53c8\u957f\u53c8\u4e71;<\/span>\u505a\u6210\u5bf9\u8c61\u53ef\u4ee5\u6309\u9700\u8bbe\u7f6e\u3001\u53ef\u590d\u7528\u3001\u53ef\u5e8f\u5217\u5316\u3002\u8fd9\u662f\u4e3a\u53ef\u8bfb\u6027\u727a\u7272\u4e86\u4e00\u70b9\u6027\u80fd\u7684\u8bbe\u8ba1\u3002<\/p>\n

—<\/span>–<\/span><\/p>\n

8.<\/span> AMQP \u6d88\u606f\u6d88\u8d39:<\/span>basic_consume \u7684 C \u5b9e\u73b0<\/p>\n

\u5927\u767d\u8bdd:<\/span> \u6d88\u8d39\u5206\u4e24\u79cd:<\/span>\u2460\u975e\u963b\u585e\u7684get\u2014\u2014\u53d1\u4e00\u4e2abasic.<\/span>get,<\/span>broker \u82e5\u6709\u6d88\u606f\u7acb\u523b\u8fd4\u56de,<\/span>\u6ca1\u6709\u5c31\u8fd4\u56de"\u7a7a"<\/span>;<\/span>\u2461\u963b\u585e\u7684consume\u2014\u2014\u53d1\u4e00\u4e2a
\n basic.<\/span>consume,<\/span>\u7136\u540e\u505c\u5728 C \u5c42\u5faa\u73af\u91cc\u6301\u7eed\u6536\u5e27,<\/span>\u6bcf\u6536\u4e00\u6761\u5c31\u56de\u8c03\u4f60\u628a PHP \u51fd\u6570,<\/span>\u76f4\u5230\u901a\u9053\/<\/span>\u8fde\u63a5\u5173\u95ed\u6216 cancel\u3002<\/p>\n

\u5b8c\u6574\u4ee3\u7801:<\/span><\/p>\n

PHP_METHOD<\/span>(<\/span>AMQPQueue,<\/span> consume)<\/span>
\n {<\/span>
\n amqp_basic_consume<\/span>(<\/span>conn,<\/span> ch-><\/span>channel_id,<\/span>
\n amqp_cstring_bytes<\/span>(<\/span>queue_name)<\/span>,<\/span>
\n amqp_cstring_bytes<\/span>(<\/span>consumer_tag)<\/span>,<\/span>
\n no_local,<\/span> no_ack,<\/span> exclusive,<\/span> 0<\/span>,<\/span> NULL<\/span>)<\/span>;<\/span><\/p>\n

\/* \u963b\u585e\u5faa\u73af:\u4e00\u5e27\u4e00\u5e27\u6536,\u76f4\u5230\u56de\u8c03\u8fd4\u56de false \/ \u8d85\u65f6 \/ \u8fde\u63a5\u65ad\u5f00 *\/<\/span>
\n while<\/span> (<\/span>1<\/span>)<\/span> {<\/span>
\n amqp_envelope_t<\/span> envelope;<\/span>
\n amqp_message_t<\/span> message;<\/span>
\n amqp_rpc_reply_t<\/span> r =<\/span> amqp_consume_message<\/span>(<\/span>conn,<\/span> &<\/span>envelope,<\/span> &<\/span>message,<\/span> &<\/span>timeout)<\/span>;<\/span><\/p>\n

if<\/span> (<\/span>r.<\/span>reply_type ==<\/span> AMQP_RESPONSE_NORMAL)<\/span> {<\/span>
\n \/* \u628a C \u7684 envelope \u5305\u6210 AMQPEnvelope \u7684 PHP \u5bf9\u8c61 *\/<\/span>
\n zval zenv;<\/span>
\n amqp_envelope_to_zval<\/span>(<\/span>&<\/span>envelope,<\/span> &<\/span>zenv)<\/span>;<\/span><\/p>\n

\/* \u8c03\u4f60\u4f20\u8fdb\u6765\u7684 PHP \u56de\u8c03 *\/<\/span>
\n zval retval;<\/span>
\n zend_call_function_with_1_param<\/span>(<\/span>callback,<\/span> &<\/span>zenv,<\/span> &<\/span>retval)<\/span>;<\/span>
\n zval_ptr_dtor<\/span>(<\/span>&<\/span>zenv)<\/span>;<\/span><\/p>\n

\/* \u56de\u8c03\u8fd4\u56de false \u5c31\u505c *\/<\/span>
\n if<\/span> (<\/span>Z_TYPE<\/span>(<\/span>retval)<\/span> ==<\/span> IS_FALSE)<\/span> {<\/span>
\n zval_ptr_dtor<\/span>(<\/span>&<\/span>retval)<\/span>;<\/span>
\n break<\/span>;<\/span>
\n }<\/span>
\n zval_ptr_dtor<\/span>(<\/span>&<\/span>retval)<\/span>;<\/span>
\n }<\/span> else<\/span> if<\/span> (<\/span>r.<\/span>reply_type ==<\/span> AMQP_RESPONSE_LIBRARY_EXCEPTION)<\/span> {<\/span>
\n \/* broker \u628a\u8fde\u63a5\/\u901a\u9053\u5173\u4e86 *\/<\/span>
\n break<\/span>;<\/span>
\n }<\/span>
\n amqp_basic_destroy_envelope<\/span>(<\/span>&<\/span>envelope)<\/span>;<\/span>
\n amqp_destroy_message<\/span>(<\/span>&<\/span>message)<\/span>;<\/span>
\n }<\/span><\/p>\n

amqp_basic_cancel<\/span>(<\/span>conn,<\/span> ch-><\/span>channel_id,<\/span> amqp_cstring_bytes<\/span>(<\/span>consumer_tag)<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/* \u975e\u963b\u585e get *\/<\/span>
\n PHP_METHOD<\/span>(<\/span>AMQPQueue,<\/span> get)<\/span>
\n {<\/span>
\n if<\/span> (<\/span>amqp_basic_get<\/span>(<\/span>conn,<\/span> ch-><\/span>channel_id,<\/span> queue,<\/span> no_ack)<\/span>)<\/span> {<\/span>
\n \/* \u6709\u6d88\u606f\u5c31\u8fd4\u56de AMQPEnvelope *\/<\/span>
\n amqp_envelope_t<\/span> envelope;<\/span>
\n amqp_consume_message<\/span>(<\/span>conn,<\/span> &<\/span>envelope,<\/span> &<\/span>message,<\/span> NULL<\/span>)<\/span>;<\/span>
\n return<\/span> envelope_to_zval<\/span>(<\/span>&<\/span>envelope)<\/span>;<\/span>
\n }<\/span>
\n RETURN_FALSE;<\/span> \/* \u6ca1\u6d88\u606f *\/<\/span>
\n }<\/span><\/p>\n

\u5927\u767d\u8bdd\u70b9\u62e8:<\/span>
\n –<\/span> consume \u963b\u585e\u610f\u5473\u7740\u4f60\u7684 PHP \u8fdb\u7a0b"\u5361"<\/span>\u5728 C \u5faa\u73af\u91cc\u3002 \u8fd9\u662f\u5b83\u548c get \u7684\u672c\u8d28\u533a\u522b:<\/span>consume \u4f1a\u4e00\u76f4\u6302\u7740\u7b49\u6d88\u606f,<\/span>\u4e0d\u91ca\u653e CPU;<\/span>get
\n \u662f\u4e00\u95ee\u4e00\u7b54,<\/span>\u6ca1\u6d88\u606f\u5c31\u8fd4\u56de false\u3002\u6240\u4ee5\u751f\u4ea7\u73af\u5883\u7528 consume +<\/span> \u56de\u8c03;<\/span>\u9700\u8981\u6279\u5904\u7406\u6216\u77ed\u4efb\u52a1\u7528 get\u3002
\n –<\/span> \u56de\u8c03\u8fd4\u56de false \u662f\u6d88\u8d39\u5faa\u73af\u7684"\u9000\u51fa\u5f00\u5173"<\/span>\u2014\u2014php–<\/span>amq\u7ea6\u5b9a\u7528\u6237\u56de\u8c03\u8fd4\u56de false \u5c31\u505c\u6b62\u6d88\u8d39\u3002\u8fd9\u662f\u5e93\u7ed9\u7528\u6237\u7684\u4e00\u79cd\u63a7\u5236\u624b\u6bb5\u3002
\n –<\/span> amqp_consume_message \u662f librabbitmq \u7684\u963b\u585e\u6536\u5355\u6761\u6d88\u606f\u51fd\u6570,<\/span>\u5b83\u5185\u90e8\u5904\u7406\u5e27\u3001heartbeat\u3001channel \u5173\u95ed\u7b49\u3002php–<\/span>amqp
\n \u53ea\u662f\u5728\u5916\u9762\u5957\u5faa\u73af\u3002<\/p>\n

—<\/span>–<\/span><\/p>\n

9.<\/span> AMQP \u4e8b\u52a1:<\/span>tx_select \/<\/span> tx_commit \/<\/span> tx_rollback \u7684 C \u5b9e\u73b0<\/p>\n

\u5927\u767d\u8bdd:<\/span> \u4e8b\u52a1\u662f\u4e00\u4e2a\u901a\u9053\u7ea7\u7684\u9009\u9879:<\/span>\u5728\u901a\u9053\u4e0a tx_select \u5f00\u542f\u4e8b\u52a1\u6a21\u5f0f,<\/span>\u4e4b\u540e\u8be5\u901a\u9053\u4e0a\u7684 publish\/<\/span>ack \u4f1a\u88ab"\u7f13\u51b2"<\/span>,<\/span>\u8981\u4e48 tx_commit
\n \u4e00\u6b21\u6027\u63d0\u4ea4,<\/span>\u8981\u4e48 tx_rollback \u5168\u90e8\u56de\u6eda\u3002\u6ce8\u610f\u4e8b\u52a1\u53ea\u80fd\u8986\u76d6\u5355\u6761\u901a\u9053,<\/span>\u8de8\u901a\u9053\u505a\u4e0d\u5230\u3002<\/p>\n

\u5b8c\u6574\u4ee3\u7801:<\/span><\/p>\n

PHP_METHOD<\/span>(<\/span>AMQPChannel,<\/span> startTransaction)<\/span>
\n {<\/span>
\n amqp_tx_select<\/span>(<\/span>conn,<\/span> ch-><\/span>channel_id)<\/span>;<\/span> \/* \u53d1 tx.select *\/<\/span>
\n \/* tx_select \u4e5f\u662f RPC,\u8981\u7b49 reply *\/<\/span>
\n amqp_rpc_reply_t<\/span> reply =<\/span> amqp_get_rpc_reply<\/span>(<\/span>conn)<\/span>;<\/span>
\n amqp_check_rpc_reply_throw<\/span>(<\/span>reply)<\/span>;<\/span>
\n }<\/span><\/p>\n

PHP_METHOD<\/span>(<\/span>AMQPChannel,<\/span> commitTransaction)<\/span>
\n {<\/span>
\n amqp_tx_commit<\/span>(<\/span>conn,<\/span> ch-><\/span>channel_id)<\/span>;<\/span> \/* \u53d1 tx.commit *\/<\/span>
\n amqp_rpc_reply_t<\/span> reply =<\/span> amqp_get_rpc_reply<\/span>(<\/span>conn)<\/span>;<\/span>
\n amqp_check_rpc_reply_throw<\/span>(<\/span>reply)<\/span>;<\/span>
\n }<\/span><\/p>\n

PHP_METHOD<\/span>(<\/span>AMQPChannel,<\/span> rollbackTransaction)<\/span>
\n {<\/span>
\n amqp_tx_rollback<\/span>(<\/span>conn,<\/span> ch-><\/span>channel_id)<\/span>;<\/span> \/* \u53d1 tx.rollback *\/<\/span>
\n amqp_rpc_reply_t<\/span> reply =<\/span> amqp_get_rpc_reply<\/span>(<\/span>conn)<\/span>;<\/span>
\n amqp_check_rpc_reply_throw<\/span>(<\/span>reply)<\/span>;<\/span>
\n }<\/span><\/p>\n

\u5927\u767d\u8bdd\u70b9\u62e8:<\/span>
\n –<\/span> \u6bcf\u6b21 startTransaction \u540e,<\/span>\u8fd9\u4e00\u6761\u901a\u9053\u4e0a\u7684\u6240\u6709\u53d1\u5e03\u90fd\u4f1a\u6682\u5b58\u5728 broker \u4fa7(<\/span>broker \u5185\u5b58)<\/span>,<\/span>\u76f4\u5230 commitTransaction
\n \u624d\u771f\u6b63\u6392\u961f,<\/span>\u6216 rollbackTransaction \u4e22\u5f03\u3002\u6240\u4ee5\u4e8b\u52a1\u80fd\u4fdd\u8bc1"\u8fd9\u4e00\u6279\u8981\u4e48\u5168\u5230\u3001\u8981\u4e48\u5168\u4e0d\u5230"<\/span>\u3002
\n –<\/span> \u4e8b\u52a1\u662f"\u901a\u9053\u7ea7"<\/span>,<\/span>\u4e0d\u662f"\u8fde\u63a5\u7ea7"<\/span>\u3001\u66f4\u4e0d\u662f"\u5ba2\u6237\u7aef\u7ea7"<\/span>\u3002\u8fd9\u610f\u5473\u7740:<\/span>\u4f60\u8981\u4e8b\u52a1,<\/span>\u5c31\u5f97\u5728\u5355\u72ec\u4e00\u6761\u901a\u9053\u4e0a\u505a,<\/span>\u522b\u548c\u5176\u4ed6\u6d88\u606f\u6df7\u540c\u4e00\u901a\u9053\u3002
\n –<\/span> \u8fd9\u662f\u6700\u5f3a\u7684 trade–<\/span>off:<\/span> \u4e8b\u52a1\u6a21\u5f0f\u4e0b\u6d88\u606f\u5148\u7f13\u51b2,<\/span>broker \u4e0d\u80fd\u7acb\u5373\u8def\u7531,<\/span>\u541e\u5410\u660e\u663e\u4e0b\u964d\u3002RabbitMQ \u5b98\u65b9\u5728\u80fd\u505a\u5230 publisher
\n confirm<\/span>(<\/span>\u4e0b\u4e00\u8282)<\/span>\u4e4b\u540e,<\/span>\u5176\u5b9e\u4e0d\u63a8\u8350\u7528\u4e8b\u52a1\u505a\u5e38\u89c4\u53d1\u5e03,<\/span>\u56e0\u4e3a\u786e\u8ba4\u673a\u5236\u80fd\u63d0\u4f9b\u7c7b\u4f3c\u7684\u53ef\u9760\u6027,<\/span>\u5374\u4e0d\u7528\u727a\u7272\u7f13\u51b2\u5e26\u6765\u7684\u541e\u5410\u3002<\/p>\n

—<\/span>–<\/span><\/p>\n

10.<\/span> AMQP Publisher Confirm:<\/span>\u53d1\u5e03\u786e\u8ba4\u7684 C \u5b9e\u73b0<\/p>\n

\u5927\u767d\u8bdd:<\/span> \u4e8b\u52a1\u662f"all-or-nothing"<\/span>\u4f46\u8981\u7f13\u51b2;<\/span>\u53d1\u5e03\u786e\u8ba4\u662f"\u6bcf\u4e2a\u6d88\u606f\u53d1\u51fa\u53bb,broker \u56de\u6211\u4e00\u4e2a OK"<\/span>\u3002\u901a\u9053\u8fdb\u5165 confirm \u6a21\u5f0f\u540e,<\/span>broker
\n \u5bf9\u6bcf\u6761 publish \u90fd\u4f1a\u56de\u4e00\u4e2a basic.<\/span>ack<\/span>(<\/span>\u786e\u8ba4)<\/span>\u6216 basic.<\/span>nack<\/span>(<\/span>\u62d2\u7edd)<\/span>\u3002\u8fd9\u6837\u4f60\u5c31\u786e\u5207\u77e5\u9053\u54ea\u6761\u6d88\u606f broker \u6536\u4e0b\u4e86\u3002<\/p>\n

\u5b8c\u6574\u4ee3\u7801:<\/span><\/p>\n

\/* \u2460\u628a\u901a\u9053\u5207\u5230 confirm \u6a21\u5f0f *\/<\/span>
\n PHP_METHOD<\/span>(<\/span>AMQPChannel,<\/span> confirmSelect)<\/span>
\n {<\/span>
\n amqp_confirm_select<\/span>(<\/span>conn,<\/span> ch-><\/span>channel_id)<\/span>;<\/span> \/* \u53d1 confirm.select *\/<\/span>
\n amqp_rpc_reply_t<\/span> reply =<\/span> amqp_get_rpc_reply<\/span>(<\/span>conn)<\/span>;<\/span>
\n amqp_check_rpc_reply_throw<\/span>(<\/span>reply)<\/span>;<\/span>
\n ch-><\/span>resource-><\/span>confirm_mode =<\/span> 1<\/span>;<\/span>
\n }<\/span><\/p>\n

\/* \u2461\u53d1\u5e03\u82e5\u5e72\u6761\u6d88\u606f\u540e,\u7b49\u786e\u8ba4 \/ \u68c0\u67e5\u7ed3\u679c *\/<\/span>
\n PHP_METHOD<\/span>(<\/span>AMQPChannel,<\/span> waitForConfirm)<\/span>
\n {<\/span>
\n amqp_connection_state_t<\/span> conn =<\/span> ch-><\/span>connection-><\/span>resource-><\/span>connection;<\/span><\/p>\n

while<\/span> (<\/span>ch-><\/span>resource-><\/span>unconfirmed_count ><\/span> 0<\/span>)<\/span> {<\/span>
\n \/* \u963b\u585e\u6536\u5e27,\u76f4\u5230 broker \u8fd4\u56de basic.ack \/ basic.nack *\/<\/span>
\n amqp_frame_t<\/span> frame;<\/span>
\n amqp_rpc_reply_t<\/span> r =<\/span> amqp_get_frame<\/span>(<\/span>conn,<\/span> &<\/span>frame)<\/span>;<\/span><\/p>\n

if<\/span> (<\/span>frame.<\/span>frame_type ==<\/span> AMQP_FRAME_METHOD)<\/span> {<\/span>
\n if<\/span> (<\/span>frame.<\/span>payload.<\/span>method.<\/span>id ==<\/span> AMQP_BASIC_ACK_METHOD)<\/span> {<\/span>
\n ch-><\/span>resource-><\/span>unconfirmed_count—<\/span>;<\/span>
\n \/* \u901a\u77e5\u7528\u6237:\u8fd9\u6761 delivery_tag \u5df2\u786e\u8ba4 *\/<\/span>
\n call_ack_callback<\/span>(<\/span>ch,<\/span> frame.<\/span>payload.<\/span>method.<\/span>decoded.<\/span>basic_ack.<\/span>delivery_tag)<\/span>;<\/span>
\n }<\/span> else<\/span> if<\/span> (<\/span>frame.<\/span>payload.<\/span>method.<\/span>id ==<\/span> AMQP_BASIC_NACK_METHOD)<\/span> {<\/span>
\n \/* nack = broker \u660e\u786e\u8bf4\u8fd9\u6761\u6ca1\u63a5\u4f4f *\/<\/span>
\n call_nack_callback<\/span>(<\/span>ch,<\/span> .<\/span>.<\/span>.<\/span>)<\/span>;<\/span>
\n }<\/span>
\n }<\/span>
\n }<\/span>
\n }<\/span><\/p>\n

\u5927\u767d\u8bdd\u70b9\u62e8:<\/span>
\n –<\/span> \u548c\u4e8b\u52a1\u7684\u533a\u522b\u4e00\u53e5\u8bdd\u8bf4\u6e05:<\/span> \u4e8b\u52a1\u5728"\u53d1\u9001\u524d"<\/span>\u5b58\u8d77\u6765\u3001\u6700\u540e\u7edf\u4e00\u4ea4;<\/span>\u786e\u8ba4\u662f\u5728"\u53d1\u9001\u65f6"<\/span>\u5c31\u53d1\u51fa\u53bb\u3001\u7b49 broker
\n \u9010\u6761\u56de\u8bdd\u3002\u6240\u4ee5\u786e\u8ba4\u4e0d\u727a\u7272\u541e\u5410(<\/span>\u4e0d\u7528\u7f13\u51b2\u6574\u6279)<\/span>,<\/span>\u4f46\u8981\u6c42\u4f60\u7b49\u56de\u8bdd\u2014\u2014\u7b49\u4e0d\u5230\u5c31\u7b49\u4e8e\u53ef\u80fd\u4e22\u4e86\u3002
\n –<\/span> \u53ef\u9760\u6295\u9012\u7684\u5b8c\u6574\u94fe\u6761\u662f:<\/span>\u2460delivery_mode=<\/span>2<\/span>(<\/span>\u843d\u76d8)<\/span>+<\/span>\u2461confirm\u6a21\u5f0f(<\/span>\u7b49 broker \u8bf4\u6536\u5230)<\/span>+<\/span> \u2462\u6d88\u8d39\u7aef\u624b\u52a8
\n ack<\/span>(<\/span>\u5904\u7406\u5b8c\u518d\u786e\u8ba4)<\/span>\u3002\u4e09\u6b65\u4e00\u8d77\u624d\u662f"\u6070\u597d\u4e00\u6b21\/\u53ef\u9760\u4e00\u6b21"<\/span>\u7684\u5de5\u7a0b\u5b9e\u8df5;<\/span>\u5355\u72ec\u4e00\u6b65\u90fd\u4e0d\u591f\u3002
\n –<\/span> \u5b9e\u9645\u5de5\u7a0b\u91cc,<\/span>confirm \u7684\u5751\u5728\u4e8e\u5982\u4f55\u5904\u7406\u672a\u786e\u8ba4\u7684\u4e2d\u95f4\u6001:<\/span>\u901a\u5e38\u505a\u6cd5\u662f"\u53d1\u4e86 N \u6761 \u2192waitForConfirm \u2192\u82e5\u6709 nack
\n \u6216\u8d85\u65f6\u672a\u786e\u8ba4,<\/span>\u5c31\u628a\u6ca1\u786e\u8ba4\u7684\u91cd\u65b0\u5165\u961f\u6216\u8865\u507f"\u3002\u8fd9\u9700\u8981\u4f60\u5728\u4e1a\u52a1\u5c42\u505a\u5e42\u7b49\u5904\u7406,<\/span>\u56e0\u4e3a confirm
\n \u4e0d\u80fd\u5e2e\u4f60\u4fdd\u8bc1"\u6070\u597d\u4e00\u6b21"<\/span>(<\/span>\u53ea\u80fd\u4fdd\u8bc1"broker \u786e\u5b9e\u6536\u5230"<\/span>\u8fd9\u6761)<\/span>\u3002<\/p>\n

—<\/span>–<\/span><\/p>\n

11.<\/span> librabbitmq \u96c6\u6210:<\/span>amqp_rpc_reply_t<\/span> \u7684 C \u5904\u7406<\/p>\n

\u5927\u767d\u8bdd:<\/span> \u8fd9\u662f\u628a"\u5e93\u7684\u62bd\u8c61"<\/span>\u7ffb\u8bd1\u6210"PHP \u80fd\u770b\u5230\u7684\u4e1c\u897f"<\/span>\u7684\u5173\u952e\u4e00\u5c42\u3002\u51e0\u4e4e\u6bcf\u4e2a AMQP \u64cd\u4f5c\u90fd\u662f"\u53d1\u4e00\u4e2a\u8bf7\u6c42\u5e27 \u2192\u7b49\u4e00\u4e2a\u54cd\u5e94\u5e27"<\/span>\u7684
\n RPC\u3002librabbitmq \u628a\u6240\u6709 RPC \u7684\u54cd\u5e94\u90fd\u7edf\u4e00\u5305\u6210\u4e00\u4e2a amqp_rpc_reply_t<\/span>,<\/span>php–<\/span>amqp \u6839\u636e\u5b83\u7684\u7c7b\u578b\u5224\u65ad\u6210\u8d25\u3001\u53d6\u51fa\u9519\u8bef\u7801\u3001\u6620\u5c04\u6210
\n PHP \u5f02\u5e38\u3002<\/p>\n

\u5b8c\u6574\u4ee3\u7801:<\/span><\/p>\n

\/* librabbitmq \u7684 RPC \u56de\u590d\u7ed3\u6784(\u771f\u5b9e\u5b9a\u4e49,\u7b80\u5316) *\/<\/span>
\n typedef<\/span> struct<\/span> amqp_rpc_reply_t_<\/span> {<\/span>
\n amqp_response_type reply_type;<\/span> \/* NORMAL \/ LIBRARY_EXCEPTION \/ SERVER_EXCEPTION *\/<\/span>
\n union<\/span> {<\/span>
\n amqp_library_error_t<\/span> lib;<\/span> \/* \u5ba2\u6237\u7aef\u5e93\u81ea\u8eab\u7684\u9519\u8bef(\u8fde\u4e0d\u4e0a\/\u8d85\u65f6\/\u5185\u5b58) *\/<\/span>
\n amqp_connection_close_t<\/span> connection_close;<\/span> \/* broker \u5173\u8fde\u63a5 *\/<\/span>
\n amqp_channel_close_t<\/span> channel_close;<\/span> \/* broker \u5173\u901a\u9053 *\/<\/span>
\n \/* \u8fd9\u4e24\u4e2a close \u7ed3\u6784\u91cc\u90fd\u6709 reply_code(uint16) \u548c reply_text(amqp_bytes_t) *\/<\/span>
\n }<\/span> reply;<\/span>
\n }<\/span> amqp_rpc_reply_t<\/span>;<\/span><\/p>\n

\/* php-amqp \u7684\u7edf\u4e00\u68c0\u67e5\u51fd\u6570 *\/<\/span>
\n void<\/span> amqp_check_rpc_reply_throw<\/span>(<\/span>amqp_rpc_reply_t<\/span> *<\/span>reply)<\/span>
\n {<\/span>
\n if<\/span> (<\/span>reply-><\/span>reply_type ==<\/span> AMQP_RESPONSE_NORMAL)<\/span> {<\/span>
\n return<\/span>;<\/span> \/* \u4e00\u5207\u6b63\u5e38 *\/<\/span>
\n }<\/span><\/p>\n

uint32_t<\/span> code;<\/span>
\n const<\/span> char<\/span> *<\/span>msg;<\/span><\/p>\n

if<\/span> (<\/span>reply-><\/span>reply_type ==<\/span> AMQP_RESPONSE_LIBRARY_EXCEPTION)<\/span> {<\/span>
\n \/* \u5e93\u7ea7\u9519\u8bef:\u6bd4\u5982 TCP \u65ad\u5f00\u3001\u63e1\u624b\u8d85\u65f6\u3001\u534f\u8bae\u9519\u4e71 *\/<\/span>
\n code =<\/span> reply-><\/span>reply.<\/span>lib.<\/span>code;<\/span>
\n msg =<\/span> amqp_error_string2<\/span>(<\/span>code)<\/span>;<\/span> \/* librabbitmq \u81ea\u5e26\u7684\u9519\u8bef\u6587\u672c *\/<\/span>
\n zend_throw_exception<\/span>(<\/span>amqp_connection_exception_class_entry,<\/span>
\n msg,<\/span> code)<\/span>;<\/span>
\n }<\/span> else<\/span> if<\/span> (<\/span>reply-><\/span>reply_type ==<\/span> AMQP_RESPONSE_SERVER_EXCEPTION)<\/span> {<\/span>
\n \/* broker \u7ea7\u9519\u8bef:\u8fd9\u91cc\u6709\u771f\u6b63\u7684 reply_code,\u8981\u9010\u7801\u7ffb\u8bd1\u6210\u4eba\u7c7b\u53ef\u8bfb *\/<\/span>
\n code =<\/span> reply-><\/span>reply.<\/span>connection_close.<\/span>reply_code;<\/span> \/* \u6216 channel_close *\/<\/span>
\n msg =<\/span> reply-><\/span>reply.<\/span>connection_close.<\/span>reply_text.<\/span>len
\n ?<\/span> (<\/span>char<\/span>*<\/span>)<\/span>reply-><\/span>reply.<\/span>connection_close.<\/span>reply_text.<\/span>bytes
\n :<\/span> "Unknown server error"<\/span>;<\/span><\/p>\n

\/* \u9010\u7801\u6620\u5c04,\u589e\u52a0\u53ef\u8bfb\u6027 *\/<\/span>
\n switch<\/span> (<\/span>code)<\/span> {<\/span>
\n case<\/span> AMQP_CONNECTION_FORCED:<\/span> msg =<\/span> "Connection was closed by broker"<\/span>;<\/span> break<\/span>;<\/span>
\n case<\/span> AMQP_NOT_FOUND:<\/span> msg =<\/span> "Not found (queue\/exchange\/vhost)"<\/span>;<\/span> break<\/span>;<\/span>
\n case<\/span> AMQP_ACCESS_REFUSED:<\/span> msg =<\/span> "Access refused (credentials\/vhost)"<\/span>;<\/span> break<\/span>;<\/span>
\n case<\/span> AMQP_CHANNEL_ERROR:<\/span> msg =<\/span> "Channel error"<\/span>;<\/span> break<\/span>;<\/span>
\n \/* … many more … *\/<\/span>
\n }<\/span>
\n zend_throw_exception<\/span>(<\/span>amqp_exception_class_entry,<\/span> msg,<\/span> code)<\/span>;<\/span>
\n }<\/span>
\n }<\/span><\/p>\n

\u5927\u767d\u8bdd\u70b9\u62e8:<\/span>
\n –<\/span> reply_type \u5c31\u662f"\u6210\u8d25\u7684\u7b2c\u4e00\u5224\u636e"<\/span>,<\/span>\u53ea\u5206\u4e09\u7c7b:<\/span> \u6b63\u5e38(<\/span>NORMAL)<\/span>\u3001\u5e93\u81ea\u5df1\u9519\u4e86(<\/span>LIBRARY)<\/span>\u3001\u670d\u52a1\u5668\u62d2\u7edd\u4e86(<\/span>SERVER)<\/span>\u3002\u5176\u4e2d SDK \u590d\u6742\u5ea6\u7684
\n 90<\/span>%<\/span> \u90fd\u85cf\u5728\u540e\u4e24\u7c7b\u3002
\n –<\/span> \u9519\u8bef\u7801\u6620\u5c04\u662f\u5b83\u7684\u589e\u503c\u70b9:<\/span> librabbitmq \u53ea\u7ed9\u4f60\u4e00\u4e2a\u539f\u59cb code \u548c\u4e00\u53e5\u8bdd,<\/span>php–<\/span>amqp \u628a\u8fd9\u4e9b\u6807\u51c6 AMQP reply–<\/span>code<\/span>(<\/span>404<\/span> not
\n found\u3001403<\/span> access refused\u3001320<\/span> connection forced\u3001406<\/span> precondition
\n failed\u2026\u2026)<\/span>\u7ffb\u8bd1\u6210\u66f4\u76f4\u89c2\u7684\u82f1\u6587,<\/span>\u5e76\u629b\u6210\u5bf9\u5e94\u5f02\u5e38\u7c7b(<\/span>\u8fde\u63a5\u7c7b\u9519\u8bef\u629bAMQPConnectionException,<\/span>\u901a\u9053\u7c7b\u629b
\n AMQPChannelException)<\/span>\u3002\u8fd9\u6b63\u662f"\u5c01\u88c5"<\/span>\u503c\u7684\u94b1\u2014\u2014\u5e93\u7684\u539f\u59cb\u62a5\u9519\u5bf9\u4f7f\u7528PHP \u7684\u4eba\u4e0d\u53cb\u597d\u3002<\/p>\n

—<\/span>–<\/span><\/p>\n

12.<\/span> \u6301\u4e45\u8fde\u63a5:<\/span>\u8de8\u8bf7\u6c42\u7684\u8fde\u63a5\u590d\u7528<\/p>\n

\u5927\u767d\u8bdd:<\/span> \u666e\u901a connect<\/span>(<\/span>)<\/span> \u662f"\u6bcf\u4e2a\u8bf7\u6c42\u5efa\u4e00\u6761\u65b0\u8fde\u63a5\u3001\u8bf7\u6c42\u7ed3\u675f\u5c31\u65ad"<\/span>,<\/span>\u8fd9\u5bf9\u77ed\u4efb\u52a1\/<\/span>Web
\n \u8bf7\u6c42\u6765\u8bf4,<\/span>\u63e1\u624b(<\/span>connect+<\/span>login)<\/span>\u7684\u6210\u672c\u5360\u6bd4\u5f88\u9ad8\u3002pconnect<\/span>(<\/span>)<\/span>(<\/span>persistent connect)<\/span>\u8ba9\u8fde\u63a5\u8de8\u591a\u4e2a PHP
\n \u8bf7\u6c42\u590d\u7528\u2014\u2014\u7b2c\u4e00\u6b21\u5efa\u597d\u540e,<\/span>\u585e\u8fdb\u6a21\u5757\u5168\u5c40\u7684\u54c8\u5e0c\u8868;<\/span>\u540e\u7eed\u8bf7\u6c42\u6309\u53c2\u6570\u627e\u8868\u3001\u547d\u4e2d\u5c31\u76f4\u63a5\u590d\u7528,<\/span>\u7701\u6389\u91cd\u590d\u63e1\u624b\u3002<\/p>\n

\u5b8c\u6574\u4ee3\u7801:<\/span><\/p>\n

\/* \u5728 amqp.h \u91cc,\u6a21\u5757\u5168\u5c40\u91cc\u6709\u4e2a\u54c8\u5e0c\u8868\u5b58\u6301\u4e45\u8fde\u63a5 *\/<\/span>
\n ZEND_BEGIN_MODULE_GLOBALS<\/span>(<\/span>amqp)<\/span>
\n HashTable persistent_connections;<\/span>
\n ZEND_END_MODULE_GLOBALS<\/span>(<\/span>amqp)<\/span><\/p>\n

\/* \u751f\u6210\u4e00\u4e2a"\u8fde\u63a5\u6307\u7eb9",\u952e = \u4e3b\u673a+\u7aef\u53e3+vhost+\u7528\u6237(\u8db3\u4ee5\u533a\u5206\u4f1a\u8bdd) *\/<\/span>
\n static<\/span> char<\/span> *<\/span>amqp_connection_key<\/span>(<\/span>amqp_connection_resource *<\/span>res)<\/span>
\n {<\/span>
\n return<\/span> strpprintf<\/span>(<\/span>0<\/span>,<\/span> "%s:%d:%s:%s"<\/span>,<\/span> res-><\/span>host,<\/span> res-><\/span>port,<\/span>
\n res-><\/span>vhost,<\/span> res-><\/span>login)<\/span>;<\/span>
\n }<\/span><\/p>\n

PHP_METHOD<\/span>(<\/span>AMQPConnection,<\/span> pconnect)<\/span>
\n {<\/span>
\n char<\/span> *<\/span>key =<\/span> amqp_connection_key<\/span>(<\/span>res)<\/span>;<\/span><\/p>\n

\/* \u2460\u5148\u67e5\u8868:\u547d\u4e2d\u5c31\u76f4\u63a5\u590d\u7528,\u4e0d\u518d\u63e1\u624b *\/<\/span>
\n zval *<\/span>existing =<\/span> zend_hash_str_find<\/span>(<\/span>&<\/span>AMQP_G<\/span>(<\/span>persistent_connections)<\/span>,<\/span> key,<\/span> strlen<\/span>(<\/span>key)<\/span>)<\/span>;<\/span>
\n if<\/span> (<\/span>existing)<\/span> {<\/span>
\n amqp_connection_resource *<\/span>old =<\/span> Z_AMQPCONNECTION_P<\/span>(<\/span>existing)<\/span>-><\/span>resource;<\/span>
\n if<\/span> (<\/span>old-><\/span>connected)<\/span> {<\/span>
\n \/* \u590d\u7528:\u628a\u5f53\u524d\u5bf9\u8c61\u6307\u5411\u5df2\u5b58\u5728\u7684\u8fde\u63a5,\u5f15\u7528\u8ba1\u6570 +1 *\/<\/span>
\n object-><\/span>resource =<\/span> old;<\/span>
\n return<\/span>;<\/span>
\n }<\/span>
\n \/* \u5426\u5219\u89c6\u4e3a\u5931\u6548,\u5220\u6389\u91cd\u5efa *\/<\/span>
\n zend_hash_str_del<\/span>(<\/span>&<\/span>AMQP_G<\/span>(<\/span>persistent_connections)<\/span>,<\/span> key,<\/span> strlen<\/span>(<\/span>key)<\/span>)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/* \u2461\u6ca1\u547d\u4e2d,\u65b0\u5efa\u4e00\u6761\u5e76\u653e\u8fdb\u8868 *\/<\/span>
\n amqp_connection_connect<\/span>(<\/span>object)<\/span>;<\/span>
\n zend_hash_str_update<\/span>(<\/span>&<\/span>AMQP_G<\/span>(<\/span>persistent_connections)<\/span>,<\/span> key,<\/span> strlen<\/span>(<\/span>key)<\/span>,<\/span> obj)<\/span>;<\/span><\/p>\n

\/* \u2462\u8bf7\u6c42\u7ed3\u675f\u65f6(RSHUTDOWN)\u4e0d\u771f\u6b63\u5173\u95ed,\u800c\u662f\u51cf\u5f15\u7528\u8ba1\u6570 *\/<\/span>
\n }<\/span><\/p>\n

PHP_RSHUTDOWN_FUNCTION<\/span>(<\/span>amqp)<\/span>
\n {<\/span>
\n \/* \u904d\u5386 persistent_connections:\u5f15\u7528\u8ba1\u6570 >0 \u5c31\u4e0d\u5173,\u7559\u7ed9\u4e0b\u4e2a\u8bf7\u6c42;
\n \u82e5\u8bf7\u6c42\u6ca1\u6b63\u5e38\u91ca\u653e,\u624d\u771f\u6b63 disconnect *\/<\/span>
\n return<\/span> SUCCESS;<\/span>
\n }<\/span><\/p>\n

\u5927\u767d\u8bdd\u70b9\u62e8:<\/span>
\n –<\/span> \u6301\u4e45\u8fde\u63a5\u7684\u672c\u8d28 =<\/span> \u7528\u4e00\u4e2a"\u8fde\u63a5\u6307\u7eb9"<\/span>\u505a key \u7684\u5168\u5c40\u7f13\u5b58\u3002 \u6307\u7eb9\u7531\u8fde\u63a5\u53c2\u6570\u62fc\u63a5\u800c\u6210,<\/span>\u4fdd\u8bc1"\u540c\u4e00\u4e2a
\n vhost\/<\/span>\u8d26\u53f7\/<\/span>\u4e3b\u673a"\u7684\u8fde\u63a5\u624d\u80fd\u590d\u7528,<\/span>\u4e0d\u4f1a\u5f20\u51a0\u674e\u6234\u3002
\n –<\/span> \u5f15\u7528\u8ba1\u6570\u662f\u751f\u547d\u7ebf:<\/span> \u56e0\u4e3a\u8fde\u63a5\u8de8\u8bf7\u6c42\u5b58\u5728,<\/span>\u5fc5\u987b\u77e5\u9053"\u8fd8\u6709\u51e0\u4e2a\u8bf7\u6c42\u5728\u7528"<\/span>,<\/span>\u624d\u80fd\u51b3\u5b9a"\u6700\u540e\u4e00\u4e2a\u7528\u5b8c\u518d\u5173"<\/span>\u3002\u8fd9\u662f\u6301\u4e45\u8fde\u63a5\u6700\u5bb9\u6613\u5199\u9519
\n bug \u7684\u5730\u65b9\u2014\u2014\u6f0f\u51cf\u5f15\u7528\u8ba1\u6570\u4f1a\u5bfc\u81f4\u8fde\u63a5\u6cc4\u6f0f(<\/span>\u6bcf\u4e2a\u8bf7\u6c42\u591a\u51fa\u4e00\u4e2a\u6ca1\u65ad\u7684\u8fde\u63a5)<\/span>,<\/span>\u6700\u7ec8\u628aRabbitMQ \u7684\u8fde\u63a5\u6570\u6491\u7206\u3002
\n –<\/span> \u6301\u4e45\u8fde\u63a5\u548c PHP–<\/span>FPM \u7684 worker \u6a21\u578b\u5929\u7136\u914d\u5bf9\u2014\u2014\u8fdb\u7a0b\u5e38\u9a7b,<\/span>\u8fde\u63a5\u4e5f\u8ddf\u7740\u5e38\u9a7b\u3002\u4f46\u5bf9\u77ed\u811a\u672c\/<\/span> CLIm
\n \u4e0b\u7684\u4e00\u6b21\u6027\u4efb\u52a1,<\/span>\u6301\u4e45\u8fde\u63a5\u6ca1\u610f\u4e49(<\/span>\u8fdb\u7a0b\u7ed3\u675f\u8fde\u63a5\u5fc5\u65ad)<\/span>\u3002<\/p>\n

—<\/span>–<\/span><\/p>\n

13.<\/span> SSL\/<\/span>TLS:<\/span>amqp_ssl_socket_set_cacert \u7684 C \u8c03\u7528<\/p>\n

\u5927\u767d\u8bdd:<\/span> \u8d70 TLS \u65f6,<\/span>php–<\/span>amqp \u4e0d\u662f\u624b\u52a8\u5f00\u4e00\u4e2a\u52a0\u5bc6 socket,<\/span>\u800c\u662f\u7528 librabbitmq \u7684 amqp_ssl_socket_*<\/span> \u7cfb\u5217\u51fd\u6570,<\/span>\u5b83\u5185\u90e8\u57fa\u4e8e
\n OpenSSL \u5efa\u4e00\u6761\u52a0\u5bc6\u7684 TCP \u901a\u9053\u3002\u63e1\u624b(<\/span>AMQP 8<\/span>
\n \u5b57\u8282\u534f\u8bae\u5934)<\/span>\u662f\u5728\u8fd9\u6761\u52a0\u5bc6\u901a\u9053\u4e4b\u4e0a\u8fdb\u884c\u7684\u3002\u8bc1\u4e66\u6821\u9a8c(<\/span>CA\u3001\u4e3b\u673a\u540d)<\/span>\u90fd\u5728\u8fd9\u51e0\u6b65\u91cc\u914d\u7f6e\u3002<\/p>\n

\u5b8c\u6574\u4ee3\u7801:<\/span><\/p>\n

\/* \u5728 connect() \u7684 TLS \u5206\u652f\u91cc,\u5b8c\u6574\u5c55\u5f00(\u5bf9\u5e94\u7b2c 3 \u8282) *\/<\/span>
\n amqp_ssl_socket_t<\/span> *<\/span>ssl =<\/span> amqp_ssl_socket_new<\/span>(<\/span>conn)<\/span>;<\/span> \/* \u2460\u5efa SSL socket \u53e5\u67c4 *\/<\/span><\/p>\n

\/* \u2461CA \u8bc1\u4e66:\u7528\u6765\u9a8c\u8bc1\u670d\u52a1\u7aef\u8bc1\u4e66\u662f\u4e0d\u662f\u4f60\u4fe1\u4efb\u7684 CA \u7b7e\u7684 *\/<\/span>
\n if<\/span> (<\/span>res-><\/span>cacert)<\/span> {<\/span>
\n amqp_ssl_socket_set_cacert<\/span>(<\/span>ssl,<\/span> res-><\/span>cacert)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/* \u2462\u53ef\u9009:\u5ba2\u6237\u7aef\u8bc1\u4e66 + \u79c1\u94a5(\u53cc\u5411 TLS \/ mTLS,\u670d\u52a1\u7aef\u8981\u8ba4\u8bc1\u4f60) *\/<\/span>
\n if<\/span> (<\/span>res-><\/span>cert &&<\/span> res-><\/span>key)<\/span> {<\/span>
\n amqp_ssl_socket_set_key<\/span>(<\/span>ssl,<\/span> res-><\/span>cert,<\/span> res-><\/span>key)<\/span>;<\/span>
\n }<\/span><\/p>\n

\/* \u2463\u9a8c\u8bc1\u5f3a\u5ea6:\u662f\u5426\u6821\u9a8c\u5bf9\u7aef\u8bc1\u4e66 \/ \u662f\u5426\u6821\u9a8c\u4e3b\u673a\u540d *\/<\/span>
\n amqp_ssl_socket_set_verify<\/span>(<\/span>ssl,<\/span> AMQP_SSLVERIFY_PEER)<\/span>;<\/span> \/* \u6821\u9a8c\u8bc1\u4e66\u94fe *\/<\/span>
\n amqp_ssl_socket_set_verify_name<\/span>(<\/span>ssl,<\/span> AMQP_SSLVERIFY_PEER_NAME)<\/span>;<\/span> \/* \u6821\u9a8c\u4e3b\u673a\u540d *\/<\/span><\/p>\n

\/* \u2464\u771f\u6b63\u5efa\u8fde\u63a5(\u89e3\u5bc6\u5c42\u5728\u6b64\u4e4b\u4e0a) *\/<\/span>
\n amqp_socket_open<\/span>(<\/span>ssl,<\/span> res-><\/span>host,<\/span> res-><\/span>port)<\/span>;<\/span><\/p>\n

\/* \u4e4b\u540e amqp_login \u8d70\u7684\u5c31\u662f\u52a0\u5bc6\u901a\u9053 *\/<\/span><\/p>\n

\u5927\u767d\u8bdd\u70b9\u62e8:<\/span>
\n –<\/span> AMQP_SSLVERIFY_*<\/span> \u5206\u4e24\u6863:<\/span> \u53ea\u6821\u9a8c\u8bc1\u4e66\u94fe(<\/span>PEER)<\/span>vs \u8fde\u4e3b\u673a\u540d\u4e00\u8d77\u6821\u9a8c(<\/span>PEER_NAME)<\/span>\u3002\u751f\u4ea7\u73af\u5883\u4e00\u5b9a\u5f00
\n PEER_NAME,<\/span>\u5426\u5219"\u8bc1\u4e66\u5408\u6cd5\u4f46\u4e0d\u5c5e\u4e8e\u8fd9\u4e2a\u57df\u540d"<\/span>\u4e5f\u80fd\u8fde,<\/span>\u4e2d\u95f4\u4eba\u653b\u51fb\u4ecd\u6709\u673a\u4f1a\u3002AMQP_SSLVERIFY_NONE \u53ea\u5efa\u8bae\u5728\u672c\u5730\u8c03\u8bd5\u7528\u3002
\n –<\/span> set_cacert \u6307 CA \u6587\u4ef6,<\/span>set_key \u6307\u5ba2\u6237\u7aef\u8bc1\u4e66+<\/span>\u79c1\u94a5(<\/span>\u4ec5 mTLS)<\/span>\u3002\u5927\u90e8\u5206\u573a\u666f\u53ea\u8981 cacert<\/span>(<\/span>\u786e\u8ba4\u670d\u52a1\u7aef\u8eab\u4efd)<\/span>+<\/span>
\n verify_name<\/span>(<\/span>\u6821\u9a8c\u57df\u540d)<\/span>\u3002
\n –<\/span> \u4e3a\u4ec0\u4e48\u52a0\u5bc6\u653e\u5728 librabbitmq \u800c\u4e0d\u662f php–<\/span>amqp?<\/span> \u56e0\u4e3a SSL \u63e1\u624b\u3001\u8bc1\u4e66\u9a8c\u8bc1\u3001\u52a0\u89e3\u5bc6\u662f"\u4f20\u8f93\u5c42"<\/span>\u7684\u4e8b,<\/span>librabbitmq \u81ea\u5df1\u5c01\u88c5\u4e86
\n OpenSSL,<\/span>php–<\/span>amqp \u53ea\u9700\u628a cacert\/<\/span>cert\/<\/span>key\/<\/span>verify \u8fd9\u51e0\u4e2a\u9009\u9879\u900f\u4f20\u8fdb\u53bb\u3002\u8fd9\u518d\u6b21\u4f53\u73b0\u5206\u5c42:<\/span>php–<\/span>amqp
\n \u53ea\u505a"\u914d\u7f6e\u7684\u642c\u8fd0\u5de5"<\/span>,<\/span>\u91cd\u6d3b\u4ea4\u7ed9\u5e93\u3002<\/p>\n

—<\/span>–<\/span><\/p>\n

\u4e09\u4e2a\u8bbe\u95ee(<\/span>\u7edf\u4e00\u56de\u7b54)<\/span><\/p>\n

1.<\/span> \u4e3a\u4ec0\u4e48\u9009"\u5c01\u88c5 librabbitmq"<\/span>\u8fd9\u4e2a\u65b9\u6848,<\/span>\u800c\u4e0d\u662f\u522b\u7684?<\/span><\/p>\n

\u4e00\u53e5\u8bdd:<\/span> \u56e0\u4e3a AMQP \u534f\u8bae\u7684"\u5e27\u7f16\u89e3\u7801 + \u7f51\u7edc I\/O"<\/span>\u662f\u8fd9\u4e2a\u9886\u57df\u6700\u5bb9\u6613\u505a\u9519\u53c8\u6700\u4e0d\u503c\u5f97\u81ea\u5df1\u91cd\u505a\u7684\u90e8\u5206,<\/span>\u800c RabbitMQ \u5b98\u65b9\u5df2\u7ecf\u7528 C
\n \u628a\u5b83\u505a\u6210\u4e86\u6210\u719f\u5e93(<\/span>librabbitmq)<\/span>,<\/span>php–<\/span>amqp \u9009\u62e9\u4e86\u7ad9\u5728\u5b83\u7684\u80a9\u8180\u4e0a\u3002<\/p>\n

\u5bf9\u6bd4\u7684\u53ef\u884c\u66ff\u4ee3,<\/span>\u5404\u81ea\u8f93\u5728\u54ea:<\/span><\/p>\n

\u250c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u252c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2510
\n \u2502 \u65b9\u6848 \u2502 \u7ed3\u5c40 \u2502
\n \u251c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u253c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2524
\n \u2502 \u7eaf PHP \u5b9e\u73b0 AMQP \u2502 \u6bcf\u4e00\u6761\u6d88\u606f\u90fd\u8981 PHP \u5c42\u9010\u5b57\u8282\u89e3\u6790\u534f\u8bae,<\/span>CPU \u548c\u5185\u5b58\u5f00\u9500\u9ad8\u4e00\u4e2a\u91cf\u7ea7;<\/span>\u957f\u65f6\u95f4\u6d88\u8d39\u65f6 PHP \u7684 \u2502
\n \u2502 \u534f\u8bae(<\/span>\u5982\u65e7\u7248 php–<\/span>amqplib)<\/span> \u2502 GC \u548c\u5185\u5b58\u6a21\u578b\u4f1a\u5f88\u5403\u529b\u3002\u7eaf PHP \u7248\u7684\u5b9a\u4f4d\u662f"\u80fd\u7528"<\/span>,<\/span>\u800c C \u7248\u5b9a\u4f4d\u662f"\u5feb"<\/span>\u3002 \u2502
\n \u251c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u253c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2524
\n \u2502 \u76f4\u63a5\u81ea\u5df1\u5199 socket +<\/span> \u2502 \u81ea\u5df1\u5b9e\u73b0 =<\/span> \u81ea\u5df1\u80cc AMQP \u5404\u79cd\u72b6\u6001\u673a(<\/span>\u8fde\u63a5\u3001\u901a\u9053\u3001handshake \u2502
\n \u2502 \u534f\u8bae\u5e27(<\/span>\u4e0d\u4f9d\u8d56 librabbitmq)<\/span> \u2502 \u8d85\u65f6\u3001heartbeat\u3001\u5f02\u5e38\u5e27)<\/span>\u7684\u9505\u3002\u91cd\u590d\u9020\u8f6e\u5b50,<\/span>\u8fd8\u5927\u6982\u7387\u9020\u5f97\u6bd4\u5b98\u65b9\u5dee\u3002 \u2502
\n \u251c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u253c\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2524
\n \u2502 \u7528\u522b\u7684\u8bed\u8a00\u5199\u7ed1\u5b9a(<\/span>\u5982 Rust \u2502 \u53ef\u884c,<\/span>\u4f46\u8981\u989d\u5916\u5f15\u5165 FFI \/<\/span> \u5916\u90e8\u53ef\u6267\u884c,<\/span>\u5206\u53d1(<\/span>\u89c1\u4e0a\u4e00\u6279 PIE \u2502
\n \u2502 \u7684 amqprs \u505a\u4e2a PHP FFI \u6865)<\/span> \u2502 \u7cfb\u5217)<\/span>\u3001\u7f16\u8bd1\u94fe\u590d\u6742\u5ea6\u98d9\u5347\u3002\u5bf9"\u8981\u5feb\u53c8\u8981\u597d\u53d1"<\/span>\u7684 PHP \u6269\u5c55,<\/span>\u76f4\u63a5\u7528 C \u5c01\u88c5 C \u5e93\u6700\u987a\u3002 \u2502
\n \u2514\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2534\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2500\u2518<\/p>\n

php–<\/span>amqp \u771f\u6b63\u7684\u8bbe\u8ba1\u51b3\u5b9a\u662f"\u628a\u534f\u8bae\u5c42\u5916\u5305,\u81ea\u5df1\u53ea\u505a OOP \u5305\u88c5\u5c42"<\/span>\u3002 \u4ee3\u4ef7\u662f\u5b83\u5f3a\u4f9d\u8d56 librabbitmq \u7684 API \u548c ABI,<\/span>librabbitmq
\n \u5347\u7ea7\u3001API \u53d8\u52a8,<\/span>php–<\/span>amqp \u5c31\u5f97\u8ddf\u7740\u9002\u914d(<\/span>\u5386\u53f2\u4e0a RabbitMQ 3.<\/span>x \u7684\u63e1\u624b\/<\/span>\u5fc3\u8df3\u6f14\u8fdb\u5c31\u52a8\u8fc7 librabbitmq \u7684\u5e95\u5c42)<\/span>\u3002<\/p>\n

2.<\/span> \u8fd9\u4e2a\u65b9\u6848\u7684 trade–<\/span>off \u662f\u4ec0\u4e48?<\/span><\/p>\n

–<\/span> \u5f3a\u8026\u5408 librabbitmq \/<\/span> \u5e73\u53f0\u5de5\u5177\u94fe\u3002 \u7f16\u8bd1\u8981
\n librabbitmq–<\/span>dev<\/span>(<\/span>\u6216\u6e90\u7801)<\/span>,<\/span>\u90e8\u7f72\u8981\u5339\u914d\u7cfb\u7edf\u67b6\u6784;<\/span>\u8de8\u5e73\u53f0(<\/span>macOS\/<\/span>Windows\/<\/span>Linux)<\/span>\u5404\u6709\u4e00\u5957\u6784\u5efa,<\/span>\u5206\u53d1\u9ebb\u70e6(<\/span>\u8fd9\u6b63\u662f\u4e0a\u4e00\u6279 PIE
\n \u60f3\u89e3\u51b3\u7684\u75db\u70b9)<\/span>\u3002
\n –<\/span> \u539f\u751f\u5316\u5e26\u6765\u7684"\u8c03\u8bd5\u5730\u72f1"<\/span>\u3002 \u51fa\u95ee\u9898\u5c31\u662f C \u5c42 segfault \/<\/span> ASan \u62a5\u544a(<\/span>\u89c1\u4e0a\u4e00\u6279 B2)<\/span>,<\/span>\u4e0d\u505a ASan \u65f6\u6781\u5176\u96be\u6392\u67e5;<\/span>amqp_rpc_reply_t<\/span>
\n \u4e00\u5c42\u4e00\u5c42\u7684\u7ed3\u6784\u4f53,<\/span>\u62a5\u9519\u4e0d\u5982\u7eaf PHP \u5e93\u53cb\u597d\u3002
\n –<\/span> Zend ABI \u7248\u672c\u788e\u7247\u3002 \u6bcf\u4e2a PHP \u5927\u7248\u672c(<\/span>8.1<\/span>\/<\/span>8.2<\/span>\/<\/span>8.3<\/span>)<\/span>ABI \u4e0d\u540c,<\/span>\u5f97\u5206\u522b\u7f16\u8bd1;<\/span>php–<\/span>amqp \u81ea\u8eab\u4e5f\u8981\u8ddf\u7740 Zend
\n \u5185\u90e8\u7ed3\u6784(<\/span>\u5982\u5bf9\u8c61\u6a21\u578b\u3001zend_object \u5347\u7ea7)<\/span>\u9002\u914d\u3002
\n –<\/span> \u963b\u585e\u6a21\u578b\u5bf9\u5e76\u53d1\u4e0d\u53cb\u597d\u3002 consume<\/span>(<\/span>)<\/span> \u662f\u963b\u585e\u5f0f C \u5faa\u73af,<\/span>\u4e00\u4e2a PHP worker \u6302\u5728\u4e00\u6761\u901a\u9053\u4e0a\u7b49\u6d88\u606f\u671f\u95f4,<\/span>\u5e72\u4e0d\u4e86\u522b\u7684\u6d3b\u3002FPM \u4e0b\u8981\u9760\u591a
\n worker \u5e42\u7b49;<\/span>\u534f\u4f5c\u5e76\u53d1\u8981\u4e48\u7528\u4e8b\u4ef6\u5faa\u73af(<\/span>\u4e0d\u5728 C \u6269\u5c55\u91cc)<\/span>,<\/span>\u8981\u4e48\u53ea\u5728 CLI \u5e38\u9a7b\u8fdb\u7a0b\u91cc\u7528\u3002
\n –<\/span> \u5c01\u88c5\u5c42\u4e5f\u6709"\u7ffb\u8bd1\u6210\u672c"<\/span>\u3002 "C \u7ed3\u6784\u4f53 \u2194PHP \u5bf9\u8c61"<\/span>\u7684\u6bcf\u4e00\u6b21\u4e92\u8f6c(<\/span>\u5c24\u5176 amqp_basic_properties_t<\/span> \u90a3\u79cd\u5341\u51e0\u5b57\u6bb5\u3001\u5e26 _flags
\n \u7684\u7ed3\u6784)<\/span>\u90fd\u4f1a\u4ea7\u751f\u989d\u5916\u5f00\u9500\u3002\u5bf9\u8d85\u5927\u6d88\u606f\/<\/span>\u8d85\u9ad8\u9891 publish,<\/span>\u8fd9\u4e2a\u8f6c\u6362\u672c\u8eab\u5c31\u662f\u74f6\u9888\u4e4b\u4e00(<\/span>\u4e0d\u8fc7\u4ecd\u8fdc\u4f4e\u4e8e\u7eaf PHP \u89e3\u6790)<\/span>\u3002
\n –<\/span> \u7248\u6743\/<\/span>\u7ef4\u62a4\u5f52\u5c5e\u3002 librabbitmq \u662f MIT,<\/span>php–<\/span>amqp \u662f PHP–<\/span>3.01<\/span>,<\/span>\u4f46\u5e93\u7684\u5347\u7ea7\u8282\u594f\u3001ABI \u7a33\u5b9a\u6027\u4e0d\u7531 php–<\/span>amqp
\n \u8bf4\u4e86\u7b97\u2014\u2014\u4f9d\u8d56\u65b9\u88ab\u4e0a\u6e38\u7ed1\u67b6\u3002<\/p>\n

3.<\/span> \u5982\u679c\u8ba9\u6211\u91cd\u65b0\u8bbe\u8ba1<\/p>\n

\u5185\u6838\u6211\u4e0d\u6539:<\/span>\u7ee7\u7eed\u5c01\u88c5 librabbitmq,<\/span>\u7ee7\u7eed\u8d70"\u534f\u8bae\u5e27\u4ea4\u7ed9 C \u5e93\u3001PHP \u53ea\u505a OOP
\n \u5305\u88c5"\u8fd9\u6761\u8def\u2014\u2014\u8fd9\u662f\u6027\u80fd\u548c\u6b63\u786e\u6027\u90fd\u6700\u7a33\u7684\u9009\u62e9\u3002\u6211\u4f1a\u6539\u56db\u4ef6\u4e8b,<\/span>\u6bcf\u4e00\u4ef6\u90fd\u51b2\u7740\u4e0a\u9762\u7684trade–<\/span>off \u53bb:<\/span><\/p>\n

1.<\/span> \u628a"\u963b\u585e"<\/span>\u8fd8\u7ed9\u7528\u6237,<\/span>\u63d0\u4f9b\u4e8b\u4ef6\u9a71\u52a8\u6a21\u5f0f\u3002 \u73b0\u7248consume<\/span>(<\/span>)<\/span>\u662f"\u4e00\u6761\u901a\u9053\u3001\u4e00\u4e2a worker\u3001\u5361\u6b7b\u5728 C \u5faa\u73af"<\/span>\u3002\u6211\u4f1a\u52a0\u4e00\u4e2a
\n \u975e\u963b\u585e\u7684"\u62c9\u53d6\u4e00\u5e27\/\u4e00\u7ec4"<\/span>API +<\/span> \u53ef\u63d2\u62d4\u4e8b\u4ef6\u5faa\u73af\u63a5\u53e3,<\/span>\u8ba9\u540c\u4e00\u4e2a\u8fde\u63a5\u80fd\u5728 N \u6761\u901a\u9053\u4e0a\u8f6e\u8be2\u53d6\u6d88\u606f,<\/span>\u800c\u4e0d\u662f N \u4e2a worker
\n \u5404\u81ea\u963b\u585e\u3002\u8fd9\u6837 FPM\/<\/span>\u957f\u4efb\u52a1\u90fd\u80fd\u9ad8\u6548,<\/span>\u4e0d\u7528\u9760\u591a\u8fdb\u7a0b\u5806\u5e76\u53d1\u3002
\n 2.<\/span> \u628a"C \u7ed3\u6784\u4f53 \u2194PHP \u5bf9\u8c61"<\/span>\u7684\u8f6c\u6362\u7f13\u5b58\/<\/span>\u590d\u7528\u3002 amqp_basic_properties_t<\/span> \u548c amqp_envelope_t<\/span>
\n \u7684\u4e92\u8f6c\u76ee\u524d\u662f\u6bcf\u6b21\u65b0\u5efa\u3001\u6bcf\u6b21\u6790\u6784\u3002\u6211\u4f1a\u5728\u6a21\u5757\u5168\u5c40\u505a\u5bf9\u8c61\u6c60,<\/span>\u5c24\u5176\u5bf9\u9ad8\u9891
\n publish,<\/span>\u8ba9\u5c5e\u6027\u7ed3\u6784\u4f53\u590d\u7528,<\/span>\u53ea\u6539\u5b57\u6bb5,<\/span>\u628a"\u7ffb\u8bd1\u6210\u672c"<\/span>\u538b\u5230\u6700\u4f4e\u3002
\n 3.<\/span> \u7ed9\u9519\u8bef\u7801\u5f15\u5165\u771f\u6b63\u7684\u7ed3\u6784\u5316\u5f02\u5e38\u5c42\u7ea7,<\/span>\u800c\u4e0d\u662f\u4e00\u4e2a\u5e26 code \u7684 message\u3002 \u73b0\u5728\u9519\u8bef\u90fd\u629b\u6210 AMQPException<\/span>(<\/span>code,<\/span> msg)<\/span>,<\/span>code
\n \u662f\u4e00\u4e2a\u88f8\u6574\u6570\u3002\u6211\u4f1a\u5b9a\u4e49:<\/span>\u8fde\u63a5\u65ad\/<\/span>\u8d85\u65f6 \u2192\u53ef\u91cd\u8bd5\u7c7b\u5f02\u5e38;<\/span>not found\/<\/span>access refused \u2192\u4e0d\u91cd\u8bd5\u7c7b\u5f02\u5e38;<\/span>\u8ba9\u8c03\u7528\u65b9\u4e00 catch
\n \u5c31\u80fd\u533a\u5206"\u8981\u4e0d\u8981\u91cd\u8bd5"<\/span>,<\/span>\u800c\u4e0d\u662f\u81ea\u5df1 switch<\/span> code\u3002\u8fd9\u5bf9"\u4fdd\u8bc1\u53ef\u9760\u6295\u9012"<\/span>\u7684\u5de5\u7a0b\u5b9e\u8df5(<\/span>\u7b2c 10<\/span> \u8282)<\/span>\u5e2e\u52a9\u6700\u5927\u3002
\n 4.<\/span> \u628a\u6301\u4e45\u8fde\u63a5\u505a\u6210\u663e\u5f0f\u6c60,<\/span>\u5e76\u52a0\u5165\u5065\u5eb7\u68c0\u67e5\u3002 \u73b0\u5728 pconnect \u9760\u4e00\u4e2a\u7b80\u5355\u54c8\u5e0c +<\/span>
\n \u5f15\u7528\u8ba1\u6570,<\/span>\u65ad\u7ebf\u540e\u80fd\u5426\u6b63\u786e\u91cd\u5efa\u3001\u4f1a\u4e0d\u4f1a\u6cc4\u6f0f,<\/span>\u662f\u6bd4\u8f83\u8106\u5f31\u7684\u70b9\u3002\u6211\u4f1a\u6539\u6210\u5e26\u5fc3\u8df3\u63a2\u6d4b +<\/span>
\n \u65ad\u7ebf\u81ea\u6108\u7684"\u8fde\u63a5\u6c60"<\/span>\u2014\u2014\u8bf7\u6c42\u53d6\u7528\u65f6\u5982\u679c\u53d1\u73b0\u8fde\u63a5\u5df2\u6b7b,<\/span>\u81ea\u52a8\u91cd\u8fde\u800c\u4e0d\u662f\u7f62\u5de5;<\/span>\u5f15\u7528\u8ba1\u6570+<\/span> \u8d85\u65f6\u95f2\u7f6e\u56de\u6536\u4e00\u8d77\u505a,<\/span>\u907f\u514d\u628a RabbitMQ
\n \u8fde\u63a5\u6570\u6491\u7206\u3002<\/p>\n

\u6838\u5fc3\u5224\u65ad:<\/span> php–<\/span>amqp \u6700\u5927\u7684\u957f\u5904(<\/span>\u5e95\u5c42\u662f\u5feb\u800c\u7a33\u7684 C \u5e93)<\/span>\u548c\u6700\u5927\u7684\u77ed\u677f(<\/span>\u963b\u585e\u6a21\u578b +<\/span> \u8f6c\u6362\u5f00\u9500 +<\/span>
\n \u5f31\u9519\u8bef\u8bed\u4e49)<\/span>\u662f\u4e00\u4f53\u4e24\u9762\u3002\u8981\u4f18\u5316\u7684\u4e0d\u662f"\u6362\u6389 librabbitmq"<\/span>,<\/span>\u800c\u662f"\u8ba9 C \u5c42\u7684\u80fd\u529b\u5bf9 PHP
\n \u4f7f\u7528\u8005\u66f4\u53cb\u597d"\u2014\u2014\u628a\u4e8b\u4ef6\u9a71\u52a8\u3001\u5bf9\u8c61\u590d\u7528\u3001\u7ed3\u6784\u5316\u5f02\u5e38\u3001\u8fde\u63a5\u6c60\u8fd9\u56db\u4ef6\u4e8b\u505a\u597d\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"

amqp（AMQP\u534f\u8bae\u6269\u5c55）GitHub： https:\/\/github.com\/php-amqp\/php-amqp\u5b8c\u6574\u6807\u98981. amqp\u6e90\u7801\u5168\u666f：RabbitMQ\u7684PHP C\u6269\u5c55\u2014\u2014librabbitmq\u7684\u5c01\u88c5
\n2. amqp\u6269\u5c55\u5165\u53e3amqp.c：MINIT\u9636\u6bb5\u7684\u7c7b\u6ce8\u518c\u4e0e\u5e38\u91cf\u5b9a\u4e49
\n3. AMQPConnection：\u8fde\u63a5\u7ba1\u7406\u7684C\u5b9e\u73b0\u2014\u2014TCP\u8fde\u63a5\u4e0eAMQP\u63e1\u624b
\n4. AMQPChannel&<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[84],"topic":[],"class_list":["post-99162","post","type-post","status-publish","format-standard","hentry","category-server","tag-android"],"yoast_head":"\namqp\uff08AMQP\u534f\u8bae\u6269\u5c55\uff09==\u6e90\u7801\u7ea7\u89e3\u6790 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.wsisp.com\/helps\/99162.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"amqp\uff08AMQP\u534f\u8bae\u6269\u5c55\uff09==\u6e90\u7801\u7ea7\u89e3\u6790 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"amqp（AMQP\u534f\u8bae\u6269\u5c55）GitHub： https:\/\/github.com\/php-amqp\/php-amqp\u5b8c\u6574\u6807\u98981. amqp\u6e90\u7801\u5168\u666f：RabbitMQ\u7684PHP C\u6269\u5c55\u2014\u2014librabbitmq\u7684\u5c01\u88c5 2. amqp\u6269\u5c55\u5165\u53e3amqp.c：MINIT\u9636\u6bb5\u7684\u7c7b\u6ce8\u518c\u4e0e\u5e38\u91cf\u5b9a\u4e49 3. AMQPConnection：\u8fde\u63a5\u7ba1\u7406\u7684C\u5b9e\u73b0\u2014\u2014TCP\u8fde\u63a5\u4e0eAMQP\u63e1\u624b 4. AMQPChannel&\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/99162.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2026-09-01T16:33:29+00:00\" \/>\n<meta name=\"author\" content=\"admin\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"admin\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"14 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/99162.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/99162.html\",\"name\":\"amqp\uff08AMQP\u534f\u8bae\u6269\u5c55\uff09==\u6e90\u7801\u7ea7\u89e3\u6790 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2026-09-01T16:33:29+00:00\",\"dateModified\":\"2026-09-01T16:33:29+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/99162.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/99162.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/99162.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"amqp\uff08AMQP\u534f\u8bae\u6269\u5c55\uff09==\u6e90\u7801\u7ea7\u89e3\u6790\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\",\"url\":\"https:\/\/www.wsisp.com\/helps\/\",\"name\":\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"description\":\"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}\"},\"query-input\":\"required name=search_term_string\"}],\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\",\"name\":\"admin\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"contentUrl\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"caption\":\"admin\"},\"sameAs\":[\"http:\/\/wp.wsisp.com\"],\"url\":\"https:\/\/www.wsisp.com\/helps\/author\/admin\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"amqp\uff08AMQP\u534f\u8bae\u6269\u5c55\uff09==\u6e90\u7801\u7ea7\u89e3\u6790 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.wsisp.com\/helps\/99162.html","og_locale":"zh_CN","og_type":"article","og_title":"amqp\uff08AMQP\u534f\u8bae\u6269\u5c55\uff09==\u6e90\u7801\u7ea7\u89e3\u6790 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"amqp（AMQP\u534f\u8bae\u6269\u5c55）GitHub： https:\/\/github.com\/php-amqp\/php-amqp\u5b8c\u6574\u6807\u98981. amqp\u6e90\u7801\u5168\u666f：RabbitMQ\u7684PHP C\u6269\u5c55\u2014\u2014librabbitmq\u7684\u5c01\u88c5 2. amqp\u6269\u5c55\u5165\u53e3amqp.c：MINIT\u9636\u6bb5\u7684\u7c7b\u6ce8\u518c\u4e0e\u5e38\u91cf\u5b9a\u4e49 3. AMQPConnection：\u8fde\u63a5\u7ba1\u7406\u7684C\u5b9e\u73b0\u2014\u2014TCP\u8fde\u63a5\u4e0eAMQP\u63e1\u624b 4. AMQPChannel&","og_url":"https:\/\/www.wsisp.com\/helps\/99162.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2026-09-01T16:33:29+00:00","author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"14 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/99162.html","url":"https:\/\/www.wsisp.com\/helps\/99162.html","name":"amqp\uff08AMQP\u534f\u8bae\u6269\u5c55\uff09==\u6e90\u7801\u7ea7\u89e3\u6790 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2026-09-01T16:33:29+00:00","dateModified":"2026-09-01T16:33:29+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/99162.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/99162.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/99162.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"amqp\uff08AMQP\u534f\u8bae\u6269\u5c55\uff09==\u6e90\u7801\u7ea7\u89e3\u6790"}]},{"@type":"WebSite","@id":"https:\/\/www.wsisp.com\/helps\/#website","url":"https:\/\/www.wsisp.com\/helps\/","name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","description":"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}"},"query-input":"required name=search_term_string"}],"inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41","name":"admin","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/","url":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","contentUrl":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","caption":"admin"},"sameAs":["http:\/\/wp.wsisp.com"],"url":"https:\/\/www.wsisp.com\/helps\/author\/admin"}]}},"_links":{"self":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/99162","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/comments?post=99162"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/99162\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=99162"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=99162"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=99162"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=99162"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}