{"id":2061,"date":"2021-11-26T11:17:44","date_gmt":"2021-11-26T03:17:44","guid":{"rendered":"https:\/\/199604.com\/?p=2061"},"modified":"2021-11-26T11:17:44","modified_gmt":"2021-11-26T03:17:44","slug":"rabbitmq%e5%ad%a6%e4%b9%a0%e6%9c%ad%e8%ae%b0","status":"publish","type":"post","link":"https:\/\/199604.com\/2061","title":{"rendered":"RabbitMQ\u5b66\u4e60\u672d\u8bb0"},"content":{"rendered":"<h1>RabbitMQ\u5b66\u4e60\u672d\u8bb0<\/h1>\n<h2>1.MQ\u6982\u8ff0<\/h2>\n<p>MQ\u5168\u79f0 Message Queue\uff08\u6d88\u606f\u961f\u5217\uff09\uff0c\u662f\u5728\u6d88\u606f\u7684\u4f20\u8f93\u8fc7\u7a0b\u4e2d\u4fdd\u5b58\u6d88\u606f\u7684\u5bb9\u5668\u3002\u591a\u7528\u4e8e\u5206\u5e03\u5f0f\u7cfb\u7edf\u4e4b\u95f4\u8fdb\u884c\u901a\u4fe1\u3002<\/p>\n<h2><strong>2.MQ<\/strong> <strong>\u7684\u4f18\u52bf\u548c\u52a3\u52bf<\/strong><\/h2>\n<p><strong>\u4f18\u52bf\uff1a<\/strong><\/p>\n<ol>\n<li>\u5e94\u7528\u89e3\u8026\uff1a\u63d0\u9ad8\u7cfb\u7edf\u5bb9\u9519\u6027\u548c\u53ef\u7ef4\u62a4\u6027<\/li>\n<li>\u5f02\u6b65\u63d0\u901f\uff1a\u63d0\u5347\u7528\u6237\u4f53\u9a8c\u548c\u7cfb\u7edf\u541e\u5410\u91cf<\/li>\n<li>\u524a\u5cf0\u586b\u8c37\uff1a\u63d0\u9ad8\u7cfb\u7edf\u7a33\u5b9a\u6027<\/li>\n<\/ol>\n<p>\u5982\u8ba2\u5355\u7cfb\u7edf\uff0c\u5728\u4e0b\u5355\u7684\u65f6\u5019\u5c31\u4f1a\u5f80\u6570\u636e\u5e93\u5199\u6570\u636e\u3002\u4f46\u662f\u6570\u636e\u5e93\u53ea\u80fd\u652f\u6491\u6bcf\u79d21000\u5de6\u53f3\u7684\u5e76\u53d1\u5199\u5165\uff0c\u5e76\u53d1\u91cf\u518d\u9ad8\u5c31\u5bb9\u6613\u5b95\u673a\u3002\u4f4e\u5cf0\u671f\u7684\u65f6\u5019\u5e76\u53d1\u4e5f\u5c31100\u591a\u4e2a\uff0c\u4f46\u662f\u5728\u9ad8\u5cf0\u671f\u65f6\u5019\uff0c\u5e76\u53d1\u91cf\u4f1a\u7a81\u7136\u6fc0\u589e\u52305000\u4ee5\u4e0a\uff0c\u8fd9\u4e2a\u65f6\u5019\u6570\u636e\u5e93\u80af\u5b9a\u5361\u6b7b\u4e86\u3002<\/p>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/01.jpg'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/01.jpg\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"\" \/><\/div><\/p>\n<p>\u6d88\u606f\u88abMQ\u4fdd\u5b58\u8d77\u6765\u4e86\uff0c\u7136\u540e\u7cfb\u7edf\u5c31\u53ef\u4ee5\u6309\u7167\u81ea\u5df1\u7684\u6d88\u8d39\u80fd\u529b\u6765\u6d88\u8d39\uff0c\u6bd4\u5982\u6bcf\u79d21000\u4e2a\u6570\u636e\uff0c\u8fd9\u6837\u6162\u6162\u5199\u5165\u6570\u636e\u5e93\uff0c\u8fd9\u6837\u5c31\u4e0d\u4f1a\u5361\u6b7b\u6570\u636e\u5e93\u4e86\u3002<\/p>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/02.jpg'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/02.jpg\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"\" \/><\/div><\/p>\n<p>\u4f46\u662f\u4f7f\u7528\u4e86MQ\u4e4b\u540e\uff0c\u9650\u5236\u6d88\u8d39\u6d88\u606f\u7684\u901f\u5ea6\u4e3a1000\uff0c\u4f46\u662f\u8fd9\u6837\u4e00\u6765\uff0c\u9ad8\u5cf0\u671f\u4ea7\u751f\u7684\u6570\u636e\u52bf\u5fc5\u4f1a\u88ab\u79ef\u538b\u5728MQ\u4e2d\uff0c\u9ad8\u5cf0\u5c31\u88ab\u201c\u524a\u201d\u6389\u4e86\u3002\u4f46\u662f\u56e0\u4e3a\u6d88\u606f\u79ef\u538b\uff0c\u5728\u9ad8\u5cf0\u671f\u8fc7\u540e\u7684\u4e00\u6bb5\u65f6\u95f4\u5185\uff0c\u6d88\u8d39\u6d88\u606f\u7684\u901f\u5ea6\u8fd8\u662f\u4f1a\u7ef4\u6301\u57281000QPS\uff0c\u76f4\u5230\u6d88\u8d39\u5b8c\u79ef\u538b\u7684\u6d88\u606f,\u8fd9\u5c31\u53eb\u505a\u201c\u586b\u8c37\u201d<\/p>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/03.jpg'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/03.jpg\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"03\" \/><\/div><\/p>\n<p><strong>\u52a3\u52bf\uff1a<\/strong><\/p>\n<ol>\n<li>\u7cfb\u7edf\u53ef\u7528\u6027\u964d\u4f4e<\/li>\n<li>\u7cfb\u7edf\u590d\u6742\u5ea6\u63d0\u9ad8<\/li>\n<li>\u4e00\u81f4\u6027\u95ee\u9898<\/li>\n<\/ol>\n<h2>3.AMQP \u548c JMS<\/h2>\n<p>MQ\u662f\u6d88\u606f\u901a\u4fe1\u7684\u6a21\u578b\uff1b\u5b9e\u73b0MQ\u7684\u5927\u81f4\u6709\u4e24\u79cd\u4e3b\u6d41\u65b9\u5f0f\uff1aAMQP\u3001JMS\u3002<\/p>\n<h3>3.1. AMQP<\/h3>\n<p>AMQP\u662f\u4e00\u79cd\u534f\u8bae\uff0c\u66f4\u51c6\u786e\u7684\u8bf4\u662f\u4e00\u79cdbinary wire-level protocol\uff08\u94fe\u63a5\u534f\u8bae\uff09\u3002\u8fd9\u662f\u5176\u548cJMS\u7684\u672c\u8d28\u5dee\u522b\uff0cAMQP\u4e0d\u4eceAPI\u5c42\u8fdb\u884c\u9650\u5b9a\uff0c\u800c\u662f\u76f4\u63a5\u5b9a\u4e49\u7f51\u7edc\u4ea4\u6362\u7684\u6570\u636e\u683c\u5f0f\u3002<\/p>\n<h3>3.2. JMS<\/h3>\n<p>JMS\u5373Java\u6d88\u606f\u670d\u52a1\uff08JavaMessage Service\uff09\u5e94\u7528\u7a0b\u5e8f\u63a5\u53e3\uff0c\u662f\u4e00\u4e2aJava\u5e73\u53f0\u4e2d\u5173\u4e8e\u9762\u5411\u6d88\u606f\u4e2d\u95f4\u4ef6\uff08MOM\uff09\u7684API\uff0c\u7528\u4e8e\u5728\u4e24\u4e2a\u5e94\u7528\u7a0b\u5e8f\u4e4b\u95f4\uff0c\u6216\u5206\u5e03\u5f0f\u7cfb\u7edf\u4e2d\u53d1\u9001\u6d88\u606f\uff0c\u8fdb\u884c\u5f02\u6b65\u901a\u4fe1\u3002<\/p>\n<h3>3.3. AMQP \u4e0e JMS \u533a\u522b<\/h3>\n<ul>\n<li>JMS\u662f\u5b9a\u4e49\u4e86\u7edf\u4e00\u7684\u63a5\u53e3\uff0c\u6765\u5bf9\u6d88\u606f\u64cd\u4f5c\u8fdb\u884c\u7edf\u4e00\uff1bAMQP\u662f\u901a\u8fc7\u89c4\u5b9a\u534f\u8bae\u6765\u7edf\u4e00\u6570\u636e\u4ea4\u4e92\u7684\u683c\u5f0f<\/li>\n<li>JMS\u9650\u5b9a\u4e86\u5fc5\u987b\u4f7f\u7528Java\u8bed\u8a00\uff1bAMQP\u53ea\u662f\u534f\u8bae\uff0c\u4e0d\u89c4\u5b9a\u5b9e\u73b0\u65b9\u5f0f\uff0c\u56e0\u6b64\u662f\u8de8\u8bed\u8a00\u7684\u3002<\/li>\n<li>JMS\u89c4\u5b9a\u4e86\u4e24\u79cd\u6d88\u606f\u6a21\u5f0f\uff1b\u800cAMQP\u7684\u6d88\u606f\u6a21\u5f0f\u66f4\u52a0\u4e30\u5bcc<\/li>\n<\/ul>\n<h2>4.<strong>\u5e38\u89c1\u7684<\/strong> <strong>MQ<\/strong> <strong>\u4ea7\u54c1<\/strong><\/h2>\n<p>\u76ee\u524d\u4e1a\u754c\u6709\u5f88\u591a\u7684 MQ \u4ea7\u54c1\uff0c\u4f8b\u5982 RabbitMQ\u3001RocketMQ\u3001ActiveMQ\u3001Kafka\u3001ZeroMQ\u3001MetaMq\u7b49\uff0c\u4e5f\u6709\u76f4\u63a5\u4f7f\u7528 Redis \u5145\u5f53\u6d88\u606f\u961f\u5217\u7684\u6848\u4f8b\u3002<\/p>\n<p>\u5e02\u573a\u4e0a\u5e38\u89c1\u7684\u6d88\u606f\u961f\u5217\u6709\u5982\u4e0b\uff1a<\/p>\n<ul>\n<li>ActiveMQ\uff1a\u57fa\u4e8eJMS<\/li>\n<li>RabbitMQ\uff1a\u57fa\u4e8eAMQP\u534f\u8bae\uff0cerlang\u8bed\u8a00\u5f00\u53d1\uff0c\u7a33\u5b9a\u6027\u597d<\/li>\n<li>RocketMQ\uff1a\u57fa\u4e8eJMS\uff0c\u963f\u91cc\u5df4\u5df4\u4ea7\u54c1<\/li>\n<li>Kafka\uff1a\u7c7b\u4f3cMQ\u7684\u4ea7\u54c1\uff1b\u5206\u5e03\u5f0f\u6d88\u606f\u7cfb\u7edf\uff0c\u9ad8\u541e\u5410\u91cf<\/li>\n<\/ul>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/image-20210616235052803.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/image-20210616235052803.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"image-20210616235052803\" \/><\/div><\/p>\n<h2>5.RabbitMQ \u7b80\u4ecb<\/h2>\n<p>RabbitMQ\u662f\u7531erlang\u8bed\u8a00\u5f00\u53d1\uff0c\u57fa\u4e8eAMQP\uff08Advanced Message Queue \u9ad8\u7ea7\u6d88\u606f\u961f\u5217\u534f\u8bae\uff09\u534f\u8bae\u5b9e\u73b0\u7684\u6d88\u606f\u961f\u5217\uff0c\u5b83\u662f\u4e00\u79cd\u5e94\u7528\u7a0b\u5e8f\u4e4b\u95f4\u7684\u901a\u4fe1\u65b9\u6cd5\uff0c\u6d88\u606f\u961f\u5217\u5728\u5206\u5e03\u5f0f\u7cfb\u7edf\u5f00\u53d1\u4e2d\u5e94\u7528\u975e\u5e38\u5e7f\u6cdb\u3002<\/p>\n<p>RabbitMQ\u5b98\u65b9\u5730\u5740\uff1ahttp:\/\/www.rabbitmq.com\/<\/p>\n<p>RabbitMQ\u63d0\u4f9b\u4e866\u79cd\u6a21\u5f0f\uff1a\u7b80\u5355\u6a21\u5f0f\uff0cwork\u6a21\u5f0f\uff0cPublish\/Subscribe\u53d1\u5e03\u4e0e\u8ba2\u9605\u6a21\u5f0f\uff0cRouting\u8def\u7531\u6a21\u5f0f\uff0cTopics\u4e3b\u9898\u6a21\u5f0f\uff0cRPC\u8fdc\u7a0b\u8c03\u7528\u6a21\u5f0f<del>\uff08\u8fdc\u7a0b\u8c03\u7528\uff0c\u4e0d\u592a\u7b97MQ\uff1b\u6682\u4e0d\u4f5c\u4ecb\u7ecd<\/del>\uff09\uff1b<\/p>\n<p>\u5b98\u7f51\u5bf9\u5e94\u6a21\u5f0f\u4ecb\u7ecd\uff1ahttps:\/\/www.rabbitmq.com\/getstarted.html<\/p>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/1555988678324.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/1555988678324.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"1555988678324\" \/><\/div><\/p>\n<h2>6.\u5b89\u88c5\u53ca\u914d\u7f6eRabbitMQ<\/h2>\n<h3>6.1 \u5b89\u88c5\u4f9d\u8d56\u73af\u5883<\/h3>\n<p>\u5b89\u88c5\u4f9d\u8d56\u73af\u5883\uff1a<\/p>\n<pre><code class=\"language-shell \">yum install build-essential openssl openssl-devel unixODBC unixODBC-devel make gcc gcc-c++ kernel-devel m4 ncurses-devel tk tc xz\n<\/code><\/pre>\n<p>\u6839\u636e\u5b98\u65b9\u5efa\u8bae\u8981\u5148\u5b89\u88c5\uff1a<\/p>\n<p><code>yum install socat<\/code><\/p>\n<p><code>yum install logrotate<\/code><\/p>\n<p>\u518d\u5b89\u88c5erlang<\/p>\n<p>\u4e0b\u8f7d\uff1ahttps:\/\/packages.erlang-solutions.com\/erlang\/rpm\/centos\/7\/x86_64\/esl-erlang_22.3.2-1~centos~7_amd64.rpm<\/p>\n<p>\u5b89\u88c5\uff1a<code>rpm -Uvh esl-erlang_22.3.2-1_centos_7_amd64.rpm --force --nodeps<\/code><\/p>\n<p>\u6700\u540e\u5b89\u88c5rabbitmq<\/p>\n<p>\u8fd9\u4e2a\u9875\u9762\u662frabbitmq\u5bf9\u5e94\u7684erlang\u7248\u672c\u67e5\u8be2\u7f51\u7ad9\uff1ahttps:\/\/www.rabbitmq.com\/which-erlang.html<\/p>\n<p>\u4e0b\u8f7d\uff1ahttps:\/\/github.com\/rabbitmq\/rabbitmq-server\/releases\/download\/v3.8.3\/rabbitmq-server-3.8.3-1.el7.noarch.rpm<\/p>\n<p>\u5b89\u88c5\uff1a<code>rpm -ivh rabbitmq-server-3.8.3-1.el7.noarch.rpm<\/code><\/p>\n<p>\u5b89\u88c5\u8def\u5f84\u9ed8\u8ba4\u5728\uff1a<\/p>\n<p><code>\/usr\/lib\/rabbitmq\/lib\/rabbitmq_server-3.8.3\/ebin<\/code><\/p>\n<h3>6.2\u5f00\u542f\u7ba1\u7406\u754c\u9762\u53ca\u914d\u7f6e<\/h3>\n<pre><code class=\"language-shell \"># \u5f00\u542frabbitmq management\u53ca\u8fdc\u7a0b\u767b\u5f55\nrabbitmq-plugins enable rabbitmq_management\n\n# \u8bbe\u7f6eguest\u8fdc\u7a0b\u8bbf\u95ee\uff1a\nvi \/usr\/lib\/rabbitmq\/lib\/rabbitmq_server-3.8.3\/ebin\/rabbit.app\n# loopback_users\u91cc\u7684&lt;&lt;\"guest\"&gt;&gt;\u5220\u9664\uff0c\u91cd\u542frabbitmq\u670d\u52a1\n# \u6bd4\u5982\u4fee\u6539\u5bc6\u7801\u3001\u914d\u7f6e\u7b49\u7b49\uff0c\u4f8b\u5982\uff1aloopback_users \u4e2d\u7684 &lt;&lt;\"guest\"&gt;&gt;,\u53ea\u4fdd\u7559guest\n<\/code><\/pre>\n<p>\u8981\u8bbf\u95eeRabbitMQ\u7684\u7ba1\u7406\u9762\u677f\uff0c\u8bf7\u4f7f\u7528\u60a8\u6700\u559c\u7231\u7684Web\u6d4f\u89c8\u5668\u5e76\u6253\u5f00\u4ee5\u4e0bURL\uff1a<\/p>\n<p>http:\/\/Your_Server_IP:15672\/<\/p>\n<h3>6.3 \u542f\u52a8\u505c\u6b62\u670d\u52a1<\/h3>\n<pre><code class=\"language-shell \">service rabbitmq-server start # \u542f\u52a8\u670d\u52a1\nservice rabbitmq-server stop # \u505c\u6b62\u670d\u52a1\nservice rabbitmq-server restart # \u91cd\u542f\u670d\u52a1\n<\/code><\/pre>\n<h3>6.4 \u8bbe\u7f6e\u914d\u7f6e\u6587\u4ef6<\/h3>\n<p>\u5982\u679c\u4e0d\u77e5\u9053\u914d\u7f6e\u6587\u4ef6\u5728\u54ea\uff0c\u53ef\u4ee5\u67e5\u627e\uff1a<\/p>\n<pre><code class=\"\">[root@wydsj-gpapp04 ~]# find \/ -name rabbitmq-defaults\n\/usr\/lib\/rabbitmq\/bin\/rabbitmq-defaults\n\/usr\/lib\/rabbitmq\/lib\/rabbitmq_server-3.8.3\/sbin\/rabbitmq-defaults\n<\/code><\/pre>\n<h3>6.5 \u914d\u7f6e\u865a\u62df\u4e3b\u673a\u53ca\u7528\u6237<\/h3>\n<h5><strong>\u89d2\u8272\u8bf4\u660e<\/strong>\uff1a<\/h5>\n<p>1\u3001 \u8d85\u7ea7\u7ba1\u7406\u5458(administrator)<\/p>\n<p>\u53ef\u767b\u9646\u7ba1\u7406\u63a7\u5236\u53f0\uff0c\u53ef\u67e5\u770b\u6240\u6709\u7684\u4fe1\u606f\uff0c\u5e76\u4e14\u53ef\u4ee5\u5bf9\u7528\u6237\uff0c\u7b56\u7565(policy)\u8fdb\u884c\u64cd\u4f5c\u3002<\/p>\n<p>2\u3001 \u76d1\u63a7\u8005(monitoring)<\/p>\n<p>\u53ef\u767b\u9646\u7ba1\u7406\u63a7\u5236\u53f0\uff0c\u540c\u65f6\u53ef\u4ee5\u67e5\u770brabbitmq\u8282\u70b9\u7684\u76f8\u5173\u4fe1\u606f(\u8fdb\u7a0b\u6570\uff0c\u5185\u5b58\u4f7f\u7528\u60c5\u51b5\uff0c\u78c1\u76d8\u4f7f\u7528\u60c5\u51b5\u7b49)<\/p>\n<p>3\u3001 \u7b56\u7565\u5236\u5b9a\u8005(policymaker)<\/p>\n<p>\u53ef\u767b\u9646\u7ba1\u7406\u63a7\u5236\u53f0, \u540c\u65f6\u53ef\u4ee5\u5bf9policy\u8fdb\u884c\u7ba1\u7406\u3002\u4f46\u65e0\u6cd5\u67e5\u770b\u8282\u70b9\u7684\u76f8\u5173\u4fe1\u606f(\u4e0a\u56fe\u7ea2\u6846\u6807\u8bc6\u7684\u90e8\u5206)\u3002<\/p>\n<p>4\u3001 \u666e\u901a\u7ba1\u7406\u8005(management)<\/p>\n<p>\u4ec5\u53ef\u767b\u9646\u7ba1\u7406\u63a7\u5236\u53f0\uff0c\u65e0\u6cd5\u770b\u5230\u8282\u70b9\u4fe1\u606f\uff0c\u4e5f\u65e0\u6cd5\u5bf9\u7b56\u7565\u8fdb\u884c\u7ba1\u7406\u3002<\/p>\n<p>5\u3001 \u5176\u4ed6<\/p>\n<p>\u65e0\u6cd5\u767b\u9646\u7ba1\u7406\u63a7\u5236\u53f0\uff0c\u901a\u5e38\u5c31\u662f\u666e\u901a\u7684\u751f\u4ea7\u8005\u548c\u6d88\u8d39\u8005\u3002<\/p>\n<h5>\u914d\u7f6e\u6709\u4e24\u79cd\u65b9\u5f0f\uff1a<\/h5>\n<ol>\n<li>\u547d\u4ee4\u884c<\/li>\n<li>\u754c\u9762<\/li>\n<\/ol>\n<h4>6.5.1 \u547d\u4ee4\u884c\u65b9\u5f0f\uff1a<\/h4>\n<h5>\u521b\u5efa\u7528\u6237\uff1a<\/h5>\n<p>\u521b\u5efa\u7528\u6237\u540dhcxtadmin\uff0c\u5bc6\u7801hcxtadmin123 \u7684\u7528\u6237<\/p>\n<pre><code class=\"\">rabbitmqctl add_user hcxtadmin hcxtadmin123\n<\/code><\/pre>\n<h5>\u8bbe\u7f6e\u8d85\u7ea7\u7ba1\u7406\u5458<\/h5>\n<p>\u8bbe\u7f6ehcxtadmin\u4e3a\u8d85\u7ea7\u7ba1\u7406\u5458<\/p>\n<pre><code class=\"\">rabbitmqctl set_user_tags hcxtadmin administrator\n<\/code><\/pre>\n<h5>\u6388\u6743\u8fdc\u7a0b\u8bbf\u95ee\uff08\u4e5f\u53ef\u4ee5\u767b\u5f55\u540e\uff0c\u53ef\u89c6\u5316\u914d\u7f6e\uff09<\/h5>\n<pre><code class=\"\">rabbitmqctl set_permissions -p \/ hcxtadmin \".\" \".\" \".*\"\n<\/code><\/pre>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/image-20210617011801106.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/image-20210617011801106.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"image-20210617011801106\" \/><\/div><\/p>\n<h5>\u67e5\u770b\u7528\u6237\u5217\u8868\uff1a<\/h5>\n<pre><code class=\"\">#\u67e5\u770b\u7528\u6237\u5217\u8868\nrabbitmqctl  list_users\n<\/code><\/pre>\n<h5>\u4fee\u6539\u5bf9\u5e94\u7528\u6237\u5bc6\u7801<\/h5>\n<pre><code class=\"\">rabbitmqctl  change_password  username  'newpasswd'\n<\/code><\/pre>\n<h4>6.5.2 \u754c\u9762\u65b9\u5f0f\uff1a<\/h4>\n<h5>\u521b\u5efa\u7528\u6237\u5e76\u4e14\u8d85\u7ea7\u7ba1\u7406\u5458\uff1a<\/h5>\n<p>\u521b\u5efa\u7528\u6237\u540dhcxtuser\uff0c\u5bc6\u7801hcxtuser123!@#\u7684\u7528\u6237<\/p>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/image-20210617012715084.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/image-20210617012715084.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"image-20210617012715084\" \/><\/div><\/p>\n<h5>\u6388\u6743\u8fdc\u7a0b\u8bbf\u95ee:<\/h5>\n<p>\u70b9\u51fb\u7528\u6237\u540d\u79f0\u8fdb\u884c\u6388\u6743<\/p>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/image-20210617013004618.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/image-20210617013004618.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"image-20210617013004618\" \/><\/div><\/p>\n<h4>6.5.3.Virtual Hosts\u914d\u7f6e<\/h4>\n<p>\u50cfmysql\u62e5\u6709\u6570\u636e\u5e93\u7684\u6982\u5ff5\u5e76\u4e14\u53ef\u4ee5\u6307\u5b9a\u7528\u6237\u5bf9\u5e93\u548c\u8868\u7b49\u64cd\u4f5c\u7684\u6743\u9650\u3002RabbitMQ\u4e5f\u6709\u7c7b\u4f3c\u7684\u6743\u9650\u7ba1\u7406\uff1b\u5728RabbitMQ\u4e2d\u53ef\u4ee5\u865a\u62df\u6d88\u606f\u670d\u52a1\u5668Virtual Host\uff0c\u6bcf\u4e2aVirtual Hosts\u76f8\u5f53\u4e8e\u4e00\u4e2a\u76f8\u5bf9\u72ec\u7acb\u7684RabbitMQ\u670d\u52a1\u5668\uff0c\u6bcf\u4e2aVirtualHost\u4e4b\u95f4\u662f\u76f8\u4e92\u9694\u79bb\u7684\u3002exchange\u3001queue\u3001message\u4e0d\u80fd\u4e92\u901a\u3002 \u76f8\u5f53\u4e8emysql\u7684db\u3002Virtual Name\u4e00\u822c\u4ee5\/\u5f00\u5934\u3002<\/p>\n<h5>1-\u521b\u5efaVirtual Hosts<\/h5>\n<p>\u5982\u4e0b\u56fe\uff1a<\/p>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/image-20210617013347343.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/image-20210617013347343.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"image-20210617013347343\" \/><\/div><\/p>\n<h5>2-\u8bbe\u7f6eVirtual Hosts\u6743\u9650<\/h5>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/image-20210617013607062.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/image-20210617013607062.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"image-20210617013607062\" \/><\/div><\/p>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/image-20210617013804832.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/image-20210617013804832.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"image-20210617013804832\" \/><\/div><\/p>\n<h3>6.6.\u5e38\u7528\u914d\u7f6e\u8bf4\u660e\uff1a<\/h3>\n<pre><code class=\"\">tcp_listerners    #\u8bbe\u7f6erabbimq\u7684\u76d1\u542c\u7aef\u53e3\uff0c\u9ed8\u8ba4\u4e3a[5672]\u3002\ndisk_free_limit     #\u78c1\u76d8\u4f4e\u6c34\u4f4d\u7ebf\uff0c\u82e5\u78c1\u76d8\u5bb9\u91cf\u4f4e\u4e8e\u6307\u5b9a\u503c\u5219\u505c\u6b62\u63a5\u6536\u6570\u636e\uff0c\u9ed8\u8ba4\u503c\u4e3a{mem_relative, 1.0},\u5373\u4e0e\u5185\u5b58\u76f8\u5173\u80541\uff1a1\uff0c\u4e5f\u53ef\u5b9a\u5236\u4e3a\u591a\u5c11byte.\nvm_memory_high_watermark    #\u8bbe\u7f6e\u5185\u5b58\u4f4e\u6c34\u4f4d\u7ebf\uff0c\u82e5\u4f4e\u4e8e\u8be5\u6c34\u4f4d\u7ebf\uff0c\u5219\u5f00\u542f\u6d41\u63a7\u673a\u5236\uff0c\u9ed8\u8ba4\u503c\u662f0.4\uff0c\u5373\u5185\u5b58\u603b\u91cf\u768440%\u3002\nhipe_compile     #\u5c06\u90e8\u5206rabbimq\u4ee3\u7801\u7528High Performance Erlang compiler\u7f16\u8bd1\uff0c\u53ef\u63d0\u5347\u6027\u80fd\uff0c\u8be5\u53c2\u6570\u662f\u5b9e\u9a8c\u6027\uff0c\u82e5\u51fa\u73b0erlang vm segfaults\uff0c\u5e94\u5173\u6389\u3002\nforce_fine_statistics    #\u8be5\u53c2\u6570\u5c5e\u4e8erabbimq_management\uff0c\u82e5\u4e3atrue\u5219\u8fdb\u884c\u7cbe\u7ec6\u5316\u7684\u7edf\u8ba1\uff0c\u4f46\u4f1a\u5f71\u54cd\u6027\u80fd\u3002\nframe_max     #\u5305\u5927\u5c0f\uff0c\u82e5\u5305\u5c0f\u5219\u4f4e\u5ef6\u8fdf\uff0c\u82e5\u5305\u5219\u9ad8\u541e\u5410\uff0c\u9ed8\u8ba4\u662f131072=128K\u3002\nheartbeat     #\u5ba2\u6237\u7aef\u4e0e\u670d\u52a1\u7aef\u5fc3\u8df3\u95f4\u9694\uff0c\u8bbe\u7f6e\u4e3a0\u5219\u5173\u95ed\u5fc3\u8df3\uff0c\u9ed8\u8ba4\u662f60\u79d2\u3002\n<\/code><\/pre>\n<h2>7.RabbitMQ\u5165\u95e8<\/h2>\n<h3>7.1. \u642d\u5efa\u793a\u4f8b\u5de5\u7a0b<\/h3>\n<h4>7.1.1. \u521b\u5efa\u5de5\u7a0b<\/h4>\n<ul>\n<li>rabitmq-consumer \uff08\u6d88\u8d39\u8005\uff09<\/li>\n<li>rabitmq-producer \uff08\u751f\u4ea7\u8005\uff09<\/li>\n<\/ul>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/image-20210620201310189.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/image-20210620201310189.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"image-20210620201310189\" \/><\/div><\/p>\n<h4>7.1.2. \u6dfb\u52a0\u4f9d\u8d56<\/h4>\n<pre data-language=XML><code class=\"language-markup \">&lt;dependencies&gt;\n    &lt;dependency&gt;\n        &lt;groupId&gt;com.rabbitmq&lt;\/groupId&gt;\n        &lt;artifactId&gt;amqp-client&lt;\/artifactId&gt;\n        &lt;version&gt;5.6.0&lt;\/version&gt;\n    &lt;\/dependency&gt;\n&lt;\/dependencies&gt;\n\n\n&lt;build&gt;\n    &lt;plugins&gt;\n        &lt;plugin&gt;\n            &lt;groupId&gt;org.apache.maven.plugins&lt;\/groupId&gt;\n            &lt;artifactId&gt;maven-compiler-plugin&lt;\/artifactId&gt;\n            &lt;version&gt;3.8.0&lt;\/version&gt;\n            &lt;configuration&gt;\n                &lt;source&gt;1.8&lt;\/source&gt;\n                &lt;target&gt;1.8&lt;\/target&gt;\n            &lt;\/configuration&gt;\n        &lt;\/plugin&gt;\n    &lt;\/plugins&gt;\n&lt;\/build&gt;\n<\/code><\/pre>\n<h3>7.2. \u7f16\u5199\u751f\u4ea7\u8005<\/h3>\n<pre><code class=\"language-java \">package com.glj.rabitmq.simple;\n\nimport com.rabbitmq.client.Channel;\nimport com.rabbitmq.client.Connection;\nimport com.rabbitmq.client.ConnectionFactory;\n\n\/**\n * Created with IntelliJ IDEA.\n *\n * @Author: GuoLiangJun\n * @Date: 2021\/6\/20\n * @Time: 20:16\n *\/\npublic class Producer {\n\n    static final String QUEUE_NAME = \"simple_queue\";\n\n    public static void main(String[] args) {\n        \/\/ \u521b\u5efa\u8fde\u63a5\u5de5\u5382\n        ConnectionFactory connectionFactory = new ConnectionFactory();\n        \/\/ \u4e3b\u673a\u5730\u5740;\u9ed8\u8ba4\u4e3a localhost\u3001127.0.0.1\n        connectionFactory.setHost(\"127.0.0.1\");\n        \/\/ \u8fde\u63a5\u7aef\u53e3;\u9ed8\u8ba4\u4e3a 5672\n        connectionFactory.setPort(5672);\n        \/\/ \u865a\u62df\u4e3b\u673a\u540d\u79f0;\u9ed8\u8ba4\u4e3a \/\n        connectionFactory.setVirtualHost(\"\/hcxtuser\");\n        \/\/ \u8fde\u63a5\u7528\u6237\u540d\uff1b\u9ed8\u8ba4\u4e3aguest\n        connectionFactory.setUsername(\"hcxtuser\");\n        \/\/ \u8fde\u63a5\u5bc6\u7801\uff1b\u9ed8\u8ba4\u4e3aguest\n        connectionFactory.setPassword(\"hcxtuser123!@#\");\n\n        try(\n                \/\/ \u521b\u5efa\u8fde\u63a5\n                Connection connection = connectionFactory.newConnection();\n                \/\/ \u521b\u5efa\u9891\u9053\n                Channel channel = connection.createChannel()\n        ){\n            \/\/ \u58f0\u660e\uff08\u521b\u5efa\uff09\u961f\u5217\n            \/**\n             * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n             * \u53c2\u65702\uff1a\u662f\u5426\u5b9a\u4e49\u6301\u4e45\u5316\u961f\u5217\n             * \u53c2\u65703\uff1a\u662f\u5426\u72ec\u5360\u672c\u6b21\u8fde\u63a5\n             * \u53c2\u65704\uff1a\u662f\u5426\u5728\u4e0d\u4f7f\u7528\u7684\u65f6\u5019\u81ea\u52a8\u5220\u9664\u961f\u5217\n             * \u53c2\u65705\uff1a\u961f\u5217\u5176\u5b83\u53c2\u6570\n             *\/\n            channel.queueDeclare(QUEUE_NAME,true,false,false,null);\n            \/\/ \u8981\u53d1\u9001\u7684\u4fe1\u606f\n            String mes = \"hello rabitmq\";\n            \/**\n             * \u53c2\u65701\uff1a\u4ea4\u6362\u673a\u540d\u79f0\uff0c\u5982\u679c\u6ca1\u6709\u6307\u5b9a\u5219\u4f7f\u7528\u9ed8\u8ba4Default Exchage\n             * \u53c2\u65702\uff1a\u8def\u7531key,\u7b80\u5355\u6a21\u5f0f\u53ef\u4ee5\u4f20\u9012\u961f\u5217\u540d\u79f0\n             * \u53c2\u65703\uff1a\u6d88\u606f\u5176\u5b83\u5c5e\u6027\n             * \u53c2\u65704\uff1a\u6d88\u606f\u5185\u5bb9\n             *\/\n            channel.basicPublish(\"\", QUEUE_NAME, null, mes.getBytes());\n            System.out.println(\"\u5df2\u53d1\u9001\u6d88\u606f\uff1a\" + mes);\n\n\n        }catch (Exception e){\n            e.printStackTrace();\n        }\n    }\n\n}\n\n<\/code><\/pre>\n<p>\u5728\u6267\u884c\u4e0a\u8ff0\u7684\u6d88\u606f\u53d1\u9001\u4e4b\u540e\uff1b\u53ef\u4ee5\u767b\u5f55rabbitMQ\u7684\u7ba1\u7406\u63a7\u5236\u53f0\uff0c\u53ef\u4ee5\u53d1\u73b0\u961f\u5217\u548c\u5176\u6d88\u606f\uff1a<\/p>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/image-20210620203458596.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/image-20210620203458596.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"image-20210620203458596\" \/><\/div><\/p>\n<h3>7.3. \u7f16\u5199\u6d88\u8d39\u8005<\/h3>\n<pre><code class=\"language-java \">package com.glj.rabitmq.simple;\n\nimport com.rabbitmq.client.*;\n\nimport java.io.IOException;\nimport java.util.concurrent.TimeoutException;\n\n\/**\n * Created with IntelliJ IDEA.\n *\n * @Author: GuoLiangJun\n * @Date: 2021\/6\/20\n * @Time: 20:44\n *\/\npublic class Consumer {\n\n    static final String QUEUE_NAME = \"simple_queue\";\n\n    public static void main(String[] args) throws Exception {\n\n        \/\/ \u521b\u5efa\u8fde\u63a5\u5de5\u5382\n        ConnectionFactory connectionFactory = new ConnectionFactory();\n        \/\/ \u4e3b\u673a\u5730\u5740;\u9ed8\u8ba4\u4e3a localhost\u3001127.0.0.1\n        connectionFactory.setHost(\"127.0.0.1\");\n        \/\/ \u8fde\u63a5\u7aef\u53e3;\u9ed8\u8ba4\u4e3a 5672\n        connectionFactory.setPort(5672);\n        \/\/ \u865a\u62df\u4e3b\u673a\u540d\u79f0;\u9ed8\u8ba4\u4e3a \/\n        connectionFactory.setVirtualHost(\"\/hcxtuser\");\n        \/\/ \u8fde\u63a5\u7528\u6237\u540d\uff1b\u9ed8\u8ba4\u4e3aguest\n        connectionFactory.setUsername(\"hcxtuser\");\n        \/\/ \u8fde\u63a5\u5bc6\u7801\uff1b\u9ed8\u8ba4\u4e3aguest\n        connectionFactory.setPassword(\"hcxtuser123!@#\");\n\n        \/\/ \u521b\u5efa\u8fde\u63a5\n        Connection connection = connectionFactory.newConnection\n                ();\n        \/\/ \u521b\u5efa\u9891\u9053\n        Channel channel = connection.createChannel();\n        \/\/ \u58f0\u660e\uff08\u521b\u5efa\uff09\u961f\u5217\n        \/**\n         * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n         * \u53c2\u65702\uff1a\u662f\u5426\u5b9a\u4e49\u6301\u4e45\u5316\u961f\u5217\n         * \u53c2\u65703\uff1a\u662f\u5426\u72ec\u5360\u672c\u6b21\u8fde\u63a5\n         * \u53c2\u65704\uff1a\u662f\u5426\u5728\u4e0d\u4f7f\u7528\u7684\u65f6\u5019\u81ea\u52a8\u5220\u9664\u961f\u5217\n         * \u53c2\u65705\uff1a\u961f\u5217\u5176\u5b83\u53c2\u6570\n         *\/\n        channel.queueDeclare(QUEUE_NAME,true,false,false,null);\n\n        DefaultConsumer defaultConsumer = new DefaultConsumer(channel){\n            @Override\n            \/**\n             \u56de\u8c03\u65b9\u6cd5\uff0c\u5f53\u4ecb\u7ecd\u6d88\u606f\u540e\uff0c\u4f1a\u81ea\u52a8\u6267\u884c\u8be5\u65b9\u6cd5\n             * consumerTag \u6d88\u606f\u8005\u6807\u7b7e\uff0c\u5728channel.basicConsume\u65f6\u5019\u53ef\u4ee5\u6307\u5b9a\n             * envelope \u6d88\u606f\u5305\u7684\u5185\u5bb9\uff0c\u53ef\u4ece\u4e2d\u83b7\u53d6\u6d88\u606fid\uff0c\u6d88\u606froutingkey\uff0c\u4ea4\u6362\u673a\uff0c\u6d88\u606f\u548c\u91cd\u4f20\u6807\u5fd7(\u6536\u5230\u6d88\u606f\u5931\u8d25\u540e\u662f\u5426\u9700\u8981\u91cd\u65b0\u53d1\u9001)\n             * properties \u5c5e\u6027\u4fe1\u606f\n             * body \u6d88\u606f\n             *\/\n            public void handleDelivery(String consumerTag,\n                                       Envelope envelope,\n                                       AMQP.BasicProperties properties,\n                                       byte[] body) throws IOException {\n                \/\/\u6d88\u606f\u8005\u6807\u7b7e\n                System.out.println(\"consumerTag:\"+consumerTag);\n                \/\/\u8def\u7531key\n                System.out.println(\"\u8def\u7531key\u4e3a\uff1a\" + envelope.getRoutingKey());\n                \/\/\u4ea4\u6362\u673a\n                System.out.println(\"\u4ea4\u6362\u673a\u4e3a\uff1a\" + envelope.getExchange());\n                \/\/\u6d88\u606fid\n                System.out.println(\"\u6d88\u606fid\u4e3a\uff1a\" + envelope.getDeliveryTag());\n                \/\/\u6536\u5230\u7684\u6d88\u606f\n                System.out.println(\"\u63a5\u6536\u5230\u7684\u6d88\u606f\u4e3a\uff1a\" + new String(body, \"utf-8\"));\n\n            }\n        };\n        \/\/\u76d1\u542c\u6d88\u606f\n        \/**\n         * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n         * \u53c2\u65702\uff1a\u662f\u5426\u81ea\u52a8\u786e\u8ba4\uff0c\u8bbe\u7f6e\u4e3atrue\u4e3a\u8868\u793a\u6d88\u606f\u63a5\u6536\u5230\u81ea\u52a8\u5411mq\u56de\u590d\u63a5\u6536\u5230\u4e86\uff0cmq\u63a5\u6536\u5230\u56de\u590d\u4f1a\u5220\u9664\u6d88\u606f\uff0c\u8bbe\u7f6e\u4e3afalse\u5219\u9700\u8981\u624b\u52a8\u786e\u8ba4\n         * \u53c2\u65703\uff1a\u6d88\u606f\u63a5\u6536\u5230\u540e\u56de\u8c03\n         *\/\n        channel.basicConsume(QUEUE_NAME,true,defaultConsumer);\n\n        \/\/\u4e0d\u5173\u95ed\u8d44\u6e90\uff0c\u5e94\u8be5\u4e00\u76f4\u76d1\u542c\u6d88\u606f\n        \/\/channel.close();\n        \/\/connection.close();\n    }\n\n}\n\n<\/code><\/pre>\n<h3>7.4. \u5c0f\u7ed3<\/h3>\n<p>\u4e0a\u8ff0\u7684\u5165\u95e8\u6848\u4f8b\u4e2d\u4e2d\u5176\u5b9e\u4f7f\u7528\u7684\u662f\u5982\u4e0b\u7684\u7b80\u5355\u6a21\u5f0f\uff1a<\/p>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/1555991074575.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/1555991074575.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"1555991074575\" \/><\/div><\/p>\n<p>\u5728\u4e0a\u56fe\u7684\u6a21\u578b\u4e2d\uff0c\u6709\u4ee5\u4e0b\u6982\u5ff5\uff1a<\/p>\n<ul>\n<li>P\uff1a\u751f\u4ea7\u8005\uff0c\u4e5f\u5c31\u662f\u8981\u53d1\u9001\u6d88\u606f\u7684\u7a0b\u5e8f<\/li>\n<li>C\uff1a\u6d88\u8d39\u8005\uff1a\u6d88\u606f\u7684\u63a5\u53d7\u8005\uff0c\u4f1a\u4e00\u76f4\u7b49\u5f85\u6d88\u606f\u5230\u6765\u3002<\/li>\n<li>queue\uff1a\u6d88\u606f\u961f\u5217\uff0c\u56fe\u4e2d\u7ea2\u8272\u90e8\u5206\u3002\u7c7b\u4f3c\u4e00\u4e2a\u90ae\u7bb1\uff0c\u53ef\u4ee5\u7f13\u5b58\u6d88\u606f\uff1b\u751f\u4ea7\u8005\u5411\u5176\u4e2d\u6295\u9012\u6d88\u606f\uff0c\u6d88\u8d39\u8005\u4ece\u5176\u4e2d\u53d6\u51fa\u6d88\u606f\u3002<\/li>\n<\/ul>\n<h2>8.AMQP<\/h2>\n<h3>8.1. \u76f8\u5173\u6982\u5ff5\u4ecb\u7ecd<\/h3>\n<p>AMQP  \u4e00\u4e2a\u63d0\u4f9b\u7edf\u4e00\u6d88\u606f\u670d\u52a1\u7684\u5e94\u7528\u5c42\u6807\u51c6\u9ad8\u7ea7\u6d88\u606f\u961f\u5217\u534f\u8bae\uff0c\u662f\u5e94\u7528\u5c42\u534f\u8bae\u7684\u4e00\u4e2a\u5f00\u653e\u6807\u51c6\uff0c\u4e3a\u9762\u5411\u6d88\u606f\u7684\u4e2d\u95f4\u4ef6\u8bbe\u8ba1\u3002<\/p>\n<p>AMQP\u662f\u4e00\u4e2a\u4e8c\u8fdb\u5236\u534f\u8bae\uff0c\u62e5\u6709\u4e00\u4e9b\u73b0\u4ee3\u5316\u7279\u70b9\uff1a\u591a\u4fe1\u9053\u3001\u534f\u5546\u5f0f\uff0c\u5f02\u6b65\uff0c\u5b89\u5168\uff0c\u6269\u5e73\u53f0\uff0c\u4e2d\u7acb\uff0c\u9ad8\u6548\u3002<\/p>\n<p>RabbitMQ\u662fAMQP\u534f\u8bae\u7684Erlang\u7684\u5b9e\u73b0\u3002<\/p>\n<table>\n<thead>\n<tr>\n<th>\u6982\u5ff5<\/th>\n<th>\u8bf4\u660e<\/th>\n<\/tr>\n<\/thead>\n<tbody>\n<tr>\n<td>\u8fde\u63a5Connection<\/td>\n<td>\u4e00\u4e2a\u7f51\u7edc\u8fde\u63a5\uff0c\u6bd4\u5982TCP\/IP\u5957\u63a5\u5b57\u8fde\u63a5\u3002<\/td>\n<\/tr>\n<tr>\n<td>\u4f1a\u8bddSession<\/td>\n<td>\u7aef\u70b9\u4e4b\u95f4\u7684\u547d\u540d\u5bf9\u8bdd\u3002\u5728\u4e00\u4e2a\u4f1a\u8bdd\u4e0a\u4e0b\u6587\u4e2d\uff0c\u4fdd\u8bc1\u201c\u6070\u597d\u4f20\u9012\u4e00\u6b21\u201d\u3002<\/td>\n<\/tr>\n<tr>\n<td>\u4fe1\u9053Channel<\/td>\n<td>\u591a\u8def\u590d\u7528\u8fde\u63a5\u4e2d\u7684\u4e00\u6761\u72ec\u7acb\u7684\u53cc\u5411\u6570\u636e\u6d41\u901a\u9053\u3002\u4e3a\u4f1a\u8bdd\u63d0\u4f9b\u7269\u7406\u4f20\u8f93\u4ecb\u8d28\u3002<\/td>\n<\/tr>\n<tr>\n<td>\u5ba2\u6237\u7aefClient<\/td>\n<td>AMQP\u8fde\u63a5\u6216\u8005\u4f1a\u8bdd\u7684\u53d1\u8d77\u8005\u3002AMQP\u662f\u975e\u5bf9\u79f0\u7684\uff0c\u5ba2\u6237\u7aef\u751f\u4ea7\u548c\u6d88\u8d39\u6d88\u606f\uff0c\u670d\u52a1\u5668\u5b58\u50a8\u548c\u8def\u7531\u8fd9\u4e9b\u6d88\u606f\u3002<\/td>\n<\/tr>\n<tr>\n<td>\u670d\u52a1\u8282\u70b9Broker<\/td>\n<td>\u6d88\u606f\u4e2d\u95f4\u4ef6\u7684\u670d\u52a1\u8282\u70b9\uff1b\u4e00\u822c\u60c5\u51b5\u4e0b\u53ef\u4ee5\u5c06\u4e00\u4e2aRabbitMQ Broker\u770b\u4f5c\u4e00\u53f0RabbitMQ \u670d\u52a1\u5668\u3002<\/td>\n<\/tr>\n<tr>\n<td>\u7aef\u70b9<\/td>\n<td>AMQP\u5bf9\u8bdd\u7684\u4efb\u610f\u4e00\u65b9\u3002\u4e00\u4e2aAMQP\u8fde\u63a5\u5305\u62ec\u4e24\u4e2a\u7aef\u70b9\uff08\u4e00\u4e2a\u662f\u5ba2\u6237\u7aef\uff0c\u4e00\u4e2a\u662f\u670d\u52a1\u5668\uff09\u3002<\/td>\n<\/tr>\n<tr>\n<td>\u6d88\u8d39\u8005Consumer<\/td>\n<td>\u4e00\u4e2a\u4ece\u6d88\u606f\u961f\u5217\u91cc\u8bf7\u6c42\u6d88\u606f\u7684\u5ba2\u6237\u7aef\u7a0b\u5e8f\u3002<\/td>\n<\/tr>\n<tr>\n<td>\u751f\u4ea7\u8005Producer<\/td>\n<td>\u4e00\u4e2a\u5411\u4ea4\u6362\u673a\u53d1\u5e03\u6d88\u606f\u7684\u5ba2\u6237\u7aef\u5e94\u7528\u7a0b\u5e8f\u3002<\/td>\n<\/tr>\n<\/tbody>\n<\/table>\n<h3>8.1.RabbitMQ\u8fd0\u8f6c\u6d41\u7a0b<\/h3>\n<p>\u5728\u5165\u95e8\u6848\u4f8b\u4e2d\uff1a<\/p>\n<ul>\n<li>\u751f\u4ea7\u8005\u53d1\u9001\u6d88\u606f\n<ol>\n<li>\u751f\u4ea7\u8005\u521b\u5efa\u8fde\u63a5\uff08Connection\uff09\uff0c\u5f00\u542f\u4e00\u4e2a\u4fe1\u9053\uff08Channel\uff09\uff0c\u8fde\u63a5\u5230RabbitMQ Broker\uff1b<\/li>\n<li>\u58f0\u660e\u961f\u5217\u5e76\u8bbe\u7f6e\u5c5e\u6027\uff1b\u5982\u662f\u5426\u6392\u5b83\uff0c\u662f\u5426\u6301\u4e45\u5316\uff0c\u662f\u5426\u81ea\u52a8\u5220\u9664\uff1b<\/li>\n<li>\u5c06\u8def\u7531\u952e\uff08\u7a7a\u5b57\u7b26\u4e32\uff09\u4e0e\u961f\u5217\u7ed1\u5b9a\u8d77\u6765\uff1b<\/li>\n<li>\u53d1\u9001\u6d88\u606f\u81f3RabbitMQ Broker\uff1b<\/li>\n<li>\u5173\u95ed\u4fe1\u9053\uff1b<\/li>\n<li>\u5173\u95ed\u8fde\u63a5\uff1b<\/li>\n<\/ol>\n<\/li>\n<li>\u6d88\u8d39\u8005\u63a5\u6536\u6d88\u606f\n<ol>\n<li>\u6d88\u8d39\u8005\u521b\u5efa\u8fde\u63a5\uff08Connection\uff09\uff0c\u5f00\u542f\u4e00\u4e2a\u4fe1\u9053\uff08Channel\uff09\uff0c\u8fde\u63a5\u5230RabbitMQ Broker<\/li>\n<li>\u5411Broker \u8bf7\u6c42\u6d88\u8d39\u76f8\u5e94\u961f\u5217\u4e2d\u7684\u6d88\u606f\uff0c\u8bbe\u7f6e\u76f8\u5e94\u7684\u56de\u8c03\u51fd\u6570\uff1b<\/li>\n<li>\u7b49\u5f85Broker\u56de\u5e94\u95ed\u5173\u6295\u9012\u54cd\u5e94\u961f\u5217\u4e2d\u7684\u6d88\u606f\uff0c\u6d88\u8d39\u8005\u63a5\u6536\u6d88\u606f\uff1b<\/li>\n<li>\u786e\u8ba4\uff08ack\uff0c\u81ea\u52a8\u786e\u8ba4\uff09\u63a5\u6536\u5230\u7684\u6d88\u606f\uff1b<\/li>\n<li>RabbitMQ\u4ece\u961f\u5217\u4e2d\u5220\u9664\u76f8\u5e94\u5df2\u7ecf\u88ab\u786e\u8ba4\u7684\u6d88\u606f\uff1b<\/li>\n<li>\u5173\u95ed\u4fe1\u9053\uff1b<\/li>\n<li>\u5173\u95ed\u8fde\u63a5\uff1b<\/li>\n<\/ol>\n<\/li>\n<\/ul>\n<h2>9.RabbitMQ\u5de5\u4f5c\u6a21\u5f0f<\/h2>\n<h3>9.1. Work queues\u5de5\u4f5c\u961f\u5217\u6a21\u5f0f<\/h3>\n<h4>9.1.1. \u6a21\u5f0f\u8bf4\u660e<\/h4>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/1556009144848.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/1556009144848.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"1556009144848\" \/><\/div><\/p>\n<p><code>Work Queues<\/code>\u4e0e\u5165\u95e8\u7a0b\u5e8f\u7684<code>\u7b80\u5355\u6a21\u5f0f<\/code>\u76f8\u6bd4\uff0c\u591a\u4e86\u4e00\u4e2a\u6216\u4e00\u4e9b\u6d88\u8d39\u7aef\uff0c\u591a\u4e2a\u6d88\u8d39\u7aef\u5171\u540c\u6d88\u8d39\u540c\u4e00\u4e2a\u961f\u5217\u4e2d\u7684\u6d88\u606f\u3002<\/p>\n<p><strong>\u5e94\u7528\u573a\u666f<\/strong>\uff1a\u5bf9\u4e8e \u4efb\u52a1\u8fc7\u91cd\u6216\u4efb\u52a1\u8f83\u591a\u60c5\u51b5\u4f7f\u7528\u5de5\u4f5c\u961f\u5217\u53ef\u4ee5\u63d0\u9ad8\u4efb\u52a1\u5904\u7406\u7684\u901f\u5ea6\u3002<\/p>\n<h4>9.1.2.\u4ee3\u7801<\/h4>\n<p><code>Work Queues<\/code>\u4e0e\u5165\u95e8\u7a0b\u5e8f\u7684<code>\u7b80\u5355\u6a21\u5f0f<\/code>\u7684\u4ee3\u7801\u662f\u51e0\u4e4e\u4e00\u6837\u7684\uff1b\u53ef\u4ee5\u5b8c\u5168\u590d\u5236\uff0c\u5e76\u590d\u5236\u591a\u4e00\u4e2a\u6d88\u8d39\u8005\u8fdb\u884c\u591a\u4e2a\u6d88\u8d39\u8005\u540c\u65f6\u6d88\u8d39\u6d88\u606f\u7684\u6d4b\u8bd5\u3002<\/p>\n<h5>\u521b\u5efaconnection\u7684\u5de5\u5177\u7c7bConnectionUtil<\/h5>\n<pre><code class=\"language-Java \">package com.glj.rabitmq.util;\n\nimport com.rabbitmq.client.Connection;\nimport com.rabbitmq.client.ConnectionFactory;\n\n\/**\n * Created with IntelliJ IDEA.\n *\n * @Author: GuoLiangJun\n * @Date: 2021\/6\/20\n * @Time: 21:09\n *\/\npublic class ConnectionUtil {\n\n    public static Connection getConnection() throws Exception {\n        \/\/ \u521b\u5efa\u8fde\u63a5\u5de5\u5382\n        ConnectionFactory connectionFactory = new ConnectionFactory();\n        \/\/ \u4e3b\u673a\u5730\u5740;\u9ed8\u8ba4\u4e3a localhost\u3001127.0.0.1\n        connectionFactory.setHost(\"127.0.0.1\");\n        \/\/ \u8fde\u63a5\u7aef\u53e3;\u9ed8\u8ba4\u4e3a 5672\n        connectionFactory.setPort(5672);\n        \/\/ \u865a\u62df\u4e3b\u673a\u540d\u79f0;\u9ed8\u8ba4\u4e3a \/\n        connectionFactory.setVirtualHost(\"\/hcxtuser\");\n        \/\/ \u8fde\u63a5\u7528\u6237\u540d\uff1b\u9ed8\u8ba4\u4e3aguest\n        connectionFactory.setUsername(\"hcxtuser\");\n        \/\/ \u8fde\u63a5\u5bc6\u7801\uff1b\u9ed8\u8ba4\u4e3aguest\n        connectionFactory.setPassword(\"hcxtuser123!@#\");\n\n        \/\/\u521b\u5efa\u8fde\u63a5\n        return connectionFactory.newConnection();\n    }\n\n}\n\n<\/code><\/pre>\n<h5>\u751f\u4ea7\u8005\uff1a<\/h5>\n<pre><code class=\"language-java \">package com.glj.rabitmq.work;\n\nimport com.glj.rabitmq.util.ConnectionUtil;\nimport com.rabbitmq.client.Channel;\nimport com.rabbitmq.client.Connection;\nimport com.rabbitmq.client.ConnectionFactory;\n\n\/**\n * Created with IntelliJ IDEA.\n *\n * @Author: GuoLiangJun\n * @Date: 2021\/6\/20\n * @Time: 20:16\n *\/\npublic class Producer {\n\n    static final String QUEUE_NAME = \"work_queue\";\n\n    public static void main(String[] args) {\n        try(\n                \/\/ \u521b\u5efa\u8fde\u63a5\n                Connection connection = ConnectionUtil.getConnection();\n                \/\/ \u521b\u5efa\u9891\u9053\n                Channel channel = connection.createChannel()\n        ){\n            \/\/ \u58f0\u660e\uff08\u521b\u5efa\uff09\u961f\u5217\n            \/**\n             * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n             * \u53c2\u65702\uff1a\u662f\u5426\u5b9a\u4e49\u6301\u4e45\u5316\u961f\u5217\n             * \u53c2\u65703\uff1a\u662f\u5426\u72ec\u5360\u672c\u6b21\u8fde\u63a5\n             * \u53c2\u65704\uff1a\u662f\u5426\u5728\u4e0d\u4f7f\u7528\u7684\u65f6\u5019\u81ea\u52a8\u5220\u9664\u961f\u5217\n             * \u53c2\u65705\uff1a\u961f\u5217\u5176\u5b83\u53c2\u6570\n             *\/\n            channel.queueDeclare(QUEUE_NAME,true,false,false,null);\n\n            for (int i = 1; i &lt; 20; i++) {\n                \/\/ \u8981\u53d1\u9001\u7684\u4fe1\u606f\n                String mes = \"rabitmq-work\u6a21\u5f0f--\"+i;\n                \/**\n                 * \u53c2\u65701\uff1a\u4ea4\u6362\u673a\u540d\u79f0\uff0c\u5982\u679c\u6ca1\u6709\u6307\u5b9a\u5219\u4f7f\u7528\u9ed8\u8ba4Default Exchage\n                 * \u53c2\u65702\uff1a\u8def\u7531key,\u7b80\u5355\u6a21\u5f0f\u53ef\u4ee5\u4f20\u9012\u961f\u5217\u540d\u79f0\n                 * \u53c2\u65703\uff1a\u6d88\u606f\u5176\u5b83\u5c5e\u6027\n                 * \u53c2\u65704\uff1a\u6d88\u606f\u5185\u5bb9\n                 *\/\n                channel.basicPublish(\"\", QUEUE_NAME, null, mes.getBytes());\n                System.out.println(\"\u5df2\u53d1\u9001\u6d88\u606f\uff1a\" + mes);\n            }\n        }catch (Exception e){\n            e.printStackTrace();\n        }\n    }\n\n}\n\n<\/code><\/pre>\n<h5>\u6d88\u8d39\u80051\uff1a<\/h5>\n<pre><code class=\"language-java \">package com.glj.rabitmq.work;\n\nimport com.glj.rabitmq.util.ConnectionUtil;\nimport com.rabbitmq.client.*;\n\nimport java.io.IOException;\n\n\/**\n * Created with IntelliJ IDEA.\n *\n * @Author: GuoLiangJun\n * @Date: 2021\/6\/20\n * @Time: 20:44\n *\/\npublic class Consumer1 {\n\n    static final String QUEUE_NAME = \"work_queue\";\n\n    public static void main(String[] args) throws Exception {\n\n        \/\/ \u521b\u5efa\u8fde\u63a5\n        Connection connection = ConnectionUtil.getConnection();\n        \/\/ \u521b\u5efa\u9891\u9053\n        Channel channel = connection.createChannel();\n        \/\/ \u58f0\u660e\uff08\u521b\u5efa\uff09\u961f\u5217\n        \/**\n         * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n         * \u53c2\u65702\uff1a\u662f\u5426\u5b9a\u4e49\u6301\u4e45\u5316\u961f\u5217\n         * \u53c2\u65703\uff1a\u662f\u5426\u72ec\u5360\u672c\u6b21\u8fde\u63a5\n         * \u53c2\u65704\uff1a\u662f\u5426\u5728\u4e0d\u4f7f\u7528\u7684\u65f6\u5019\u81ea\u52a8\u5220\u9664\u961f\u5217\n         * \u53c2\u65705\uff1a\u961f\u5217\u5176\u5b83\u53c2\u6570\n         *\/\n        channel.queueDeclare(QUEUE_NAME,true,false,false,null);\n\n        DefaultConsumer defaultConsumer = new DefaultConsumer(channel){\n            @Override\n            \/**\n             \u56de\u8c03\u65b9\u6cd5\uff0c\u5f53\u4ecb\u7ecd\u6d88\u606f\u540e\uff0c\u4f1a\u81ea\u52a8\u6267\u884c\u8be5\u65b9\u6cd5\n             * consumerTag \u6d88\u606f\u8005\u6807\u7b7e\uff0c\u5728channel.basicConsume\u65f6\u5019\u53ef\u4ee5\u6307\u5b9a\n             * envelope \u6d88\u606f\u5305\u7684\u5185\u5bb9\uff0c\u53ef\u4ece\u4e2d\u83b7\u53d6\u6d88\u606fid\uff0c\u6d88\u606froutingkey\uff0c\u4ea4\u6362\u673a\uff0c\u6d88\u606f\u548c\u91cd\u4f20\u6807\u5fd7(\u6536\u5230\u6d88\u606f\u5931\u8d25\u540e\u662f\u5426\u9700\u8981\u91cd\u65b0\u53d1\u9001)\n             * properties \u5c5e\u6027\u4fe1\u606f\n             * body \u6d88\u606f\n             *\/\n            public void handleDelivery(String consumerTag,\n                                       Envelope envelope,\n                                       AMQP.BasicProperties properties,\n                                       byte[] body) throws IOException {\n                \/\/\u6536\u5230\u7684\u6d88\u606f\n                System.out.println(\"\u63a5\u6536\u5230\u7684\u6d88\u606f\u4e3a\uff1a\" + new String(body, \"utf-8\"));\n\n            }\n        };\n        \/\/\u76d1\u542c\u6d88\u606f\n        \/**\n         * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n         * \u53c2\u65702\uff1a\u662f\u5426\u81ea\u52a8\u786e\u8ba4\uff0c\u8bbe\u7f6e\u4e3atrue\u4e3a\u8868\u793a\u6d88\u606f\u63a5\u6536\u5230\u81ea\u52a8\u5411mq\u56de\u590d\u63a5\u6536\u5230\u4e86\uff0cmq\u63a5\u6536\u5230\u56de\u590d\u4f1a\u5220\u9664\u6d88\u606f\uff0c\u8bbe\u7f6e\u4e3afalse\u5219\u9700\u8981\u624b\u52a8\u786e\u8ba4\n         * \u53c2\u65703\uff1a\u6d88\u606f\u63a5\u6536\u5230\u540e\u56de\u8c03\n         *\/\n        channel.basicConsume(QUEUE_NAME,true,defaultConsumer);\n\n        \/\/\u4e0d\u5173\u95ed\u8d44\u6e90\uff0c\u5e94\u8be5\u4e00\u76f4\u76d1\u542c\u6d88\u606f\n        \/\/channel.close();\n        \/\/connection.close();\n    }\n\n}\n\n<\/code><\/pre>\n<h5>\u6d88\u8d39\u80052\uff1a<\/h5>\n<pre><code class=\"language-java \">package com.glj.rabitmq.work;\n\nimport com.glj.rabitmq.util.ConnectionUtil;\nimport com.rabbitmq.client.*;\n\nimport java.io.IOException;\n\n\/**\n * Created with IntelliJ IDEA.\n *\n * @Author: GuoLiangJun\n * @Date: 2021\/6\/20\n * @Time: 20:44\n *\/\npublic class Consumer2 {\n\n    static final String QUEUE_NAME = \"work_queue\";\n\n    public static void main(String[] args) throws Exception {\n        \/\/ \u521b\u5efa\u8fde\u63a5\n        Connection connection = ConnectionUtil.getConnection();\n        \/\/ \u521b\u5efa\u9891\u9053\n        Channel channel = connection.createChannel();\n        \/\/ \u58f0\u660e\uff08\u521b\u5efa\uff09\u961f\u5217\n        \/**\n         * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n         * \u53c2\u65702\uff1a\u662f\u5426\u5b9a\u4e49\u6301\u4e45\u5316\u961f\u5217\n         * \u53c2\u65703\uff1a\u662f\u5426\u72ec\u5360\u672c\u6b21\u8fde\u63a5\n         * \u53c2\u65704\uff1a\u662f\u5426\u5728\u4e0d\u4f7f\u7528\u7684\u65f6\u5019\u81ea\u52a8\u5220\u9664\u961f\u5217\n         * \u53c2\u65705\uff1a\u961f\u5217\u5176\u5b83\u53c2\u6570\n         *\/\n        channel.queueDeclare(QUEUE_NAME,true,false,false,null);\n\n        DefaultConsumer defaultConsumer = new DefaultConsumer(channel){\n            @Override\n            \/**\n             \u56de\u8c03\u65b9\u6cd5\uff0c\u5f53\u4ecb\u7ecd\u6d88\u606f\u540e\uff0c\u4f1a\u81ea\u52a8\u6267\u884c\u8be5\u65b9\u6cd5\n             * consumerTag \u6d88\u606f\u8005\u6807\u7b7e\uff0c\u5728channel.basicConsume\u65f6\u5019\u53ef\u4ee5\u6307\u5b9a\n             * envelope \u6d88\u606f\u5305\u7684\u5185\u5bb9\uff0c\u53ef\u4ece\u4e2d\u83b7\u53d6\u6d88\u606fid\uff0c\u6d88\u606froutingkey\uff0c\u4ea4\u6362\u673a\uff0c\u6d88\u606f\u548c\u91cd\u4f20\u6807\u5fd7(\u6536\u5230\u6d88\u606f\u5931\u8d25\u540e\u662f\u5426\u9700\u8981\u91cd\u65b0\u53d1\u9001)\n             * properties \u5c5e\u6027\u4fe1\u606f\n             * body \u6d88\u606f\n             *\/\n            public void handleDelivery(String consumerTag,\n                                       Envelope envelope,\n                                       AMQP.BasicProperties properties,\n                                       byte[] body) throws IOException {\n                \/\/\u6536\u5230\u7684\u6d88\u606f\n                System.out.println(\"\u63a5\u6536\u5230\u7684\u6d88\u606f\u4e3a\uff1a\" + new String(body, \"utf-8\"));\n\n            }\n        };\n        \/\/\u76d1\u542c\u6d88\u606f\n        \/**\n         * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n         * \u53c2\u65702\uff1a\u662f\u5426\u81ea\u52a8\u786e\u8ba4\uff0c\u8bbe\u7f6e\u4e3atrue\u4e3a\u8868\u793a\u6d88\u606f\u63a5\u6536\u5230\u81ea\u52a8\u5411mq\u56de\u590d\u63a5\u6536\u5230\u4e86\uff0cmq\u63a5\u6536\u5230\u56de\u590d\u4f1a\u5220\u9664\u6d88\u606f\uff0c\u8bbe\u7f6e\u4e3afalse\u5219\u9700\u8981\u624b\u52a8\u786e\u8ba4\n         * \u53c2\u65703\uff1a\u6d88\u606f\u63a5\u6536\u5230\u540e\u56de\u8c03\n         *\/\n        channel.basicConsume(QUEUE_NAME,true,defaultConsumer);\n\n        \/\/\u4e0d\u5173\u95ed\u8d44\u6e90\uff0c\u5e94\u8be5\u4e00\u76f4\u76d1\u542c\u6d88\u606f\n        \/\/channel.close();\n        \/\/connection.close();\n    }\n\n}\n\n<\/code><\/pre>\n<h5>\u5c0f\u7ed3<\/h5>\n<p>\u5728\u4e00\u4e2a\u961f\u5217\u4e2d\u5982\u679c\u6709\u591a\u4e2a\u6d88\u8d39\u8005\uff0c\u90a3\u4e48\u6d88\u8d39\u8005\u4e4b\u95f4\u5bf9\u4e8e\u540c\u4e00\u4e2a\u6d88\u606f\u7684\u5173\u7cfb\u662f<strong>\u7ade\u4e89<\/strong>\u7684\u5173\u7cfb\u3002<\/p>\n<h3>9.2.\u8ba2\u9605\u6a21\u5f0f\u7c7b\u578b\u8bf4\u660e<\/h3>\n<p>\u524d\u97622\u4e2a\u6848\u4f8b\u4e2d\uff0c\u53ea\u67093\u4e2a\u89d2\u8272\uff1a<\/p>\n<ul>\n<li>P\uff1a\u751f\u4ea7\u8005\uff0c\u4e5f\u5c31\u662f\u8981\u53d1\u9001\u6d88\u606f\u7684\u7a0b\u5e8f<\/li>\n<li>C\uff1a\u6d88\u8d39\u8005\uff1a\u6d88\u606f\u7684\u63a5\u53d7\u8005\uff0c\u4f1a\u4e00\u76f4\u7b49\u5f85\u6d88\u606f\u5230\u6765\u3002<\/li>\n<li>queue\uff1a\u6d88\u606f\u961f\u5217\uff0c\u56fe\u4e2d\u7ea2\u8272\u90e8\u5206<\/li>\n<\/ul>\n<p>\u8ba2\u9605\u6a21\u5f0f\u793a\u4f8b\u56fe\uff1a<\/p>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/1556014499573.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/1556014499573.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"1556014499573\" \/><\/div><\/p>\n<p>\u800c\u5728\u8ba2\u9605\u6a21\u578b\u4e2d\uff0c\u591a\u4e86\u4e00\u4e2aexchange\u89d2\u8272\uff0c\u800c\u4e14\u8fc7\u7a0b\u7565\u6709\u53d8\u5316\uff1a<\/p>\n<ul>\n<li>P\uff1a\u751f\u4ea7\u8005\uff0c\u4e5f\u5c31\u662f\u8981\u53d1\u9001\u6d88\u606f\u7684\u7a0b\u5e8f\uff0c\u4f46\u662f\u4e0d\u518d\u53d1\u9001\u5230\u961f\u5217\u4e2d\uff0c\u800c\u662f\u53d1\u7ed9X\uff08\u4ea4\u6362\u673a\uff09<\/li>\n<li>C\uff1a\u6d88\u8d39\u8005\uff0c\u6d88\u606f\u7684\u63a5\u53d7\u8005\uff0c\u4f1a\u4e00\u76f4\u7b49\u5f85\u6d88\u606f\u5230\u6765\u3002<\/li>\n<li>Queue\uff1a\u6d88\u606f\u961f\u5217\uff0c\u63a5\u6536\u6d88\u606f\u3001\u7f13\u5b58\u6d88\u606f\u3002<\/li>\n<li>Exchange\uff1a\u4ea4\u6362\u673a\uff0c\u56fe\u4e2d\u7684X\u3002\u4e00\u65b9\u9762\uff0c\u63a5\u6536\u751f\u4ea7\u8005\u53d1\u9001\u7684\u6d88\u606f\u3002\u53e6\u4e00\u65b9\u9762\uff0c\u77e5\u9053\u5982\u4f55\u5904\u7406\u6d88\u606f\uff0c\u4f8b\u5982\u9012\u4ea4\u7ed9\u67d0\u4e2a\u7279\u522b\u961f\u5217\u3001\u9012\u4ea4\u7ed9\u6240\u6709\u961f\u5217\u3001\u6216\u662f\u5c06\u6d88\u606f\u4e22\u5f03\u3002\u5230\u5e95\u5982\u4f55\u64cd\u4f5c\uff0c\u53d6\u51b3\u4e8eExchange\u7684\u7c7b\u578b\u3002Exchange\u6709\u5e38\u89c1\u4ee5\u4e0b3\u79cd\u7c7b\u578b\uff1a\n<ul>\n<li>Fanout\uff1a\u5e7f\u64ad\uff0c\u5c06\u6d88\u606f\u4ea4\u7ed9\u6240\u6709\u7ed1\u5b9a\u5230\u4ea4\u6362\u673a\u7684\u961f\u5217<\/li>\n<li>Direct\uff1a\u5b9a\u5411\uff0c\u628a\u6d88\u606f\u4ea4\u7ed9\u7b26\u5408\u6307\u5b9arouting key \u7684\u961f\u5217<\/li>\n<li>Topic\uff1a\u901a\u914d\u7b26\uff0c\u628a\u6d88\u606f\u4ea4\u7ed9\u7b26\u5408routing pattern\uff08\u8def\u7531\u6a21\u5f0f\uff09 \u7684\u961f\u5217<\/li>\n<\/ul>\n<\/li>\n<\/ul>\n<p><strong>Exchange\uff08\u4ea4\u6362\u673a\uff09\u53ea\u8d1f\u8d23\u8f6c\u53d1\u6d88\u606f\uff0c\u4e0d\u5177\u5907\u5b58\u50a8\u6d88\u606f\u7684\u80fd\u529b<\/strong>\uff0c\u56e0\u6b64\u5982\u679c\u6ca1\u6709\u4efb\u4f55\u961f\u5217\u4e0eExchange\u7ed1\u5b9a\uff0c\u6216\u8005\u6ca1\u6709\u7b26\u5408\u8def\u7531\u89c4\u5219\u7684\u961f\u5217\uff0c\u90a3\u4e48\u6d88\u606f\u4f1a\u4e22\u5931\uff01<\/p>\n<h3>9.3.Publish\/Subscribe\u53d1\u5e03\u4e0e\u8ba2\u9605\u6a21\u5f0f(fanout)<\/h3>\n<h4>\u6a21\u5f0f\u8bf4\u660e<\/h4>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/1556010329032.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/1556010329032.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"1556010329032\" \/><\/div><\/p>\n<p>\u53d1\u5e03\u8ba2\u9605\u6a21\u5f0f\uff1a<br \/>\n1\u3001\u6bcf\u4e2a\u6d88\u8d39\u8005\u76d1\u542c\u81ea\u5df1\u7684\u961f\u5217\u3002<br \/>\n2\u3001\u751f\u4ea7\u8005\u5c06\u6d88\u606f\u53d1\u7ed9broker\uff0c\u7531\u4ea4\u6362\u673a\u5c06\u6d88\u606f\u8f6c\u53d1\u5230\u7ed1\u5b9a\u6b64\u4ea4\u6362\u673a\u7684\u6bcf\u4e2a\u961f\u5217\uff0c\u6bcf\u4e2a\u7ed1\u5b9a\u4ea4\u6362\u673a\u7684\u961f\u5217\u90fd\u5c06\u63a5\u6536<br \/>\n\u5230\u6d88\u606f<\/p>\n<h4>\u4ee3\u7801\uff1a<\/h4>\n<h5>1.\u751f\u4ea7\u8005\uff1a<\/h5>\n<pre><code class=\"language-java \">package com.glj.rabitmq.ps;\n\nimport com.glj.rabitmq.util.ConnectionUtil;\nimport com.rabbitmq.client.BuiltinExchangeType;\nimport com.rabbitmq.client.Channel;\nimport com.rabbitmq.client.Connection;\n\n\/**\n * Created with IntelliJ IDEA.\n *\n * @Author: GuoLiangJun\n * @Date: 2021\/6\/20\n * @Time: 20:16\n *\/\npublic class Producer {\n\n    \/\/\u4ea4\u6362\u673a\u540d\u79f0\n    static final String FANOUT_EXCHAGE = \"fanout_exchange\";\n    \/\/\u961f\u5217\u540d\u79f0\n    static final String FANOUT_QUEUE_1 = \"fanout_queue_1\";\n    \/\/\u961f\u5217\u540d\u79f0\n    static final String FANOUT_QUEUE_2 = \"fanout_queue_2\";\n\n    public static void main(String[] args) {\n        try(\n                \/\/ \u521b\u5efa\u8fde\u63a5\n                Connection connection = ConnectionUtil.getConnection();\n                \/\/ \u521b\u5efa\u9891\u9053\n                Channel channel = connection.createChannel()\n        ){\n            \/**\n                \u58f0\u660e\u4ea4\u6362\u673a\n                exchangeDeclare(String exchange, BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, Map&lt;String, Object&gt; arguments)\n               \u53c2\u6570\uff1a\n                1. exchange:\u4ea4\u6362\u673a\u540d\u79f0\n                2. type:\u4ea4\u6362\u673a\u7c7b\u578b\n                    DIRECT(\"direct\"),\uff1a\u5b9a\u5411\n                    FANOUT(\"fanout\"),\uff1a\u6247\u5f62\uff08\u5e7f\u64ad\uff09\uff0c\u53d1\u9001\u6d88\u606f\u5230\u6bcf\u4e00\u4e2a\u4e0e\u4e4b\u7ed1\u5b9a\u961f\u5217\u3002\n                    TOPIC(\"topic\"),\u901a\u914d\u7b26\u7684\u65b9\u5f0f\n                    HEADERS(\"headers\");\u53c2\u6570\u5339\u914d\n\n                3. durable:\u662f\u5426\u6301\u4e45\u5316\n                4. autoDelete:\u81ea\u52a8\u5220\u9664\n                5. internal\uff1a\u5185\u90e8\u4f7f\u7528\u3002 \u4e00\u822cfalse\n                6. arguments\uff1a\u53c2\u6570\n             *\/\n            channel.exchangeDeclare(FANOUT_EXCHAGE, BuiltinExchangeType.FANOUT,true,false,false,null);\n\n            \/\/ \u58f0\u660e\uff08\u521b\u5efa\uff09\u961f\u5217\n            \/**\n             * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n             * \u53c2\u65702\uff1a\u662f\u5426\u5b9a\u4e49\u6301\u4e45\u5316\u961f\u5217\n             * \u53c2\u65703\uff1a\u662f\u5426\u72ec\u5360\u672c\u6b21\u8fde\u63a5\n             * \u53c2\u65704\uff1a\u662f\u5426\u5728\u4e0d\u4f7f\u7528\u7684\u65f6\u5019\u81ea\u52a8\u5220\u9664\u961f\u5217\n             * \u53c2\u65705\uff1a\u961f\u5217\u5176\u5b83\u53c2\u6570\n             *\/\n            channel.queueDeclare(FANOUT_QUEUE_1,true,false,false,null);\n            channel.queueDeclare(FANOUT_QUEUE_2,true,false,false,null);\n\n            \/**\n             * \u961f\u5217\u7ed1\u5b9a\u4ea4\u6362\u673a\n            queueBind(String queue, String exchange, String routingKey)\n            \u53c2\u6570\uff1a\n                1. queue\uff1a\u961f\u5217\u540d\u79f0\n                2. exchange\uff1a\u4ea4\u6362\u673a\u540d\u79f0\n                3. routingKey\uff1a\u8def\u7531\u952e\uff0c\u7ed1\u5b9a\u89c4\u5219\n                    \u5982\u679c\u4ea4\u6362\u673a\u7684\u7c7b\u578b\u4e3afanout \uff0croutingKey\u8bbe\u7f6e\u4e3a\"\"\n             *\/\n            channel.queueBind(FANOUT_QUEUE_1,FANOUT_EXCHAGE,\"\");\n            channel.queueBind(FANOUT_QUEUE_2,FANOUT_EXCHAGE,\"\");\n\n            for (int i = 1; i &lt; 20; i++) {\n                \/\/ \u8981\u53d1\u9001\u7684\u4fe1\u606f\n                String mes = \"rabitmq-work\u6a21\u5f0f--\"+i;\n                \/**\n                 * \u53c2\u65701\uff1a\u4ea4\u6362\u673a\u540d\u79f0\uff0c\u5982\u679c\u6ca1\u6709\u6307\u5b9a\u5219\u4f7f\u7528\u9ed8\u8ba4Default Exchage\n                 * \u53c2\u65702\uff1a\u8def\u7531key,\u7b80\u5355\u6a21\u5f0f\u53ef\u4ee5\u4f20\u9012\u961f\u5217\u540d\u79f0\n                 * \u53c2\u65703\uff1a\u6d88\u606f\u5176\u5b83\u5c5e\u6027\n                 * \u53c2\u65704\uff1a\u6d88\u606f\u5185\u5bb9\n                 *\/\n                channel.basicPublish(FANOUT_EXCHAGE, \"\", null, mes.getBytes());\n                System.out.println(\"\u5df2\u53d1\u9001\u6d88\u606f\uff1a\" + mes);\n            }\n        }catch (Exception e){\n            e.printStackTrace();\n        }\n    }\n\n}\n\n<\/code><\/pre>\n<h5>2.\u6d88\u8d39\u80051:<\/h5>\n<pre><code class=\"language-java \">package com.glj.rabitmq.ps;\n\nimport com.glj.rabitmq.util.ConnectionUtil;\nimport com.rabbitmq.client.*;\n\nimport java.io.IOException;\n\n\/**\n * Created with IntelliJ IDEA.\n *\n * @Author: GuoLiangJun\n * @Date: 2021\/6\/20\n * @Time: 20:44\n *\/\npublic class Consumer1 {\n\n    \/\/\u4ea4\u6362\u673a\u540d\u79f0\n    static final String FANOUT_EXCHAGE = \"fanout_exchange\";\n    \/\/\u961f\u5217\u540d\u79f0\n    static final String FANOUT_QUEUE_1 = \"fanout_queue_1\";\n\n    public static void main(String[] args) throws Exception {\n\n        \/\/ \u521b\u5efa\u8fde\u63a5\n        Connection connection = ConnectionUtil.getConnection();\n        \/\/ \u521b\u5efa\u9891\u9053\n        Channel channel = connection.createChannel();\n\n        \/**\n         \u58f0\u660e\u4ea4\u6362\u673a\n         exchangeDeclare(String exchange, BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, Map&lt;String, Object&gt; arguments)\n         \u53c2\u6570\uff1a\n         1. exchange:\u4ea4\u6362\u673a\u540d\u79f0\n         2. type:\u4ea4\u6362\u673a\u7c7b\u578b\n         DIRECT(\"direct\"),\uff1a\u5b9a\u5411\n         FANOUT(\"fanout\"),\uff1a\u6247\u5f62\uff08\u5e7f\u64ad\uff09\uff0c\u53d1\u9001\u6d88\u606f\u5230\u6bcf\u4e00\u4e2a\u4e0e\u4e4b\u7ed1\u5b9a\u961f\u5217\u3002\n         TOPIC(\"topic\"),\u901a\u914d\u7b26\u7684\u65b9\u5f0f\n         HEADERS(\"headers\");\u53c2\u6570\u5339\u914d\n\n         3. durable:\u662f\u5426\u6301\u4e45\u5316\n         4. autoDelete:\u81ea\u52a8\u5220\u9664\n         5. internal\uff1a\u5185\u90e8\u4f7f\u7528\u3002 \u4e00\u822cfalse\n         6. arguments\uff1a\u53c2\u6570\n         *\/\n        channel.exchangeDeclare(FANOUT_EXCHAGE, BuiltinExchangeType.FANOUT,true,false,false,null);\n\n        \/\/ \u58f0\u660e\uff08\u521b\u5efa\uff09\u961f\u5217\n        \/**\n         * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n         * \u53c2\u65702\uff1a\u662f\u5426\u5b9a\u4e49\u6301\u4e45\u5316\u961f\u5217\n         * \u53c2\u65703\uff1a\u662f\u5426\u72ec\u5360\u672c\u6b21\u8fde\u63a5\n         * \u53c2\u65704\uff1a\u662f\u5426\u5728\u4e0d\u4f7f\u7528\u7684\u65f6\u5019\u81ea\u52a8\u5220\u9664\u961f\u5217\n         * \u53c2\u65705\uff1a\u961f\u5217\u5176\u5b83\u53c2\u6570\n         *\/\n        channel.queueDeclare(FANOUT_QUEUE_1,true,false,false,null);\n\n        \/**\n         * \u961f\u5217\u7ed1\u5b9a\u4ea4\u6362\u673a\n         queueBind(String queue, String exchange, String routingKey)\n         \u53c2\u6570\uff1a\n         1. queue\uff1a\u961f\u5217\u540d\u79f0\n         2. exchange\uff1a\u4ea4\u6362\u673a\u540d\u79f0\n         3. routingKey\uff1a\u8def\u7531\u952e\uff0c\u7ed1\u5b9a\u89c4\u5219\n         \u5982\u679c\u4ea4\u6362\u673a\u7684\u7c7b\u578b\u4e3afanout \uff0croutingKey\u8bbe\u7f6e\u4e3a\"\"\n         *\/\n        channel.queueBind(FANOUT_QUEUE_1,FANOUT_EXCHAGE,\"\");\n\n        DefaultConsumer defaultConsumer = new DefaultConsumer(channel){\n            @Override\n            \/**\n             \u56de\u8c03\u65b9\u6cd5\uff0c\u5f53\u4ecb\u7ecd\u6d88\u606f\u540e\uff0c\u4f1a\u81ea\u52a8\u6267\u884c\u8be5\u65b9\u6cd5\n             * consumerTag \u6d88\u606f\u8005\u6807\u7b7e\uff0c\u5728channel.basicConsume\u65f6\u5019\u53ef\u4ee5\u6307\u5b9a\n             * envelope \u6d88\u606f\u5305\u7684\u5185\u5bb9\uff0c\u53ef\u4ece\u4e2d\u83b7\u53d6\u6d88\u606fid\uff0c\u6d88\u606froutingkey\uff0c\u4ea4\u6362\u673a\uff0c\u6d88\u606f\u548c\u91cd\u4f20\u6807\u5fd7(\u6536\u5230\u6d88\u606f\u5931\u8d25\u540e\u662f\u5426\u9700\u8981\u91cd\u65b0\u53d1\u9001)\n             * properties \u5c5e\u6027\u4fe1\u606f\n             * body \u6d88\u606f\n             *\/\n            public void handleDelivery(String consumerTag,\n                                       Envelope envelope,\n                                       AMQP.BasicProperties properties,\n                                       byte[] body) throws IOException {\n                \/\/\u6536\u5230\u7684\u6d88\u606f\n                System.out.println(\"\u6d88\u8d39\u80051-\u63a5\u6536\u5230\u7684\u6d88\u606f\u4e3a\uff1a\" + new String(body, \"utf-8\"));\n\n            }\n        };\n        \/\/\u76d1\u542c\u6d88\u606f\n        \/**\n         * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n         * \u53c2\u65702\uff1a\u662f\u5426\u81ea\u52a8\u786e\u8ba4\uff0c\u8bbe\u7f6e\u4e3atrue\u4e3a\u8868\u793a\u6d88\u606f\u63a5\u6536\u5230\u81ea\u52a8\u5411mq\u56de\u590d\u63a5\u6536\u5230\u4e86\uff0cmq\u63a5\u6536\u5230\u56de\u590d\u4f1a\u5220\u9664\u6d88\u606f\uff0c\u8bbe\u7f6e\u4e3afalse\u5219\u9700\u8981\u624b\u52a8\u786e\u8ba4\n         * \u53c2\u65703\uff1a\u6d88\u606f\u63a5\u6536\u5230\u540e\u56de\u8c03\n         *\/\n        channel.basicConsume(FANOUT_QUEUE_1,true,defaultConsumer);\n\n        \/\/\u4e0d\u5173\u95ed\u8d44\u6e90\uff0c\u5e94\u8be5\u4e00\u76f4\u76d1\u542c\u6d88\u606f\n        \/\/channel.close();\n        \/\/connection.close();\n    }\n\n}\n\n<\/code><\/pre>\n<h5>3.\u6d88\u8d39\u80052\uff1a<\/h5>\n<pre><code class=\"language-java \">package com.glj.rabitmq.ps;\n\nimport com.glj.rabitmq.util.ConnectionUtil;\nimport com.rabbitmq.client.*;\n\nimport java.io.IOException;\n\n\/**\n * Created with IntelliJ IDEA.\n *\n * @Author: GuoLiangJun\n * @Date: 2021\/6\/20\n * @Time: 20:44\n *\/\npublic class Consumer2 {\n\n    \/\/\u4ea4\u6362\u673a\u540d\u79f0\n    static final String FANOUT_EXCHAGE = \"fanout_exchange\";\n    \/\/\u961f\u5217\u540d\u79f0\n    static final String FANOUT_QUEUE_1 = \"fanout_queue_2\";\n\n    public static void main(String[] args) throws Exception {\n\n        \/\/ \u521b\u5efa\u8fde\u63a5\n        Connection connection = ConnectionUtil.getConnection();\n        \/\/ \u521b\u5efa\u9891\u9053\n        Channel channel = connection.createChannel();\n\n        \/**\n         \u58f0\u660e\u4ea4\u6362\u673a\n         exchangeDeclare(String exchange, BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, Map&lt;String, Object&gt; arguments)\n         \u53c2\u6570\uff1a\n         1. exchange:\u4ea4\u6362\u673a\u540d\u79f0\n         2. type:\u4ea4\u6362\u673a\u7c7b\u578b\n         DIRECT(\"direct\"),\uff1a\u5b9a\u5411\n         FANOUT(\"fanout\"),\uff1a\u6247\u5f62\uff08\u5e7f\u64ad\uff09\uff0c\u53d1\u9001\u6d88\u606f\u5230\u6bcf\u4e00\u4e2a\u4e0e\u4e4b\u7ed1\u5b9a\u961f\u5217\u3002\n         TOPIC(\"topic\"),\u901a\u914d\u7b26\u7684\u65b9\u5f0f\n         HEADERS(\"headers\");\u53c2\u6570\u5339\u914d\n\n         3. durable:\u662f\u5426\u6301\u4e45\u5316\n         4. autoDelete:\u81ea\u52a8\u5220\u9664\n         5. internal\uff1a\u5185\u90e8\u4f7f\u7528\u3002 \u4e00\u822cfalse\n         6. arguments\uff1a\u53c2\u6570\n         *\/\n        channel.exchangeDeclare(FANOUT_EXCHAGE, BuiltinExchangeType.FANOUT,true,false,false,null);\n\n        \/\/ \u58f0\u660e\uff08\u521b\u5efa\uff09\u961f\u5217\n        \/**\n         * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n         * \u53c2\u65702\uff1a\u662f\u5426\u5b9a\u4e49\u6301\u4e45\u5316\u961f\u5217\n         * \u53c2\u65703\uff1a\u662f\u5426\u72ec\u5360\u672c\u6b21\u8fde\u63a5\n         * \u53c2\u65704\uff1a\u662f\u5426\u5728\u4e0d\u4f7f\u7528\u7684\u65f6\u5019\u81ea\u52a8\u5220\u9664\u961f\u5217\n         * \u53c2\u65705\uff1a\u961f\u5217\u5176\u5b83\u53c2\u6570\n         *\/\n        channel.queueDeclare(FANOUT_QUEUE_1,true,false,false,null);\n\n        \/**\n         * \u961f\u5217\u7ed1\u5b9a\u4ea4\u6362\u673a\n         queueBind(String queue, String exchange, String routingKey)\n         \u53c2\u6570\uff1a\n         1. queue\uff1a\u961f\u5217\u540d\u79f0\n         2. exchange\uff1a\u4ea4\u6362\u673a\u540d\u79f0\n         3. routingKey\uff1a\u8def\u7531\u952e\uff0c\u7ed1\u5b9a\u89c4\u5219\n         \u5982\u679c\u4ea4\u6362\u673a\u7684\u7c7b\u578b\u4e3afanout \uff0croutingKey\u8bbe\u7f6e\u4e3a\"\"\n         *\/\n        channel.queueBind(FANOUT_QUEUE_1,FANOUT_EXCHAGE,\"\");\n\n        DefaultConsumer defaultConsumer = new DefaultConsumer(channel){\n            @Override\n            \/**\n             \u56de\u8c03\u65b9\u6cd5\uff0c\u5f53\u4ecb\u7ecd\u6d88\u606f\u540e\uff0c\u4f1a\u81ea\u52a8\u6267\u884c\u8be5\u65b9\u6cd5\n             * consumerTag \u6d88\u606f\u8005\u6807\u7b7e\uff0c\u5728channel.basicConsume\u65f6\u5019\u53ef\u4ee5\u6307\u5b9a\n             * envelope \u6d88\u606f\u5305\u7684\u5185\u5bb9\uff0c\u53ef\u4ece\u4e2d\u83b7\u53d6\u6d88\u606fid\uff0c\u6d88\u606froutingkey\uff0c\u4ea4\u6362\u673a\uff0c\u6d88\u606f\u548c\u91cd\u4f20\u6807\u5fd7(\u6536\u5230\u6d88\u606f\u5931\u8d25\u540e\u662f\u5426\u9700\u8981\u91cd\u65b0\u53d1\u9001)\n             * properties \u5c5e\u6027\u4fe1\u606f\n             * body \u6d88\u606f\n             *\/\n            public void handleDelivery(String consumerTag,\n                                       Envelope envelope,\n                                       AMQP.BasicProperties properties,\n                                       byte[] body) throws IOException {\n                \/\/\u6536\u5230\u7684\u6d88\u606f\n                System.out.println(\"\u6d88\u8d39\u80052-\u63a5\u6536\u5230\u7684\u6d88\u606f\u4e3a\uff1a\" + new String(body, \"utf-8\"));\n\n            }\n        };\n        \/\/\u76d1\u542c\u6d88\u606f\n        \/**\n         * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n         * \u53c2\u65702\uff1a\u662f\u5426\u81ea\u52a8\u786e\u8ba4\uff0c\u8bbe\u7f6e\u4e3atrue\u4e3a\u8868\u793a\u6d88\u606f\u63a5\u6536\u5230\u81ea\u52a8\u5411mq\u56de\u590d\u63a5\u6536\u5230\u4e86\uff0cmq\u63a5\u6536\u5230\u56de\u590d\u4f1a\u5220\u9664\u6d88\u606f\uff0c\u8bbe\u7f6e\u4e3afalse\u5219\u9700\u8981\u624b\u52a8\u786e\u8ba4\n         * \u53c2\u65703\uff1a\u6d88\u606f\u63a5\u6536\u5230\u540e\u56de\u8c03\n         *\/\n        channel.basicConsume(FANOUT_QUEUE_1,true,defaultConsumer);\n\n        \/\/\u4e0d\u5173\u95ed\u8d44\u6e90\uff0c\u5e94\u8be5\u4e00\u76f4\u76d1\u542c\u6d88\u606f\n        \/\/channel.close();\n        \/\/connection.close();\n    }\n\n}\n\n<\/code><\/pre>\n<h5>4.\u5c0f\u7ed3<\/h5>\n<p>\u4ea4\u6362\u673a\u9700\u8981\u4e0e\u961f\u5217\u8fdb\u884c\u7ed1\u5b9a\uff0c\u7ed1\u5b9a\u4e4b\u540e\uff1b\u4e00\u4e2a\u6d88\u606f\u53ef\u4ee5\u88ab\u591a\u4e2a\u6d88\u8d39\u8005\u90fd\u6536\u5230\u3002<\/p>\n<h5>5.<strong>\u53d1\u5e03\u8ba2\u9605\u6a21\u5f0f\u4e0e\u5de5\u4f5c\u961f\u5217\u6a21\u5f0f\u7684\u533a\u522b<\/strong><\/h5>\n<p>1\u3001\u5de5\u4f5c\u961f\u5217\u6a21\u5f0f\u4e0d\u7528\u5b9a\u4e49\u4ea4\u6362\u673a\uff0c\u800c\u53d1\u5e03\/\u8ba2\u9605\u6a21\u5f0f\u9700\u8981\u5b9a\u4e49\u4ea4\u6362\u673a\u3002<\/p>\n<p>2\u3001\u53d1\u5e03\/\u8ba2\u9605\u6a21\u5f0f\u7684\u751f\u4ea7\u65b9\u662f\u9762\u5411\u4ea4\u6362\u673a\u53d1\u9001\u6d88\u606f\uff0c\u5de5\u4f5c\u961f\u5217\u6a21\u5f0f\u7684\u751f\u4ea7\u65b9\u662f\u9762\u5411\u961f\u5217\u53d1\u9001\u6d88\u606f(\u5e95\u5c42\u4f7f\u7528\u9ed8\u8ba4\u4ea4\u6362\u673a)\u3002<\/p>\n<p>3\u3001\u53d1\u5e03\/\u8ba2\u9605\u6a21\u5f0f\u9700\u8981\u8bbe\u7f6e\u961f\u5217\u548c\u4ea4\u6362\u673a\u7684\u7ed1\u5b9a\uff0c\u5de5\u4f5c\u961f\u5217\u6a21\u5f0f\u4e0d\u9700\u8981\u8bbe\u7f6e\uff0c\u5b9e\u9645\u4e0a\u5de5\u4f5c\u961f\u5217\u6a21\u5f0f\u4f1a\u5c06\u961f\u5217\u7ed1 \u5b9a\u5230\u9ed8\u8ba4\u7684\u4ea4\u6362\u673a .<\/p>\n<h3>9.4. Routing\u8def\u7531\u6a21\u5f0f(direct)<\/h3>\n<h4>\u6a21\u5f0f\u8bf4\u660e<\/h4>\n<h5>\u8def\u7531\u6a21\u5f0f\u7279\u70b9\uff1a<\/h5>\n<ul>\n<li>\u961f\u5217\u4e0e\u4ea4\u6362\u673a\u7684\u7ed1\u5b9a\uff0c\u4e0d\u80fd\u662f\u4efb\u610f\u7ed1\u5b9a\u4e86\uff0c\u800c\u662f\u8981\u6307\u5b9a\u4e00\u4e2a<code>RoutingKey<\/code>\uff08\u8def\u7531key\uff09<\/li>\n<li>\u6d88\u606f\u7684\u53d1\u9001\u65b9\u5728 \u5411 Exchange\u53d1\u9001\u6d88\u606f\u65f6\uff0c\u4e5f\u5fc5\u987b\u6307\u5b9a\u6d88\u606f\u7684 <code>RoutingKey<\/code>\u3002<\/li>\n<li>Exchange\u4e0d\u518d\u628a\u6d88\u606f\u4ea4\u7ed9\u6bcf\u4e00\u4e2a\u7ed1\u5b9a\u7684\u961f\u5217\uff0c\u800c\u662f\u6839\u636e\u6d88\u606f\u7684<code>Routing Key<\/code>\u8fdb\u884c\u5224\u65ad\uff0c\u53ea\u6709\u961f\u5217\u7684<code>Routingkey<\/code>\u4e0e\u6d88\u606f\u7684 <code>Routing key<\/code>\u5b8c\u5168\u4e00\u81f4\uff0c\u624d\u4f1a\u63a5\u6536\u5230\u6d88\u606f<\/li>\n<\/ul>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/1556029284397.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/1556029284397.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"1556029284397\" \/><\/div><\/p>\n<h5>\u56fe\u89e3\uff1a<\/h5>\n<ul>\n<li>P\uff1a\u751f\u4ea7\u8005\uff0c\u5411Exchange\u53d1\u9001\u6d88\u606f\uff0c\u53d1\u9001\u6d88\u606f\u65f6\uff0c\u4f1a\u6307\u5b9a\u4e00\u4e2arouting key\u3002<\/li>\n<li>X\uff1aExchange\uff08\u4ea4\u6362\u673a\uff09\uff0c\u63a5\u6536\u751f\u4ea7\u8005\u7684\u6d88\u606f\uff0c\u7136\u540e\u628a\u6d88\u606f\u9012\u4ea4\u7ed9 \u4e0erouting key\u5b8c\u5168\u5339\u914d\u7684\u961f\u5217<\/li>\n<li>C1\uff1a\u6d88\u8d39\u8005\uff0c\u5176\u6240\u5728\u961f\u5217\u6307\u5b9a\u4e86\u9700\u8981routing key \u4e3a error \u7684\u6d88\u606f<\/li>\n<li>C2\uff1a\u6d88\u8d39\u8005\uff0c\u5176\u6240\u5728\u961f\u5217\u6307\u5b9a\u4e86\u9700\u8981routing key \u4e3a info\u3001error\u3001warning \u7684\u6d88\u606f<\/li>\n<\/ul>\n<h4>\u4ee3\u7801<\/h4>\n<p>\u5728\u7f16\u7801\u4e0a\u4e0e <code>Publish\/Subscribe\u53d1\u5e03\u4e0e\u8ba2\u9605\u6a21\u5f0f<\/code> \u7684\u533a\u522b\u662f\u4ea4\u6362\u673a\u7684\u7c7b\u578b\u4e3a\uff1aDirect\uff0c\u8fd8\u6709\u961f\u5217\u7ed1\u5b9a\u4ea4\u6362\u673a\u7684\u65f6\u5019\u9700\u8981\u6307\u5b9arouting key\u3002<\/p>\n<h5>1.\u751f\u4ea7\u8005\uff1a<\/h5>\n<pre><code class=\"language-java \">package com.glj.rabitmq.routing;\n\nimport com.glj.rabitmq.util.ConnectionUtil;\nimport com.rabbitmq.client.BuiltinExchangeType;\nimport com.rabbitmq.client.Channel;\nimport com.rabbitmq.client.Connection;\n\n\/**\n * Created with IntelliJ IDEA.\n *\n * @Author: GuoLiangJun\n * @Date: 2021\/6\/20\n * @Time: 20:16\n *\/\npublic class Producer {\n\n    \/\/\u4ea4\u6362\u673a\u540d\u79f0\n    static final String FANOUT_EXCHAGE = \"direct_exchange\";\n    \/\/\u961f\u5217\u540d\u79f0\n    static final String FANOUT_QUEUE_1 = \"direct_queue_1\";\n    \/\/\u961f\u5217\u540d\u79f0\n    static final String FANOUT_QUEUE_2 = \"direct_queue_2\";\n\n    public static void main(String[] args) {\n        try(\n                \/\/ \u521b\u5efa\u8fde\u63a5\n                Connection connection = ConnectionUtil.getConnection();\n                \/\/ \u521b\u5efa\u9891\u9053\n                Channel channel = connection.createChannel()\n        ){\n            \/**\n                \u58f0\u660e\u4ea4\u6362\u673a\n                exchangeDeclare(String exchange, BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, Map&lt;String, Object&gt; arguments)\n               \u53c2\u6570\uff1a\n                1. exchange:\u4ea4\u6362\u673a\u540d\u79f0\n                2. type:\u4ea4\u6362\u673a\u7c7b\u578b\n                    DIRECT(\"direct\"),\uff1a\u5b9a\u5411\n                    FANOUT(\"fanout\"),\uff1a\u6247\u5f62\uff08\u5e7f\u64ad\uff09\uff0c\u53d1\u9001\u6d88\u606f\u5230\u6bcf\u4e00\u4e2a\u4e0e\u4e4b\u7ed1\u5b9a\u961f\u5217\u3002\n                    TOPIC(\"topic\"),\u901a\u914d\u7b26\u7684\u65b9\u5f0f\n                    HEADERS(\"headers\");\u53c2\u6570\u5339\u914d\n\n                3. durable:\u662f\u5426\u6301\u4e45\u5316\n                4. autoDelete:\u81ea\u52a8\u5220\u9664\n                5. internal\uff1a\u5185\u90e8\u4f7f\u7528\u3002 \u4e00\u822cfalse\n                6. arguments\uff1a\u53c2\u6570\n             *\/\n            channel.exchangeDeclare(FANOUT_EXCHAGE, BuiltinExchangeType.DIRECT,true,false,false,null);\n\n            \/\/ \u58f0\u660e\uff08\u521b\u5efa\uff09\u961f\u5217\n            \/**\n             * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n             * \u53c2\u65702\uff1a\u662f\u5426\u5b9a\u4e49\u6301\u4e45\u5316\u961f\u5217\n             * \u53c2\u65703\uff1a\u662f\u5426\u72ec\u5360\u672c\u6b21\u8fde\u63a5\n             * \u53c2\u65704\uff1a\u662f\u5426\u5728\u4e0d\u4f7f\u7528\u7684\u65f6\u5019\u81ea\u52a8\u5220\u9664\u961f\u5217\n             * \u53c2\u65705\uff1a\u961f\u5217\u5176\u5b83\u53c2\u6570\n             *\/\n            channel.queueDeclare(FANOUT_QUEUE_1,true,false,false,null);\n            channel.queueDeclare(FANOUT_QUEUE_2,true,false,false,null);\n\n            \/**\n             * \u961f\u5217\u7ed1\u5b9a\u4ea4\u6362\u673a\n            queueBind(String queue, String exchange, String routingKey)\n            \u53c2\u6570\uff1a\n                1. queue\uff1a\u961f\u5217\u540d\u79f0\n                2. exchange\uff1a\u4ea4\u6362\u673a\u540d\u79f0\n                3. routingKey\uff1a\u8def\u7531\u952e\uff0c\u7ed1\u5b9a\u89c4\u5219\n                    \u5982\u679c\u4ea4\u6362\u673a\u7684\u7c7b\u578b\u4e3afanout \uff0croutingKey\u8bbe\u7f6e\u4e3a\"\"\n             *\/\n            channel.queueBind(FANOUT_QUEUE_1,FANOUT_EXCHAGE,\"error\");\n            channel.queueBind(FANOUT_QUEUE_2,FANOUT_EXCHAGE,\"error\");\n            channel.queueBind(FANOUT_QUEUE_2,FANOUT_EXCHAGE,\"info\");\n            channel.queueBind(FANOUT_QUEUE_2,FANOUT_EXCHAGE,\"warn\");\n\n            \/\/ \u8981\u53d1\u9001\u7684\u4fe1\u606f\n            String mes = \"rabitmq---info\";\n            \/**\n             * \u53c2\u65701\uff1a\u4ea4\u6362\u673a\u540d\u79f0\uff0c\u5982\u679c\u6ca1\u6709\u6307\u5b9a\u5219\u4f7f\u7528\u9ed8\u8ba4Default Exchage\n             * \u53c2\u65702\uff1a\u8def\u7531key,\u7b80\u5355\u6a21\u5f0f\u53ef\u4ee5\u4f20\u9012\u961f\u5217\u540d\u79f0\n             * \u53c2\u65703\uff1a\u6d88\u606f\u5176\u5b83\u5c5e\u6027\n             * \u53c2\u65704\uff1a\u6d88\u606f\u5185\u5bb9\n             *\/\n            channel.basicPublish(FANOUT_EXCHAGE, \"info\", null, mes.getBytes());\n            System.out.println(\"\u5df2\u53d1\u9001\u6d88\u606f\uff1a\" + mes);\n\n            \/\/ \u8981\u53d1\u9001\u7684\u4fe1\u606f\n            mes = \"rabitmq---error\";\n            channel.basicPublish(FANOUT_EXCHAGE, \"error\", null, mes.getBytes());\n            System.out.println(\"\u5df2\u53d1\u9001\u6d88\u606f\uff1a\" + mes);\n        }catch (Exception e){\n            e.printStackTrace();\n        }\n    }\n\n}\n\n<\/code><\/pre>\n<h5>2.\u6d88\u8d39\u80051\uff1a<\/h5>\n<pre><code class=\"language-java \">package com.glj.rabitmq.routing;\n\nimport com.glj.rabitmq.util.ConnectionUtil;\nimport com.rabbitmq.client.*;\n\nimport java.io.IOException;\n\n\/**\n * Created with IntelliJ IDEA.\n *\n * @Author: GuoLiangJun\n * @Date: 2021\/6\/20\n * @Time: 20:44\n *\/\npublic class Consumer1 {\n\n    \/\/\u4ea4\u6362\u673a\u540d\u79f0\n    static final String FANOUT_EXCHAGE = \"direct_exchange\";\n    \/\/\u961f\u5217\u540d\u79f0\n    static final String FANOUT_QUEUE_1 = \"direct_queue_1\";\n\n    public static void main(String[] args) throws Exception {\n\n        \/\/ \u521b\u5efa\u8fde\u63a5\n        Connection connection = ConnectionUtil.getConnection();\n        \/\/ \u521b\u5efa\u9891\u9053\n        Channel channel = connection.createChannel();\n\n        \/**\n         \u58f0\u660e\u4ea4\u6362\u673a\n         exchangeDeclare(String exchange, BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, Map&lt;String, Object&gt; arguments)\n         \u53c2\u6570\uff1a\n         1. exchange:\u4ea4\u6362\u673a\u540d\u79f0\n         2. type:\u4ea4\u6362\u673a\u7c7b\u578b\n         DIRECT(\"direct\"),\uff1a\u5b9a\u5411\n         FANOUT(\"fanout\"),\uff1a\u6247\u5f62\uff08\u5e7f\u64ad\uff09\uff0c\u53d1\u9001\u6d88\u606f\u5230\u6bcf\u4e00\u4e2a\u4e0e\u4e4b\u7ed1\u5b9a\u961f\u5217\u3002\n         TOPIC(\"topic\"),\u901a\u914d\u7b26\u7684\u65b9\u5f0f\n         HEADERS(\"headers\");\u53c2\u6570\u5339\u914d\n\n         3. durable:\u662f\u5426\u6301\u4e45\u5316\n         4. autoDelete:\u81ea\u52a8\u5220\u9664\n         5. internal\uff1a\u5185\u90e8\u4f7f\u7528\u3002 \u4e00\u822cfalse\n         6. arguments\uff1a\u53c2\u6570\n         *\/\n        channel.exchangeDeclare(FANOUT_EXCHAGE, BuiltinExchangeType.DIRECT,true,false,false,null);\n\n        \/\/ \u58f0\u660e\uff08\u521b\u5efa\uff09\u961f\u5217\n        \/**\n         * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n         * \u53c2\u65702\uff1a\u662f\u5426\u5b9a\u4e49\u6301\u4e45\u5316\u961f\u5217\n         * \u53c2\u65703\uff1a\u662f\u5426\u72ec\u5360\u672c\u6b21\u8fde\u63a5\n         * \u53c2\u65704\uff1a\u662f\u5426\u5728\u4e0d\u4f7f\u7528\u7684\u65f6\u5019\u81ea\u52a8\u5220\u9664\u961f\u5217\n         * \u53c2\u65705\uff1a\u961f\u5217\u5176\u5b83\u53c2\u6570\n         *\/\n        channel.queueDeclare(FANOUT_QUEUE_1,true,false,false,null);\n\n        \/**\n         * \u961f\u5217\u7ed1\u5b9a\u4ea4\u6362\u673a\n         queueBind(String queue, String exchange, String routingKey)\n         \u53c2\u6570\uff1a\n         1. queue\uff1a\u961f\u5217\u540d\u79f0\n         2. exchange\uff1a\u4ea4\u6362\u673a\u540d\u79f0\n         3. routingKey\uff1a\u8def\u7531\u952e\uff0c\u7ed1\u5b9a\u89c4\u5219\n         \u5982\u679c\u4ea4\u6362\u673a\u7684\u7c7b\u578b\u4e3afanout \uff0croutingKey\u8bbe\u7f6e\u4e3a\"\"\n         *\/\n        channel.queueBind(FANOUT_QUEUE_1,FANOUT_EXCHAGE,\"error\");\n\n        DefaultConsumer defaultConsumer = new DefaultConsumer(channel){\n            @Override\n            \/**\n             \u56de\u8c03\u65b9\u6cd5\uff0c\u5f53\u4ecb\u7ecd\u6d88\u606f\u540e\uff0c\u4f1a\u81ea\u52a8\u6267\u884c\u8be5\u65b9\u6cd5\n             * consumerTag \u6d88\u606f\u8005\u6807\u7b7e\uff0c\u5728channel.basicConsume\u65f6\u5019\u53ef\u4ee5\u6307\u5b9a\n             * envelope \u6d88\u606f\u5305\u7684\u5185\u5bb9\uff0c\u53ef\u4ece\u4e2d\u83b7\u53d6\u6d88\u606fid\uff0c\u6d88\u606froutingkey\uff0c\u4ea4\u6362\u673a\uff0c\u6d88\u606f\u548c\u91cd\u4f20\u6807\u5fd7(\u6536\u5230\u6d88\u606f\u5931\u8d25\u540e\u662f\u5426\u9700\u8981\u91cd\u65b0\u53d1\u9001)\n             * properties \u5c5e\u6027\u4fe1\u606f\n             * body \u6d88\u606f\n             *\/\n            public void handleDelivery(String consumerTag,\n                                       Envelope envelope,\n                                       AMQP.BasicProperties properties,\n                                       byte[] body) throws IOException {\n                \/\/\u6536\u5230\u7684\u6d88\u606f\n                System.out.println(\"\u6d88\u8d39\u80051-\u63a5\u6536\u5230\u7684\u6d88\u606f\u4e3a\uff1a\" + new String(body, \"utf-8\"));\n\n            }\n        };\n        \/\/\u76d1\u542c\u6d88\u606f\n        \/**\n         * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n         * \u53c2\u65702\uff1a\u662f\u5426\u81ea\u52a8\u786e\u8ba4\uff0c\u8bbe\u7f6e\u4e3atrue\u4e3a\u8868\u793a\u6d88\u606f\u63a5\u6536\u5230\u81ea\u52a8\u5411mq\u56de\u590d\u63a5\u6536\u5230\u4e86\uff0cmq\u63a5\u6536\u5230\u56de\u590d\u4f1a\u5220\u9664\u6d88\u606f\uff0c\u8bbe\u7f6e\u4e3afalse\u5219\u9700\u8981\u624b\u52a8\u786e\u8ba4\n         * \u53c2\u65703\uff1a\u6d88\u606f\u63a5\u6536\u5230\u540e\u56de\u8c03\n         *\/\n        channel.basicConsume(FANOUT_QUEUE_1,true,defaultConsumer);\n\n        \/\/\u4e0d\u5173\u95ed\u8d44\u6e90\uff0c\u5e94\u8be5\u4e00\u76f4\u76d1\u542c\u6d88\u606f\n        \/\/channel.close();\n        \/\/connection.close();\n    }\n\n}\n\n<\/code><\/pre>\n<h5>3.\u6d88\u8d39\u80052\uff1a<\/h5>\n<pre><code class=\"language-java \">package com.glj.rabitmq.routing;\n\nimport com.glj.rabitmq.util.ConnectionUtil;\nimport com.rabbitmq.client.*;\n\nimport java.io.IOException;\n\n\/**\n * Created with IntelliJ IDEA.\n *\n * @Author: GuoLiangJun\n * @Date: 2021\/6\/20\n * @Time: 20:44\n *\/\npublic class Consumer2 {\n\n    \/\/\u4ea4\u6362\u673a\u540d\u79f0\n    static final String FANOUT_EXCHAGE = \"direct_exchange\";\n    \/\/\u961f\u5217\u540d\u79f0\n    static final String FANOUT_QUEUE_1 = \"direct_queue_2\";\n\n    public static void main(String[] args) throws Exception {\n\n        \/\/ \u521b\u5efa\u8fde\u63a5\n        Connection connection = ConnectionUtil.getConnection();\n        \/\/ \u521b\u5efa\u9891\u9053\n        Channel channel = connection.createChannel();\n\n        \/**\n         \u58f0\u660e\u4ea4\u6362\u673a\n         exchangeDeclare(String exchange, BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, Map&lt;String, Object&gt; arguments)\n         \u53c2\u6570\uff1a\n         1. exchange:\u4ea4\u6362\u673a\u540d\u79f0\n         2. type:\u4ea4\u6362\u673a\u7c7b\u578b\n         DIRECT(\"direct\"),\uff1a\u5b9a\u5411\n         FANOUT(\"fanout\"),\uff1a\u6247\u5f62\uff08\u5e7f\u64ad\uff09\uff0c\u53d1\u9001\u6d88\u606f\u5230\u6bcf\u4e00\u4e2a\u4e0e\u4e4b\u7ed1\u5b9a\u961f\u5217\u3002\n         TOPIC(\"topic\"),\u901a\u914d\u7b26\u7684\u65b9\u5f0f\n         HEADERS(\"headers\");\u53c2\u6570\u5339\u914d\n\n         3. durable:\u662f\u5426\u6301\u4e45\u5316\n         4. autoDelete:\u81ea\u52a8\u5220\u9664\n         5. internal\uff1a\u5185\u90e8\u4f7f\u7528\u3002 \u4e00\u822cfalse\n         6. arguments\uff1a\u53c2\u6570\n         *\/\n        channel.exchangeDeclare(FANOUT_EXCHAGE, BuiltinExchangeType.DIRECT,true,false,false,null);\n\n        \/\/ \u58f0\u660e\uff08\u521b\u5efa\uff09\u961f\u5217\n        \/**\n         * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n         * \u53c2\u65702\uff1a\u662f\u5426\u5b9a\u4e49\u6301\u4e45\u5316\u961f\u5217\n         * \u53c2\u65703\uff1a\u662f\u5426\u72ec\u5360\u672c\u6b21\u8fde\u63a5\n         * \u53c2\u65704\uff1a\u662f\u5426\u5728\u4e0d\u4f7f\u7528\u7684\u65f6\u5019\u81ea\u52a8\u5220\u9664\u961f\u5217\n         * \u53c2\u65705\uff1a\u961f\u5217\u5176\u5b83\u53c2\u6570\n         *\/\n        channel.queueDeclare(FANOUT_QUEUE_1,true,false,false,null);\n\n        \/**\n         * \u961f\u5217\u7ed1\u5b9a\u4ea4\u6362\u673a\n         queueBind(String queue, String exchange, String routingKey)\n         \u53c2\u6570\uff1a\n         1. queue\uff1a\u961f\u5217\u540d\u79f0\n         2. exchange\uff1a\u4ea4\u6362\u673a\u540d\u79f0\n         3. routingKey\uff1a\u8def\u7531\u952e\uff0c\u7ed1\u5b9a\u89c4\u5219\n         \u5982\u679c\u4ea4\u6362\u673a\u7684\u7c7b\u578b\u4e3afanout \uff0croutingKey\u8bbe\u7f6e\u4e3a\"\"\n         *\/\n        channel.queueBind(FANOUT_QUEUE_1,FANOUT_EXCHAGE,\"error\");\n        channel.queueBind(FANOUT_QUEUE_1,FANOUT_EXCHAGE,\"info\");\n        channel.queueBind(FANOUT_QUEUE_1,FANOUT_EXCHAGE,\"warn\");\n\n        DefaultConsumer defaultConsumer = new DefaultConsumer(channel){\n            @Override\n            \/**\n             \u56de\u8c03\u65b9\u6cd5\uff0c\u5f53\u4ecb\u7ecd\u6d88\u606f\u540e\uff0c\u4f1a\u81ea\u52a8\u6267\u884c\u8be5\u65b9\u6cd5\n             * consumerTag \u6d88\u606f\u8005\u6807\u7b7e\uff0c\u5728channel.basicConsume\u65f6\u5019\u53ef\u4ee5\u6307\u5b9a\n             * envelope \u6d88\u606f\u5305\u7684\u5185\u5bb9\uff0c\u53ef\u4ece\u4e2d\u83b7\u53d6\u6d88\u606fid\uff0c\u6d88\u606froutingkey\uff0c\u4ea4\u6362\u673a\uff0c\u6d88\u606f\u548c\u91cd\u4f20\u6807\u5fd7(\u6536\u5230\u6d88\u606f\u5931\u8d25\u540e\u662f\u5426\u9700\u8981\u91cd\u65b0\u53d1\u9001)\n             * properties \u5c5e\u6027\u4fe1\u606f\n             * body \u6d88\u606f\n             *\/\n            public void handleDelivery(String consumerTag,\n                                       Envelope envelope,\n                                       AMQP.BasicProperties properties,\n                                       byte[] body) throws IOException {\n                \/\/\u6536\u5230\u7684\u6d88\u606f\n                System.out.println(\"\u6d88\u8d39\u80052-\u63a5\u6536\u5230\u7684\u6d88\u606f\u4e3a\uff1a\" + new String(body, \"utf-8\"));\n\n            }\n        };\n        \/\/\u76d1\u542c\u6d88\u606f\n        \/**\n         * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n         * \u53c2\u65702\uff1a\u662f\u5426\u81ea\u52a8\u786e\u8ba4\uff0c\u8bbe\u7f6e\u4e3atrue\u4e3a\u8868\u793a\u6d88\u606f\u63a5\u6536\u5230\u81ea\u52a8\u5411mq\u56de\u590d\u63a5\u6536\u5230\u4e86\uff0cmq\u63a5\u6536\u5230\u56de\u590d\u4f1a\u5220\u9664\u6d88\u606f\uff0c\u8bbe\u7f6e\u4e3afalse\u5219\u9700\u8981\u624b\u52a8\u786e\u8ba4\n         * \u53c2\u65703\uff1a\u6d88\u606f\u63a5\u6536\u5230\u540e\u56de\u8c03\n         *\/\n        channel.basicConsume(FANOUT_QUEUE_1,true,defaultConsumer);\n\n        \/\/\u4e0d\u5173\u95ed\u8d44\u6e90\uff0c\u5e94\u8be5\u4e00\u76f4\u76d1\u542c\u6d88\u606f\n        \/\/channel.close();\n        \/\/connection.close();\n    }\n\n}\n\n<\/code><\/pre>\n<h5>\u5c0f\u7ed3<\/h5>\n<p>Routing\u6a21\u5f0f\u8981\u6c42\u961f\u5217\u5728\u7ed1\u5b9a\u4ea4\u6362\u673a\u65f6\u8981\u6307\u5b9arouting key\uff0c\u6d88\u606f\u4f1a\u8f6c\u53d1\u5230\u7b26\u5408routing key\u7684\u961f\u5217\u3002<\/p>\n<h3>9.5.Topics\u901a\u914d\u7b26\u6a21\u5f0f<\/h3>\n<h3>\u6a21\u5f0f\u8bf4\u660e<\/h3>\n<p><code>Topic<\/code>\u7c7b\u578b\u4e0e<code>Direct<\/code>\u76f8\u6bd4\uff0c\u90fd\u662f\u53ef\u4ee5\u6839\u636e<code>RoutingKey<\/code>\u628a\u6d88\u606f\u8def\u7531\u5230\u4e0d\u540c\u7684\u961f\u5217\u3002\u53ea\u4e0d\u8fc7<code>Topic<\/code>\u7c7b\u578b<code>Exchange<\/code>\u53ef\u4ee5\u8ba9\u961f\u5217\u5728\u7ed1\u5b9a<code>Routing key<\/code> \u7684\u65f6\u5019<strong>\u4f7f\u7528\u901a\u914d\u7b26<\/strong>\uff01<\/p>\n<p><code>Routingkey<\/code> \u4e00\u822c\u90fd\u662f\u6709\u4e00\u4e2a\u6216\u591a\u4e2a\u5355\u8bcd\u7ec4\u6210\uff0c\u591a\u4e2a\u5355\u8bcd\u4e4b\u95f4\u4ee5\u201d.\u201d\u5206\u5272\uff0c\u4f8b\u5982\uff1a <code>item.insert<\/code><\/p>\n<p>\u901a\u914d\u7b26\u89c4\u5219\uff1a<\/p>\n<p><code>#<\/code>\uff1a\u5339\u914d\u4e00\u4e2a\u6216\u591a\u4e2a\u8bcd<\/p>\n<p><code>*<\/code>\uff1a\u5339\u914d\u4e0d\u591a\u4e0d\u5c11\u6070\u597d1\u4e2a\u8bcd<\/p>\n<p>\u4e3e\u4f8b\uff1a<\/p>\n<p><code>item.#<\/code>\uff1a\u80fd\u591f\u5339\u914d<code>item.insert.abc<\/code> \u6216\u8005 <code>item.insert<\/code><\/p>\n<p><code>item.*<\/code>\uff1a\u53ea\u80fd\u5339\u914d<code>item.insert<\/code><\/p>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/1556031362048.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/1556031362048.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"1556031362048\" \/><\/div><\/p>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/1556031519931.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/1556031519931.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"1556031519931\" \/><\/div><\/p>\n<p>\u56fe\u89e3\uff1a<\/p>\n<ul>\n<li>\u7ea2\u8272Queue\uff1a\u7ed1\u5b9a\u7684\u662f<code>usa.#<\/code> \uff0c\u56e0\u6b64\u51e1\u662f\u4ee5 <code>usa.<\/code>\u5f00\u5934\u7684<code>routing key<\/code> \u90fd\u4f1a\u88ab\u5339\u914d\u5230<\/li>\n<li>\u9ec4\u8272Queue\uff1a\u7ed1\u5b9a\u7684\u662f<code>#.news<\/code> \uff0c\u56e0\u6b64\u51e1\u662f\u4ee5 <code>.news<\/code>\u7ed3\u5c3e\u7684 <code>routing key<\/code> \u90fd\u4f1a\u88ab\u5339\u914d<\/li>\n<\/ul>\n<h4>\u4ee3\u7801<\/h4>\n<p>\u5728\u7f16\u7801\u4e0a\u4e0e <code>\u8def\u7531\u6a21\u5f0f<\/code> \u7684\u533a\u522b\u662f\u4ea4\u6362\u673a\u7684\u7c7b\u578b\u4e3a\uff1aTOPIC\uff0c\u8fd8\u6709<code>\u6d88\u8d39\u8005<\/code>\u4e0d\u9700\u8981\u7ed1\u5b9a\u58f0\u660e\u961f\u5217\u3001\u4e0d\u9700\u8981\u961f\u5217\u7ed1\u5b9a\u4ea4\u6362\u673a\u3002<\/p>\n<h5>1.\u751f\u4ea7\u8005<\/h5>\n<p>\u4f7f\u7528topic\u7c7b\u578b\u7684Exchange\uff0c\u53d1\u9001\u6d88\u606f\u7684routing key\u67093\u79cd\uff1a <code>#.error<\/code>\u3001<code>user.*<\/code>\u3001<code>*.*<\/code>\uff1a<\/p>\n<pre><code class=\"language-java \">package com.glj.rabitmq.topic;\n\nimport com.glj.rabitmq.util.ConnectionUtil;\nimport com.rabbitmq.client.BuiltinExchangeType;\nimport com.rabbitmq.client.Channel;\nimport com.rabbitmq.client.Connection;\n\n\/**\n * Created with IntelliJ IDEA.\n *\n * @Author: GuoLiangJun\n * @Date: 2021\/6\/20\n * @Time: 20:16\n *\/\npublic class Producer {\n\n    \/\/\u4ea4\u6362\u673a\u540d\u79f0\n    static final String EXCHAGE = \"topic_exchange\";\n    \/\/\u961f\u5217\u540d\u79f0\n    static final String QUEUE_1 = \"topic_queue_1\";\n    \/\/\u961f\u5217\u540d\u79f0\n    static final String QUEUE_2 = \"topic_queue_2\";\n\n    public static void main(String[] args) {\n        try(\n                \/\/ \u521b\u5efa\u8fde\u63a5\n                Connection connection = ConnectionUtil.getConnection();\n                \/\/ \u521b\u5efa\u9891\u9053\n                Channel channel = connection.createChannel()\n        ){\n            \/**\n                \u58f0\u660e\u4ea4\u6362\u673a\n                exchangeDeclare(String exchange, BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, Map&lt;String, Object&gt; arguments)\n               \u53c2\u6570\uff1a\n                1. exchange:\u4ea4\u6362\u673a\u540d\u79f0\n                2. type:\u4ea4\u6362\u673a\u7c7b\u578b\n                    DIRECT(\"direct\"),\uff1a\u5b9a\u5411\n                    FANOUT(\"fanout\"),\uff1a\u6247\u5f62\uff08\u5e7f\u64ad\uff09\uff0c\u53d1\u9001\u6d88\u606f\u5230\u6bcf\u4e00\u4e2a\u4e0e\u4e4b\u7ed1\u5b9a\u961f\u5217\u3002\n                    TOPIC(\"topic\"),\u901a\u914d\u7b26\u7684\u65b9\u5f0f\n                    HEADERS(\"headers\");\u53c2\u6570\u5339\u914d\n\n                3. durable:\u662f\u5426\u6301\u4e45\u5316\n                4. autoDelete:\u81ea\u52a8\u5220\u9664\n                5. internal\uff1a\u5185\u90e8\u4f7f\u7528\u3002 \u4e00\u822cfalse\n                6. arguments\uff1a\u53c2\u6570\n             *\/\n            channel.exchangeDeclare(EXCHAGE, BuiltinExchangeType.TOPIC,true,false,false,null);\n\n            \/\/ \u58f0\u660e\uff08\u521b\u5efa\uff09\u961f\u5217\n            \/**\n             * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n             * \u53c2\u65702\uff1a\u662f\u5426\u5b9a\u4e49\u6301\u4e45\u5316\u961f\u5217\n             * \u53c2\u65703\uff1a\u662f\u5426\u72ec\u5360\u672c\u6b21\u8fde\u63a5\n             * \u53c2\u65704\uff1a\u662f\u5426\u5728\u4e0d\u4f7f\u7528\u7684\u65f6\u5019\u81ea\u52a8\u5220\u9664\u961f\u5217\n             * \u53c2\u65705\uff1a\u961f\u5217\u5176\u5b83\u53c2\u6570\n             *\/\n            channel.queueDeclare(QUEUE_1,true,false,false,null);\n            channel.queueDeclare(QUEUE_2,true,false,false,null);\n\n            \/**\n             * \u961f\u5217\u7ed1\u5b9a\u4ea4\u6362\u673a\n            queueBind(String queue, String exchange, String routingKey)\n            \u53c2\u6570\uff1a\n                1. queue\uff1a\u961f\u5217\u540d\u79f0\n                2. exchange\uff1a\u4ea4\u6362\u673a\u540d\u79f0\n                3. routingKey\uff1a\u8def\u7531\u952e\uff0c\u7ed1\u5b9a\u89c4\u5219\n                    \u5982\u679c\u4ea4\u6362\u673a\u7684\u7c7b\u578b\u4e3afanout \uff0croutingKey\u8bbe\u7f6e\u4e3a\"\"\n             *\/\n            channel.queueBind(QUEUE_1,EXCHAGE,\"#.error\");\n            channel.queueBind(QUEUE_2,EXCHAGE,\"user.*\");\n            channel.queueBind(QUEUE_2,EXCHAGE,\"*.*\");\n\n            \/\/ \u8981\u53d1\u9001\u7684\u4fe1\u606f\n            String mes = \"rabitmq---info\";\n            \/**\n             * \u53c2\u65701\uff1a\u4ea4\u6362\u673a\u540d\u79f0\uff0c\u5982\u679c\u6ca1\u6709\u6307\u5b9a\u5219\u4f7f\u7528\u9ed8\u8ba4Default Exchage\n             * \u53c2\u65702\uff1a\u8def\u7531key,\u7b80\u5355\u6a21\u5f0f\u53ef\u4ee5\u4f20\u9012\u961f\u5217\u540d\u79f0\n             * \u53c2\u65703\uff1a\u6d88\u606f\u5176\u5b83\u5c5e\u6027\n             * \u53c2\u65704\uff1a\u6d88\u606f\u5185\u5bb9\n             *\/\n            channel.basicPublish(EXCHAGE, \"user.info\", null, mes.getBytes());\n            System.out.println(\"\u5df2\u53d1\u9001\u6d88\u606f\uff1a\" + mes);\n\n        }catch (Exception e){\n            e.printStackTrace();\n        }\n    }\n\n}\n\n<\/code><\/pre>\n<h5>2.\u6d88\u8d39\u8005:one::<\/h5>\n<pre><code class=\"language-java \">package com.glj.rabitmq.topic;\n\nimport com.glj.rabitmq.util.ConnectionUtil;\nimport com.rabbitmq.client.*;\n\nimport java.io.IOException;\n\n\/**\n * Created with IntelliJ IDEA.\n *\n * @Author: GuoLiangJun\n * @Date: 2021\/6\/20\n * @Time: 20:44\n *\/\npublic class Consumer1 {\n\n    \/\/\u4ea4\u6362\u673a\u540d\u79f0\n    static final String EXCHAGE = \"topic_exchange\";\n    \/\/\u961f\u5217\u540d\u79f0\n    static final String QUEUE_1 = \"topic_queue_1\";\n\n    public static void main(String[] args) throws Exception {\n\n        \/\/ \u521b\u5efa\u8fde\u63a5\n        Connection connection = ConnectionUtil.getConnection();\n        \/\/ \u521b\u5efa\u9891\u9053\n        Channel channel = connection.createChannel();\n\n        \/**\n         \u58f0\u660e\u4ea4\u6362\u673a\n         exchangeDeclare(String exchange, BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, Map&lt;String, Object&gt; arguments)\n         \u53c2\u6570\uff1a\n         1. exchange:\u4ea4\u6362\u673a\u540d\u79f0\n         2. type:\u4ea4\u6362\u673a\u7c7b\u578b\n         DIRECT(\"direct\"),\uff1a\u5b9a\u5411\n         FANOUT(\"fanout\"),\uff1a\u6247\u5f62\uff08\u5e7f\u64ad\uff09\uff0c\u53d1\u9001\u6d88\u606f\u5230\u6bcf\u4e00\u4e2a\u4e0e\u4e4b\u7ed1\u5b9a\u961f\u5217\u3002\n         TOPIC(\"topic\"),\u901a\u914d\u7b26\u7684\u65b9\u5f0f\n         HEADERS(\"headers\");\u53c2\u6570\u5339\u914d\n\n         3. durable:\u662f\u5426\u6301\u4e45\u5316\n         4. autoDelete:\u81ea\u52a8\u5220\u9664\n         5. internal\uff1a\u5185\u90e8\u4f7f\u7528\u3002 \u4e00\u822cfalse\n         6. arguments\uff1a\u53c2\u6570\n         *\/\n        channel.exchangeDeclare(EXCHAGE, BuiltinExchangeType.TOPIC,true,false,false,null);\n\n        DefaultConsumer defaultConsumer = new DefaultConsumer(channel){\n            @Override\n            \/**\n             \u56de\u8c03\u65b9\u6cd5\uff0c\u5f53\u4ecb\u7ecd\u6d88\u606f\u540e\uff0c\u4f1a\u81ea\u52a8\u6267\u884c\u8be5\u65b9\u6cd5\n             * consumerTag \u6d88\u606f\u8005\u6807\u7b7e\uff0c\u5728channel.basicConsume\u65f6\u5019\u53ef\u4ee5\u6307\u5b9a\n             * envelope \u6d88\u606f\u5305\u7684\u5185\u5bb9\uff0c\u53ef\u4ece\u4e2d\u83b7\u53d6\u6d88\u606fid\uff0c\u6d88\u606froutingkey\uff0c\u4ea4\u6362\u673a\uff0c\u6d88\u606f\u548c\u91cd\u4f20\u6807\u5fd7(\u6536\u5230\u6d88\u606f\u5931\u8d25\u540e\u662f\u5426\u9700\u8981\u91cd\u65b0\u53d1\u9001)\n             * properties \u5c5e\u6027\u4fe1\u606f\n             * body \u6d88\u606f\n             *\/\n            public void handleDelivery(String consumerTag,\n                                       Envelope envelope,\n                                       AMQP.BasicProperties properties,\n                                       byte[] body) throws IOException {\n                \/\/\u6536\u5230\u7684\u6d88\u606f\n                System.out.println(\"\u6d88\u8d39\u80051-\u63a5\u6536\u5230\u7684\u6d88\u606f\u4e3a\uff1a\" + new String(body, \"utf-8\"));\n\n            }\n        };\n        \/\/\u76d1\u542c\u6d88\u606f\n        \/**\n         * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n         * \u53c2\u65702\uff1a\u662f\u5426\u81ea\u52a8\u786e\u8ba4\uff0c\u8bbe\u7f6e\u4e3atrue\u4e3a\u8868\u793a\u6d88\u606f\u63a5\u6536\u5230\u81ea\u52a8\u5411mq\u56de\u590d\u63a5\u6536\u5230\u4e86\uff0cmq\u63a5\u6536\u5230\u56de\u590d\u4f1a\u5220\u9664\u6d88\u606f\uff0c\u8bbe\u7f6e\u4e3afalse\u5219\u9700\u8981\u624b\u52a8\u786e\u8ba4\n         * \u53c2\u65703\uff1a\u6d88\u606f\u63a5\u6536\u5230\u540e\u56de\u8c03\n         *\/\n        channel.basicConsume(QUEUE_1,true,defaultConsumer);\n\n        \/\/\u4e0d\u5173\u95ed\u8d44\u6e90\uff0c\u5e94\u8be5\u4e00\u76f4\u76d1\u542c\u6d88\u606f\n        \/\/channel.close();\n        \/\/connection.close();\n    }\n\n}\n\n<\/code><\/pre>\n<h5>3.\u6d88\u8d39\u8005:two::<\/h5>\n<pre><code class=\"language-java \">package com.glj.rabitmq.topic;\n\nimport com.glj.rabitmq.util.ConnectionUtil;\nimport com.rabbitmq.client.*;\n\nimport java.io.IOException;\n\n\/**\n * Created with IntelliJ IDEA.\n *\n * @Author: GuoLiangJun\n * @Date: 2021\/6\/20\n * @Time: 20:44\n *\/\npublic class Consumer2 {\n\n    \/\/\u4ea4\u6362\u673a\u540d\u79f0\n    static final String EXCHAGE = \"topic_exchange\";\n    \/\/\u961f\u5217\u540d\u79f0\n    static final String QUEUE_1 = \"topic_queue_2\";\n\n    public static void main(String[] args) throws Exception {\n\n        \/\/ \u521b\u5efa\u8fde\u63a5\n        Connection connection = ConnectionUtil.getConnection();\n        \/\/ \u521b\u5efa\u9891\u9053\n        Channel channel = connection.createChannel();\n\n        \/**\n         \u58f0\u660e\u4ea4\u6362\u673a\n         exchangeDeclare(String exchange, BuiltinExchangeType type, boolean durable, boolean autoDelete, boolean internal, Map&lt;String, Object&gt; arguments)\n         \u53c2\u6570\uff1a\n         1. exchange:\u4ea4\u6362\u673a\u540d\u79f0\n         2. type:\u4ea4\u6362\u673a\u7c7b\u578b\n         DIRECT(\"direct\"),\uff1a\u5b9a\u5411\n         FANOUT(\"fanout\"),\uff1a\u6247\u5f62\uff08\u5e7f\u64ad\uff09\uff0c\u53d1\u9001\u6d88\u606f\u5230\u6bcf\u4e00\u4e2a\u4e0e\u4e4b\u7ed1\u5b9a\u961f\u5217\u3002\n         TOPIC(\"topic\"),\u901a\u914d\u7b26\u7684\u65b9\u5f0f\n         HEADERS(\"headers\");\u53c2\u6570\u5339\u914d\n\n         3. durable:\u662f\u5426\u6301\u4e45\u5316\n         4. autoDelete:\u81ea\u52a8\u5220\u9664\n         5. internal\uff1a\u5185\u90e8\u4f7f\u7528\u3002 \u4e00\u822cfalse\n         6. arguments\uff1a\u53c2\u6570\n         *\/\n        channel.exchangeDeclare(EXCHAGE, BuiltinExchangeType.TOPIC,true,false,false,null);\n\n        DefaultConsumer defaultConsumer = new DefaultConsumer(channel){\n            @Override\n            \/**\n             \u56de\u8c03\u65b9\u6cd5\uff0c\u5f53\u4ecb\u7ecd\u6d88\u606f\u540e\uff0c\u4f1a\u81ea\u52a8\u6267\u884c\u8be5\u65b9\u6cd5\n             * consumerTag \u6d88\u606f\u8005\u6807\u7b7e\uff0c\u5728channel.basicConsume\u65f6\u5019\u53ef\u4ee5\u6307\u5b9a\n             * envelope \u6d88\u606f\u5305\u7684\u5185\u5bb9\uff0c\u53ef\u4ece\u4e2d\u83b7\u53d6\u6d88\u606fid\uff0c\u6d88\u606froutingkey\uff0c\u4ea4\u6362\u673a\uff0c\u6d88\u606f\u548c\u91cd\u4f20\u6807\u5fd7(\u6536\u5230\u6d88\u606f\u5931\u8d25\u540e\u662f\u5426\u9700\u8981\u91cd\u65b0\u53d1\u9001)\n             * properties \u5c5e\u6027\u4fe1\u606f\n             * body \u6d88\u606f\n             *\/\n            public void handleDelivery(String consumerTag,\n                                       Envelope envelope,\n                                       AMQP.BasicProperties properties,\n                                       byte[] body) throws IOException {\n                \/\/\u6536\u5230\u7684\u6d88\u606f\n                System.out.println(\"\u6d88\u8d39\u80051-\u63a5\u6536\u5230\u7684\u6d88\u606f\u4e3a\uff1a\" + new String(body, \"utf-8\"));\n\n            }\n        };\n        \/\/\u76d1\u542c\u6d88\u606f\n        \/**\n         * \u53c2\u65701\uff1a\u961f\u5217\u540d\u79f0\n         * \u53c2\u65702\uff1a\u662f\u5426\u81ea\u52a8\u786e\u8ba4\uff0c\u8bbe\u7f6e\u4e3atrue\u4e3a\u8868\u793a\u6d88\u606f\u63a5\u6536\u5230\u81ea\u52a8\u5411mq\u56de\u590d\u63a5\u6536\u5230\u4e86\uff0cmq\u63a5\u6536\u5230\u56de\u590d\u4f1a\u5220\u9664\u6d88\u606f\uff0c\u8bbe\u7f6e\u4e3afalse\u5219\u9700\u8981\u624b\u52a8\u786e\u8ba4\n         * \u53c2\u65703\uff1a\u6d88\u606f\u63a5\u6536\u5230\u540e\u56de\u8c03\n         *\/\n        channel.basicConsume(QUEUE_1,true,defaultConsumer);\n\n        \/\/\u4e0d\u5173\u95ed\u8d44\u6e90\uff0c\u5e94\u8be5\u4e00\u76f4\u76d1\u542c\u6d88\u606f\n        \/\/channel.close();\n        \/\/connection.close();\n    }\n\n}\n\n<\/code><\/pre>\n<h5>\u5c0f\u7ed3<\/h5>\n<p>Topic\u4e3b\u9898\u6a21\u5f0f\u53ef\u4ee5\u5b9e\u73b0 <code>Publish\/Subscribe\u53d1\u5e03\u4e0e\u8ba2\u9605\u6a21\u5f0f<\/code> \u548c <code>Routing\u8def\u7531\u6a21\u5f0f<\/code> \u7684\u529f\u80fd\uff1b\u53ea\u662fTopic\u5728\u914d\u7f6erouting key \u7684\u65f6\u5019\u53ef\u4ee5\u4f7f\u7528\u901a\u914d\u7b26\uff0c\u663e\u5f97\u66f4\u52a0\u7075\u6d3b\u3002<\/p>\n<h3>9.6. \u6a21\u5f0f\u603b\u7ed3<\/h3>\n<h4>RabbitMQ\u5de5\u4f5c\u6a21\u5f0f\uff1a<\/h4>\n<h5><strong>1\u3001\u7b80\u5355\u6a21\u5f0f HelloWorld<\/strong><\/h5>\n<p>\u4e00\u4e2a\u751f\u4ea7\u8005\u3001\u4e00\u4e2a\u6d88\u8d39\u8005\uff0c\u4e0d\u9700\u8981\u8bbe\u7f6e\u4ea4\u6362\u673a\uff08\u4f7f\u7528\u9ed8\u8ba4\u7684\u4ea4\u6362\u673a\uff09<\/p>\n<h5><strong>2\u3001\u5de5\u4f5c\u961f\u5217\u6a21\u5f0f Work Queue<\/strong><\/h5>\n<p>\u4e00\u4e2a\u751f\u4ea7\u8005\u3001\u591a\u4e2a\u6d88\u8d39\u8005\uff08\u7ade\u4e89\u5173\u7cfb\uff09\uff0c\u4e0d\u9700\u8981\u8bbe\u7f6e\u4ea4\u6362\u673a\uff08\u4f7f\u7528\u9ed8\u8ba4\u7684\u4ea4\u6362\u673a\uff09<\/p>\n<h5><strong>3\u3001\u53d1\u5e03\u8ba2\u9605\u6a21\u5f0f Publish\/subscribe<\/strong><\/h5>\n<p>\u9700\u8981\u8bbe\u7f6e\u7c7b\u578b\u4e3afanout\u7684\u4ea4\u6362\u673a\uff0c\u5e76\u4e14\u4ea4\u6362\u673a\u548c\u961f\u5217\u8fdb\u884c\u7ed1\u5b9a\uff0c\u5f53\u53d1\u9001\u6d88\u606f\u5230\u4ea4\u6362\u673a\u540e\uff0c\u4ea4\u6362\u673a\u4f1a\u5c06\u6d88\u606f\u53d1\u9001\u5230\u7ed1\u5b9a\u7684\u961f\u5217<\/p>\n<h5><strong>4\u3001\u8def\u7531\u6a21\u5f0f Routing<\/strong><\/h5>\n<p>\u9700\u8981\u8bbe\u7f6e\u7c7b\u578b\u4e3adirect\u7684\u4ea4\u6362\u673a\uff0c\u4ea4\u6362\u673a\u548c\u961f\u5217\u8fdb\u884c\u7ed1\u5b9a\uff0c\u5e76\u4e14\u6307\u5b9arouting key\uff0c\u5f53\u53d1\u9001\u6d88\u606f\u5230\u4ea4\u6362\u673a\u540e\uff0c\u4ea4\u6362\u673a\u4f1a\u6839\u636erouting key\u5c06\u6d88\u606f\u53d1\u9001\u5230\u5bf9\u5e94\u7684\u961f\u5217<\/p>\n<h5><strong>5\u3001\u901a\u914d\u7b26\u6a21\u5f0f Topic<\/strong><\/h5>\n<p>\u9700\u8981\u8bbe\u7f6e\u7c7b\u578b\u4e3atopic\u7684\u4ea4\u6362\u673a\uff0c\u4ea4\u6362\u673a\u548c\u961f\u5217\u8fdb\u884c\u7ed1\u5b9a\uff0c\u5e76\u4e14\u6307\u5b9a\u901a\u914d\u7b26\u65b9\u5f0f\u7684routing key\uff0c\u5f53\u53d1\u9001\u6d88\u606f\u5230\u4ea4\u6362\u673a\u540e\uff0c\u4ea4\u6362\u673a\u4f1a\u6839\u636erouting key\u5c06\u6d88\u606f\u53d1\u9001\u5230\u5bf9\u5e94\u7684\u961f\u5217<\/p>\n<h2>10.Spring Boot\u6574\u5408RabbitMQ<\/h2>\n<p>\u5728Spring\u9879\u76ee\u4e2d\uff0c\u53ef\u4ee5\u4f7f\u7528Spring-Rabbit\u53bb\u64cd\u4f5cRabbitMQ<br \/>\nhttps:\/\/github.com\/spring-projects\/spring-amqp<\/p>\n<p>\u5c24\u5176\u662f\u5728spring boot\u9879\u76ee\u4e2d\u53ea\u9700\u8981\u5f15\u5165\u5bf9\u5e94\u7684amqp\u542f\u52a8\u5668\u4f9d\u8d56\u5373\u53ef\uff0c\u65b9\u4fbf\u7684\u4f7f\u7528RabbitTemplate\u53d1\u9001\u6d88\u606f\uff0c\u4f7f\u7528\u6ce8\u89e3\u63a5\u6536\u6d88\u606f\u3002<\/p>\n<p><em>\u4e00\u822c\u5728\u5f00\u53d1\u8fc7\u7a0b\u4e2d<\/em>\uff1a<\/p>\n<p><strong>\u751f\u4ea7\u8005\u5de5\u7a0b\uff1a<\/strong><\/p>\n<ol>\n<li>application.properties\u6587\u4ef6\u914d\u7f6eRabbitMQ\u76f8\u5173\u4fe1\u606f\uff1b<\/li>\n<li>\u5728\u751f\u4ea7\u8005\u5de5\u7a0b\u4e2d\u7f16\u5199\u914d\u7f6e\u7c7b\uff0c\u7528\u4e8e\u521b\u5efa\u4ea4\u6362\u673a\u548c\u961f\u5217\uff0c\u5e76\u8fdb\u884c\u7ed1\u5b9a<\/p>\n<\/li>\n<li>\n<p>\u6ce8\u5165RabbitTemplate\u5bf9\u8c61\uff0c\u901a\u8fc7RabbitTemplate\u5bf9\u8c61\u53d1\u9001\u6d88\u606f\u5230\u4ea4\u6362\u673a<\/p>\n<\/li>\n<\/ol>\n<p><strong>\u6d88\u8d39\u8005\u5de5\u7a0b\uff1a<\/strong><\/p>\n<ol>\n<li>application.properties\u6587\u4ef6\u914d\u7f6eRabbitMQ\u76f8\u5173\u4fe1\u606f<\/p>\n<\/li>\n<li>\n<p>\u521b\u5efa\u6d88\u606f\u5904\u7406\u7c7b\uff0c\u7528\u4e8e\u63a5\u6536\u961f\u5217\u4e2d\u7684\u6d88\u606f\u5e76\u8fdb\u884c\u5904\u7406<\/p>\n<\/li>\n<\/ol>\n<h3>10.1 \u642d\u5efa\u751f\u4ea7\u8005\u5de5\u7a0b<\/h3>\n<p>\u521b\u5efa\u751f\u4ea7\u8005\u5de5\u7a0brabitmq-producer-boot<\/p>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/image-20210622001415320.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/image-20210622001415320.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"image-20210622001415320\" \/><\/div><\/p>\n<p>pom.xml \u5f15\u5165\uff1a<\/p>\n<pre data-language=XML><code class=\"language-markup \">&lt;dependency&gt;\n    &lt;groupId&gt;org.springframework.boot&lt;\/groupId&gt;\n    &lt;artifactId&gt;spring-boot-starter-amqp&lt;\/artifactId&gt;\n&lt;\/dependency&gt;\n<\/code><\/pre>\n<h4>10.1.1\u914d\u7f6eRabbitMQ<\/h4>\n<h5>\u914d\u7f6e\u6587\u4ef6application.properties<\/h5>\n<pre><code class=\"language-properties \">spring.rabbitmq.host=127.0.0.1\nspring.rabbitmq.port=5672\nspring.rabbitmq.username=hcxtuser\nspring.rabbitmq.password=hcxtuser123!@#\nspring.rabbitmq.virtual-host=\/hcxtuser\n<\/code><\/pre>\n<h5>\u7ed1\u5b9a\u4ea4\u6362\u673a\u548c\u961f\u5217<\/h5>\n<p>\u521b\u5efaRabbitMQ\u961f\u5217\u4e0e\u4ea4\u6362\u673a\u7ed1\u5b9a\u7684\u914d\u7f6e\u7c7bcom.glj.rabbitmq.config.RabbitMQConfig<\/p>\n<pre><code class=\"language-java \">package com.glj.rabbitmq.config;\n\nimport org.springframework.amqp.core.*;\nimport org.springframework.beans.factory.annotation.Qualifier;\nimport org.springframework.context.annotation.Bean;\nimport org.springframework.context.annotation.Configuration;\n\n\/**\n * Created with IntelliJ IDEA.\n *\n * @Author: GuoLiangJun\n * @Date: 2021\/6\/22\n * @Time: 0:02\n *\/\n@Configuration\npublic class RabbitMQConfig {\n\n    \/\/\u4ea4\u6362\u673a\u540d\u79f0\n    public static final String EXCHANGE_NAME = \"boot_topic_exchange\";\n    \/\/\u961f\u5217\u540d\u79f0\n    public static final String QUEUE_NAME = \"boot_queue\";\n\n    \/\/\u58f0\u660e\u4ea4\u6362\u673a\n    @Bean(\"bootExchange\")\n    public Exchange bootExchange(){\n        return ExchangeBuilder.topicExchange(EXCHANGE_NAME).durable(true).build();\n    }\n\n    \/\/\u58f0\u660e\u961f\u5217\n    @Bean(\"bootQueue\")\n    public Queue bootQueue(){\n        return QueueBuilder.durable(QUEUE_NAME).build();\n    }\n\n    \/\/\u7ed1\u5b9a\u961f\u5217\u548c\u4ea4\u6362\u673a\n    @Bean\n    public Binding bootQueueExchange(@Qualifier(\"bootQueue\") Queue queue,\n                                     @Qualifier(\"bootExchange\") Exchange exchange){\n        return BindingBuilder.bind(queue).to(exchange).with(\"boot.#\").noargs();\n    }\n\n}\n\n<\/code><\/pre>\n<h5>\u6d4b\u8bd5.<\/h5>\n<pre><code class=\"language-java \">package com.glj;\n\nimport com.glj.rabbitmq.config.RabbitMQConfig;\nimport org.junit.Test;\nimport org.junit.runner.RunWith;\nimport org.springframework.amqp.rabbit.core.RabbitTemplate;\nimport org.springframework.beans.factory.annotation.Autowired;\nimport org.springframework.boot.test.context.SpringBootTest;\nimport org.springframework.test.context.junit4.SpringRunner;\n\n@SpringBootTest\n@RunWith(SpringRunner.class)\npublic class RabitmqProducerBootApplicationTests {\n\n    @Autowired\n    private RabbitTemplate rabbitTemplate;\n\n    @Test\n    public void testSend() {\n        String msg = \"\u6b64\u6d88\u606f:boot.rabbitmq\";\n        rabbitTemplate.convertAndSend(RabbitMQConfig.EXCHANGE_NAME,\"boot.rabbitmq\",msg);\n    }\n\n}\n\n<\/code><\/pre>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/image-20210622001742704.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/image-20210622001742704.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"image-20210622001742704\" \/><\/div><\/p>\n<h3>10.2 \u642d\u5efa\u6d88\u8d39\u8005\u5de5\u7a0b<\/h3>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='\u7b14\u8bb0\u56fe\u7247\/image-20210622002020872.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"\u7b14\u8bb0\u56fe\u7247\/image-20210622002020872.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"image-20210622002020872\" \/><\/div><\/p>\n<p><span class=\"text-highlighted-inline\" style=\"background-color: #fffd38;\">pom.xml \u548capplication.properties\u4e0e\u751f\u4ea7\u8005\u4e00\u81f4&#8230;<\/span><\/p>\n<h4>10.2.1\u914d\u7f6eRabbitMQ<\/h4>\n<h5>\u6d88\u606f\u76d1\u542c\u5904\u7406\u7c7b<\/h5>\n<p>\u7f16\u5199\u6d88\u606f\u76d1\u542c\u5668com.glj.rabbitmq.listener.RabbitMQListener<\/p>\n<pre><code class=\"language-java \">package com.glj.rabbitmq.listener;\n\n\/**\n * Created with IntelliJ IDEA.\n *\n * @Author: GuoLiangJun\n * @Date: 2021\/6\/22\n * @Time: 0:23\n *\/\n\nimport org.springframework.amqp.core.Message;\nimport org.springframework.amqp.rabbit.annotation.RabbitListener;\nimport org.springframework.stereotype.Component;\n\n@Component\npublic class RabbitMQListener {\n\n    @RabbitListener(queues = \"boot_queue\")\n    public void ListenQueue(Message message){\n        System.out.println(\"\u6d88\u8d39\u8005\u63a5\u6536\u5230\u7684\u6d88\u606f\u4e3a\uff1a\" + new String(message.getBody()));\n    }\n\n}\n\n<\/code><\/pre>\n<h2>11.<strong>RabbitMQ<\/strong> <strong>\u9ad8\u7ea7\u7279\u6027<\/strong><\/h2>\n<h3>11.1 <strong>\u6d88\u606f\u7684\u53ef\u9760\u6295\u9012<\/strong><\/h3>\n<p>\u5728\u4f7f\u7528 RabbitMQ \u7684\u65f6\u5019\uff0c\u4f5c\u4e3a\u6d88\u606f\u53d1\u9001\u65b9\u5e0c\u671b\u675c\u7edd\u4efb\u4f55\u6d88\u606f\u4e22\u5931\u6216\u8005\u6295\u9012\u5931\u8d25\u573a\u666f\u3002RabbitMQ \u4e3a\u6211\u4eec\u63d0\u4f9b\u4e86\u4e24\u79cd\u65b9\u5f0f\u7528\u6765\u63a7\u5236\u6d88\u606f\u7684\u6295\u9012\u53ef\u9760\u6027\u6a21\u5f0f\u3002<\/p>\n<ul>\n<li>confirm \u786e\u8ba4\u6a21\u5f0f<\/li>\n<li>return \u9000\u56de\u6a21\u5f0f<\/li>\n<\/ul>\n<p>rabbitmq \u6574\u4e2a\u6d88\u606f\u6295\u9012\u7684\u8def\u5f84\u4e3a\uff1a<\/p>\n<p>producer&#8212;>rabbitmq broker&#8212;>exchange&#8212;>queue&#8212;>consumer<\/p>\n<ul>\n<li>\u6d88\u606f\u4ece producer \u5230 exchange \u5219\u4f1a\u8fd4\u56de\u4e00\u4e2a confirmCallback \u3002<\/li>\n<li>\u6d88\u606f\u4ece exchange&#8211;>queue \u6295\u9012\u5931\u8d25\u5219\u4f1a\u8fd4\u56de\u4e00\u4e2a returnCallback \u3002<\/li>\n<\/ul>\n<p>\u6211\u4eec\u5c06\u5229\u7528\u8fd9\u4e24\u4e2a callback \u63a7\u5236\u6d88\u606f\u7684\u53ef\u9760\u6027\u6295\u9012<\/p>\n<h4>confirm \u786e\u8ba4\u6a21\u5f0f<\/h4>\n<p>\u6d88\u606f\u4ece producer \u5230 exchange \u5219\u4f1a\u8fd4\u56de\u4e00\u4e2a confirmCallback<\/p>\n<p>\u5728spring boot \u751f\u4ea7\u8005\u4e2d\u7ee7\u7eed\u54b1\u4eec\u7684\u64cd\u4f5c.<\/p>\n<h5>1.\u786e\u8ba4\u6a21\u5f0f\u7684\u5f00\u542f<\/h5>\n<p>\u5728\u914d\u7f6e\u6587\u4ef6application.properties \u65b0\u589e <code>spring.rabbitmq.publisher-confirms=true<\/code><\/p>\n<p>2.\u5728rabbitTemplate \u5b9a\u4e49ConfirmCallBack\u56de\u8c03\u51fd\u6570<\/p>\n<pre><code class=\"language-java \">package com.glj.rabbitmq.config;\n\nimport org.springframework.amqp.core.*;\nimport org.springframework.beans.factory.annotation.Qualifier;\nimport org.springframework.context.annotation.Bean;\nimport org.springframework.context.annotation.Configuration;\n\n\/**\n * Created with IntelliJ IDEA.\n *\n * @Author: GuoLiangJun\n * @Date: 2021\/6\/22\n * @Time: 0:02\n *\/\n@Configuration\npublic class RabbitMQConfigWithConfirm {\n\n    public static final String CONFIRM_EXCHANGE_NAME = \"confirm_exchange\";\n    public static final String CONFIRM_QUEUE_NAME = \"confirm_queue\";\n\n\n    \/\/\u786e\u8ba4\u6a21\u5f0f\n\n    @Bean(\"confirmExchange\")\n    public Exchange confirmExchange(){\n        return new TopicExchange(CONFIRM_EXCHANGE_NAME,true,false,null);\n    }\n\n    @Bean(\"confirmQueue\")\n    public Queue confirmQueue(){\n        return new Queue(CONFIRM_QUEUE_NAME,true,false,false);\n    }\n\n    @Bean\n    public Binding confirmQueueExchange(@Qualifier(\"confirmQueue\") Queue queue,\n                                        @Qualifier(\"confirmExchange\") Exchange exchange){\n        return BindingBuilder.bind(queue).to(exchange).with(\"confirm\").noargs();\n    }\n\n}\n\n<\/code><\/pre>\n<p>\u6d4b\u8bd5\u7c7b\u4e2d\uff1a<\/p>\n<pre><code class=\"language-java \">@Test\npublic void testConfirm(){\n    \/\/ \u5b9a\u4e49\u56de\u8c03\n    rabbitTemplate.setConfirmCallback(new RabbitTemplate.ConfirmCallback() {\n        \/**\n             *\n             * @param correlationData \u76f8\u5173\u914d\u7f6e\u4fe1\u606f\n             * @param ack exchange\u4ea4\u6362\u673a \u662f\u5426\u6210\u529f\u6536\u5230\u6d88\u606f\n             * @param cause \u5931\u8d25\u539f\u56e0\n             *\/\n        @Override\n        public void confirm(CorrelationData correlationData, boolean ack, String cause) {\n            System.out.println(\"confirm\u65b9\u6cd5\u88ab\u6267\u884c\u4e86...\"+ack);\n            if (!ack){\n                \/\/\u63a5\u53d7\u6210\u529f\n                System.out.println(\"\u63a5\u53d7\"+cause);\n            }else{\n                \/\/\u5931\u8d25\n                System.out.println(\"\u5931\u8d25\u539f\u56e0\uff1a\"+cause);\n            }\n        }\n    });\n    String msg = \"\u6b64\u6d88\u606f:confirm \u65b9\u6cd5\u6d4b\u8bd5\";\n    rabbitTemplate.convertAndSend(RabbitMQConfigWithConfirm.CONFIRM_EXCHANGE_NAME,\"confirm\",msg);\n}\n<\/code><\/pre>\n<h4>return \u9000\u56de\u6a21\u5f0f<\/h4>\n<p>\u6d88\u606f\u4ece exchange&#8211;>queue \u6295\u9012\u5931\u8d25\u5219\u4f1a\u8fd4\u56de\u4e00\u4e2a returnCallback \u3002<\/p>\n<p>\u5728spring boot \u751f\u4ea7\u8005\u4e2d\u7ee7\u7eed\u54b1\u4eec\u7684\u64cd\u4f5c.<\/p>\n<h5>1.\u786e\u8ba4\u6a21\u5f0f\u7684\u5f00\u542f<\/h5>\n<p>\u5728\u914d\u7f6e\u6587\u4ef6application.properties \u65b0\u589e <code>spring.rabbitmq.publisher-returns=true<\/code><\/p>\n<p>2.\u5728rabbitTemplate \u5b9a\u4e49ReturnCallBack\u56de\u8c03\u51fd\u6570<\/p>\n<pre><code class=\"language-java \">@Test\npublic void testReturn(){\n    \/\/\u8bbe\u7f6e\u4ea4\u6362\u673a\u5904\u7406\u5931\u8d25\u6d88\u606f\u7684\u6a21\u5f0f\n    rabbitTemplate.setMandatory(true);\n\n    \/\/\u8bbe\u7f6e\u56de\u8c03\n    rabbitTemplate.setReturnCallback(new RabbitTemplate.ReturnCallback() {\n        \/**\n             *\n             * @param message \u6d88\u606f\u5bf9\u8c61\n             * @param replyCode \u8fd4\u56de\u9519\u8bef\u7801\n             * @param replyText \u8fd4\u56de\u9519\u8bef\u4fe1\u606f\n             * @param exchange \u4ea4\u6362\u673a\n             * @param routingKey \u8def\u7531\n             *\/\n        @Override\n        public void returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey) {\n            System.out.println(\"return \u6267\u884c\u4e86....\");\n            System.out.println(\"message\uff1a\"+message);\n            System.out.println(\"replyCode\uff1a\"+replyCode);\n            System.out.println(\"replyText\uff1a\"+replyText);\n            System.out.println(\"exchange\uff1a\"+exchange);\n            System.out.println(\"routingKey\uff1a\"+routingKey);\n        }\n    });\n    String msg = \"\u6b64\u6d88\u606f:confirm-return \u65b9\u6cd5\u6d4b\u8bd5\";\n    rabbitTemplate.convertAndSend(\"confirm_exchange\",\"confirm111\",msg);\n}\n<\/code><\/pre>\n<h4><strong>\u6d88\u606f\u7684\u53ef\u9760\u6295\u9012\u5c0f\u7ed3<\/strong><\/h4>\n<p>\u8bbe\u7f6eConnectionFactory\u7684publisher-confirms=&#8221;true&#8221; \u5f00\u542f \u786e\u8ba4\u6a21\u5f0f\u3002<\/p>\n<p>\u4f7f\u7528rabbitTemplate.setConfirmCallback\u8bbe\u7f6e\u56de\u8c03\u51fd\u6570\u3002\u5f53\u6d88\u606f\u53d1\u9001\u5230exchange\u540e\u56de\u8c03confirm\u65b9\u6cd5\u3002\u5728\u65b9\u6cd5\u4e2d\u5224\u65adack\uff0c\u5982\u679c\u4e3atrue\uff0c\u5219\u53d1\u9001\u6210\u529f\uff0c\u5982\u679c\u4e3afalse\uff0c\u5219\u53d1\u9001\u5931\u8d25\uff0c\u9700\u8981\u5904\u7406\u3002<\/p>\n<p>\u8bbe\u7f6eConnectionFactory\u7684publisher-returns=&#8221;true&#8221; \u5f00\u542f \u9000\u56de\u6a21\u5f0f\u3002<\/p>\n<p>\u4f7f\u7528rabbitTemplate.setReturnCallback\u8bbe\u7f6e\u9000\u56de\u51fd\u6570\uff0c\u5f53\u6d88\u606f\u4eceexchange\u8def\u7531\u5230queue\u5931\u8d25\u540e\uff0c\u5982\u679c\u8bbe\u7f6e\u4e86rabbitTemplate.setMandatory(true)\u53c2\u6570\uff0c\u5219\u4f1a\u5c06\u6d88\u606f\u9000\u56de\u7ed9producer\u3002\u5e76\u6267\u884c\u56de\u8c03\u51fd\u6570returnedMessage\u3002<\/p>\n<p>\u5728RabbitMQ\u4e2d\u4e5f\u63d0\u4f9b\u4e86\u4e8b\u52a1\u673a\u5236\uff0c\u4f46\u662f\u6027\u80fd\u8f83\u5dee\uff0c\u6b64\u5904\u4e0d\u505a\u8bb2\u89e3\u3002\u4f7f\u7528channel\u4e0b\u5217\u65b9\u6cd5\uff0c\u5b8c\u6210\u4e8b\u52a1\u63a7\u5236\uff1a<\/p>\n<ol>\n<li>txSelect(), \u7528\u4e8e\u5c06\u5f53\u524dchannel\u8bbe\u7f6e\u6210transaction\u6a21\u5f0f<\/li>\n<li>txCommit()\uff0c\u7528\u4e8e\u63d0\u4ea4\u4e8b\u52a1<\/li>\n<li>txRollback(),\u7528\u4e8e\u56de\u6eda\u4e8b\u52a1<\/li>\n<\/ol>\n<h4><strong>Consumer Ack<\/strong><\/h4>\n<p>ack\u6307Acknowledge\uff0c\u786e\u8ba4\u3002 \u8868\u793a\u6d88\u8d39\u7aef\u6536\u5230\u6d88\u606f\u540e\u7684\u786e\u8ba4\u65b9\u5f0f\u3002<\/p>\n<p>\u6709\u4e09\u79cd\u786e\u8ba4\u65b9\u5f0f\uff1a<\/p>\n<ol>\n<li>\u81ea\u52a8\u786e\u8ba4\uff1aacknowledge=&#8221;none&#8221;<\/li>\n<li>\u624b\u52a8\u786e\u8ba4\uff1aacknowledge=&#8221;manual&#8221;<\/li>\n<li>\u6839\u636e\u5f02\u5e38\u60c5\u51b5\u786e\u8ba4\uff1aacknowledge=&#8221;auto&#8221;<\/li>\n<\/ol>\n<p>\u5176\u4e2d\u81ea\u52a8\u786e\u8ba4\u662f\u6307\uff0c\u5f53\u6d88\u606f\u4e00\u65e6\u88abConsumer\u63a5\u6536\u5230\uff0c\u5219\u81ea\u52a8\u786e\u8ba4\u6536\u5230\uff0c\u5e76\u5c06\u76f8\u5e94 message \u4ece RabbitMQ \u7684\u6d88\u606f\u7f13\u5b58\u4e2d\u79fb\u9664\u3002\u4f46\u662f\u5728\u5b9e\u9645\u4e1a\u52a1\u5904\u7406\u4e2d\uff0c\u5f88\u53ef\u80fd\u6d88\u606f\u63a5\u6536\u5230\uff0c\u4e1a\u52a1\u5904\u7406\u51fa\u73b0\u5f02\u5e38\uff0c\u90a3\u4e48\u8be5\u6d88\u606f\u5c31\u4f1a\u4e22\u5931\u3002\u5982\u679c\u8bbe\u7f6e\u4e86\u624b\u52a8\u786e\u8ba4\u65b9\u5f0f\uff0c\u5219\u9700\u8981\u5728\u4e1a\u52a1\u5904\u7406\u6210\u529f\u540e\uff0c\u8c03\u7528channel.basicAck()\uff0c\u624b\u52a8\u7b7e\u6536\uff0c\u5982\u679c\u51fa\u73b0\u5f02\u5e38\uff0c\u5219\u8c03\u7528channel.basicNack()\u65b9\u6cd5\uff0c\u8ba9\u5176\u81ea\u52a8\u91cd\u65b0\u53d1\u9001\u6d88\u606f\u3002<\/p>\n<h4><strong>\u6d88\u8d39\u7aef\u9650\u6d41<\/strong><\/h4>\n<p>\u00d8\u914d\u7f6e prefetch\u5c5e\u6027\u8bbe\u7f6e\u6d88\u8d39\u7aef\u4e00\u6b21\u62c9\u53d6\u591a\u5c11\u6d88\u606f<\/p>\n<p>\u00d8\u6d88\u8d39\u7aef\u7684\u786e\u8ba4\u6a21\u5f0f\u4e00\u5b9a\u4e3a\u624b\u52a8\u786e\u8ba4\u3002acknowledge=&#8221;manual&#8221;<\/p>\n<h4><strong>TTL<\/strong><\/h4>\n<p>TTL \u5168\u79f0 Time To Live\uff08\u5b58\u6d3b\u65f6\u95f4\/\u8fc7\u671f\u65f6\u95f4\uff09\u3002<\/p>\n<p>\u5f53\u6d88\u606f\u5230\u8fbe\u5b58\u6d3b\u65f6\u95f4\u540e\uff0c\u8fd8\u6ca1\u6709\u88ab\u6d88\u8d39\uff0c\u4f1a\u88ab\u81ea\u52a8\u6e05\u9664\u3002<\/p>\n<p>RabbitMQ\u53ef\u4ee5\u5bf9\u6d88\u606f\u8bbe\u7f6e\u8fc7\u671f\u65f6\u95f4\uff0c\u4e5f\u53ef\u4ee5\u5bf9\u6574\u4e2a\u961f\u5217\uff08Queue\uff09\u8bbe\u7f6e\u8fc7\u671f\u65f6\u95f4\u3002<\/p>\n<p>\u5b9e\u73b0\uff1a<\/p>\n<p>\u8bbe\u7f6e\u961f\u5217\u8fc7\u671f\u65f6\u95f4\u4f7f\u7528\u53c2\u6570\uff1ax-message-ttl\uff0c\u5355\u4f4d\uff1ams(\u6beb\u79d2)\uff0c\u4f1a\u5bf9\u6574\u4e2a\u961f\u5217\u6d88\u606f\u7edf\u4e00\u8fc7\u671f\u3002<\/p>\n<p>\u8bbe\u7f6e\u6d88\u606f\u8fc7\u671f\u65f6\u95f4\u4f7f\u7528\u53c2\u6570\uff1aexpiration\u3002\u5355\u4f4d\uff1ams(\u6beb\u79d2)\uff0c\u5f53\u8be5\u6d88\u606f\u5728\u961f\u5217\u5934\u90e8\u65f6\uff08\u6d88\u8d39\u65f6\uff09\uff0c\u4f1a\u5355\u72ec\u5224\u65ad\u8fd9\u4e00\u6d88\u606f\u662f\u5426\u8fc7\u671f\u3002<\/p>\n<p>\u5982\u679c\u4e24\u8005\u90fd\u8fdb\u884c\u4e86\u8bbe\u7f6e\uff0c\u4ee5\u65f6\u95f4\u77ed\u7684\u4e3a\u51c6\u3002<\/p>\n<h4><strong>\u6b7b\u4fe1\u961f\u5217<\/strong><\/h4>\n<p>\u6b7b\u4fe1\u961f\u5217\uff0c\u82f1\u6587\u7f29\u5199\uff1aDLX \u3002Dead Letter Exchange\uff08\u6b7b\u4fe1\u4ea4\u6362\u673a\uff09\uff0c\u5f53\u6d88\u606f\u6210\u4e3aDead message\u540e\uff0c\u53ef\u4ee5\u88ab\u91cd\u65b0\u53d1\u9001\u5230\u53e6\u4e00\u4e2a\u4ea4\u6362\u673a\uff0c\u8fd9\u4e2a\u4ea4\u6362\u673a\u5c31\u662fDLX\u3002<\/p>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/image-20210624220505093.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/image-20210624220505093.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"image-20210624220505093\" \/><\/div><\/p>\n<p>\u6d88\u606f\u6210\u4e3a\u6b7b\u4fe1\u7684\u4e09\u79cd\u60c5\u51b5\uff1a<\/p>\n<ol>\n<li>\u961f\u5217\u6d88\u606f\u957f\u5ea6\u5230\u8fbe\u9650\u5236\uff1b<\/p>\n<\/li>\n<li>\n<p>\u6d88\u8d39\u8005\u62d2\u63a5\u6d88\u8d39\u6d88\u606f\uff0cbasicNack\/basicReject,\u5e76\u4e14\u4e0d\u628a\u6d88\u606f\u91cd\u65b0\u653e\u5165\u539f\u76ee\u6807\u961f\u5217,requeue=false\uff1b<\/p>\n<\/li>\n<li>\n<p>\u539f\u961f\u5217\u5b58\u5728\u6d88\u606f\u8fc7\u671f\u8bbe\u7f6e\uff0c\u6d88\u606f\u5230\u8fbe\u8d85\u65f6\u65f6\u95f4\u672a\u88ab\u6d88\u8d39\uff1b<\/p>\n<\/li>\n<\/ol>\n<h5><strong>\u961f\u5217\u7ed1\u5b9a\u6b7b\u4fe1\u4ea4\u6362\u673a\uff1a<\/strong><\/h5>\n<p>\u7ed9\u961f\u5217\u8bbe\u7f6e\u53c2\u6570\uff1a x-dead-letter-exchange \u548c x-dead-letter-routing-key<\/p>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/image-20210624220537822.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/image-20210624220537822.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"image-20210624220537822\" \/><\/div><\/p>\n<h5><strong>\u6b7b\u4fe1\u961f\u5217\u5c0f\u7ed3<\/strong><\/h5>\n<p>1.\u6b7b\u4fe1\u4ea4\u6362\u673a\u548c\u6b7b\u4fe1\u961f\u5217\u548c\u666e\u901a\u7684\u6ca1\u6709\u533a\u522b<\/p>\n<p>2.\u5f53\u6d88\u606f\u6210\u4e3a\u6b7b\u4fe1\u540e\uff0c\u5982\u679c\u8be5\u961f\u5217\u7ed1\u5b9a\u4e86\u6b7b\u4fe1\u4ea4\u6362\u673a\uff0c\u5219\u6d88\u606f\u4f1a\u88ab\u6b7b\u4fe1\u4ea4\u6362\u673a\u91cd\u65b0\u8def\u7531\u5230\u6b7b\u4fe1\u961f\u5217<\/p>\n<p>3.\u6d88\u606f\u6210\u4e3a\u6b7b\u4fe1\u7684\u4e09\u79cd\u60c5\u51b5\uff1a<\/p>\n<ol>\n<li>\u961f\u5217\u6d88\u606f\u957f\u5ea6\u5230\u8fbe\u9650\u5236\uff1b<\/p>\n<\/li>\n<li>\n<p>\u6d88\u8d39\u8005\u62d2\u63a5\u6d88\u8d39\u6d88\u606f\uff0c\u5e76\u4e14\u4e0d\u91cd\u56de\u961f\u5217\uff1b<\/p>\n<\/li>\n<li>\n<p>\u539f\u961f\u5217\u5b58\u5728\u6d88\u606f\u8fc7\u671f\u8bbe\u7f6e\uff0c\u6d88\u606f\u5230\u8fbe\u8d85\u65f6\u65f6\u95f4\u672a\u88ab\u6d88\u8d39\uff1b<\/p>\n<\/li>\n<\/ol>\n<h4><strong>\u5ef6\u8fdf\u961f\u5217<\/strong><\/h4>\n<p>\u5ef6\u8fdf\u961f\u5217\uff0c\u5373\u6d88\u606f\u8fdb\u5165\u961f\u5217\u540e\u4e0d\u4f1a\u7acb\u5373\u88ab\u6d88\u8d39\uff0c\u53ea\u6709\u5230\u8fbe\u6307\u5b9a\u65f6\u95f4\u540e\uff0c\u624d\u4f1a\u88ab\u6d88\u8d39\u3002<\/p>\n<p>\u4f7f\u7528\uff1aTTL+\u6b7b\u4fe1\u961f\u5217 \u7ec4\u5408\u5b9e\u73b0\u5ef6\u8fdf\u961f\u5217\u7684\u6548\u679c\u3002<\/p>\n<p><div class='fancybox-wrapper lazyload-container-unload' data-fancybox='post-images' href='https:\/\/qn.199604.com\/typoraImg\/image-20210624220811711.png'><img class=\"lazyload lazyload-style-1\" src=\"data:image\/svg+xml;base64,PCEtLUFyZ29uTG9hZGluZy0tPgo8c3ZnIHdpZHRoPSIxIiBoZWlnaHQ9IjEiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgc3Ryb2tlPSIjZmZmZmZmMDAiPjxnPjwvZz4KPC9zdmc+\"  decoding=\"async\" data-original=\"https:\/\/qn.199604.com\/typoraImg\/image-20210624220811711.png\" src=\"data:image\/png;base64,iVBORw0KGgoAAAANSUhEUgAAAAEAAAABCAYAAAAfFcSJAAAAAXNSR0IArs4c6QAAAARnQU1BAACxjwv8YQUAAAAJcEhZcwAADsQAAA7EAZUrDhsAAAANSURBVBhXYzh8+PB\/AAffA0nNPuCLAAAAAElFTkSuQmCC\" alt=\"image-20210624220811711\" \/><\/div><\/p>\n<h5><strong>\u5ef6\u8fdf\u961f\u5217\u5c0f\u7ed3<\/strong><\/h5>\n<ol>\n<li>\n<p>\u5ef6\u8fdf\u961f\u5217 \u6307\u6d88\u606f\u8fdb\u5165\u961f\u5217\u540e\uff0c\u53ef\u4ee5\u88ab\u5ef6\u8fdf\u4e00\u5b9a\u65f6\u95f4\uff0c\u518d\u8fdb\u884c\u6d88\u8d39\u3002<\/p>\n<\/li>\n<li>\n<p>RabbitMQ\u6ca1\u6709\u63d0\u4f9b\u5ef6\u8fdf\u961f\u5217\u529f\u80fd\uff0c\u4f46\u662f\u53ef\u4ee5\u4f7f\u7528 \uff1a TTL + DLX \u6765\u5b9e\u73b0\u5ef6\u8fdf\u961f\u5217\u6548\u679c\u3002<\/p>\n<\/li>\n<\/ol>\n","protected":false},"excerpt":{"rendered":"<p>RabbitMQ\u5b66\u4e60\u672d\u8bb0 1.MQ\u6982\u8ff0 MQ\u5168\u79f0 Message Queue\uff08\u6d88\u606f\u961f\u5217\uff09\uff0c\u662f\u5728\u6d88\u606f\u7684\u4f20\u8f93\u8fc7\u7a0b\u4e2d [&hellip;]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[292,340],"tags":[341],"class_list":["post-2061","post","type-post","status-publish","format-standard","hentry","category-java","category-mq","tag-rabbitmq"],"_links":{"self":[{"href":"https:\/\/199604.com\/wp-json\/wp\/v2\/posts\/2061","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/199604.com\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/199604.com\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/199604.com\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/199604.com\/wp-json\/wp\/v2\/comments?post=2061"}],"version-history":[{"count":1,"href":"https:\/\/199604.com\/wp-json\/wp\/v2\/posts\/2061\/revisions"}],"predecessor-version":[{"id":2062,"href":"https:\/\/199604.com\/wp-json\/wp\/v2\/posts\/2061\/revisions\/2062"}],"wp:attachment":[{"href":"https:\/\/199604.com\/wp-json\/wp\/v2\/media?parent=2061"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/199604.com\/wp-json\/wp\/v2\/categories?post=2061"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/199604.com\/wp-json\/wp\/v2\/tags?post=2061"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}