\u8fd9\u4e2a\u5927\u7eb2\u53ef\u4ee5\u4f5c\u4e3a\u60a8\u7684RabbitMQ\u6559\u7a0b\u7684\u57fa\u672c\u6846\u67b6\u3002\u60a8\u53ef\u4ee5\u6839\u636e\u5b9e\u9645\u60c5\u51b5\u8c03\u6574\u987a\u5e8f\u548c\u5185\u5bb9\uff0c\u4ee5\u6ee1\u8db3\u60a8\u7684\u9700\u6c42\u3002\u5982\u679c\u60a8\u9700\u8981\u66f4\u8be6\u7ec6\u7684\u6559\u7a0b\u5185\u5bb9\uff0c\u6211\u53ef\u4ee5\u4e3a\u60a8\u63d0\u4f9b\u3002<\/p>\n\n\n\n\n\n \u8bf7\u8be6\u7ec6\u89e3\u91caRabbitMQ\u7b80\u4ecb<\/p>\n\n\n\n RabbitMQ\u662f\u4e00\u6b3e\u5f00\u6e90\u7684\u3001\u9ad8\u6027\u80fd\u7684\u3001\u53ef\u9760\u7684\u3001\u6613\u4e8e\u6269\u5c55\u7684\u5206\u5e03\u5f0f\u6d88\u606f\u961f\u5217\u4e2d\u95f4\u4ef6\uff0c\u5b83\u57fa\u4e8eAdvanced Message Queuing Protocol\uff08AMQP\uff09\u534f\u8bae\u5b9e\u73b0\u3002RabbitMQ\u6700\u521d\u662f\u4e3a\u4e86\u5b9e\u73b0\u53ef\u6269\u5c55\u7684\u3001\u8de8\u8bed\u8a00\u7684\u3001\u677e\u8026\u5408\u7684\u4f01\u4e1a\u7ea7\u6d88\u606f\u4f20\u9012\u7cfb\u7edf\u800c\u8bbe\u8ba1\u7684\u3002\u5b83\u652f\u6301\u591a\u79cd\u5ba2\u6237\u7aef\u5e93\uff0c\u53ef\u4ee5\u4e0e\u5404\u79cd\u7f16\u7a0b\u8bed\u8a00\uff08\u5982Python\u3001Java\u3001C#\u3001Ruby\u7b49\uff09\u548c\u5e73\u53f0\uff08\u5982Windows\u3001Linux\u3001MacOS\u7b49\uff09\u65e0\u7f1d\u96c6\u6210\u3002<\/p>\n\n\n\n RabbitMQ\u7684\u6838\u5fc3\u7279\u6027\u5305\u62ec\uff1a<\/p>\n\n\n\n RabbitMQ\u5e7f\u6cdb\u5e94\u7528\u4e8e\u5404\u79cd\u573a\u666f\uff0c\u5982\u5f02\u6b65\u4efb\u52a1\u5904\u7406\u3001\u4e8b\u4ef6\u9a71\u52a8\u67b6\u6784\u3001\u65e5\u5fd7\u6536\u96c6\u3001\u5b9e\u65f6\u6d88\u606f\u901a\u77e5\u7b49\u3002\u901a\u8fc7RabbitMQ\uff0c\u7cfb\u7edf\u7ec4\u4ef6\u53ef\u4ee5\u5b9e\u73b0\u677e\u8026\u5408\u3001\u9ad8\u53ef\u9760\u6027\u548c\u9ad8\u53ef\u6269\u5c55\u6027\u7684\u6d88\u606f\u901a\u4fe1\u3002<\/p>\n\n\n\n\n\n \u8bf7\u8be6\u7ec6\u89e3\u91caRabbitMQ\u7684\u5e94\u7528\u573a\u666f<\/p>\n\n\n\n RabbitMQ\u4f5c\u4e3a\u4e00\u6b3e\u529f\u80fd\u5f3a\u5927\u7684\u6d88\u606f\u961f\u5217\u4e2d\u95f4\u4ef6\uff0c\u5728\u8bb8\u591a\u5e94\u7528\u573a\u666f\u4e2d\u90fd\u80fd\u53d1\u6325\u5176\u4f18\u52bf\u3002\u4ee5\u4e0b\u662f\u4e00\u4e9b\u5e38\u89c1\u7684RabbitMQ\u5e94\u7528\u573a\u666f\uff1a<\/p>\n\n\n\n \u8fd9\u4e9b\u5e94\u7528\u573a\u666f\u4ec5\u4e3aRabbitMQ\u7684\u4e00\u90e8\u5206\uff0c\u5b9e\u9645\u4e0a\uff0cRabbitMQ\u53ef\u4ee5\u5e94\u7528\u4e8e\u8bb8\u591a\u5176\u4ed6\u573a\u666f\u3002\u901a\u8fc7\u7075\u6d3b\u914d\u7f6e\u548c\u4f7f\u7528RabbitMQ\uff0c\u53ef\u4ee5\u5b9e\u73b0\u590d\u6742\u7684\u6d88\u606f\u4f20\u9012\u9700\u6c42\uff0c\u5e2e\u52a9\u6784\u5efa\u9ad8\u6548\u3001\u53ef\u6269\u5c55\u7684\u7cfb\u7edf\u3002<\/p>\n\n\n\n\n\n \u8bf7\u8be6\u7ec6\u89e3\u91caRabbitMQ\u7684\u5b89\u88c5\u8981\u6c42<\/p>\n\n\n\n RabbitMQ\u7684\u5b89\u88c5\u8981\u6c42\u4e3b\u8981\u5305\u62ec\u64cd\u4f5c\u7cfb\u7edf\u548c\u4f9d\u8d56\u73af\u5883\u3002\u4ee5\u4e0b\u662fRabbitMQ\u7684\u5b89\u88c5\u8981\u6c42\uff1a<\/p>\n\n\n\n \u5728\u6ee1\u8db3\u8fd9\u4e9b\u5b89\u88c5\u8981\u6c42\u540e\uff0c\u60a8\u53ef\u4ee5\u5f00\u59cb\u5b89\u88c5RabbitMQ\u3002\u5b89\u88c5\u8fc7\u7a0b\u4e2d\uff0c\u53ef\u4ee5\u53c2\u8003RabbitMQ\u5b98\u65b9\u6587\u6863\uff0c\u6309\u7167\u5bf9\u5e94\u64cd\u4f5c\u7cfb\u7edf\u7684\u6307\u5357\u8fdb\u884c\u5b89\u88c5\u3002\u5b89\u88c5\u5b8c\u6210\u540e\uff0c\u8fd8\u9700\u8981\u8fdb\u884c\u4e00\u4e9b\u57fa\u672c\u914d\u7f6e\uff0c\u4ee5\u4fbf\u4f7f\u7528RabbitMQ\u7684\u5404\u9879\u529f\u80fd\u3002<\/p>\n\n\n\n\n\n \u8bf7\u8be6\u7ec6\u89e3\u91ca\u5b89\u88c5RabbitMQ Server<\/p>\n\n\n\n \u6839\u636e\u4e0d\u540c\u7684\u64cd\u4f5c\u7cfb\u7edf\uff0c\u5b89\u88c5RabbitMQ Server\u7684\u8fc7\u7a0b\u7565\u6709\u4e0d\u540c\u3002\u8fd9\u91cc\u5c06\u5206\u522b\u4ecb\u7ecd\u5728Linux\u3001Windows\u548cMacOS\u4e0a\u5b89\u88c5RabbitMQ Server\u7684\u65b9\u6cd5\u3002<\/p>\n\n\n\n \u5728\u5b89\u88c5RabbitMQ Server\u4e4b\u524d\uff0c\u8bf7\u786e\u4fdd\u5df2\u7ecf\u5b89\u88c5\u4e86\u76f8\u5e94\u7248\u672c\u7684Erlang\/OTP\u73af\u5883\u3002<\/p>\n\n\n\n \u5b89\u88c5\u5b8c\u6210\u540e\uff0c\u53ef\u4ee5\u901a\u8fc7\u4ee5\u4e0b\u547d\u4ee4\u542f\u52a8RabbitMQ Server\uff1a<\/p>\n\n\n\n \u5efa\u8bae\u5728\u5b89\u88c5\u5b8c\u6210\u540e\u8fdb\u884c\u4e00\u4e9b\u57fa\u672c\u914d\u7f6e\uff0c\u5982\u542f\u7528RabbitMQ\u7684\u7ba1\u7406\u63d2\u4ef6\u3001\u8bbe\u7f6e\u7528\u6237\u548c\u6743\u9650\u7b49\u3002\u5177\u4f53\u914d\u7f6e\u65b9\u6cd5\u53ef\u53c2\u8003RabbitMQ\u5b98\u65b9\u6587\u6863\u3002<\/p>\n\n\n\n\n\n \u8bf7\u8be6\u7ec6\u89e3\u91ca\u5b89\u88c5RabbitMQ\u5ba2\u6237\u7aef\u5e93<\/p>\n\n\n\n RabbitMQ\u652f\u6301\u591a\u79cd\u7f16\u7a0b\u8bed\u8a00\uff0c\u4e3a\u5404\u79cd\u8bed\u8a00\u63d0\u4f9b\u4e86\u5bf9\u5e94\u7684\u5ba2\u6237\u7aef\u5e93\u3002\u4ee5\u4e0b\u5c06\u4ecb\u7ecd\u51e0\u79cd\u5e38\u89c1\u7f16\u7a0b\u8bed\u8a00\u7684RabbitMQ\u5ba2\u6237\u7aef\u5e93\u5b89\u88c5\u65b9\u6cd5\uff1a<\/p>\n\n\n\n \u8fd9\u4e9b\u4ec5\u4e3a\u5e38\u89c1\u7f16\u7a0b\u8bed\u8a00\u7684RabbitMQ\u5ba2\u6237\u7aef\u5e93\u5b89\u88c5\u65b9\u6cd5\u3002\u5176\u4ed6\u7f16\u7a0b\u8bed\u8a00\u4e5f\u6709\u76f8\u5e94\u7684\u5ba2\u6237\u7aef\u5e93\uff0c\u53ef\u4ee5\u53c2\u8003RabbitMQ\u5b98\u65b9\u6587\u6863\u548c\u5bf9\u5e94\u5e93\u7684\u6587\u6863\u8fdb\u884c\u5b89\u88c5\u548c\u4f7f\u7528\u3002<\/p>\n\n\n\n\n\n \u8bf7\u8be6\u7ec6\u89e3\u91ca\u914d\u7f6eRabbitMQ<\/p>\n\n\n\n RabbitMQ\u63d0\u4f9b\u4e86\u7075\u6d3b\u7684\u914d\u7f6e\u9009\u9879\uff0c\u53ef\u4ee5\u6839\u636e\u9700\u8981\u8fdb\u884c\u4e2a\u6027\u5316\u914d\u7f6e\u3002\u4ee5\u4e0b\u662f\u4e00\u4e9b\u5e38\u89c1\u7684RabbitMQ\u914d\u7f6e\u4efb\u52a1\uff1a<\/p>\n\n\n\n \u8fd9\u4e9b\u4ec5\u4e3aRabbitMQ\u7684\u5e38\u89c1\u914d\u7f6e\u4efb\u52a1\u3002RabbitMQ\u8fd8\u652f\u6301\u66f4\u591a\u7684\u914d\u7f6e\u9009\u9879\uff0c\u5982\u65e5\u5fd7\u3001\u5185\u5b58\u3001\u78c1\u76d8\u4f7f\u7528\u9650\u5236\u7b49\u3002\u5177\u4f53\u914d\u7f6e\u65b9\u6cd5\u53ef\u53c2\u8003RabbitMQ\u5b98\u65b9\u6587\u6863\u3002<\/p>\n\n\n\n\n\n \u8bf7\u8be6\u7ec6\u89e3\u91ca\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\u7684\u6d88\u606f\u961f\u5217\uff08Message Queues\uff09<\/p>\n\n\n\n \u5728RabbitMQ\u4e2d\uff0c\u6d88\u606f\u961f\u5217\uff08Message Queues\uff09\u662f\u4e00\u79cd\u6838\u5fc3\u7ec4\u4ef6\uff0c\u8d1f\u8d23\u5b58\u50a8\u5f85\u5904\u7406\u7684\u6d88\u606f\u3002\u4e86\u89e3\u6d88\u606f\u961f\u5217\u7684\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\u6709\u52a9\u4e8e\u66f4\u597d\u5730\u4f7f\u7528RabbitMQ\u3002\u4ee5\u4e0b\u662f\u4e00\u4e9b\u4e0e\u6d88\u606f\u961f\u5217\u76f8\u5173\u7684\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\uff1a<\/p>\n\n\n\n \u8bf7\u8be6\u7ec6\u89e3\u91ca\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\u7684\u751f\u4ea7\u8005\uff08Producers\uff09<\/p>\n\n\n\n \u5728RabbitMQ\u4e2d\uff0c\u751f\u4ea7\u8005\uff08Producer\uff09\u662f\u8d1f\u8d23\u53d1\u9001\u6d88\u606f\u7684\u5b9e\u4f53\uff0c\u901a\u5e38\u662f\u5e94\u7528\u7a0b\u5e8f\u7684\u4e00\u4e2a\u7ec4\u4ef6\u3002\u751f\u4ea7\u8005\u5c06\u6d88\u606f\u53d1\u9001\u5230RabbitMQ\u670d\u52a1\u5668\uff0c\u4ee5\u4fbf\u540e\u7eed\u5904\u7406\u548c\u4f20\u9012\u3002\u4ee5\u4e0b\u662f\u4e0e\u751f\u4ea7\u8005\u76f8\u5173\u7684\u4e00\u4e9b\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\uff1a<\/p>\n\n\n\n \u5728\u4f7f\u7528RabbitMQ\u65f6\uff0c\u751f\u4ea7\u8005\u901a\u5e38\u9700\u8981\u6267\u884c\u4ee5\u4e0b\u6b65\u9aa4\uff1a<\/p>\n\n\n\n \u8fd9\u4e9b\u662f\u4e0e\u751f\u4ea7\u8005\u76f8\u5173\u7684\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\u3002\u8981\u6839\u636e\u5b9e\u9645\u9700\u6c42\u4f7f\u7528\u751f\u4ea7\u8005\uff0c\u9700\u8981\u4e86\u89e3\u66f4\u591a\u5173\u4e8eRabbitMQ\u7684\u77e5\u8bc6\uff0c\u5982\u4ea4\u6362\u5668\u7c7b\u578b\u3001\u6301\u4e45\u5316\u3001\u6d88\u606f\u5c5e\u6027\u7b49\u3002\u53ef\u4ee5\u53c2\u8003RabbitMQ\u5b98\u65b9\u6587\u6863\u4ee5\u83b7\u53d6\u66f4\u591a\u4fe1\u606f\u3002<\/p>\n\n\n\n\n\n \u8bf7\u8be6\u7ec6\u89e3\u91ca\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\u7684\u6d88\u8d39\u8005\uff08Consumers\uff09<\/p>\n\n\n\n \u5728RabbitMQ\u4e2d\uff0c\u6d88\u8d39\u8005\uff08Consumer\uff09\u662f\u4ece\u6d88\u606f\u961f\u5217\u4e2d\u63a5\u6536\u5e76\u5904\u7406\u6d88\u606f\u7684\u5b9e\u4f53\uff0c\u901a\u5e38\u662f\u5e94\u7528\u7a0b\u5e8f\u7684\u4e00\u4e2a\u7ec4\u4ef6\u3002\u4ee5\u4e0b\u662f\u4e0e\u6d88\u8d39\u8005\u76f8\u5173\u7684\u4e00\u4e9b\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\uff1a<\/p>\n\n\n\n \u5728\u4f7f\u7528RabbitMQ\u65f6\uff0c\u6d88\u8d39\u8005\u901a\u5e38\u9700\u8981\u6267\u884c\u4ee5\u4e0b\u6b65\u9aa4\uff1a<\/p>\n\n\n\n \u8fd9\u4e9b\u662f\u4e0e\u6d88\u8d39\u8005\u76f8\u5173\u7684\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\u3002\u4e3a\u4e86\u66f4\u6709\u6548\u5730\u4f7f\u7528\u6d88\u8d39\u8005\uff0c\u60a8\u53ef\u80fd\u8fd8\u9700\u8981\u4e86\u89e3RabbitMQ\u7684\u5176\u4ed6\u77e5\u8bc6\uff0c\u4f8b\u5982\u961f\u5217\u6301\u4e45\u6027\u3001\u6d88\u606f\u5c5e\u6027\u3001\u8d1f\u8f7d\u5747\u8861\u7b49\u3002\u60a8\u53ef\u4ee5\u53c2\u8003RabbitMQ\u5b98\u65b9\u6587\u6863\u4ee5\u83b7\u53d6\u66f4\u591a\u4fe1\u606f\u3002<\/p>\n\n\n\n\n\n \u8bf7\u8be6\u7ec6\u89e3\u91ca\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\u7684\u4ea4\u6362\u673a\uff08Exchanges\uff09<\/p>\n\n\n\n \u5728RabbitMQ\u4e2d\uff0c\u4ea4\u6362\u5668\uff08Exchanges\uff09\u662f\u8d1f\u8d23\u5904\u7406\u6d88\u606f\u8def\u7531\u7684\u6838\u5fc3\u7ec4\u4ef6\u3002\u751f\u4ea7\u8005\u5c06\u6d88\u606f\u53d1\u9001\u5230\u4ea4\u6362\u5668\uff0c\u4ea4\u6362\u5668\u6839\u636e\u6d88\u606f\u7684\u8def\u7531\u952e\uff08Routing Key\uff09\u548c\u4e0e\u961f\u5217\u7684\u7ed1\u5b9a\u5173\u7cfb\uff08Bindings\uff09\uff0c\u5c06\u6d88\u606f\u8def\u7531\u5230\u4e00\u4e2a\u6216\u591a\u4e2a\u961f\u5217\u3002\u4ee5\u4e0b\u662f\u4e0e\u4ea4\u6362\u5668\u76f8\u5173\u7684\u4e00\u4e9b\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\uff1a<\/p>\n\n\n\n \u5728\u4f7f\u7528RabbitMQ\u65f6\uff0c\u901a\u5e38\u9700\u8981\u6267\u884c\u4ee5\u4e0b\u6b65\u9aa4\u6765\u58f0\u660e\u548c\u4f7f\u7528\u4ea4\u6362\u5668\uff1a<\/p>\n\n\n\n \u8bf7\u7ee7\u7eed<\/p>\n\n\n\n \u8005\uff09\u53d1\u9001\u6d88\u606f\u5230\u4ea4\u6362\u5668\uff0c\u6307\u5b9a\u8def\u7531\u952e\u3002 5. \uff08\u6d88\u8d39\u8005\uff09\u58f0\u660e\u961f\u5217\uff08\u5982\u679c\u5c1a\u672a\u58f0\u660e\uff09\u3002<\/p>\n\n\n\n \u8fd9\u4e9b\u662f\u4e0e\u4ea4\u6362\u5668\u76f8\u5173\u7684\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\u3002\u4e3a\u4e86\u66f4\u6709\u6548\u5730\u4f7f\u7528\u4ea4\u6362\u5668\uff0c\u60a8\u53ef\u80fd\u8fd8\u9700\u8981\u4e86\u89e3RabbitMQ\u7684\u5176\u4ed6\u77e5\u8bc6\uff0c\u4f8b\u5982\u961f\u5217\u6301\u4e45\u6027\u3001\u6d88\u606f\u5c5e\u6027\u3001\u751f\u4ea7\u8005\u548c\u6d88\u8d39\u8005\u7684\u9ad8\u7ea7\u7528\u6cd5\u7b49\u3002\u60a8\u53ef\u4ee5\u53c2\u8003RabbitMQ\u5b98\u65b9\u6587\u6863\u4ee5\u83b7\u53d6\u66f4\u591a\u4fe1\u606f\u3002<\/p>\n\n\n\n\n\n \u8bf7\u8be6\u7ec6\u89e3\u91ca\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\u7684\u7ed1\u5b9a\uff08Bindings\uff09<\/p>\n\n\n\n \u5728RabbitMQ\u4e2d\uff0c\u7ed1\u5b9a\uff08Bindings\uff09\u662f\u961f\u5217\u548c\u4ea4\u6362\u5668\u4e4b\u95f4\u7684\u5173\u7cfb\uff0c\u7528\u4e8e\u6307\u5b9a\u4ea4\u6362\u5668\u5982\u4f55\u5c06\u6d88\u606f\u8def\u7531\u5230\u961f\u5217\u3002\u4ee5\u4e0b\u662f\u4e0e\u7ed1\u5b9a\u76f8\u5173\u7684\u4e00\u4e9b\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\uff1a<\/p>\n\n\n\n \u5728\u4f7f\u7528RabbitMQ\u65f6\uff0c\u901a\u5e38\u9700\u8981\u6267\u884c\u4ee5\u4e0b\u6b65\u9aa4\u6765\u521b\u5efa\u548c\u4f7f\u7528\u7ed1\u5b9a\uff1a<\/p>\n\n\n\n \u8fd9\u4e9b\u662f\u4e0e\u7ed1\u5b9a\u76f8\u5173\u7684\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\u3002\u4e3a\u4e86\u66f4\u6709\u6548\u5730\u4f7f\u7528\u7ed1\u5b9a\uff0c\u60a8\u53ef\u80fd\u8fd8\u9700\u8981\u4e86\u89e3RabbitMQ\u7684\u5176\u4ed6\u77e5\u8bc6\uff0c\u4f8b\u5982\u4ea4\u6362\u5668\u7c7b\u578b\u3001\u961f\u5217\u6301\u4e45\u6027\u3001\u6d88\u606f\u5c5e\u6027\u3001\u751f\u4ea7\u8005\u548c\u6d88\u8d39\u8005\u7684\u9ad8\u7ea7\u7528\u6cd5\u7b49\u3002\u60a8\u53ef\u4ee5\u53c2\u8003RabbitMQ\u5b98\u65b9\u6587\u6863\u4ee5\u83b7\u53d6\u66f4\u591a\u4fe1\u606f\u3002<\/p>\n\n\n\n\n\n \u8bf7\u8be6\u7ec6\u89e3\u91ca\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\u7684\u8def\u7531\u952e\uff08Routing Keys\uff09<\/p>\n\n\n\n \u5728RabbitMQ\u4e2d\uff0c\u8def\u7531\u952e\uff08Routing Key\uff09\u662f\u751f\u4ea7\u8005\u5728\u53d1\u9001\u6d88\u606f\u65f6\u6307\u5b9a\u7684\u4e00\u4e2a\u5b57\u7b26\u4e32\uff0c\u7528\u4e8e\u5e2e\u52a9\u4ea4\u6362\u5668\u5224\u65ad\u5982\u4f55\u5c06\u6d88\u606f\u8def\u7531\u5230\u961f\u5217\u3002\u8def\u7531\u952e\u7684\u4f5c\u7528\u548c\u4f7f\u7528\u65b9\u5f0f\u56e0\u4ea4\u6362\u5668\u7c7b\u578b\u800c\u5f02\u3002\u4ee5\u4e0b\u662f\u4e0e\u8def\u7531\u952e\u76f8\u5173\u7684\u4e00\u4e9b\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\uff1a<\/p>\n\n\n\n \u5728\u4f7f\u7528RabbitMQ\u65f6\uff0c\u901a\u5e38\u9700\u8981\u6267\u884c\u4ee5\u4e0b\u6b65\u9aa4\u6765\u6307\u5b9a\u548c\u4f7f\u7528\u8def\u7531\u952e\uff1a<\/p>\n\n\n\n \u8fd9\u4e9b\u662f\u4e0e\u8def\u7531\u952e\u76f8\u5173\u7684\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\u3002\u4e3a\u4e86\u66f4\u6709\u6548\u5730\u4f7f\u7528\u8def\u7531\u952e\uff0c\u60a8\u53ef\u80fd\u8fd8\u9700\u8981\u4e86\u89e3RabbitMQ\u7684\u5176\u4ed6\u77e5\u8bc6\uff0c\u4f8b\u5982\u4ea4\u6362\u5668\u7c7b\u578b\u3001\u961f\u5217\u6301\u4e45\u6027\u3001\u6d88\u606f\u5c5e\u6027\u3001\u751f\u4ea7\u8005\u548c\u6d88\u8d39\u8005\u7684\u9ad8\u7ea7\u7528\u6cd5\u7b49\u3002\u60a8\u53ef\u4ee5\u53c2\u8003RabbitMQ\u5b98\u65b9\u6587\u6863\u4ee5\u83b7\u53d6\u66f4\u591a\u4fe1\u606f\u3002<\/p>\n\n\n\n\n\n \u8bf7\u8be6\u7ec6\u89e3\u91ca\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\u7684\u6301\u4e45\u5316\uff08Persistence\uff09<\/p>\n\n\n\n \u5728RabbitMQ\u4e2d\uff0c\u6301\u4e45\u5316\uff08Persistence\uff09\u662f\u4e00\u79cd\u786e\u4fdd\u5728RabbitMQ\u670d\u52a1\u5668\u91cd\u542f\u540e\uff0c\u6d88\u606f\u548c\u914d\u7f6e\u4fe1\u606f\u4ecd\u7136\u5b58\u5728\u7684\u673a\u5236\u3002\u6301\u4e45\u5316\u53ef\u4ee5\u5e94\u7528\u4e8e\u961f\u5217\u3001\u4ea4\u6362\u5668\u548c\u6d88\u606f\u3002\u4ee5\u4e0b\u662f\u4e0e\u6301\u4e45\u5316\u76f8\u5173\u7684\u4e00\u4e9b\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\uff1a<\/p>\n\n\n\n \u4e3a\u4e86\u5b9e\u73b0\u6301\u4e45\u5316\uff0c\u901a\u5e38\u9700\u8981\u6267\u884c\u4ee5\u4e0b\u6b65\u9aa4\uff1a<\/p>\n\n\n\n \u8fd9\u4e9b\u662f\u4e0e\u6301\u4e45\u5316\u76f8\u5173\u7684\u57fa\u672c\u6982\u5ff5\u548c\u672f\u8bed\u3002\u4e3a\u4e86\u66f4\u6709\u6548\u5730\u4f7f\u7528\u6301\u4e45\u5316\uff0c\u60a8\u53ef\u80fd\u8fd8\u9700\u8981\u4e86\u89e3RabbitMQ\u7684\u5176\u4ed6\u77e5\u8bc6\uff0c\u4f8b\u5982\u6d88\u606f\u5c5e\u6027\u3001\u751f\u4ea7\u8005\u548c\u6d88\u8d39\u8005\u7684\u9ad8\u7ea7\u7528\u6cd5\u3001\u6027\u80fd\u4f18\u5316\u7b49\u3002\u60a8\u53ef\u4ee5\u53c2\u8003RabbitMQ\u5b98\u65b9\u6587\u6863\u4ee5\u83b7\u53d6\u66f4\u591a\u4fe1\u606f\u3002<\/p>\n\n\n\n\n\n \u8bf7\u8be6\u7ec6\u89e3\u91ca\u7f16\u5199\u4e00\u4e2a\u7b80\u5355\u7684\u751f\u4ea7\u8005\u7a0b\u5e8f<\/p>\n\n\n\n \u4ee5\u4e0b\u662f\u4e00\u4e2a\u4f7f\u7528Python\u548cpika\u5e93\u7f16\u5199\u7684\u7b80\u5355RabbitMQ\u751f\u4ea7\u8005\u7a0b\u5e8f\u3002\u5728\u8fd9\u4e2a\u4f8b\u5b50\u4e2d\uff0c\u6211\u4eec\u5c06\u4f7f\u7528\u76f4\u63a5\u4ea4\u6362\u5668\u5c06\u4e00\u4e2a\u7b80\u5355\u7684\u6587\u672c\u6d88\u606f\u53d1\u9001\u5230\u540d\u4e3a”my_queue”\u7684\u961f\u5217\u3002<\/p>\n\n\n\n \u9996\u5148\uff0c\u8bf7\u786e\u4fdd\u5df2\u7ecf\u5b89\u88c5\u4e86pika\u5e93\u3002\u5982\u679c\u5c1a\u672a\u5b89\u88c5\uff0c\u8bf7\u4f7f\u7528\u4ee5\u4e0b\u547d\u4ee4\u5b89\u88c5\uff1a<\/p>\n\n\n\n \u63a5\u4e0b\u6765\uff0c\u7f16\u5199\u4e00\u4e2a\u7b80\u5355\u7684\u751f\u4ea7\u8005\u7a0b\u5e8f\uff1a<\/p>\n\n\n\n \u5728\u8fd9\u4e2a\u7a0b\u5e8f\u4e2d\uff0c\u6211\u4eec\u9996\u5148\u5efa\u7acb\u4e0eRabbitMQ\u670d\u52a1\u5668\u7684\u8fde\u63a5\uff0c\u7136\u540e\u521b\u5efa\u4e00\u4e2a\u901a\u9053\u3002\u63a5\u7740\uff0c\u6211\u4eec\u58f0\u660e\u4e00\u4e2a\u540d\u4e3a”my_direct_exchange”\u7684\u76f4\u63a5\u4ea4\u6362\u5668\uff0c\u4ee5\u53ca\u4e00\u4e2a\u540d\u4e3a”my_queue”\u7684\u6301\u4e45\u5316\u961f\u5217\u3002\u7136\u540e\uff0c\u6211\u4eec\u5c06\u961f\u5217\u7ed1\u5b9a\u5230\u4ea4\u6362\u5668\uff0c\u4f7f\u7528\u8def\u7531\u952e”my_routing_key”\u3002<\/p>\n\n\n\n \u63a5\u4e0b\u6765\uff0c\u6211\u4eec\u4f7f\u7528 \u6700\u540e\uff0c\u6211\u4eec\u5173\u95ed\u4e0eRabbitMQ\u670d\u52a1\u5668\u7684\u8fde\u63a5\u3002<\/p>\n\n\n\n \u8981\u8fd0\u884c\u6b64\u7a0b\u5e8f\uff0c\u8bf7\u5c06\u4ee3\u7801\u4fdd\u5b58\u5230\u540d\u4e3a \u5982\u679c\u4e00\u5207\u6b63\u5e38\uff0c\u60a8\u5c06\u770b\u5230”Sent message: Hello, RabbitMQ!”\u7684\u8f93\u51fa\u3002\u8fd9\u8868\u793a\u6d88\u606f\u5df2\u6210\u529f\u53d1\u9001\u5230RabbitMQ\u670d\u52a1\u5668\u3002\u63a5\u4e0b\u6765\uff0c\u60a8\u53ef\u4ee5\u7f16\u5199\u4e00\u4e2a\u6d88\u8d39\u8005\u7a0b\u5e8f\u6765\u63a5\u6536\u548c\u5904\u7406\u8fd9\u6761\u6d88\u606f\u3002<\/p>\n\n\n\n\n\n \u8bf7\u8be6\u7ec6\u89e3\u91ca\u7f16\u5199\u4e00\u4e2a\u7b80\u5355\u7684\u6d88\u8d39\u8005\u7a0b\u5e8f<\/p>\n\n\n\n \u4ee5\u4e0b\u662f\u4e00\u4e2a\u4f7f\u7528Python\u548cpika\u5e93\u7f16\u5199\u7684\u7b80\u5355RabbitMQ\u6d88\u8d39\u8005\u7a0b\u5e8f\u3002\u5728\u8fd9\u4e2a\u4f8b\u5b50\u4e2d\uff0c\u6211\u4eec\u5c06\u4ece\u540d\u4e3a”my_queue”\u7684\u961f\u5217\u63a5\u6536\u6d88\u606f\uff0c\u5e76\u6253\u5370\u6536\u5230\u7684\u6d88\u606f\u5185\u5bb9\u3002<\/p>\n\n\n\n \u9996\u5148\uff0c\u8bf7\u786e\u4fdd\u5df2\u7ecf\u5b89\u88c5\u4e86pika\u5e93\u3002\u5982\u679c\u5c1a\u672a\u5b89\u88c5\uff0c\u8bf7\u4f7f\u7528\u4ee5\u4e0b\u547d\u4ee4\u5b89\u88c5\uff1a<\/p>\n\n\n\n \u63a5\u4e0b\u6765\uff0c\u7f16\u5199\u4e00\u4e2a\u7b80\u5355\u7684\u6d88\u8d39\u8005\u7a0b\u5e8f\uff1a<\/p>\n\n\n\n \u5728\u8fd9\u4e2a\u7a0b\u5e8f\u4e2d\uff0c\u6211\u4eec\u9996\u5148\u5b9a\u4e49\u4e86\u4e00\u4e2a\u540d\u4e3a \u63a5\u7740\uff0c\u6211\u4eec\u5efa\u7acb\u4e0eRabbitMQ\u670d\u52a1\u5668\u7684\u8fde\u63a5\uff0c\u521b\u5efa\u4e00\u4e2a\u901a\u9053\uff0c\u5e76\u58f0\u660e\u4e00\u4e2a\u540d\u4e3a”my_queue”\u7684\u6301\u4e45\u5316\u961f\u5217\u3002<\/p>\n\n\n\n \u7136\u540e\uff0c\u6211\u4eec\u8bbe\u7f6e\u8d28\u91cf\u63a7\u5236\uff08Quality of Service, QoS\uff09\uff0c\u4f7f\u7528 \u6700\u540e\uff0c\u6211\u4eec\u4f7f\u7528 \u8981\u8fd0\u884c\u6b64\u7a0b\u5e8f\uff0c\u8bf7\u5c06\u4ee3\u7801\u4fdd\u5b58\u5230\u540d\u4e3a \u5982\u679c\u4e00\u5207\u6b63\u5e38\uff0c\u60a8\u5c06\u770b\u5230”Waiting for messages. To exit press CTRL+C”\u7684\u8f93\u51fa\u3002\u8fd9\u8868\u793a\u6d88\u8d39\u8005\u5df2\u6210\u529f\u8fde\u63a5\u5230RabbitMQ\u670d\u52a1\u5668\uff0c\u5e76\u7b49\u5f85\u63a5\u6536\u6d88\u606f\u3002\u5f53\u6709\u65b0\u6d88\u606f\u5230\u8fbe\u65f6\uff0c\u6d88\u8d39\u8005\u5c06\u6253\u5370\u6536\u5230\u7684\u6d88\u606f\u5185\u5bb9\u3002<\/p>\n\n\n\n \u8bf7\u786e\u4fdd\u5728\u8fd0\u884c\u6d88\u8d39\u8005\u7a0b\u5e8f\u4e4b\u524d\uff0c\u5df2\u7ecf\u8fd0\u884c\u4e86\u751f\u4ea7\u8005\u7a0b\u5e8f\u53d1\u9001\u4e86\u4e00\u6761\u6d88\u606f\u3002\u5426\u5219\uff0c\u6d88\u8d39\u8005\u5c06\u4e0d\u4f1a\u6536\u5230\u4efb\u4f55\u6d88\u606f\u3002<\/p>\n\n\n\n\n\n \u8bf7\u8be6\u7ec6\u89e3\u91ca\u5982\u4f55\u5b9e\u73b0\u6d88\u606f\u786e\u8ba4\u673a\u5236<\/p>\n\n\n\n \u5728RabbitMQ\u4e2d\uff0c\u6d88\u606f\u786e\u8ba4\u673a\u5236\uff08Message Acknowledgment\uff09\u7528\u4e8e\u786e\u4fdd\u6d88\u606f\u5728\u6210\u529f\u5904\u7406\u4e4b\u524d\uff0c\u4e0d\u4f1a\u4ece\u961f\u5217\u4e2d\u5220\u9664\u3002\u8fd9\u6709\u52a9\u4e8e\u786e\u4fdd\u5728\u6d88\u8d39\u8005\u5f02\u5e38\u7ec8\u6b62\u6216\u5904\u7406\u6d88\u606f\u65f6\u51fa\u73b0\u9519\u8bef\u7684\u60c5\u51b5\u4e0b\uff0c\u6d88\u606f\u4e0d\u4f1a\u4e22\u5931\u3002\u4ee5\u4e0b\u662f\u5982\u4f55\u5728\u751f\u4ea7\u8005\u548c\u6d88\u8d39\u8005\u7a0b\u5e8f\u4e2d\u5b9e\u73b0\u6d88\u606f\u786e\u8ba4\u673a\u5236\u7684\u8be6\u7ec6\u8bf4\u660e\u3002<\/p>\n\n\n\n \u5728\u8fd9\u91cc\uff0c\u6211\u4eec\u5c06 \u5728\u8fd9\u91cc\uff0c\u6211\u4eec\u4f7f\u7528 \u6b64\u5916\uff0c\u9700\u8981\u5728\u6ce8\u518c\u6d88\u8d39\u8005\u56de\u8c03\u51fd\u6570\u65f6\uff0c\u8bbe\u7f6e \u8fd9\u544a\u8bc9RabbitMQ\uff0c\u6211\u4eec\u5c06\u624b\u52a8\u53d1\u9001\u6d88\u606f\u786e\u8ba4\u3002\u5982\u679c\u5c06 \u8fd9\u5c31\u662f\u5982\u4f55\u5728RabbitMQ\u751f\u4ea7\u8005\u548c\u6d88\u8d39\u8005\u7a0b\u5e8f\u4e2d\u5b9e\u73b0\u6d88\u606f\u786e\u8ba4\u673a\u5236\u3002\u5b9e\u73b0\u6b64\u673a\u5236\u53ef\u4ee5\u786e\u4fdd\u6d88\u606f\u5728\u5904\u7406\u8fc7\u7a0b\u4e2d\u4e0d\u4f1a\u4e22\u5931\uff0c\u63d0\u9ad8\u7cfb\u7edf\u7684\u53ef\u9760\u6027\u3002\u4f46\u9700\u8981\u6ce8\u610f\u7684\u662f\uff0c\u6d88\u606f\u786e\u8ba4\u4f1a\u5e26\u6765\u989d\u5916\u7684\u6027\u80fd\u5f00\u9500\uff0c\u56e0\u4e3a\u9700\u8981\u8fdb\u884c\u989d\u5916\u7684\u7f51\u7edc\u901a\u4fe1\u3002\u5728\u5bf9\u6027\u80fd\u8981\u6c42\u8f83\u9ad8\u7684\u573a\u666f\u4e0b\uff0c\u53ef\u4ee5\u8003\u8651\u4f7f\u7528\u5176\u4ed6\u7b56\u7565\u6765\u786e\u4fdd\u6d88\u606f\u7684\u53ef\u9760\u6027\uff0c\u5982\u4f7f\u7528\u6301\u4e45\u5316\u961f\u5217\u548c\u4ea4\u6362\u5668\uff0c\u6216\u91c7\u7528\u6d88\u606f\u91cd\u8bd5\u548c\u6b7b\u4fe1\u961f\u5217\u7b49\u3002<\/p>\n\n\n\n\n\n \u8bf7\u8be6\u7ec6\u89e3\u91ca\u8bbe\u7f6e\u6d88\u606f\u4f18\u5148\u7ea7<\/p>\n\n\n\n \u5728RabbitMQ\u4e2d\uff0c\u53ef\u4ee5\u901a\u8fc7\u8bbe\u7f6e\u6d88\u606f\u4f18\u5148\u7ea7\u6765\u63a7\u5236\u6d88\u606f\u5728\u961f\u5217\u4e2d\u7684\u987a\u5e8f\u3002\u4f18\u5148\u7ea7\u8f83\u9ad8\u7684\u6d88\u606f\u5c06\u4f18\u5148\u88ab\u6d88\u8d39\u8005\u63a5\u6536\u548c\u5904\u7406\u3002\u4ee5\u4e0b\u662f\u5982\u4f55\u8bbe\u7f6e\u6d88\u606f\u4f18\u5148\u7ea7\u7684\u8be6\u7ec6\u8bf4\u660e\uff1a<\/p>\n\n\n\n \u5728\u8fd9\u4e2a\u4f8b\u5b50\u4e2d\uff0c\u6211\u4eec\u5c06\u961f\u5217\u7684\u6700\u5927\u4f18\u5148\u7ea7\u8bbe\u7f6e\u4e3a10\u3002\u6ce8\u610f\uff0c\u4f18\u5148\u7ea7\u503c\u7684\u8303\u56f4\u662f0\uff08\u6700\u4f4e\uff09\u5230255\uff08\u6700\u9ad8\uff09\u3002<\/p>\n\n\n\n \u5728\u8fd9\u4e2a\u4f8b\u5b50\u4e2d\uff0c\u6211\u4eec\u5c06\u6d88\u606f\u7684\u4f18\u5148\u7ea7\u8bbe\u7f6e\u4e3a5\u3002\u6839\u636e\u5b9e\u9645\u9700\u6c42\uff0c\u53ef\u4ee5\u4e3a\u4e0d\u540c\u7684\u6d88\u606f\u8bbe\u7f6e\u4e0d\u540c\u7684\u4f18\u5148\u7ea7\u3002<\/p>\n\n\n\n \u8fd9\u5c31\u662f\u5982\u4f55\u5728RabbitMQ\u4e2d\u8bbe\u7f6e\u6d88\u606f\u4f18\u5148\u7ea7\u3002\u901a\u8fc7\u8bbe\u7f6e\u4f18\u5148\u7ea7\uff0c\u53ef\u4ee5\u786e\u4fdd\u5173\u952e\u6d88\u606f\u5728\u961f\u5217\u4e2d\u4f18\u5148\u88ab\u5904\u7406\uff0c\u4ece\u800c\u63d0\u9ad8\u7cfb\u7edf\u7684\u54cd\u5e94\u901f\u5ea6\u548c\u53ef\u9760\u6027\u3002\u7136\u800c\uff0c\u8bf7\u6ce8\u610f\uff0c\u4f7f\u7528\u6d88\u606f\u4f18\u5148\u7ea7\u4f1a\u5e26\u6765\u989d\u5916\u7684\u6027\u80fd\u5f00\u9500\uff0c\u56e0\u4e3aRabbitMQ\u9700\u8981\u6839\u636e\u4f18\u5148\u7ea7\u5bf9\u6d88\u606f\u8fdb\u884c\u6392\u5e8f\u3002\u5728\u5bf9\u6027\u80fd\u8981\u6c42\u8f83\u9ad8\u7684\u573a\u666f\u4e0b\uff0c\u53ef\u4ee5\u8003\u8651\u4f7f\u7528\u5176\u4ed6\u7b56\u7565\u6765\u786e\u4fdd\u5173\u952e\u6d88\u606f\u7684\u5904\u7406\uff0c\u5982\u4f7f\u7528\u4e13\u95e8\u7684\u961f\u5217\u6216\u4ea4\u6362\u5668\u7b49\u3002<\/p>\n\n\n\n\n\n \u8bf7\u8be6\u7ec6\u89e3\u91ca\u4f7f\u7528\u6b7b\u4fe1\u961f\u5217\u5904\u7406\u5931\u8d25\u6d88\u606f<\/p>\n\n\n\n \u5728RabbitMQ\u4e2d\uff0c\u6b7b\u4fe1\u961f\u5217\uff08Dead-Letter Queue\uff0c\u7b80\u79f0DLQ\uff09\u662f\u7528\u4e8e\u5904\u7406\u65e0\u6cd5\u6b63\u5e38\u5904\u7406\u7684\u6d88\u606f\u7684\u7279\u6b8a\u961f\u5217\u3002\u5f53\u6d88\u606f\u5728\u6d88\u8d39\u8005\u4e2d\u56e0\u4e3a\u67d0\u79cd\u539f\u56e0\u65e0\u6cd5\u5904\u7406\u65f6\uff0c\u53ef\u4ee5\u5c06\u5176\u53d1\u9001\u5230\u6b7b\u4fe1\u961f\u5217\uff0c\u4ee5\u4fbf\u540e\u7eed\u8fdb\u884c\u8bca\u65ad\u548c\u4fee\u590d\u3002\u4ee5\u4e0b\u662f\u5982\u4f55\u4f7f\u7528\u6b7b\u4fe1\u961f\u5217\u5904\u7406\u5931\u8d25\u6d88\u606f\u7684\u8be6\u7ec6\u8bf4\u660e\uff1a<\/p>\n\n\n\n \u5728\u8fd9\u4e2a\u4f8b\u5b50\u4e2d\uff0c\u6211\u4eec\u521b\u5efa\u4e86\u4e00\u4e2a\u540d\u4e3a \u5728\u8fd9\u4e2a\u4f8b\u5b50\u4e2d\uff0c\u6211\u4eec\u5c06\u4e3b\u961f\u5217\u7684\u6b7b\u4fe1\u4ea4\u6362\u5668\u8bbe\u7f6e\u4e3a \u5728\u8fd9\u4e2a\u4f8b\u5b50\u4e2d\uff0c\u6211\u4eec\u6a21\u62df\u4e86\u4e00\u4e2a\u5728\u5904\u7406\u6d88\u606f\u65f6\u53d1\u751f\u7684\u9519\u8bef\u3002\u5f53\u6355\u83b7\u5230\u5f02\u5e38\u65f6\uff0c\u6211\u4eec\u4f7f\u7528 \u8bf7\u7ee7\u7eed<\/p>\n\n\n\n \u5728\u8fd9\u4e2a\u4f8b\u5b50\u4e2d\uff0c\u6211\u4eec\u5b9a\u4e49\u4e86\u4e00\u4e2a\u540d\u4e3a \u8fd9\u5c31\u662f\u5982\u4f55\u5728RabbitMQ\u4e2d\u4f7f\u7528\u6b7b\u4fe1\u961f\u5217\u5904\u7406\u5931\u8d25\u6d88\u606f\u3002\u4f7f\u7528\u6b7b\u4fe1\u961f\u5217\u53ef\u4ee5\u786e\u4fdd\u65e0\u6cd5\u6b63\u5e38\u5904\u7406\u7684\u6d88\u606f\u4e0d\u4f1a\u4e22\u5931\uff0c\u540c\u65f6\u4f7f\u60a8\u80fd\u591f\u5728\u540e\u7eed\u8fdb\u884c\u8bca\u65ad\u548c\u4fee\u590d\u3002\u8fd9\u6709\u52a9\u4e8e\u63d0\u9ad8\u7cfb\u7edf\u7684\u53ef\u9760\u6027\u548c\u5065\u58ee\u6027\u3002\u7136\u800c\uff0c\u8bf7\u6ce8\u610f\uff0c\u6b7b\u4fe1\u961f\u5217\u4f1a\u5e26\u6765\u989d\u5916\u7684\u6027\u80fd\u5f00\u9500\uff0c\u56e0\u4e3a\u9700\u8981\u989d\u5916\u7684\u961f\u5217\u548c\u6d88\u8d39\u8005\u6765\u5904\u7406\u5931\u8d25\u6d88\u606f\u3002\u5728\u5bf9\u6027\u80fd\u8981\u6c42\u8f83\u9ad8\u7684\u573a\u666f\u4e0b\uff0c\u53ef\u4ee5\u8003\u8651\u4f7f\u7528\u5176\u4ed6\u7b56\u7565\u6765\u786e\u4fdd\u6d88\u606f\u7684\u53ef\u9760\u6027\uff0c\u5982\u4f7f\u7528\u6301\u4e45\u5316\u961f\u5217\u548c\u4ea4\u6362\u5668\uff0c\u6216\u91c7\u7528\u6d88\u606f\u91cd\u8bd5\u7b49\u3002<\/p>\n\n\n\n\n\n \u8bf7\u8be6\u7ec6\u89e3\u91ca\u4f7f\u7528\u4ea4\u6362\u673a\u5b9e\u73b0\u4e0d\u540c\u7684\u6d88\u606f\u8def\u7531\u7b56\u7565<\/p>\n\n\n\n RabbitMQ\u4e2d\u7684\u4ea4\u6362\u5668\uff08Exchanges\uff09\u7528\u4e8e\u6839\u636e\u9884\u5b9a\u4e49\u7684\u8def\u7531\u7b56\u7565\u5c06\u6d88\u606f\u8def\u7531\u5230\u4e0d\u540c\u7684\u961f\u5217\u3002\u4ee5\u4e0b\u662f\u4f7f\u7528\u4e0d\u540c\u7c7b\u578b\u7684\u4ea4\u6362\u5668\u5b9e\u73b0\u4e0d\u540c\u6d88\u606f\u8def\u7531\u7b56\u7565\u7684\u8be6\u7ec6\u8bf4\u660e\uff1a<\/p>\n\n\n\n \u901a\u914d\u7b26\uff1a<\/p>\n\n\n\n \u8bf7\u7ee7\u7eed<\/p>\n\n\n\n![\"gun](\"https:\/\/chat.openai.com\/_next\/image?url=https%3A%2F%2Flh3.googleusercontent.com%2Fa%2FAGNmyxbwVdnTP0E2eBqDrujRQjV-wFP12Thr4vFgysVv5A%3Ds96-c&w=96&q=75\")
\n
\n
\n
\n
\n
\n
curl -fsSL https:\/\/packages.rabbitmq.com\/gpg\/RABBITMQ-SIGNING-KEY.asc | sudo gpg --dearmor -o \/usr\/share\/keyrings\/rabbitmq-archive-keyring.gpg <\/code>1.2 \u521b\u5efaAPT\u6e90\u6587\u4ef6\uff1abashCopy codeecho \"deb [signed-by=\/usr\/share\/keyrings\/rabbitmq-archive-keyring.gpg] https:\/\/packages.rabbitmq.com\/debian\/ $(lsb_release -sc) main\" | sudo tee \/etc\/apt\/sources.list.d\/rabbitmq.list <\/code>1.3 \u66f4\u65b0APT\u7f13\u5b58\u5e76\u5b89\u88c5RabbitMQ Server\uff1asqlCopy codesudo apt-get update sudo apt-get install rabbitmq-server<\/code><\/li>\n\n\n\nbrew update brew install rabbitmq <\/code>3.3 \u5c06RabbitMQ\u7684\u53ef\u6267\u884c\u6587\u4ef6\u8def\u5f84\u6dfb\u52a0\u5230PATH\u73af\u5883\u53d8\u91cf\u4e2d\uff1abashCopy codeecho 'export PATH=$PATH:\/usr\/local\/sbin' >> ~\/.zshrc source ~\/.zshrc<\/code><\/li>\n<\/ol>\n\n\n\n\n
sudo rabbitmq-server<\/code><\/li>\n\n\n\n\n
pip install pika<\/code><\/li>\n\n\n\npom.xml<\/code>\u6587\u4ef6\u4e2d\u6dfb\u52a0RabbitMQ Java\u5ba2\u6237\u7aef\u5e93\u4f9d\u8d56\uff1axmlCopy code<dependencies> <dependency> <groupId>com.rabbitmq<\/groupId> <artifactId>amqp-client<\/artifactId> <version>5.13.1<\/version> <\/dependency> <\/dependencies> <\/code>\u5982\u679c\u4f7f\u7528Gradle\uff0c\u53ef\u4ee5\u5728build.gradle<\/code>\u6587\u4ef6\u4e2d\u6dfb\u52a0\u4f9d\u8d56\uff1aarduinoCopy codedependencies { implementation 'com.rabbitmq:amqp-client:5.13.1' }<\/code><\/li>\n\n\n\nnuget install RabbitMQ.Client <\/code>\u6216\u5728Visual Studio\u4e2d\u4f7f\u7528NuGet\u5305\u7ba1\u7406\u5668\u641c\u7d22\u5e76\u5b89\u88c5RabbitMQ.Client<\/code>\u3002<\/li>\n\n\n\nnpm install amqplib<\/code><\/li>\n\n\n\ngem install bunny<\/code><\/li>\n<\/ol>\n\n\n\n\n
\n
\/etc\/rabbitmq\/rabbitmq.conf<\/code><\/li>\n\n\n\n\/usr\/local\/etc\/rabbitmq\/rabbitmq.conf<\/code><\/li>\n\n\n\n%APPDATA%\\RabbitMQ\\rabbitmq.conf<\/code> \u901a\u8fc7\u7f16\u8f91\u6b64\u914d\u7f6e\u6587\u4ef6\uff0c\u53ef\u4ee5\u66f4\u6539RabbitMQ\u7684\u5404\u9879\u914d\u7f6e\u53c2\u6570\u3002\u914d\u7f6e\u6587\u4ef6\u4f7f\u7528Erlang\u914d\u7f6e\u6587\u4ef6\u8bed\u6cd5\uff0c\u4e5f\u53ef\u4ee5\u9009\u62e9\u4f7f\u7528\u65b0\u7684RabbitMQ\u914d\u7f6e\u6587\u4ef6\u8bed\u6cd5\uff08\u4ece3.7.0\u7248\u672c\u5f00\u59cb\u652f\u6301\uff09\u3002<\/li>\n<\/ul>\n<\/li>\n\n\n\nrabbitmq-plugins<\/code>\u547d\u4ee4\u5217\u51fa\u6240\u6709\u53ef\u7528\u63d2\u4ef6\uff1aCopy coderabbitmq-plugins list <\/code>2.2 \u4f7f\u7528rabbitmq-plugins<\/code>\u547d\u4ee4\u542f\u7528\u6240\u9700\u63d2\u4ef6\uff0c\u5982\u542f\u7528\u7ba1\u7406\u63d2\u4ef6\uff1abashCopy coderabbitmq-plugins enable rabbitmq_management <\/code>\u542f\u7528\u63d2\u4ef6\u540e\uff0c\u53ef\u80fd\u9700\u8981\u91cd\u542fRabbitMQ Server\u4ee5\u4f7f\u66f4\u6539\u751f\u6548\u3002<\/li>\n\n\n\nrabbitmqctl<\/code>\u547d\u4ee4\u521b\u5efa\u65b0\u7528\u6237\uff1aCopy coderabbitmqctl add_user myuser mypassword <\/code>3.2 \u4f7f\u7528rabbitmqctl<\/code>\u547d\u4ee4\u4e3a\u7528\u6237\u5206\u914d\u89d2\u8272\uff1aCopy coderabbitmqctl set_user_tags myuser administrator <\/code>3.3 \u4f7f\u7528rabbitmqctl<\/code>\u547d\u4ee4\u8bbe\u7f6e\u7528\u6237\u6743\u9650\uff1aarduinoCopy coderabbitmqctl set_permissions -p \/ myuser \".*\" \".*\" \".*\" <\/code>\u8fd9\u91cc\uff0c\/<\/code>\u8868\u793a\u9ed8\u8ba4\u865a\u62df\u4e3b\u673a\uff0c\".*\"<\/code>\u8868\u793a\u5141\u8bb8\u7528\u6237\u8fdb\u884c\u6240\u6709\u64cd\u4f5c\u3002<\/li>\n\n\n\n~\/.erlang.cookie<\/code>\u6587\u4ef6\u4e2d\uff09\u3002 4.3 \u4f7f\u7528rabbitmqctl<\/code>\u547d\u4ee4\u5c06\u8282\u70b9\u52a0\u5165\u96c6\u7fa4\uff1acssCopy coderabbitmqctl join_cluster rabbit@node1 <\/code>4.4 \u914d\u7f6e\u955c\u50cf\u961f\u5217\uff0c\u53ef\u5728\u521b\u5efa\u961f\u5217\u65f6\u6307\u5b9ax-ha-policy<\/code>\u53c2\u6570\uff1aarduinoCopy codechannel.queue_declare(queue='my_queue', durable=True, arguments={'x-ha-policy': 'all'})<\/code><\/li>\n<\/ol>\n\n\n\n\n
\n
\n
\n
\n
\n
\n
\n
\n
\n
\n
\n
\n
\n
\n
bashCopy code
pip install pika\n<\/code><\/pre>\n\n\n\npythonCopy code
import pika\n\n# \u5efa\u7acb\u4e0eRabbitMQ\u670d\u52a1\u5668\u7684\u8fde\u63a5\nconnection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))\nchannel = connection.channel()\n\n# \u58f0\u660e\u4ea4\u6362\u5668\nexchange_name = 'my_direct_exchange'\nexchange_type = 'direct'\nchannel.exchange_declare(exchange=exchange_name, exchange_type=exchange_type)\n\n# \u58f0\u660e\u961f\u5217\nqueue_name = 'my_queue'\nchannel.queue_declare(queue=queue_name, durable=True)\n\n# \u521b\u5efa\u7ed1\u5b9a\nrouting_key = 'my_routing_key'\nchannel.queue_bind(exchange=exchange_name, queue=queue_name, routing_key=routing_key)\n\n# \u53d1\u9001\u6d88\u606f\nmessage = 'Hello, RabbitMQ!'\nchannel.basic_publish(exchange=exchange_name, routing_key=routing_key, body=message,\n properties=pika.BasicProperties(delivery_mode=2)) # delivery_mode=2 \u8868\u793a\u6d88\u606f\u6301\u4e45\u5316\n\nprint(\"Sent message: {}\".format(message))\n\n# \u5173\u95ed\u8fde\u63a5\nconnection.close()\n<\/code><\/pre>\n\n\n\nbasic_publish<\/code>\u65b9\u6cd5\u53d1\u9001\u4e00\u6761\u6d88\u606f\uff0c\u6307\u5b9a\u4ea4\u6362\u5668\u3001\u8def\u7531\u952e\u548c\u6d88\u606f\u5185\u5bb9\u3002\u4e3a\u4e86\u4f7f\u6d88\u606f\u6301\u4e45\u5316\uff0c\u6211\u4eec\u8bbe\u7f6edelivery_mode=2<\/code>\u3002<\/p>\n\n\n\nproducer.py<\/code>\u7684\u6587\u4ef6\u4e2d\uff0c\u5e76\u5728\u547d\u4ee4\u884c\u4e2d\u8fd0\u884c\u4ee5\u4e0b\u547d\u4ee4\uff1a<\/p>\n\n\n\nbashCopy code
python producer.py\n<\/code><\/pre>\n\n\n\nbashCopy code
pip install pika\n<\/code><\/pre>\n\n\n\npythonCopy code
import pika\n\ndef callback(ch, method, properties, body):\n print(\"Received message: {}\".format(body.decode()))\n ch.basic_ack(delivery_tag=method.delivery_tag) # \u786e\u8ba4\u6d88\u606f\u5df2\u5904\u7406\n\n# \u5efa\u7acb\u4e0eRabbitMQ\u670d\u52a1\u5668\u7684\u8fde\u63a5\nconnection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))\nchannel = connection.channel()\n\n# \u58f0\u660e\u961f\u5217\nqueue_name = 'my_queue'\nchannel.queue_declare(queue=queue_name, durable=True)\n\n# \u8bbe\u7f6e\u8d28\u91cf\u63a7\u5236\nchannel.basic_qos(prefetch_count=1)\n\n# \u5f00\u59cb\u63a5\u6536\u6d88\u606f\nchannel.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=False)\n\nprint('Waiting for messages. To exit press CTRL+C')\nchannel.start_consuming()\n<\/code><\/pre>\n\n\n\ncallback<\/code>\u7684\u56de\u8c03\u51fd\u6570\uff0c\u7528\u4e8e\u5904\u7406\u6536\u5230\u7684\u6d88\u606f\u3002\u5f53\u63a5\u6536\u5230\u6d88\u606f\u65f6\uff0c\u6211\u4eec\u5c06\u6253\u5370\u6d88\u606f\u5185\u5bb9\uff0c\u5e76\u5411RabbitMQ\u53d1\u9001\u786e\u8ba4\uff0c\u8868\u660e\u6d88\u606f\u5df2\u6210\u529f\u5904\u7406\u3002<\/p>\n\n\n\nprefetch_count=1<\/code>\uff0c\u8868\u793a\u5728\u6d88\u8d39\u8005\u6ca1\u6709\u786e\u8ba4\u5f53\u524d\u6d88\u606f\u4e4b\u524d\uff0c\u4e0d\u4f1a\u63a5\u6536\u65b0\u7684\u6d88\u606f\u3002<\/p>\n\n\n\nbasic_consume<\/code>\u65b9\u6cd5\u6ce8\u518c\u56de\u8c03\u51fd\u6570\uff0c\u5e76\u542f\u52a8\u6d88\u606f\u63a5\u6536\u5faa\u73af\u3002\u6d88\u8d39\u8005\u7a0b\u5e8f\u5c06\u6301\u7eed\u8fd0\u884c\uff0c\u7b49\u5f85\u65b0\u6d88\u606f\u7684\u5230\u6765\u3002<\/p>\n\n\n\nconsumer.py<\/code>\u7684\u6587\u4ef6\u4e2d\uff0c\u5e76\u5728\u547d\u4ee4\u884c\u4e2d\u8fd0\u884c\u4ee5\u4e0b\u547d\u4ee4\uff1a<\/p>\n\n\n\nbashCopy code
python consumer.py\n<\/code><\/pre>\n\n\n\n\n
pythonCopy code
channel.basic_publish(exchange=exchange_name, routing_key=routing_key, body=message,\n properties=pika.BasicProperties(delivery_mode=2)) # delivery_mode=2 \u8868\u793a\u6d88\u606f\u6301\u4e45\u5316\n<\/code><\/pre>\n\n\n\ndelivery_mode<\/code>\u8bbe\u7f6e\u4e3a2\uff0c\u8868\u793a\u6d88\u606f\u6301\u4e45\u5316\u3002\u8fd9\u6837\uff0c\u5373\u4f7fRabbitMQ\u670d\u52a1\u5668\u91cd\u542f\uff0c\u6d88\u606f\u4e5f\u4f1a\u4fdd\u7559\u5728\u961f\u5217\u4e2d\uff0c\u7b49\u5f85\u88ab\u6d88\u8d39\u3002<\/p>\n\n\n\n\n
pythonCopy code
def callback(ch, method, properties, body):\n print(\"Received message: {}\".format(body.decode()))\n ch.basic_ack(delivery_tag=method.delivery_tag) # \u786e\u8ba4\u6d88\u606f\u5df2\u5904\u7406\n<\/code><\/pre>\n\n\n\nbasic_ack<\/code>\u65b9\u6cd5\u53d1\u9001\u786e\u8ba4\uff0c\u4f20\u9012delivery_tag<\/code>\u53c2\u6570\u3002delivery_tag<\/code>\u662f\u4e00\u4e2a\u9012\u589e\u7684\u6574\u6570\uff0c\u7528\u4e8e\u552f\u4e00\u6807\u8bc6\u6d88\u606f\u3002\u53ea\u6709\u5728\u6536\u5230\u786e\u8ba4\u540e\uff0cRabbitMQ\u624d\u4f1a\u4ece\u961f\u5217\u4e2d\u5220\u9664\u8be5\u6d88\u606f\u3002\u5982\u679c\u6d88\u8d39\u8005\u5728\u5904\u7406\u6d88\u606f\u65f6\u51fa\u73b0\u5f02\u5e38\uff0c\u53ef\u4ee5\u9009\u62e9\u4e0d\u53d1\u9001\u786e\u8ba4\uff0c\u8fd9\u6837\u6d88\u606f\u4f1a\u4fdd\u7559\u5728\u961f\u5217\u4e2d\uff0c\u7b49\u5f85\u5176\u4ed6\u6d88\u8d39\u8005\u91cd\u65b0\u5904\u7406\u3002<\/p>\n\n\n\nauto_ack=False<\/code>\uff1a<\/p>\n\n\n\npythonCopy code
channel.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=False)\n<\/code><\/pre>\n\n\n\nauto_ack<\/code>\u8bbe\u7f6e\u4e3aTrue\uff08\u9ed8\u8ba4\u503c\uff09\uff0cRabbitMQ\u5c06\u5728\u5c06\u6d88\u606f\u53d1\u9001\u7ed9\u6d88\u8d39\u8005\u540e\u7acb\u5373\u5220\u9664\u5b83\uff0c\u800c\u4e0d\u7b49\u5f85\u786e\u8ba4\u3002\u8fd9\u53ef\u80fd\u5bfc\u81f4\u5728\u6d88\u8d39\u8005\u5904\u7406\u6d88\u606f\u65f6\u51fa\u73b0\u9519\u8bef\u7684\u60c5\u51b5\u4e0b\uff0c\u6d88\u606f\u4e22\u5931\u3002<\/p>\n\n\n\n\n
x-max-priority<\/code>\u53c2\u6570\u3002\u8fd9\u5c06\u544a\u8bc9RabbitMQ\u8be5\u961f\u5217\u652f\u6301\u7684\u6700\u5927\u4f18\u5148\u7ea7\u3002<\/li>\n<\/ol>\n\n\n\npythonCopy code
queue_name = 'priority_queue'\nchannel.queue_declare(queue=queue_name, durable=True, arguments={'x-max-priority': 10})\n<\/code><\/pre>\n\n\n\n\n
pika.BasicProperties<\/code>\u8bbe\u7f6e\u6d88\u606f\u7684priority<\/code>\u5c5e\u6027\u3002<\/li>\n<\/ol>\n\n\n\npythonCopy code
message_priority = 5 # \u8bbe\u7f6e\u4f18\u5148\u7ea7\u4e3a5\uff0c\u53ef\u4ee5\u6839\u636e\u5b9e\u9645\u9700\u6c42\u81ea\u884c\u8c03\u6574\nchannel.basic_publish(exchange=exchange_name, routing_key=routing_key, body=message,\n properties=pika.BasicProperties(priority=message_priority, delivery_mode=2))\n<\/code><\/pre>\n\n\n\n\n
auto_ack=False<\/code>\u5e76\u5728\u5904\u7406\u6d88\u606f\u540e\u53d1\u9001\u786e\u8ba4\u3002\u8fd9\u5c06\u786e\u4fddRabbitMQ\u6309\u7167\u4f18\u5148\u7ea7\u987a\u5e8f\u5206\u53d1\u6d88\u606f\u3002<\/li>\n<\/ol>\n\n\n\npythonCopy code
channel.basic_consume(queue=queue_name, on_message_callback=callback, auto_ack=False)\n<\/code><\/pre>\n\n\n\n\n
pythonCopy code
dead_letter_exchange_name = 'dead_letter_exchange'\ndead_letter_exchange_type = 'direct'\ndead_letter_queue_name = 'dead_letter_queue'\nrouting_key = 'dead_letter_routing_key'\n\nchannel.exchange_declare(exchange=dead_letter_exchange_name, exchange_type=dead_letter_exchange_type)\nchannel.queue_declare(queue=dead_letter_queue_name, durable=True)\nchannel.queue_bind(exchange=dead_letter_exchange_name, queue=dead_letter_queue_name, routing_key=routing_key)\n<\/code><\/pre>\n\n\n\ndead_letter_exchange<\/code>\u7684\u76f4\u63a5\u4ea4\u6362\u5668\uff0c\u4ee5\u53ca\u4e00\u4e2a\u540d\u4e3adead_letter_queue<\/code>\u7684\u6301\u4e45\u5316\u961f\u5217\u3002\u6211\u4eec\u4f7f\u7528dead_letter_routing_key<\/code>\u5c06\u961f\u5217\u7ed1\u5b9a\u5230\u4ea4\u6362\u5668\u3002<\/p>\n\n\n\n\n
x-dead-letter-exchange<\/code>\u548cx-dead-letter-routing-key<\/code>\u53c2\u6570\u3002\u8fd9\u5c06\u544a\u8bc9RabbitMQ\uff0c\u5f53\u6d88\u606f\u65e0\u6cd5\u6b63\u5e38\u5904\u7406\u65f6\uff0c\u5e94\u5c06\u5176\u53d1\u9001\u5230\u6307\u5b9a\u7684\u6b7b\u4fe1\u4ea4\u6362\u5668\u548c\u961f\u5217\u3002<\/li>\n<\/ol>\n\n\n\npythonCopy code
main_queue_name = 'main_queue'\nchannel.queue_declare(queue=main_queue_name, durable=True, arguments={\n 'x-dead-letter-exchange': dead_letter_exchange_name,\n 'x-dead-letter-routing-key': routing_key\n})\n<\/code><\/pre>\n\n\n\ndead_letter_exchange<\/code>\uff0c\u6b7b\u4fe1\u8def\u7531\u952e\u8bbe\u7f6e\u4e3adead_letter_routing_key<\/code>\u3002<\/p>\n\n\n\n\n
basic_nack<\/code>\u65b9\u6cd5\u62d2\u7edd\u6d88\u606f\uff0c\u5e76\u5c06\u5176\u53d1\u9001\u5230\u6b7b\u4fe1\u961f\u5217\u3002<\/li>\n<\/ol>\n\n\n\npythonCopy code
def callback(ch, method, properties, body):\n try:\n # \u5904\u7406\u6d88\u606f\u7684\u903b\u8f91\n print(\"Received message: {}\".format(body.decode()))\n # \u6a21\u62df\u4e00\u4e2a\u9519\u8bef\n raise ValueError(\"An error occurred while processing the message\")\n ch.basic_ack(delivery_tag=method.delivery_tag) # \u786e\u8ba4\u6d88\u606f\u5df2\u5904\u7406\n except Exception as e:\n print(\"Error: {}\".format(e))\n ch.basic_nack(delivery_tag=method.delivery_tag, requeue=False) # \u62d2\u7edd\u6d88\u606f\uff0c\u4e0d\u91cd\u65b0\u5165\u961f\n<\/code><\/pre>\n\n\n\nbasic_nack<\/code>\u65b9\u6cd5\u62d2\u7edd\u6d88\u606f\uff0c\u5e76\u8bbe\u7f6erequeue=False<\/code>\uff0c\u4ee5\u9632\u6b62\u6d88\u606f\u91cd\u65b0\u8fdb\u5165\u4e3b\u961f\u5217\u3002\u7531\u4e8e\u6211\u4eec\u5df2\u7ecf\u4e3a\u4e3b\u961f\u5217\u914d\u7f6e\u4e86\u6b7b\u4fe1\u4ea4\u6362\u5668\u548c\u8def\u7531\u952e\uff0cRabbitMQ\u5c06\u81ea\u52a8\u5c06\u8fd9\u4e2a\u88ab\u62d2\u7edd\u7684\u6d88\u606f\u53d1\u9001\u5230\u6b7b\u4fe1\u961f\u5217\u3002<\/p>\n\n\n\n\n
\n
pythonCopy code
def dead_letter_callback(ch, method, properties, body):\n print(\"Received dead-lettered message: {}\".format(body.decode()))\n # \u5728\u8fd9\u91cc\uff0c\u60a8\u53ef\u4ee5\u5bf9\u6b7b\u4fe1\u6d88\u606f\u6267\u884c\u4efb\u4f55\u8bca\u65ad\u6216\u4fee\u590d\u64cd\u4f5c\uff0c\u4f8b\u5982\u5c06\u6d88\u606f\u4fe1\u606f\u8bb0\u5f55\u5230\u65e5\u5fd7\u6216\u6570\u636e\u5e93\u4e2d\n ch.basic_ack(delivery_tag=method.delivery_tag) # \u786e\u8ba4\u6b7b\u4fe1\u6d88\u606f\u5df2\u5904\u7406\n\n# \u5efa\u7acb\u4e0eRabbitMQ\u670d\u52a1\u5668\u7684\u8fde\u63a5\nconnection = pika.BlockingConnection(pika.ConnectionParameters('localhost'))\nchannel = connection.channel()\n\n# \u8bbe\u7f6e\u8d28\u91cf\u63a7\u5236\nchannel.basic_qos(prefetch_count=1)\n\n# \u5f00\u59cb\u63a5\u6536\u6b7b\u4fe1\u961f\u5217\u4e2d\u7684\u6d88\u606f\nchannel.basic_consume(queue=dead_letter_queue_name, on_message_callback=dead_letter_callback, auto_ack=False)\n\nprint('Waiting for dead-lettered messages. To exit press CTRL+C')\nchannel.start_consuming()\n<\/code><\/pre>\n\n\n\ndead_letter_callback<\/code>\u7684\u56de\u8c03\u51fd\u6570\uff0c\u7528\u4e8e\u5904\u7406\u6b7b\u4fe1\u961f\u5217\u4e2d\u7684\u6d88\u606f\u3002\u5f53\u63a5\u6536\u5230\u6b7b\u4fe1\u6d88\u606f\u65f6\uff0c\u6211\u4eec\u5c06\u6253\u5370\u6d88\u606f\u5185\u5bb9\uff0c\u5e76\u6267\u884c\u4efb\u4f55\u6240\u9700\u7684\u8bca\u65ad\u6216\u4fee\u590d\u64cd\u4f5c\u3002\u5728\u5904\u7406\u6b7b\u4fe1\u6d88\u606f\u540e\uff0c\u6211\u4eec\u5411RabbitMQ\u53d1\u9001\u786e\u8ba4\uff0c\u8868\u660e\u6d88\u606f\u5df2\u6210\u529f\u5904\u7406\u3002<\/p>\n\n\n\n\n
pythonCopy code
exchange_name = 'direct_exchange'\nexchange_type = 'direct'\nrouting_key = 'info' # \u53ef\u4ee5\u662f\u4efb\u610f\u5b57\u7b26\u4e32\uff0c\u4f8b\u5982\uff1a'info', 'warning', 'error' \u7b49\n\n# \u58f0\u660e\u4ea4\u6362\u5668\nchannel.exchange_declare(exchange=exchange_name, exchange_type=exchange_type)\n\n# \u5c06\u961f\u5217\u7ed1\u5b9a\u5230\u4ea4\u6362\u5668\u5e76\u6307\u5b9a\u8def\u7531\u952e\nchannel.queue_bind(exchange=exchange_name, queue=queue_name, routing_key=routing_key)\n<\/code><\/pre>\n\n\n\n\n
pythonCopy code
exchange_name = 'fanout_exchange'\nexchange_type = 'fanout'\n\n# \u58f0\u660e\u4ea4\u6362\u5668\nchannel.exchange_declare(exchange=exchange_name, exchange_type=exchange_type)\n\n# \u5c06\u961f\u5217\u7ed1\u5b9a\u5230\u4ea4\u6362\u5668\uff08\u8def\u7531\u952e\u5728\u6247\u5f62\u4ea4\u6362\u5668\u4e2d\u4f1a\u88ab\u5ffd\u7565\uff09\nchannel.queue_bind(exchange=exchange_name, queue=queue_name)\n<\/code><\/pre>\n\n\n\n\n
pythonCopy code
exchange_name = 'topic_exchange'\nexchange_type = 'topic'\nbinding_key = '*.info' # \u53ef\u4ee5\u5305\u542b\u901a\u914d\u7b26\uff0c\u4f8b\u5982\uff1a'*.info', 'system.*', 'system.warning' \u7b49\n\n# \u58f0\u660e\u4ea4\u6362\u5668\nchannel.exchange_declare(exchange=exchange_name, exchange_type=exchange_type)\n\n# \u5c06\u961f\u5217\u7ed1\u5b9a\u5230\u4ea4\u6362\u5668\u5e76\u6307\u5b9a\u7ed1\u5b9a\u952e\nchannel.queue_bind(exchange=exchange_name, queue=queue_name, routing_key=binding_key)\n<\/code><\/pre>\n\n\n\n\n
\n
pythonCopy code
exchange_name = 'headers_exchange'\nexchange_type = 'headers'\nheaders = {'x-match': 'all', 'header1': 'value1', 'header2': 'value2'}\n\n# \u58f0\u660e\u4ea4\u6362\u5668\nchannel.exchange_declare(exchange=exchange_name, exchange_type=exchange_type\n<\/code><\/pre>\n\n\n\n\n\narduinoCopy code