{"id":279,"date":"2023-05-27T20:07:46","date_gmt":"2023-05-27T12:07:46","guid":{"rendered":"https:\/\/xinchewhd.com.cn\/?p=279"},"modified":"2023-05-27T20:07:47","modified_gmt":"2023-05-27T12:07:47","slug":"579ca92387","status":"publish","type":"post","link":"https:\/\/xinchewhd.com.cn\/index.php\/java\/579ca92387\/","title":{"rendered":"RabbitMQ \u6709\u54ea\u51e0\u79cd\u6d88\u606f\u6a21\u5f0f\uff1f"},"content":{"rendered":"
\n

\u539f\u6587\uff1ajuejin.cn\/post\/6998363970037874724<\/span><\/p>\n

\u524d\u8a00<\/span><\/strong><\/h2>\n

Rabbitmq \u662f\u4f7f\u7528 Erlang \u8bed\u8a00\u5f00\u53d1\u7684\u5f00\u6e90\u6d88\u606f\u961f\u5217\u7cfb\u7edf\uff0c\u57fa\u4e8e AMQP \u5b9e\u73b0\uff0c\u662f\u4e00\u79cd\u5e94\u7528\u7a0b\u5e8f\u5bf9\u5e94\u7528\u7a0b\u5e8f\u7684\u901a\u4fe1\u65b9\u6cd5\uff0c\u5e94\u7528\u7a0b\u5e8f\u901a\u8fc7\u8bfb\u5199\u51fa\u5165\u961f\u5217\u7684\u6d88\u606f\u6765\u901a\u4fe1\uff0c\u800c\u65e0\u9700\u4e13\u7528\u8fde\u63a5\u6765\u94fe\u63a5\u5b83\u4eec\u3002\u6d88\u606f\u4f20\u9012\u6307\u7684\u662f\u5e94\u7528\u7a0b\u5e8f\u4e4b\u95f4\u901a\u8fc7\u5728\u6d88\u606f\u4e2d\u53d1\u9001\u6570\u636e\u8fdb\u884c\u901a\u4fe1\uff0c\u800c\u4e0d\u662f\u901a\u8fc7\u76f4\u63a5\u8c03\u7528\u5f7c\u6b64\u901a\u4fe1\uff0c\u76f4\u63a5\u8c03\u7528\u901a\u5e38\u662f\u6307\u8fdc\u7a0b\u8fc7\u7a0b\u8c03\u7528\u7684\u6280\u672f\u3002<\/span><\/span><\/h2>\n

\u6838\u5fc3\u7ec4\u6210<\/span><\/strong><\/h2>\n

    \n
  • \n
    Server\uff1a\u53c8\u79f0 Broker\uff0c\u63a5\u6536\u5ba2\u6237\u7aef\u7684\u8fde\u63a5\uff0c\u5b9e\u73b0 AMQP \u5b9e\u4f53\u670d\u52a1\uff0c\u5b89\u88c5 rabbitmq-server<\/span><\/section>\n<\/li>\n
  • \n
    Connection\uff1a\u8fde\u63a5\uff0c\u5e94\u7528\u7a0b\u5e8f\u4e0eBroker\u7684\u7f51\u7edc\u8fde\u63a5TCP\/IP\/\u4e09\u6b21\u63e1\u624b\u548c\u56db\u6b21\u6325\u624b<\/span><\/section>\n<\/li>\n
  • \n
    Channel\uff1a\u7f51\u7edc\u4fe1\u9053\uff0c\u51e0\u4e4e\u6240\u6709\u64cd\u4f5c\u90fd\u5728 Channel \u4e2d\u8fdb\u884c\uff0cChannel \u662f\u8fdb\u884c\u6d88\u606f\u8bfb\u5199\u7684\u901a\u9053\uff0c\u5ba2\u6237\u7aef\u53ef\u4ee5\u5efa\u7acb\u591a\u4e2a Channel\uff0c\u6bcf\u4e2a Channel \u4ee3\u8868\u4e00\u4e2a\u4f1a\u8bdd\u4efb\u52a1\u3002<\/span><\/section>\n<\/li>\n
  • \n
    Message\uff1a\u6d88\u606f\uff0c\u670d\u52a1\u4e0e\u5e94\u7528\u7a0b\u5e8f\u4e4b\u95f4\u4f20\u9001\u7684\u6570\u636e\uff0c\u7531 Properties \u548c Body \u7ec4\u6210\uff0cProperties \u53ef\u4ee5\u5bf9\u6d88\u606f\u8fdb\u884c\u4fee\u9970\uff0c\u6bd4\u5982\u6d88\u606f\u7684\u4f18\u5148\u7ea7\uff0c\u5ef6\u8fdf\u7b49\u9ad8\u7ea7\u7279\u6027\uff0cBody \u5219\u662f\u6d88\u606f\u4f53\u7684\u5185\u5bb9\u3002<\/span><\/section>\n<\/li>\n
  • \n
    Virtual Host\uff1a\u865a\u62df\u5730\u5740\uff0c\u7528\u4e8e\u8fdb\u884c\u903b\u8f91\u9694\u79bb\uff0c\u6700\u4e0a\u5c42\u7684\u6d88\u606f\u8def\u7531\uff0c\u4e00\u4e2a\u865a\u62df\u4e3b\u673a\u53ef\u4ee5\u6709\u82e5\u5e72\u4e2a exchange \u548c queue\uff0c\u540c\u4e00\u4e2a\u865a\u62df\u4e3b\u673a\u91cc\u9762\u4e0d\u80fd\u6709\u76f8\u540c\u540d\u79f0\u7684 exchange<\/span><\/section>\n<\/li>\n
  • \n
    Exchange\uff1a\u4ea4\u6362\u673a\uff0c\u63a5\u6536\u6d88\u606f\uff0c\u6839\u636e\u8def\u7531\u952e\u53d1\u9001\u6d88\u606f\u5230\u7ed1\u5b9a\u7684\u961f\u5217\uff08\u4e0d\u5177\u5907\u6d88\u606f\u5b58\u50a8\u80fd\u529b\uff09<\/span><\/section>\n<\/li>\n
  • \n
    Bindings\uff1aexchange \u548c queue \u4e4b\u95f4\u7684\u865a\u62df\u8fde\u63a5\uff0cbinding \u4e2d\u53ef\u4ee5\u4fdd\u5b58\u591a\u4e2a routing key<\/span><\/section>\n<\/li>\n
  • \n
    Routing key\uff1a\u662f\u4e00\u4e2a\u8def\u7531\u89c4\u5219\uff0c\u865a\u62df\u673a\u53ef\u4ee5\u7528\u5b83\u6765\u786e\u5b9a\u5982\u4f55\u8def\u7531\u4e00\u4e2a\u7279\u5b9a\u6d88\u606f<\/span><\/section>\n<\/li>\n
  • \n
    Queue\uff1a\u961f\u5217\uff0c\u4e5f\u79f0\u4e3a Message Queue\uff0c\u6d88\u606f\u961f\u5217\uff0c\u4fdd\u5b58\u6d88\u606f\u5e76\u5c06\u5b83\u4eec\u8f6c\u53d1\u7ed9\u6d88\u8d39\u8005<\/span><\/section>\n<\/li>\n<\/ul>\n

    Rabbitmq \u6d88\u606f\u6a21\u5f0f<\/span><\/strong><\/h2>\n

    3.1 Simple \u6a21\u5f0f<\/span><\/strong><\/h2>\n

    Simple \u6a21\u5f0f\u662f\u6700\u7b80\u5355\u7684\u4e00\u4e2a\u6a21\u5f0f\uff0c\u7531\u4e00\u4e2a\u751f\u4ea7\u8005\uff0c\u4e00\u4e2a\u961f\u5217\uff0c\u4e00\u4e2a\u6d88\u8d39\u8005\u7ec4\u6210\uff0c\u751f\u4ea7\u8005\u5c06\u6d88\u606f\u901a\u8fc7\u4ea4\u6362\u673a\uff08\u6b64\u65f6\uff0c\u56fe\u4e2d\u5e76\u6ca1\u6709\u4ea4\u6362\u673a\u7684\u6982\u5ff5\uff0c\u5982\u4e0d\u5b9a\u4e49\u4ea4\u6362\u673a\uff0c\u4f1a\u4f7f\u7528\u9ed8\u8ba4\u7684\u4ea4\u6362\u673a\uff09\u628a\u6d88\u606f\u5b58\u50a8\u5230\u961f\u5217\uff0c\u6d88\u8d39\u8005\u4ece\u961f\u5217\u4e2d\u53d6\u51fa\u6d88\u606f\u8fdb\u884c\u5904\u7406\u3002<\/span><\/p>\n

    Productor<\/span><\/strong><\/p>\n

    public\u00a0class\u00a0Send\u00a0{\n\u00a0\u00a0\u00a0\u00a0private\u00a0final\u00a0static\u00a0String\u00a0QUEUE_NAME\u00a0=\u00a0\"queue1\"<\/span>;\n\n\u00a0\u00a0\u00a0\u00a0public\u00a0static\u00a0void\u00a0main(String[]\u00a0args)\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a01\u3001\u521b\u5efa\u8fde\u63a5\u5de5\u7a0b\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0ConnectionFactory\u00a0factory\u00a0=\u00a0new\u00a0ConnectionFactory();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setHost(\"192.168.96.109\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setVirtualHost(\"\/\"<\/span>);\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Connection\u00a0connection\u00a0=\u00a0null;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Channel\u00a0channel\u00a0=\u00a0null;\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0try\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a02\u3001\u521b\u5efa\u8fde\u63a5\u3001\u901a\u9053\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0connection\u00a0=\u00a0factory.newConnection();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel\u00a0=\u00a0connection.createChannel();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a03\u3001\u58f0\u660e\u961f\u5217\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.queueDeclare(QUEUE_NAME,\u00a0false<\/span>,\u00a0false<\/span>,\u00a0false<\/span>,\u00a0null);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a0\u6d88\u606f\u5185\u5bb9\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0String\u00a0message\u00a0=\u00a0\"Hello\u00a0world\"<\/span>;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a04\u3001\u53d1\u9001\u6d88\u606f\u5230\u6307\u5b9a\u961f\u5217\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.basicPublish(\"\"<\/span>,\u00a0QUEUE_NAME,\u00a0null,\u00a0message.getBytes(StandardCharsets.UTF_8));\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0System.out.println(\"\u00a0[x]\u00a0Sent\u00a0'\"<\/span>\u00a0+\u00a0message\u00a0+\u00a0\"'\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\u00a0catch\u00a0(TimeoutException\u00a0|\u00a0IOException\u00a0e)\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0e.printStackTrace();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\u00a0finally\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a0\u5173\u95ed\u901a\u9053\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0if<\/span>\u00a0(channel\u00a0!=\u00a0null\u00a0&&\u00a0channel.isOpen())\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0try\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.close();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\u00a0catch\u00a0(Exception\u00a0e)\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0e.printStackTrace();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a0\u5173\u95ed\u8fde\u63a5\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0if<\/span>\u00a0(connection\u00a0!=\u00a0null\u00a0&&\u00a0connection.isOpen())\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0try\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0connection.close();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\u00a0catch\u00a0(Exception\u00a0e)\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0e.printStackTrace();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0}\n}\n<\/code><\/pre>\n
    Customer<\/span><\/strong><\/p>\n
    public\u00a0class\u00a0Recv\u00a0{\n\u00a0\u00a0\u00a0\u00a0private\u00a0final\u00a0static\u00a0String\u00a0QUEUE_NAME\u00a0=\u00a0\"queue1\"<\/span>;\n\n\u00a0\u00a0\u00a0\u00a0public\u00a0static\u00a0void\u00a0main(String[]\u00a0args)\u00a0throws\u00a0IOException,\u00a0TimeoutException\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a01\u3001\u521b\u5efa\u8fde\u63a5\u5de5\u7a0b\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0ConnectionFactory\u00a0factory\u00a0=\u00a0new\u00a0ConnectionFactory();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setHost(\"192.168.96.109\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setVirtualHost(\"\/\"<\/span>);\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a02\u3001\u83b7\u53d6\u00a0Connection\u548c\u00a0Channel\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Connection\u00a0connection\u00a0=\u00a0factory.newConnection();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Channel\u00a0channel\u00a0=\u00a0connection.createChannel();\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a03\u3001\u58f0\u660e\u961f\u5217\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.queueDeclare(QUEUE_NAME,\u00a0false<\/span>,\u00a0false<\/span>,\u00a0false<\/span>,\u00a0null);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0System.out.println(\"\u00a0[*]\u00a0Waiting\u00a0for\u00a0messages.\u00a0To\u00a0exit\u00a0press\u00a0CTRL+C\"<\/span>);\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0DeliverCallback\u00a0deliverCallback\u00a0=\u00a0(consumerTag,\u00a0delivery)\u00a0->\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0String\u00a0message\u00a0=\u00a0new\u00a0String(delivery.getBody(),\u00a0\"UTF-8\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0System.out.println(\"\u00a0[x]\u00a0Received\u00a0'\"<\/span>\u00a0+\u00a0message\u00a0+\u00a0\"'\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0};\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.basicConsume(QUEUE_NAME,\u00a0true<\/span>,\u00a0deliverCallback,\u00a0consumerTag\u00a0->\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0});\n\u00a0\u00a0\u00a0\u00a0}\n}\n<\/code><\/pre>\n
    \u89c2\u5bdf\u53ef\u89c6\u5316\u754c\u9762\uff0c\u4f1a\u770b\u5230\u6d88\u606f\u5148\u4f1a\u88ab\u5199\u5165\u5230\u961f\u5217\u4e2d\uff0c\u968f\u540e\u53c8\u88ab\u6d88\u8d39\u8005\u6d88\u8d39\u4e86\u3002<\/span><\/p>\n
    3.2 Fanout \u6a21\u5f0f<\/span><\/strong><\/p>\n
    Fanout\u2014\u2014\u53d1\u5e03\u8ba2\u9605\u6a21\u5f0f\uff0c\u662f\u4e00\u79cd\u5e7f\u64ad\u673a\u5236\u3002<\/span><\/p>\n
    \u6b64\u6a21\u5f0f\u5305\u62ec\uff1a\u4e00\u4e2a\u751f\u4ea7\u8005\u3001\u4e00\u4e2a\u4ea4\u6362\u673a (exchange)\u3001\u591a\u4e2a\u961f\u5217\u3001\u591a\u4e2a\u6d88\u8d39\u8005\u3002\u751f\u4ea7\u8005\u5c06\u6d88\u606f\u53d1\u9001\u5230\u4ea4\u6362\u673a\uff0c\u4ea4\u6362\u673a\u4e0d\u5b58\u50a8\u6d88\u606f\uff0c\u5c06\u6d88\u606f\u5b58\u50a8\u5230\u961f\u5217\uff0c\u6d88\u8d39\u8005\u4ece\u961f\u5217\u4e2d\u53d6\u6d88\u606f\u3002\u5982\u679c\u751f\u4ea7\u8005\u5c06\u6d88\u606f\u53d1\u9001\u5230\u6ca1\u6709\u7ed1\u5b9a\u961f\u5217\u7684\u4ea4\u6362\u673a\u4e0a\uff0c\u6d88\u606f\u5c06\u4e22\u5931\u3002<\/span><\/p>\n
    \u7528 Java demo \u5b9e\u73b0\u6b64\u6a21\u5f0f<\/span><\/p>\n
    Productor<\/span><\/strong><\/p>\n
    public\u00a0class\u00a0Productor\u00a0{\n\u00a0\u00a0\u00a0private\u00a0static\u00a0final\u00a0String\u00a0EXCHANGE_NAME\u00a0=\u00a0\"fanout_exchange\"<\/span>;\n\n\u00a0\u00a0\u00a0public\u00a0static\u00a0void\u00a0main(String[]\u00a0args)\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a01\u3001\u521b\u5efa\u8fde\u63a5\u5de5\u7a0b\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0ConnectionFactory\u00a0factory\u00a0=\u00a0new\u00a0ConnectionFactory();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setHost(\"192.168.96.109\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setUsername(\"admin\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setPassword(\"admin\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setVirtualHost(\"\/\"<\/span>);\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Connection\u00a0connection\u00a0=\u00a0null;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Channel\u00a0channel\u00a0=\u00a0null;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0try\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a02\u3001\u83b7\u53d6\u8fde\u63a5\u3001\u901a\u9053\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0connection\u00a0=\u00a0factory.newConnection();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel\u00a0=\u00a0connection.createChannel();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a0\u6d88\u606f\u5185\u5bb9\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0String\u00a0message\u00a0=\u00a0\"hello\u00a0fanout\u00a0mode\"<\/span>;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a0\u6307\u5b9a\u8def\u7531key\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0String\u00a0routeKey\u00a0=\u00a0\"\"<\/span>;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0String\u00a0type<\/span>\u00a0=\u00a0\"fanout\"<\/span>;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a03\u3001\u58f0\u660e\u4ea4\u6362\u673a\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.exchangeDeclare(EXCHANGE_NAME,\u00a0type<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a04\u3001\u58f0\u660e\u961f\u5217\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.queueDeclare(\"queue1\"<\/span>,\u00a0true<\/span>,\u00a0false<\/span>,\u00a0false<\/span>,\u00a0null);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.queueDeclare(\"queue2\"<\/span>,\u00a0true<\/span>,\u00a0false<\/span>,\u00a0false<\/span>,\u00a0null);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.queueDeclare(\"queue3\"<\/span>,\u00a0true<\/span>,\u00a0false<\/span>,\u00a0false<\/span>,\u00a0null);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.queueDeclare(\"queue4\"<\/span>,\u00a0true<\/span>,\u00a0false<\/span>,\u00a0false<\/span>,\u00a0null);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a05\u3001\u7ed1\u5b9a\u00a0channel\u00a0\u4e0e\u00a0queue\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.queueBind(\"queue1\"<\/span>,\u00a0EXCHANGE_NAME,\u00a0routeKey);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.queueBind(\"queue2\"<\/span>,\u00a0EXCHANGE_NAME,\u00a0routeKey);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.queueBind(\"queue3\"<\/span>,\u00a0EXCHANGE_NAME,\u00a0routeKey);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.queueBind(\"queue4\"<\/span>,\u00a0EXCHANGE_NAME,\u00a0routeKey);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a06\u3001\u53d1\u5e03\u6d88\u606f\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.basicPublish(EXCHANGE_NAME,\u00a0routeKey,\u00a0null,\u00a0message.getBytes(\"UTF-8\"<\/span>));\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0System.out.println(\"\u6d88\u606f\u53d1\u9001\u6210\u529f!\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\u00a0catch\u00a0(IOException\u00a0|\u00a0TimeoutException\u00a0e)\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0e.printStackTrace();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0System.out.println(\"\u6d88\u606f\u53d1\u9001\u5f02\u5e38\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}finally\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a0\u5173\u95ed\u901a\u9053\u548c\u8fde\u63a5......\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0}\n}\n<\/code><\/pre>\n
    Customer<\/strong><\/span><\/p>\n
    public\u00a0class\u00a0Customer\u00a0{\n\u00a0\u00a0\u00a0\u00a0private\u00a0static\u00a0Runnable\u00a0runnable\u00a0=\u00a0new\u00a0Runnable<\/span>()\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0@Override\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0public\u00a0void\u00a0run<\/span>()\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a0\u521b\u5efa\u8fde\u63a5\u5de5\u5382\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0ConnectionFactory\u00a0factory\u00a0=\u00a0new\u00a0ConnectionFactory();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setHost(\"192.168.96.109\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setUsername(\"admin\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setPassword(\"admin\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setVirtualHost(\"\/\"<\/span>);\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0final\u00a0String\u00a0queueName\u00a0=\u00a0Thread.currentThread().getName();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Connection\u00a0connection\u00a0=\u00a0null;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Channel\u00a0channel\u00a0=\u00a0null;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0try\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a0\u83b7\u53d6\u8fde\u63a5\u3001\u901a\u9053\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0connection\u00a0=\u00a0factory.newConnection();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel\u00a0=\u00a0connection.createChannel();\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Channel\u00a0finalChannel\u00a0=\u00a0channel;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0finalChannel.basicConsume(queueName,\u00a0true<\/span>,\u00a0new\u00a0DeliverCallback<\/span>()\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0@Override\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0public\u00a0void\u00a0handle(String\u00a0consumerTag,\u00a0Delivery\u00a0delivery)\u00a0throws\u00a0IOException\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0System.out.println(delivery.getEnvelope().getDeliveryTag());\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0System.out.println(queueName\u00a0+\u00a0\":\u6536\u5230\u6d88\u606f\u662f\uff1a\"<\/span>\u00a0+\u00a0new\u00a0String(delivery.getBody(),\u00a0\"UTF-8\"<\/span>));\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0},\u00a0new\u00a0CancelCallback<\/span>()\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0@Override\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0public\u00a0void\u00a0handle(String\u00a0consumerTag)\u00a0throws\u00a0IOException\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0});\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0System.out.println(queueName\u00a0+\u00a0\":\u5f00\u59cb\u63a5\u6536\u6d88\u606f\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\u00a0catch\u00a0(IOException\u00a0|\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0TimeoutException\u00a0e)\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0e.printStackTrace();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\u00a0finally\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a0\u5173\u95ed\u901a\u9053\u548c\u8fde\u63a5......\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\n\u00a0\u00a0\u00a0\u00a0};\n\n\u00a0\u00a0\u00a0\u00a0public\u00a0static\u00a0void\u00a0main(String[]\u00a0args)\u00a0throws\u00a0IOException,\u00a0TimeoutException\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a0\u521b\u5efa\u7ebf\u7a0b\u5206\u522b\u4ece\u56db\u4e2a\u961f\u5217\u4e2d\u83b7\u53d6\u6d88\u606f\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0new\u00a0Thread(runnable,\u00a0\"queue1\"<\/span>).start();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0new\u00a0Thread(runnable,\u00a0\"queue2\"<\/span>).start();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0new\u00a0Thread(runnable,\u00a0\"queue3\"<\/span>).start();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0new\u00a0Thread(runnable,\u00a0\"queue4\"<\/span>).start();\n\u00a0\u00a0\u00a0\u00a0}\n}\n<\/code><\/pre>\n
    \u6267\u884c\u5b8c Productor \u53d1\u73b0\u56db\u4e2a\u961f\u5217\u4e2d\u5206\u522b\u589e\u52a0\u4e86\u4e00\u6761\u6d88\u606f\uff0c\u800c\u6267\u884c\u5b8c Customer \u540e\u56db\u4e2a\u961f\u5217\u4e2d\u7684\u6d88\u606f\u90fd\u88ab\u6d88\u8d39\u8005\u6d88\u8d39\u4e86\u3002<\/span><\/p>\n
    3.3 Direct \u6a21\u5f0f<\/span><\/strong><\/p>\n
    Direct \u6a21\u5f0f\u662f\u5728 Fanout \u6a21\u5f0f\u57fa\u7840\u4e0a\u6dfb\u52a0\u4e86 routing key\uff0cFanout\uff08\u53d1\u5e03\/\u8ba2\u9605\uff09\u6a21\u5f0f\u662f\u4ea4\u6362\u673a\u5c06\u6d88\u606f\u5b58\u50a8\u5230\u6240\u6709\u7ed1\u5b9a\u7684\u961f\u5217\u4e2d\uff0c\u800c Direct \u6a21\u5f0f\u662f\u5728\u6b64\u57fa\u7840\u4e0a\uff0c\u6dfb\u52a0\u4e86\u8fc7\u6ee4\u6761\u4ef6\uff0c\u4ea4\u6362\u673a\u53ea\u4f1a\u5c06\u6d88\u606f\u5b58\u50a8\u5230\u6ee1\u8db3 routing key \u7684\u961f\u5217\u4e2d\u3002<\/span><\/p>\n
    \u5728\u4e0a\u56fe\u4e2d\uff0c\u6211\u4eec\u53ef\u4ee5\u770b\u5230\u4ea4\u6362\u673a\u7ed1\u5b9a\u4e86\u4e24\u4e2a\u961f\u5217\uff0c\u5176\u4e2d\u961f\u5217 Q1\u7ed1\u5b9a\u7684 routing key \u4e3a \u201corange\u201d \uff0c\u961f\u5217Q2\u7ed1\u5b9a\u7684routing key \u4e3a \u201cblack\u201d \u548c \u201cgreen\u201d\u3002\u5728\u8fd9\u6837\u7684\u8bbe\u7f6e\u4e2d\uff0c\u53d1\u5e03 routing key \u4e3a \u201corange\u201d \u7684\u6d88\u606f\u5c06\u88ab\u8def\u7531\u5230 Q1\uff0crouting key \u4e3a \u201cblack\u201d \u6216 \u201cgreen\u201d \u7684\u6d88\u606f\u5c06\u88ab\u8def\u7531\u5230 Q2<\/span><\/p>\n
    \u5728 rabbitmq \u4e2d\u7ed9\u961f\u5217\u7ed1\u5b9a routing_key\uff0crouting_key \u5fc5\u987b\u662f\u5355\u8bcd\u5217\u8868\u3002<\/span><\/p>\n
    \u7528 Java demo \u5b9e\u73b0\u6b64\u6a21\u5f0f<\/span><\/p>\n
    Productor<\/span><\/strong><\/p>\n
    public\u00a0class\u00a0Productor\u00a0{\n\u00a0\u00a0\u00a0\u00a0private\u00a0static\u00a0final\u00a0String\u00a0EXCHANGE_NAME\u00a0=\u00a0\"direct_exchange\"<\/span>;\n\n\u00a0\u00a0\u00a0\u00a0public\u00a0static\u00a0void\u00a0main(String[]\u00a0args)\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a01\u3001\u521b\u5efa\u8fde\u63a5\u5de5\u7a0b\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0ConnectionFactory\u00a0factory\u00a0=\u00a0new\u00a0ConnectionFactory();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setHost(\"192.168.96.109\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setUsername(\"admin\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setPassword(\"admin\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setVirtualHost(\"\/\"<\/span>);\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Connection\u00a0connection\u00a0=\u00a0null;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Channel\u00a0channel\u00a0=\u00a0null;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0try\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a02\u3001\u83b7\u53d6\u8fde\u63a5\u3001\u901a\u9053\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0connection\u00a0=\u00a0factory.newConnection();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel\u00a0=\u00a0connection.createChannel();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a0\u6d88\u606f\u5185\u5bb9\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0String\u00a0message\u00a0=\u00a0\"hello\u00a0direct\u00a0mode\"<\/span>;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a0\u6307\u5b9a\u8def\u7531key\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0String\u00a0routeKey\u00a0=\u00a0\"email\"<\/span>;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0String\u00a0type<\/span>\u00a0=\u00a0\"direct\"<\/span>;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a03\u3001\u58f0\u660e\u4ea4\u6362\u673a\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.exchangeDeclare(EXCHANGE_NAME,\u00a0type<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a04\u3001\u58f0\u660e\u961f\u5217\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.queueDeclare(\"queue1\"<\/span>,\u00a0true<\/span>,\u00a0false<\/span>,\u00a0false<\/span>,\u00a0null);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.queueDeclare(\"queue2\"<\/span>,\u00a0true<\/span>,\u00a0false<\/span>,\u00a0false<\/span>,\u00a0null);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.queueDeclare(\"queue3\"<\/span>,\u00a0true<\/span>,\u00a0false<\/span>,\u00a0false<\/span>,\u00a0null);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a05\u3001\u7ed1\u5b9a\u00a0channel\u00a0\u4e0e\u00a0queue\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.queueBind(\"queue1\"<\/span>,\u00a0EXCHANGE_NAME,\u00a0\"email\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.queueBind(\"queue2\"<\/span>,\u00a0EXCHANGE_NAME,\u00a0\"sms\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.queueBind(\"queue3\"<\/span>,\u00a0EXCHANGE_NAME,\u00a0\"vx\"<\/span>);\n\u00a0\u00a0\u00a0\/\/\u00a06\u3001\u53d1\u5e03\u6d88\u606f\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.basicPublish(EXCHANGE_NAME,\u00a0routeKey,\u00a0null,\u00a0message.getBytes(\"UTF-8\"<\/span>));\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0System.out.println(\"\u6d88\u606f\u53d1\u9001\u6210\u529f!\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\u00a0catch\u00a0(IOException\u00a0|\u00a0TimeoutException\u00a0e)\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0e.printStackTrace();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0System.out.println(\"\u6d88\u606f\u53d1\u9001\u5f02\u5e38\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\u00a0finally\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a0\u5173\u95ed\u901a\u9053\u548c\u8fde\u63a5......\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0}\n}\n<\/code><\/pre>\n
    \u53ef\u4ee5\u901a\u8fc7\u53ef\u89c6\u5316\u9875\u9762\u67e5\u770b\uff0c\u5404\u961f\u5217\u7ed1\u5b9a\u7684 routing_key<\/span><\/p>\n
    \u7531\u4e8e\u8bbe\u7f6e\u7684 routing_key\u4e3a \u201cemail\u201d\uff0c\u6240\u4ee5\uff0c\u5e94\u8be5\u53ea\u6709 queue1 \u5b58\u50a8\u4e86\u4e00\u6761\u6d88\u606f\u3002<\/span><\/p>\n
    Customer \u4e0e\u4e0a\u8ff0 fanout \u793a\u4f8b\u4e00\u81f4\u3002<\/span><\/p>\n
    3.4 Topic \u6a21\u5f0f<\/span><\/strong><\/p>\n
    Topic \u6a21\u5f0f\u662f\u751f\u4ea7\u8005\u901a\u8fc7\u4ea4\u6362\u673a\u5c06\u6d88\u606f\u5b58\u50a8\u5230\u961f\u5217\u540e\uff0c\u4ea4\u6362\u673a\u6839\u636e\u7ed1\u5b9a\u961f\u5217\u7684 routing key \u7684\u503c\u8fdb\u884c\u901a\u914d\u7b26\u5339\u914d\uff0c\u5982\u679c\u5339\u914d\u901a\u8fc7\uff0c\u6d88\u606f\u5c06\u88ab\u5b58\u50a8\u5230\u8be5\u961f\u5217\uff0c\u5982\u679c routing key \u7684\u503c\u5339\u914d\u5230\u4e86\u591a\u4e2a\u961f\u5217\uff0c\u6d88\u606f\u5c06\u4f1a\u88ab\u53d1\u9001\u5230\u591a\u4e2a\u961f\u5217\uff1b\u5982\u679c\u4e00\u4e2a\u961f\u5217\u4e5f\u6ca1\u5339\u914d\u4e0a\uff0c\u8be5\u6d88\u606f\u5c06\u4e22\u5931\u3002<\/span><\/p>\n
    routing_key \u5fc5\u987b\u662f\u5355\u8bcd\u5217\u8868\uff0c\u7528\u70b9\u5206\u9694\uff0c\u5176\u4e2d * \u548c # \u7684\u542b\u4e49\u4e3a\uff1a<\/span><\/p>\n
      \n
    • \n
      *\uff1a1\u4e2a\u5355\u8bcd<\/span><\/section>\n<\/li>\n
    • \n
      #\uff1a0\u4e2a\u6216\u591a\u4e2a\u5355\u8bcd<\/span><\/section>\n<\/li>\n<\/ul>\n
      \u7528Java demo \u5b9e\u73b0\u6b64\u6a21\u5f0f<\/span><\/p>\n
      Productor<\/span><\/strong><\/p>\n
      public\u00a0class\u00a0Productor\u00a0{\n\u00a0\u00a0\u00a0\u00a0private\u00a0static\u00a0final\u00a0String\u00a0EXCHANGE_NAME\u00a0=\u00a0\"topic_exchange\"<\/span>;\n\n\u00a0\u00a0\u00a0\u00a0public\u00a0static\u00a0void\u00a0main(String[]\u00a0args)\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a01\u3001\u521b\u5efa\u8fde\u63a5\u5de5\u7a0b\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0ConnectionFactory\u00a0factory\u00a0=\u00a0new\u00a0ConnectionFactory();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setHost(\"192.168.96.109\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setUsername(\"admin\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setPassword(\"admin\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setVirtualHost(\"\/\"<\/span>);\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Connection\u00a0connection\u00a0=\u00a0null;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Channel\u00a0channel\u00a0=\u00a0null;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0try\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a02\u3001\u83b7\u53d6\u8fde\u63a5\u3001\u901a\u9053\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0connection\u00a0=\u00a0factory.newConnection();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel\u00a0=\u00a0connection.createChannel();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a0\u6d88\u606f\u5185\u5bb9\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0String\u00a0message\u00a0=\u00a0\"hello\u00a0topic\u00a0mode\"<\/span>;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a0\u6307\u5b9a\u8def\u7531key\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0String\u00a0routeKey\u00a0=\u00a0\"com.order.test.xxx\"<\/span>;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0String\u00a0type<\/span>\u00a0=\u00a0\"topic\"<\/span>;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a03\u3001\u58f0\u660e\u4ea4\u6362\u673a\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.exchangeDeclare(EXCHANGE_NAME,\u00a0type<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a04\u3001\u58f0\u660e\u961f\u5217\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.queueDeclare(\"queue5\"<\/span>,true<\/span>,false<\/span>,false<\/span>,null);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.queueDeclare(\"queue6\"<\/span>,true<\/span>,false<\/span>,false<\/span>,null);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a05\u3001\u7ed1\u5b9a\u00a0channel\u00a0\u4e0e\u00a0queue\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.queueBind(\"queue5\"<\/span>,\u00a0EXCHANGE_NAME,\u00a0\"*.order.#\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.queueBind(\"queue6\"<\/span>,\u00a0EXCHANGE_NAME,\u00a0\"#.test.*\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a06\u3001\u53d1\u5e03\u6d88\u606f\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.basicPublish(EXCHANGE_NAME,\u00a0routeKey,\u00a0null,\u00a0message.getBytes(\"UTF-8\"<\/span>));\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0System.out.println(\"\u6d88\u606f\u53d1\u9001\u6210\u529f!\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\u00a0catch\u00a0(IOException\u00a0|\u00a0TimeoutException\u00a0e)\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0e.printStackTrace();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0System.out.println(\"\u6d88\u606f\u53d1\u9001\u5f02\u5e38\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\u00a0finally\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a0\u5173\u95ed\u901a\u9053\u548c\u8fde\u63a5......\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0}\n}\n<\/code><\/pre>\n
      \u6267\u884c\u5b8c Productor \u540e\uff0c\u901a\u8fc7\u53ef\u89c6\u5316\u9875\u9762\u67e5\u770b\u5230\uff0cqueue \u7ed1\u5b9a\u7684 routing_key<\/span><\/p>\n
      \u7531\u4e8e\u4e0a\u8ff0\u4f8b\u5b50\u4e2d\uff0crouting_key\u4e3a\uff1a\u201ccom.order.test.xxx\u201d\uff0c\u90a3\u4e48 queue5 \u548c queue6 \u90fd\u5c06\u63a5\u6536\u5230\u6d88\u606f\u3002<\/span><\/p>\n
      Customer \u4e0e\u4e0a\u8ff0\u5b9e\u4f8b\u4e00\u6837\uff0c\u6267\u884c\u5b8c Customer \u540e\uff0c\u518d\u6b21\u67e5\u770b\u961f\u5217\u4fe1\u606f\uff0cqueue5 \u548c queue6 \u7684\u6d88\u606f\u90fd\u88ab\u6d88\u8d39\u4e86\u3002<\/span><\/p>\n
      3.5 Work \u6a21\u5f0f<\/span><\/strong><\/section>\n
      \u5f53\u6709\u591a\u4e2a\u6d88\u8d39\u8005\u65f6\uff0c\u5982\u4f55\u5747\u8861\u6d88\u606f\u8005\u6d88\u8d39\u6d88\u606f\u7684\u591a\u5c11\uff0c\u4e3b\u8981\u6709\u4e24\u79cd\u6a21\u5f0f\uff1a<\/span><\/p>\n
        \n
      • \n
        \u8f6e\u8be2\u6a21\u5f0f\u5206\u53d1\uff1a\u6309\u987a\u5e8f\u8f6e\u8be2\u5206\u53d1\uff0c\u6bcf\u4e2a\u6d88\u8d39\u8005\u83b7\u5f97\u76f8\u540c\u6570\u91cf\u7684\u6d88\u606f<\/span><\/section>\n<\/li>\n
      • \n
        \u516c\u5e73\u5206\u53d1\uff1a\u6839\u636e\u6d88\u8d39\u8005\u6d88\u8d39\u80fd\u529b\u516c\u5e73\u5206\u53d1\uff0c\u5904\u7406\u5feb\u7684\u5904\u7406\u7684\u591a\uff0c\u5904\u7406\u6162\u7684\u5904\u7406\u7684\u5c11\uff0c\u6309\u52b3\u5206\u914d<\/span><\/section>\n<\/li>\n<\/ul>\n
        3.5.1 \u8f6e\u8be2\u5206\u53d1<\/span><\/strong><\/h4>\n
        \u5728\u8fd9\u79cd\u6a21\u5f0f\u4e0b\uff0crabbitmq \u91c7\u7528\u8f6e\u8be2\u7684\u65b9\u5f0f\u5c06\u4efb\u52a1\u5206\u914d\u7ed9\u591a\u4e2a\u6d88\u8d39\u8005\uff0c\u4f46\u53ef\u80fd\u51fa\u73b0\u4e00\u79cd\u60c5\u51b5\uff0c\u5f53\u5206\u914d\u7ed9\u67d0\u4e00\u4e2a\u6d88\u8d39\u8005\u7684\u4efb\u52a1\u5f88\u590d\u6742\u65f6\uff0c\u800c\u6709\u4e9b\u6d88\u8d39\u8005\u63a5\u6536\u7684\u4efb\u52a1\u8f83\u8f7b\u91cf\uff0c\u4f1a\u51fa\u73b0\u6709\u7684\u6d88\u8d39\u8005\u5f88\u5fd9\uff0c\u800c\u6709\u7684\u6d88\u8d39\u8005\u5904\u4e8e\u7a7a\u95f2\u7684\u72b6\u6001\uff0c\u800c rabbitmq \u4e0d\u4f1a\u611f\u77e5\u5230\u8fd9\u79cd\u60c5\u51b5\u7684\u53d1\u751f\uff0crabbitmq \u4e0d\u8003\u8651\u6d88\u8d39\u8005\u672a\u786e\u8ba4\u6d88\u606f\u7684\u6570\u91cf\uff0c\u53ea\u662f\u76f2\u76ee\u7684\u5206\u914d\u4efb\u52a1\u3002<\/span><\/p>\n
        \u7528 Java demo \u5b9e\u73b0\u6b64\u6a21\u5f0f<\/span><\/p>\n
        Productor<\/span><\/strong><\/p>\n
        public\u00a0class\u00a0Productor\u00a0{\n\u00a0\u00a0\u00a0\u00a0public\u00a0static\u00a0void\u00a0main(String[]\u00a0args)\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a01\u3001\u521b\u5efa\u8fde\u63a5\u5de5\u7a0b\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0ConnectionFactory\u00a0factory\u00a0=\u00a0new\u00a0ConnectionFactory();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setHost(\"192.168.96.109\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setUsername(\"admin\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setPassword(\"admin\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setVirtualHost(\"\/\"<\/span>);\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Connection\u00a0connection\u00a0=\u00a0null;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Channel\u00a0channel\u00a0=\u00a0null;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0try\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a02\u3001\u83b7\u53d6\u8fde\u63a5\u3001\u901a\u9053\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0connection\u00a0=\u00a0factory.newConnection();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel\u00a0=\u00a0connection.createChannel();\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a03\u3001\u5411\u00a0Queue1\u00a0\u53d1\u5e0320\u4e2a\u6d88\u606f\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0for<\/span>\u00a0(int\u00a0i\u00a0=\u00a00;\u00a0i\u00a0<\u00a020;\u00a0i++)\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0String\u00a0msg\u00a0=\u00a0\"feiyangyang:\u00a0\"<\/span>\u00a0+\u00a0i;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel.basicPublish(\"\"<\/span>,\u00a0\"queue1\"<\/span>,\u00a0null,\u00a0msg.getBytes(StandardCharsets.UTF_8));\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0System.out.println(\"\u6d88\u606f\u53d1\u9001\u6210\u529f!\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\u00a0catch\u00a0(IOException\u00a0|\u00a0TimeoutException\u00a0e)\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0e.printStackTrace();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0System.out.println(\"\u6d88\u606f\u53d1\u9001\u5f02\u5e38\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\u00a0finally\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a0\u5173\u95ed\u901a\u9053\u548c\u8fde\u63a5......\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0}\n}\n<\/code><\/pre>\n
        Worker1<\/span><\/strong><\/p>\n
        public\u00a0class\u00a0Worker1\u00a0{\n\u00a0\u00a0\u00a0\u00a0public\u00a0static\u00a0void\u00a0main(String[]\u00a0args)\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a01\u3001\u521b\u5efa\u8fde\u63a5\u5de5\u5382\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0ConnectionFactory\u00a0factory\u00a0=\u00a0new\u00a0ConnectionFactory();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setHost(\"192.168.96.109\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setUsername(\"admin\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setPassword(\"admin\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0factory.setVirtualHost(\"\/\"<\/span>);\n\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Connection\u00a0connection\u00a0=\u00a0null;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Channel\u00a0channel\u00a0=\u00a0null;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0try\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a0\u83b7\u53d6\u8fde\u63a5\u3001\u901a\u9053\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0connection\u00a0=\u00a0factory.newConnection();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0channel\u00a0=\u00a0connection.createChannel();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Channel\u00a0finalChannel\u00a0=\u00a0channel;\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0finalChannel.basicConsume(\"queue1\"<\/span>,\u00a0true<\/span>,\u00a0new\u00a0DeliverCallback<\/span>()\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0@Override\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0public\u00a0void\u00a0handle(String\u00a0consumerTag,\u00a0Delivery\u00a0delivery)\u00a0throws\u00a0IOException\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0System.out.println(\"Worker1\"<\/span>\u00a0+\u00a0\":\u6536\u5230\u6d88\u606f\u662f\uff1a\"<\/span>\u00a0+\u00a0new\u00a0String(delivery.getBody(),\u00a0\"UTF-8\"<\/span>));\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0try\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Thread.sleep(2000);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\u00a0catch\u00a0(InterruptedException\u00a0e)\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0e.printStackTrace();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0},\u00a0new\u00a0CancelCallback<\/span>()\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0@Override\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0public\u00a0void\u00a0handle(String\u00a0consumerTag)\u00a0throws\u00a0IOException\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0});\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0System.out.println(\"Worker1\u00a0\u5f00\u59cb\u63a5\u6536\u6d88\u606f\"<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0System.in.read();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\u00a0catch\u00a0(IOException\u00a0|\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0TimeoutException\u00a0e)\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0e.printStackTrace();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\u00a0finally\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a0\u5173\u95ed\u901a\u9053\u548c\u8fde\u63a5......\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0}\n}\n<\/code><\/pre>\n
        Worker2 \u4e0e Worker1 \u76f8\u540c<\/span><\/p>\n
        \u6211\u4eec\u770b\u4e0b\u6d88\u606f\u5206\u53d1\u7ed3\u679c\uff1a<\/span><\/p>\n
        Worker1\u00a0\u5f00\u59cb\u63a5\u6536\u6d88\u606f\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang:\u00a00\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 2\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 4\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 6\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 8\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 10\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 12\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 14\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 16\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 18\n\nWorker2\u00a0\u5f00\u59cb\u63a5\u6536\u6d88\u606f\nWorker2:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 1\nWorker2:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 3\nWorker2:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 5\nWorker2:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 7\nWorker2:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 9\nWorker2:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 11\nWorker2:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 13\nWorker2:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 15\nWorker2:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 17\nWorker2:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 19\n<\/code><\/pre>\n
        \u53ef\u4ee5\u770b\u51fa\uff0c\u8f6e\u8be2\u5206\u53d1\u6a21\u5f0f\u5c31\u662f\u5c06\u6d88\u606f\u5747\u8861\u7684\u5206\u914d\u6240\u6709\u6d88\u8d39\u8005\u3002<\/span><\/p>\n
        3.5.2 \u516c\u5e73\u5206\u53d1<\/span><\/strong><\/h4>\n
        \u4e3a\u4e86\u89e3\u51b3 Work \u8f6e\u8be2\u5206\u53d1\u6a21\u5f0f \u8fd9\u4e2a\u95ee\u9898\uff0crabbitmq \u4f7f\u7528\u5e26\u6709 perfetchCount = 1 \u8bbe\u7f6e\u7684 basicQos \u65b9\u6cd5\u3002\u5f53\u6d88\u8d39\u8005\u63a5\u53d7\u5904\u7406\u5e76\u786e\u8ba4\u524d\u4e00\u6761\u6d88\u606f\u524d\uff0c\u4e0d\u5411\u6b64\u6d88\u8d39\u8005\u53d1\u9001\u65b0\u6d88\u606f\uff0c\u4f1a\u5206\u914d\u7ed9\u5176\u4ed6\u7a7a\u95f2\u7684\u6d88\u8d39\u8005\u3002<\/span><\/p>\n
        Productor \u4ee3\u7801\u4e0e\u4e0a\u8ff0\u8f6e\u8be2\u6a21\u5f0f\u76f8\u540c\uff0c\u800c Customer \u4e2d\u7a0d\u4f5c\u4fee\u6539<\/span><\/p>\n
        Worker1<\/span><\/strong><\/p>\n
        \/\/\u00a0Channel\u00a0\u4f7f\u7528\u00a0Qos\u00a0\u673a\u5236\nfinalChannel.basicQos(1);\nfinalChannel.basicConsume(\"queue1\"<\/span>,\u00a0false<\/span>,\u00a0new\u00a0DeliverCallback<\/span>()\u00a0{\n\u00a0\u00a0\u00a0\u00a0@Override\n\u00a0\u00a0\u00a0\u00a0public\u00a0void\u00a0handle(String\u00a0consumerTag,\u00a0Delivery\u00a0delivery)\u00a0throws\u00a0IOException\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0System.out.println(\"Worker1\"<\/span>\u00a0+\u00a0\":\u6536\u5230\u6d88\u606f\u662f\uff1a\"<\/span>\u00a0+\u00a0new\u00a0String(delivery.getBody(),\u00a0\"UTF-8\"<\/span>));\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0try\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0Thread.sleep(1000);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\/\/\u00a0\u6539\u6210\u624b\u52a8\u5e94\u7b54\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0finalChannel.basicAck(delivery.getEnvelope().getDeliveryTag(),\u00a0false<\/span>);\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\u00a0catch\u00a0(InterruptedException\u00a0e)\u00a0{\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0e.printStackTrace();\n\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0}\n\u00a0\u00a0\u00a0\u00a0}\n},\u00a0new\u00a0CancelCallback<\/span>()\u00a0{\n\u00a0\u00a0\u00a0\u00a0@Override\n\u00a0\u00a0\u00a0\u00a0public\u00a0void\u00a0handle(String\u00a0consumerTag)\u00a0throws\u00a0IOException\u00a0{\n\u00a0\u00a0\u00a0\u00a0}\n});\n<\/code><\/pre>\n
        \u4e0a\u8ff0\u5b9e\u4f8b\u76f8\u8f83\u4e8e\u8f6e\u8be2\u5206\u53d1\u6a21\u5f0f\uff0c\u6dfb\u52a0\u4e86 Qos \u673a\u5236\uff0c\u8bbe\u7f6e\u503c\u4e3a1\uff0c\u4ee3\u8868\u6d88\u8d39\u8005\u6bcf\u6b21\u4ece\u961f\u5217\u4e2d\u83b7\u53d6\u51e0\u6761\u6d88\u606f\uff0c\u5c06 Worker1 \u7684 sleep \u65f6\u95f4\u8bbe\u7f6e\u4e3a 1s\uff0c\u5c06 Worker2 \u7684 sleep \u65f6\u95f4\u8bbe\u7f6e\u4e3a 2s\uff0c\u67e5\u770b\u6d88\u606f\u5206\u53d1\u7ed3\u679c<\/span><\/p>\n
        Worker1\u00a0\u5f00\u59cb\u63a5\u6536\u6d88\u606f\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang:\u00a00\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 2\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 4\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 5\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 7\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 8\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 10\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 11\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 13\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 14\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 16\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 17\nWorker1:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 19\nWorker2\u00a0\u5f00\u59cb\u63a5\u6536\u6d88\u606f\nWorker2:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 1\nWorker2:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 3\nWorker2:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 6\nWorker2:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 9\nWorker2:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 12\nWorker2:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 15\nWorker2:\u6536\u5230\u6d88\u606f\u662f\uff1afeiyangyang: 18\n<\/code><\/pre>\n
        \u5f53\u4f7f\u7528 Work \u516c\u5e73\u5206\u53d1\u6a21\u5f0f\u65f6\uff0c\u8981\u8bbe\u7f6e\u6d88\u8d39\u8005\u4e3a\u624b\u52a8\u5e94\u7b54\uff0c\u5e76\u4e14\u5f00\u542f Qos \u673a\u5236\u3002<\/span><\/p>\n
        \u9632\u6b62\u6d88\u606f\u4e22\u5931\u673a\u5236<\/span><\/strong><\/p>\n
        4.1 \u6d88\u606f\u786e\u8ba4<\/span><\/strong><\/p>\n
        \u6d88\u8d39\u8005\u5b8c\u6210\u4e00\u9879\u4efb\u52a1\u53ef\u80fd\u9700\u8981\u51e0\u79d2\u949f\uff0c\u5982\u679c\u5176\u4e2d\u4e00\u4e2a\u6d88\u8d39\u8005\u5f00\u59cb\u4e86\u4e00\u9879\u957f\u671f\u4efb\u52a1\u5e76\u4e14\u53ea\u5b8c\u6210\u4e86\u90e8\u5206\u4efb\u52a1\u800c\u6b7b\u4ea1\uff0c\u5982\u679c\u5c06 autoAck \u8bbe\u7f6e\u4e3a true \uff0c\u4e00\u65e6 RabbitMQ \u5c06\u6d88\u606f\u4f20\u9012\u7ed9\u6d88\u8d39\u8005\uff0c\u5b83\u4f1a\u7acb\u5373\u5c06\u5176\u6807\u8bb0\u4e3a\u5220\u9664\uff0c\u5728\u8fd9\u79cd\u60c5\u51b5\u4e0b\uff0c\u6211\u4eec\u5c06\u4e22\u5931\u6240\u6709\u5df2\u5206\u6d3e\u7ed9\u8be5\u7279\u5b9a\u6d88\u8d39\u8005\u4f46\u5c1a\u672a\u5904\u7406\u7684\u6d88\u606f\u3002<\/span><\/p>\n
        \u5982\u679c\u5176\u4e2d\u4e00\u4e2a\u6d88\u8d39\u8005\u5b95\u4e86\uff0crabbitmq \u53ef\u4ee5\u5c06\u5176\u6d88\u606f\u5206\u914d\u7ed9\u5176\u4ed6\u6d88\u8d39\u8005\u3002\u4e3a\u4e86\u786e\u4fdd\u6d88\u606f\u4e0d\u4f1a\u4e22\u5931\uff0crabbitmq \u91c7\u7528\u6d88\u606f\u786e\u8ba4\uff0c\u6d88\u8d39\u8005\u53d1\u56de\u786e\u8ba4\u6d88\u606f\uff0c\u544a\u8bc9 rabbitmq \u6d88\u606f\u5df2\u7ecf\u88ab\u63a5\u6536\u5e76\u5904\u7406\uff0c\u6b64\u65f6\uff0crabbitmq \u53ef\u4ee5\u653e\u5fc3\u7684\u5220\u9664\u8fd9\u6761\u6d88\u606f\u3002<\/span><\/p>\n
        \u5982\u679c\u6d88\u8d39\u8005\u5728\u6ca1\u6709\u53d1\u9001 ack \u7684\u60c5\u51b5\u4e0b\u5b95\u4e86\uff0crabbitmq \u5c06\u7406\u89e3\u4e3a\u8be5\u6761\u6d88\u606f\u672a\u88ab\u6d88\u8d39\u8005\u5904\u7406\u5b8c\uff0c\u5982\u679c\u6709\u5176\u4ed6\u6d88\u8d39\u8005\u5728\u7ebf\uff0c\u5c06\u8fc5\u901f\u91cd\u65b0\u4ea4\u4ed8\u7ed9\u5176\u4ed6\u6d88\u8d39\u8005\uff0c\u8fd9\u6837\u5c31\u53ef\u4ee5\u786e\u4fdd\u4e0d\u4f1a\u4e22\u5931\u6d88\u606f\u4e86\u3002<\/span><\/p>\n
        \u9ed8\u8ba4\u60c5\u51b5\u4e0brabbitmq \u4f1a\u542f\u7528\u624b\u52a8\u6d88\u606f\u786e\u8ba4\uff0c\u4e5f\u5c31\u662f autoAck \u9ed8\u8ba4\u4e3a false\uff0c\u4e00\u65e6\u6211\u4eec\u5b8c\u6210\u4e86\u4e00\u9879\u4efb\u52a1\uff0c\u9700\u8981\u624b\u52a8\u7684\u8fdb\u884c\u6d88\u606f\u786e\u8ba4\uff0c\u6240\u4ee5 autoAck \u9700\u8981\u4fdd\u6301\u4e3a\u9ed8\u8ba4\u503c false\uff0c\u5e76\u4f7f\u7528\u5982\u4e0b\u65b9\u6cd5\u8fdb\u884c\u624b\u52a8\u5e94\u7b54\u3002<\/span><\/p>\n
        channel.basicAck(delivery.getEnvelope().getDeliveryTag(),\u00a0false<\/span>);\n<\/code><\/pre>\n
        4.2 \u6301\u4e45\u5316<\/span><\/strong><\/h3>\n
        rabbitmq \u7684\u6d88\u606f\u786e\u8ba4\u673a\u5236\u53ef\u4ee5\u4fdd\u8bc1\u6d88\u606f\u4e0d\u4f1a\u4e22\u5931\uff0c\u4f46\u662f\u5982\u679c rabbitmq \u670d\u52a1\u5668\u505c\u6b62\uff0c\u6211\u4eec\u7684\u4efb\u52a1\u4ecd\u7136\u4f1a\u4e22\u5931\u3002<\/h3>\n
        \u5f53 rabbitmq \u9000\u51fa\u6216\u5d29\u6e83\u65f6\uff0c\u5982\u679c\u4e0d\u8fdb\u884c\u6301\u4e45\u5316\uff0c\u961f\u5217\u548c\u6d88\u606f\u90fd\u4f1a\u6d88\u5931\u3002\u9700\u8981\u505a\u4e24\u4ef6\u4e8b\u6765\u786e\u4fdd\u6d88\u606f\u4e0d\u4f1a\u4e22\u5931\uff0c\u5c06\u961f\u5217\u548c\u6d88\u606f\u90fd\u6807\u8bb0\u4e3a\u6301\u4e45\u7684\u3002<\/span><\/h3>\n
        \u8bbe\u7f6e\u961f\u5217\u6301\u4e45<\/strong><\/h3>\n
        boolean\u00a0durable\u00a0=\u00a0true<\/span>;\nchannel.queueDeclare(\"hello\"<\/span>,\u00a0durable,\u00a0false<\/span>,\u00a0false<\/span>,\u00a0null);\n<\/code><\/pre>\n
        \u8bbe\u7f6e\u6d88\u606f\u6301\u4e45<\/strong><\/span><\/section>\n
        channel.basicPublish(\"\"<\/span>,\u00a0\"task_queue\"<\/span>,\u00a0MessageProperties.PERSISTENT_TEXT_PLAIN,\u00a0message.getBytes());\n<\/code><\/pre>\n
        \u5c06\u6d88\u606f\u6807\u8bb0\u4e3a\u6301\u4e45\u6027\u5e76\u4e0d\u80fd\u5b8c\u5168\u4fdd\u8bc1\u6d88\u606f\u4e0d\u4f1a\u4e22\u5931\uff0c\u5f53 rabbitmq \u63a5\u6536\u5230\u6d88\u606f\u5e76\u4e14\u8fd8\u6ca1\u4fdd\u5b58\u65f6\uff0c\u4ecd\u7136\u6709\u5f88\u77ed\u7684\u65f6\u95f4\u7a97\u53e3\u4f1a\u4f7f\u6d88\u606f\u4e22\u5931\uff0c\u5982\u679c\u9700\u8981\u66f4\u5f3a\u7684\u4fdd\u8bc1\uff0c\u53ef\u4ee5\u4f7f\u7528\u53d1\u5e03\u8005\u786e\u8ba4\u673a\u5236\u3002<\/span><\/p>\n
        \u4f7f\u7528\u573a\u666f<\/span><\/strong><\/p>\n
        \n
        \u89e3\u8026\u3001\u524a\u5cf0\u3001\u5f02\u6b65<\/p>\n<\/blockquote>\n
        \u89e3\u8026<\/span><\/strong><\/p>\n
        \u5728\u5fae\u670d\u52a1\u67b6\u6784\u4f53\u7cfb\u4e2d\uff0c\u5fae\u670d\u52a1A\u9700\u8981\u4e0e\u5fae\u670d\u52a1B\u8fdb\u884c\u901a\u4fe1\uff0c\u4f20\u7edf\u7684\u505a\u6cd5\u662fA\u8c03\u7528B\u7684\u63a5\u53e3\u3002\u4f46\u8fd9\u6837\u505a\u5982\u679c\u7cfb\u7edfB\u65e0\u6cd5\u8bbf\u95ee\u6216\u8fde\u63a5\u8d85\u65f6\uff0c\u7cfb\u7edfA\u9700\u8981\u7b49\u5f85\uff0c\u76f4\u5230\u7cfb\u7edfB\u505a\u51fa\u54cd\u5e94\uff0c\u5e76\u4e14A\u4e0eB\u5b58\u5728\u4e25\u91cd\u7684\u8026\u5408\u73b0\u8c61\u3002\u5982\u679c\u5f15\u5165\u6d88\u606f\u961f\u5217\u8fdb\u884c\u7cfb\u7edfAB\u7684\u901a\u4fe1\uff0c\u6d41\u7a0b\u662f\u8fd9\u6837\u7684\uff1a<\/span><\/p>\n
          \n
        • \n
          \u7cfb\u7edfA\u5c06\u6d88\u606f\u5b58\u50a8\u5230\u6d88\u606f\u961f\u5217\u4e2d\uff0c\u8fd4\u56de\u6210\u529f\u4fe1\u606f<\/span><\/section>\n<\/li>\n
        • \n
          \u7cfb\u7edfB\u4ece\u961f\u5217\u4e2d\u83b7\u53d6\u6d88\u606f\uff0c\u8fdb\u884c\u5904\u7406\u64cd\u4f5c<\/span><\/section>\n<\/li>\n<\/ul>\n
          \u7cfb\u7edfA\u5c06\u6d88\u606f\u653e\u5230\u961f\u5217\u4e2d\uff0c\u5c31\u4e0d\u7528\u5173\u5fc3\u7cfb\u7edfB\u662f\u5426\u53ef\u4ee5\u83b7\u53d6\u7b49\u5176\u4ed6\u4e8b\u60c5\u4e86\uff0c\u5b9e\u73b0\u4e86\u4e24\u4e2a\u7cfb\u7edf\u95f4\u7684\u89e3\u8026\u3002<\/span><\/p>\n
          \u4f7f\u7528\u573a\u666f\uff1a<\/span><\/p>\n
            \n
          • \n
            \u77ed\u4fe1\u3001\u90ae\u4ef6\u901a\u77e5<\/span><\/section>\n<\/li>\n<\/ul>\n
            \u524a\u5cf0<\/span><\/strong><\/p>\n
            \u7cfb\u7edfA\u6bcf\u79d2\u8bf7\u6c42100\u4e2a\uff0c\u7cfb\u7edf\u53ef\u4ee5\u7a33\u5b9a\u8fd0\u884c\uff0c\u4f46\u5982\u679c\u5728\u79d2\u6740\u6d3b\u52a8\u4e2d\uff0c\u6bcf\u79d2\u5e76\u53d1\u8fbe\u52301w\u4e2a\uff0c\u4f46\u7cfb\u7edf\u6700\u5927\u5904\u7406\u80fd\u529b\u53ea\u80fd\u6bcf\u79d2\u5904\u7406 1000 \u4e2a\uff0c\u6240\u4ee5\uff0c\u5728\u79d2\u6740\u6d3b\u52a8\u4e2d\uff0c\u7cfb\u7edf\u670d\u52a1\u5668\u4f1a\u51fa\u73b0\u5b95\u673a\u7684\u73b0\u8c61\u3002\u5982\u679c\u5f15\u5165 MQ \uff0c\u53ef\u4ee5\u89e3\u51b3\u8fd9\u4e2a\u95ee\u9898\u3002\u6bcf\u79d2 1w\u4e2a\u8bf7\u6c42\u4f1a\u5bfc\u81f4\u7cfb\u7edf\u5d29\u6e83\uff0c\u90a3\u6211\u4eec\u8ba9\u7528\u6237\u53d1\u9001\u7684\u8bf7\u6c42\u90fd\u5b58\u50a8\u5230\u961f\u5217\u4e2d\uff0c\u7531\u4e8e\u7cfb\u7edf\u6700\u5927\u5904\u7406\u80fd\u529b\u662f\u6bcf\u79d21000\u4e2a\u8bf7\u6c42\uff0c\u8ba9\u7cfb\u7edfA\u6bcf\u79d2\u53ea\u4ece\u961f\u5217\u4e2d\u62c9\u53d61000\u4e2a\u8bf7\u6c42\uff0c\u4fdd\u8bc1\u7cfb\u7edf\u80fd\u7a33\u5b9a\u8fd0\u884c\uff0c\u5728\u79d2\u6740\u671f\u95f4\uff0c\u8bf7\u6c42\u5927\u91cf\u8fdb\u5165\u5230\u961f\u5217\uff0c\u79ef\u538b\u5230MQ\u4e2d\uff0c\u800c\u7cfb\u7edf\u6bcf\u79d2\u53ea\u4ece\u961f\u5217\u4e2d\u53d61000\u4e2a\u8bf7\u6c42\u5904\u7406\u3002\u8fd9\u79cd\u77ed\u6682\u7684\u9ad8\u5cf0\u671f\u79ef\u538b\u662f\u6ca1\u95ee\u9898\u7684\uff0c\u56e0\u4e3a\u9ad8\u5cf0\u671f\u4e00\u65e6\u8fc7\u53bb\uff0c\u6bcf\u79d2\u8bf7\u6c42\u6570\u8fc5\u901f\u9012\u51cf\uff0c\u800c\u7cfb\u7edf\u6bcf\u79d2\u8fd8\u662f\u4ece\u961f\u5217\u4e2d\u53d61000\u4e2a\u8bf7\u6c42\u8fdb\u884c\u5904\u7406\uff0c\u7cfb\u7edf\u4f1a\u5feb\u901f\u5c06\u79ef\u538b\u7684\u6d88\u606f\u6d88\u8d39\u6389\u3002<\/span><\/p>\n
            \u4f7f\u7528\u573a\u666f\uff1a<\/span><\/p>\n
              \n
            • \n
              \u79d2\u6740\u6d3b\u52a8<\/section>\n<\/li>\n
            • \n
              \u56e2\u62a2\u6d3b\u52a8<\/section>\n<\/li>\n<\/ul>\n
              \u5f02\u6b65<\/span><\/strong><\/p>\n
              \u7528\u6237\u6ce8\u518c\uff0c\u9700\u8981\u53d1\u9001\u6ce8\u518c\u90ae\u4ef6\u548c\u6ce8\u518c\u77ed\u4fe1\uff0c\u4f20\u7edf\u7684\u505a\u6cd5\u6709\u4e24\u79cd\uff1a\u4e32\u884c\u3001\u5e76\u884c\u3002<\/span><\/p>\n
                \n
              • \n
                \u4e32\u884c\u65b9\u5f0f\uff1a\u5c06\u6ce8\u518c\u4fe1\u606f\u5199\u5e93\u540e\uff0850ms\uff09\uff0c\u53d1\u9001\u90ae\u4ef6\uff0850ms\uff09\uff0c\u518d\u53d1\u9001\u77ed\u4fe1\uff0850ms\uff09\uff0c\u4efb\u52a1\u5b8c\u6210\u540e\uff0c\u8fd4\u56de\u5ba2\u6237\u7aef\uff0c\u5171\u8017\u65f6\uff08150ms\uff09<\/span><\/section>\n<\/li>\n
              • \n
                \u5e76\u884c\u65b9\u5f0f\uff1a\u5c06\u6ce8\u518c\u4fe1\u606f\u5199\u5e93\u540e\uff0850ms\uff09\uff0c\u5f00\u542f\u5b50\u7ebf\u7a0b\u8ba9\u53d1\u9001\u90ae\u4ef6\u548c\u53d1\u9001\u77ed\u4fe1\u540c\u65f6\u8fdb\u884c\uff0850ms\uff09\uff0c\u8fd4\u56de\u5ba2\u6237\u7aef\uff0c\u5171\u8017\u65f6\uff08100ms\uff09<\/span><\/section>\n<\/li>\n
              • \n
                \u5f15\u5165MQ\uff0c\u5c06\u6ce8\u518c\u4fe1\u606f\u5199\u5e93\uff0850ms\uff09\uff0c\u5c06\u53d1\u9001\u90ae\u4ef6\u548c\u77ed\u4fe1\u7684\u64cd\u4f5c\u5199\u5165\u961f\u5217\uff085s\uff09\uff0c\u8fd4\u56de\u5ba2\u6237\u7aef\uff0c\u800c\u6d88\u8d39\u8005\u4ec0\u4e48\u65f6\u5019\u4ece\u961f\u5217\u4e2d\u53d6\u6d88\u606f\u8fdb\u884c\u5904\u7406\uff0c\u4e0d\u7528\u5173\u5fc3\uff0c\u5171\u8017\u65f6\uff0855ms\uff09<\/span><\/section>\n<\/li>\n<\/ul>\n
                \u4f7f\u7528\u573a\u666f\uff1a<\/span><\/p>\n
                  \n
                • \n
                  \u5c06\u4e0d\u662f\u5fc5\u987b\u7b49\u5f85\u54cd\u5e94\u7ed3\u679c\u7684\u4e1a\u52a1\u903b\u8f91\u8fdb\u884c\u5f02\u6b65\u5904\u7406<\/span><\/section>\n<\/li>\n<\/ul>\n<\/section>\n
                  \n
                  <\/section>\n<\/section>\n
                  \n","raw":"","protected":false},"excerpt":{"rendered":"
                  \u539f\u6587\uff1ajuejin.cn\/post\/6998363970037874724 \u524d\u8a00 Rabbitmq \u662f\u4f7f\u7528 Erlang \u8bed\u8a00\u5f00\u53d1 …<\/p>\n","protected":false},"author":1,"featured_media":280,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"emotion":"","emotion_color":"","title_style":"","license":"","footnotes":""},"categories":[2,7],"tags":[],"class_list":["post-279","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-java","category-spring-boot"],"post_thumbnail_image":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200447158-150x150.jpg","content_first_image":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200449251.jpg","post_medium_image_300":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200447158.jpg","post_thumbnail_image_624":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200447158.jpg","post_frist_image":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200449251.jpg","post_medium_image":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200447158.jpg","post_large_image":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200447158.jpg","post_full_image":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200447158.jpg","post_all_images":[{"imagesurl":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200449251.jpg","id":"image0"},{"imagesurl":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200449251.jpg","id":"image1"},{"imagesurl":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200451454.jpg","id":"image2"},{"imagesurl":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200451454.jpg","id":"image3"},{"imagesurl":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200452178.jpg","id":"image4"},{"imagesurl":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200452178.jpg","id":"image5"},{"imagesurl":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200453637.jpg","id":"image6"},{"imagesurl":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200453637.jpg","id":"image7"},{"imagesurl":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200455100.jpg","id":"image8"},{"imagesurl":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200455100.jpg","id":"image9"},{"imagesurl":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200456280.jpg","id":"image10"},{"imagesurl":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200456280.jpg","id":"image11"},{"imagesurl":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200457236.jpg","id":"image12"},{"imagesurl":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200457236.jpg","id":"image13"},{"imagesurl":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200458295.jpg","id":"image14"},{"imagesurl":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200458295.jpg","id":"image15"},{"imagesurl":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200459852.jpg","id":"image16"},{"imagesurl":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200459852.jpg","id":"image17"},{"imagesurl":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200500120.jpg","id":"image18"},{"imagesurl":"\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230527200500120.jpg","id":"image19"}],"videoAdId":"","listAd":"0","listAdId":"","listAdEvery":6,"total_comments":1,"category_name":"Java","post_date":"2023-05-27","like_count":"0","praiseWord":"\u9f13\u52b1","copyright_state":"","excitationAd":"0","rewardedVideoAdId":"","detailAdId":"","detailAd":"0","enterpriseMinapp":"0","audios":[],"postImageUrl":"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2023\/05\/20230519082947553.jpg","avatarurls":[],"related_posts":null,"pageviews":324,"next_post_id":309,"next_post_title":"SpringBoot\u6574\u5408Canal+RabbitMQ\u76d1\u542c\u6570\u636e\u53d8\u66f4~","previous_post_id":269,"previous_post_title":"\u7ec6\u6570\u7ebf\u7a0b\u6c60\u768410\u4e2a\u5751\uff0c\u9762\u8bd5\u7ebf\u7a0b\u4e0d\u6015\u4e0d\u6015\u5566","_links":{"self":[{"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/posts\/279","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/comments?post=279"}],"version-history":[{"count":0,"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/posts\/279\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/media\/280"}],"wp:attachment":[{"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/media?parent=279"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/categories?post=279"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/xinchewhd.com.cn\/index.php\/wp-json\/wp\/v2\/tags?post=279"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}