{"id":32292,"date":"2023-10-13T00:46:36","date_gmt":"2023-03-21T19:32:24","guid":{"rendered":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8zeromqnodejs%e8%87%aa%e5%b7%b1%e5%ae%9e%e7%8e%b0docker%e5%ae%b9%e5%99%a8%e7%9a%84%e8%87%aa%e5%8a%a8%e7%bc%a9%e6%94%be%e5%8a%9f%e8%83%bd\/"},"modified":"2024-05-04T03:58:14","modified_gmt":"2024-05-03T19:58:14","slug":"%e4%bd%bf%e7%94%a8zeromqnodejs%e8%87%aa%e5%b7%b1%e5%ae%9e%e7%8e%b0docker%e5%ae%b9%e5%99%a8%e7%9a%84%e8%87%aa%e5%8a%a8%e7%bc%a9%e6%94%be%e5%8a%9f%e8%83%bd","status":"publish","type":"post","link":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8zeromqnodejs%e8%87%aa%e5%b7%b1%e5%ae%9e%e7%8e%b0docker%e5%ae%b9%e5%99%a8%e7%9a%84%e8%87%aa%e5%8a%a8%e7%bc%a9%e6%94%be%e5%8a%9f%e8%83%bd\/","title":{"rendered":"\u4f7f\u7528ZeroMQ+NodeJS\u81ea\u5df1\u5b9e\u73b0Docker\u5bb9\u5668\u7684\u81ea\u52a8\u7f29\u653e\u529f\u80fd"},"content":{"rendered":"<h2>\u9996\u5148<\/h2>\n<p>\u6211\u73b0\u5728\u6b63\u5728\u5f00\u53d1\u4e00\u79cd\u6240\u8c13\u7684\u81ea\u52a9\u6570\u636e\u79d1\u5b66\u5e73\u53f0\uff0c\u7c7b\u4f3c\u4e8e\u5728\u5e38\u89c4\u7684BI\u5de5\u5177\u4e0a\u6dfb\u52a0\u4e86\u6570\u636e\u9884\u5904\u7406\u548c\u673a\u5668\u5b66\u4e60\u529f\u80fd\u7684\u4ea7\u54c1\u3002<\/p>\n<p>UI\u662f\u4e00\u4e2aWeb\u5e94\u7528\u7a0b\u5e8f\uff0c\u4f46\u5728\u540e\u7aef\u9700\u8981\u5f02\u6b65\u8fd0\u884cR\u548cPython\u7a0b\u5e8f\uff0c\u5e76\u4e14\u5e0c\u671b\u80fd\u591f\u6839\u636e\u7528\u6237\u7684\u8d1f\u8f7d\u6765\u589e\u52a0\u6216\u51cf\u5c11\u8ba1\u7b97\u8d44\u6e90\u3002\u56e0\u6b64\uff0c\u6211\u4eec\u4f7f\u7528Docker\u6765\u6267\u884cR\u548cPython\u7684\u5904\u7406\uff0c\u5e76\u5728Web\u670d\u52a1\u7aef\u5b9e\u73b0\u4e86\u5bf9\u5b83\u4eec\u7684\u7b80\u5355\u63a7\u5236\u529f\u80fd\u3002<\/p>\n<h2>\u6784\u6210\u56fe<\/h2>\n<div><img decoding=\"async\" class=\"post-images\" title=\"\" src=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d113837434c4406bf2f76\/4-0.jpeg\" alt=\"architecture.jpg\" \/><\/div>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">Web\u30a2\u30d7\u30ea\u30b1\u30fc\u30b7\u30e7\u30f3\u306e\u30b5\u30fc\u30d0\u30b5\u30a4\u30c9\u306fNodejs(Express)\u3092\u4f7f\u7528<\/ul>\n<\/li>\n<\/ul>\n<p>&nbsp;<\/p>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">Web\u30b5\u30fc\u30d0\u30db\u30b9\u30c8\u3068\u30ef\u30fc\u30ab\u30db\u30b9\u30c8\u306fVM\u3092\u5225\u306b\u3059\u308b<\/ul>\n<\/li>\n<\/ul>\n<p>&nbsp;<\/p>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">\u30c7\u30fc\u30bf\u51e6\u7406\u3092\u884c\u3046\u8a08\u7b97\u30a8\u30f3\u30b8\u30f3\uff08Python\u3067\u5b9f\u88c5\uff09\u306fDocker\u30b3\u30f3\u30c6\u30ca\u4e0a\u3067\u884c\u3046<\/ul>\n<\/li>\n<\/ul>\n<p>&nbsp;<\/p>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">Web\u30b5\u30fc\u30d0\u3068\u8a08\u7b97\u30a8\u30f3\u30b8\u30f3\u3068\u306e\u3084\u308a\u53d6\u308a\u306f\u3001ZeroMQ\u4e0a\u3067JSON\u3067\u884c\u3046<\/ul>\n<\/li>\n<\/ul>\n<p>&nbsp;<\/p>\n<ul class=\"post-ul\">\u30c7\u30fc\u30bf\u672c\u4f53\u306e\u683c\u7d0d\u30fb\u30a2\u30af\u30bb\u30b9\u306b\u306f\u30b5\u30fc\u30d0\u30db\u30b9\u30c8\u3068\u30ef\u30fc\u30ab\u30db\u30b9\u30c8\u4e21\u65b9\u304b\u3089\u8aad\u307f\u66f8\u304d\u3067\u304d\u308b\u5171\u6709\u30d5\u30a1\u30a4\u30eb\u30b9\u30c8\u30ec\u30fc\u30b8\uff08NFS\u7b49\uff09\u3092\u5229\u7528<\/ul>\n<h2>\u5de5\u4f5c\u8fdb\u7a0b\uff08\u8d1f\u8d23\u4f7f\u7528Python\u8fdb\u884c\u6570\u636e\u5904\u7406\u7684\u90e8\u5206\uff09\u3002<\/h2>\n<p>\u6784\u6210\u56fe\u4e2d\u5199\u7740\u201c\u8ba1\u7b97\u5f15\u64ce\u201d\u7684\u90e8\u5206\u662f\u8fdb\u884c\u6570\u636e\u5904\u7406\u7684\u5de5\u4f5c\u8fdb\u7a0b\u3002\u8fd9\u91cc\u662f\u4e00\u4e2a\u5b9e\u65bd\u9009\u62e9\u7684\u9009\u9879\u3002<\/p>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">\u30c7\u30fc\u30bf\u51e6\u7406\u306e\u30ea\u30af\u30a8\u30b9\u30c8\u306e\u305f\u3073\u306b\u30d7\u30ed\u30bb\u30b9\u3092\u751f\u6210\u30fb\u7d42\u4e86\u3055\u305b\u308b<\/ul>\n<\/li>\n<\/ul>\n<p>&nbsp;<\/p>\n<ul class=\"post-ul\">\u30d7\u30ed\u30bb\u30b9\u306f\u30c7\u30fc\u30e2\u30f3\u7684\u306b\u7a3c\u50cd\u3055\u305b\u305f\u307e\u307e\u30ea\u30af\u30a8\u30b9\u30c8\u306e\u3042\u308b\u305f\u3073\u306b\u30c7\u30fc\u30bf\u51e6\u7406\u3092\u884c\u3046<\/ul>\n<p>\u6709\u4e24\u4e2a\u9009\u62e9\uff0c\u4f46\u6211\u9009\u62e9\u4e86\u540e\u8005\u3002<\/p>\n<p>\u6211\u6709\u4ee5\u4e0b\u7684\u539f\u56e0\uff0c\u5373\u4f7f\u662f Docker \u5bb9\u5668\uff0c\u6bcf\u4e2a\u6570\u636e\u5904\u7406\u6b65\u9aa4\u90fd\u751f\u6210\u548c\u5220\u9664\u5bb9\u5668\u53ef\u80fd\u4f1a\u9020\u6210\u5f88\u5927\u7684\u8d1f\u8f7d\uff0c\u800c\u4e14\u4f7f\u7528 ZeroMQ \u53ef\u4ee5\u5728\u4fdd\u6301\u8fdb\u7a0b\u7684\u540c\u65f6\u8f7b\u677e\u8fdb\u884c\u5f02\u6b65\u901a\u4fe1\u3002<\/p>\n<h2>Web\u670d\u52a1\u5668\u548c\u8ba1\u7b97\u5f15\u64ce\u4e4b\u95f4\u7684\u5f02\u6b65\u901a\u4fe1\u6a21\u578b<\/h2>\n<p>\u5728ZeroMQ\u7684\u5957\u63a5\u5b57\u4e2d\uff0c\u6709\u51e0\u79cd\u7c7b\u578b\uff0c\u5982PUB\/SUB\uff0cPUSH\/PULL\uff0cREQ\/REP\u7b49\uff08\u5982\u679c\u4f60\u5bf9\u5b83\u4eec\u7684\u533a\u522b\u4e0d\u592a\u4e86\u89e3\uff0c\u53ef\u4ee5\u5728Qiita\u4e0a\u627e\u5230\u4e00\u4e9b\u5f88\u597d\u7684\u89e3\u91ca\u6587\u7ae0\uff0c\u53ef\u4ee5\u4eceQiita\u7684\u6807\u7b7e\u4e0a\u8ffd\u6eaf\u4e00\u4e0b\uff09\u3002<\/p>\n<h3>\u91cd\u8981\u7684\u6587\u4ef6<\/h3>\n<p>\u9996\u5148\uff0c\u5728\u8bbe\u8ba1\u4e2d\u6709\u4ee5\u4e0b\u8981\u6c42\u3002<\/p>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">\u30b3\u30f3\u30c6\u30ca\u6570\u306f\u8ca0\u8377\u306b\u5fdc\u3058\u3066\u5909\u52d5\u3059\u308b\u305f\u3081Docker\u30cd\u30c3\u30c8\u30ef\u30fc\u30af\u4e0a\u306eIP\u30a2\u30c9\u30ec\u30b9\u304c\u30b3\u30f3\u30c6\u30ca\u3054\u3068\u306b\u5909\u308f\u308b(\u30dd\u30fc\u30c8\u306f\u56fa\u5b9a\u3057\u3066\u304a\u3051\u308b)<\/ul>\n<\/li>\n<\/ul>\n<p>&nbsp;<\/p>\n<ul class=\"post-ul\">\n<li style=\"list-style-type: none;\">\n<ul class=\"post-ul\">ZeroMQ\u306e\u30bd\u30b1\u30c3\u30c8\u3092\u5b9f\u884c\u4e2d\u306b\u751f\u6210\u30fb\u6d88\u6ec5\u3055\u305b\u308b\u3088\u3046\u306a\u8a2d\u8a08\u306f\u8907\u96d1\u3059\u304e\u308b\u306e\u3067\u30c0\u30e1(\u4e88\u3081\u6c7a\u3081\u3089\u308c\u305f\u6570\u30fb\u7a2e\u985e\u306e\u30bd\u30b1\u30c3\u30c8\u3092\u30d7\u30ed\u30bb\u30b9\u306e\u6700\u521d\u306b\u4f5c\u3063\u3066\u305d\u308c\u3092\u4f7f\u3046\u3060\u3051\u3067\u5341\u5206\u3067\u3042\u308b\u3079\u304d\uff09<\/ul>\n<\/li>\n<\/ul>\n<p>&nbsp;<\/p>\n<ul class=\"post-ul\">Python\u306e\u30d7\u30ed\u30bb\u30b9\u304c\u30b3\u30b1\u305f\u308a\u624b\u52d5\u3067Docker\u30b3\u30f3\u30c6\u30ca\u3092\u8d77\u52d5\u30fb\u505c\u6b62\u3057\u305f\u308a\u3057\u3066\u3082Web\u30b5\u30fc\u30d0\u5074\u304c\u305d\u308c\u306a\u308a\u306b\u67d4\u8edf\u306b\u5bfe\u5fdc\u3067\u304d\u308b<\/ul>\n<p>\u4e3a\u4e86\u6ee1\u8db3\u8fd9\u4e9b\u8981\u6c42\uff0c\u6211\u8bbe\u8ba1\u4e86\u4e0b\u9762\u8fd9\u4e2a\u901a\u4fe1\u6a21\u578b\u3002<\/p>\n<h3>\u8bf7\u7528\u4e2d\u6587\u628a\u4ee5\u4e0b\u5185\u5bb9\u6539\u8ff0\u4e00\u904d\uff0c\u53ea\u9700\u63d0\u4f9b\u4e00\u79cd\u9009\u9879\uff1a<\/h3>\n<p>\u5957\u63a5\u5b57\u7684\u6784\u6210\u548c\u987a\u5e8f<\/p>\n<div><img decoding=\"async\" class=\"post-images\" title=\"\" src=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d113837434c4406bf2f76\/18-0.jpeg\" alt=\"communication.jpg\" \/><\/div>\n<p>\u5173\u4e8e\u7aef\u53e3\u53f7\uff0cPUB\/SUB\u7ed1\u5b9a\u57285556\uff0cPUSH\/PULL\u7ed1\u5b9a\u57285557\uff0c\u8fd9\u4e9b\u662f\u56fa\u5b9a\u7684\u3002\u65e0\u8bba\u662fWeb\u670d\u52a1\u5668\u7aef\u8fd8\u662f\u5bb9\u5668\u7aef\uff0c\u90fd\u5206\u522b\u901a\u8fc7bind\u548cconnect\u8fdb\u884c\u8fde\u63a5\u3002<\/p>\n<p>\u6211\u8ba4\u4e3a\u987a\u5e8f\u56fe\u603b\u4f53\u4e0a\u770b\u8d77\u6765\u5f88\u81ea\u7136\uff0c\u4f46\u6709\u4e00\u4e2a\u5730\u65b9\u53ef\u80fd\u4f1a\u611f\u5230\u4e0d\u8212\u670d\uff0c\u5c31\u662f\u53d1\u9001\u547d\u4ee4\u7684\u90e8\u5206\u4f7f\u7528\u4e86\u201cPUB\u201d\u5957\u63a5\u5b57\u8fdb\u884c\u5904\u7406\uff0c\u4f46\u8fd9\u6b63\u662f\u8fd9\u4e2a\u8bbe\u8ba1\u7684\u4eae\u70b9\u3002<\/p>\n<p>\u5728ZeroMQ\u4e2d\uff0c\u8981\u5efa\u7acb\u4e0e\u5bf9\u65b9\u7684\u8fde\u63a5\uff0c\u5f53\u7136\u9700\u8981\u6307\u5b9a\u5bf9\u65b9\u7684IP\u5730\u5740\u548c\u7aef\u53e3\u3002\u4f46\u662f\uff0c\u6839\u636e\u4e0a\u8ff0\u8981\u6c42\uff0c\u5728\u5bb9\u5668\u81ea\u7531\u589e\u51cf\u7684\u73af\u5883\u4e2d\uff0c\u7531\u4e8eIP\u5730\u5740\u4e5f\u53ef\u4ee5\u81ea\u7531\u589e\u51cf\uff0c\u4e3a\u4e86\u80fd\u591f\u4f7f\u7528\u5355\u64ad\u65b9\u5f0f\u6267\u884c\u5904\u7406\u547d\u4ee4\uff0cWeb\u670d\u52a1\u5668\u8fdb\u7a0b\u4e5f\u5fc5\u987b\u4e3a\u6bcf\u4e2a\u5bb9\u5668\u62e5\u6709\u81ea\u5df1\u7684ZeroMQ\u5957\u63a5\u5b57\u3002<\/p>\n<p>\u56e0\u6b64\uff0c\u9996\u5148\u5728\u7a7a\u95f2\u7684\u8fdb\u7a0b\u4e2d\u7684\u4e00\u6bb5\u65f6\u95f4\uff08\u5728\u5f53\u524d\u5b9e\u73b0\u4e2d\u4e3a500\u6beb\u79d2\uff09\u5185\u8fdb\u884c\u52df\u96c6\uff08ping\uff09\uff0c\u5de5\u4f5c\u8fdb\u7a0b\u4f1a\u5728\u81ea\u5df1\u7684ID\uff08\u5373\u4e3b\u673a\u540d\u6216IP\u5730\u5740\uff09\u4e4b\u540e\u8fdb\u884c\u56de\u5e94\uff08pong\uff09\u3002\u4ece\u56de\u5e94\u4e2d\u9009\u62e9\u4e00\u4e2a\u8fdb\u7a0b\uff0c\u5e76\u5728\u6570\u636e\u5904\u7406\u547d\u4ee4\u7684JSON\u4e2d\u6307\u5b9a\u8be5ID\uff0c\u518d\u50cfping\u4e00\u6837\u4f7f\u7528PUB\u5957\u63a5\u5b57\u8fdb\u884c\u5e7f\u64ad\u3002<\/p>\n<p>\u6bcf\u4e2a\u8fdb\u7a0b\uff08\u5305\u62ec\u6b63\u5728\u6267\u884c\u5904\u7406\u7684\u8fdb\u7a0b\uff09\u90fd\u4f1a\u63a5\u6536\u5230\u8be5\u547d\u4ee4\uff0c\u5e76\u5728\u88ab\u5206\u914d\u5230\u7684\u60c5\u51b5\u4e0b\u6267\u884c\u5904\u7406\u3002\u5728ZeroMQ\u7684PUB\/SUB\u6a21\u5f0f\u4e2d\uff0cSUB\u7aef\u53ef\u4ee5\u8f7b\u677e\u5730\u8fc7\u6ee4\u60f3\u8981\u8ba2\u9605\u7684\u6d88\u606f\u3002\u56e0\u6b64\uff0c\u901a\u8fc7\u4f7f\u7528\u7a7a\u683c\u5206\u9694\u6d88\u606f\u5b57\u7b26\u4e32\uff0c\u5c06\u5176\u9996\u90e8\u7684\u6807\u8bb0\uff08\u4e3b\u9898\u540d\u79f0\uff09\u8bbe\u7f6e\u4e3a\u5de5\u4f5c\u8fdb\u7a0bID\uff0c\u7136\u540e\u8ba2\u9605\u4e24\u4e2a\u4e3b\u9898\uff1a\u201c\u81ea\u5df1\u201d\u6216\u201c\u6240\u6709\u4eba\u201d\uff0c\u5373\u53ef\u3002\u53e6\u5916\uff0c\u5f53\u63a5\u6536\u5230\u6d88\u606f\u65f6\uff0c\u6b63\u5728\u6267\u884c\u5904\u7406\u7684\u8282\u70b9\u4f1a\u5728\u5904\u7406\u5b8c\u6210\u540e\u8bfb\u53d6\u8be5\u6d88\u606f\u7684\u547d\u4ee4\uff0c\u4f46\u56e0\u4e3a\u4e3b\u9898\u4e0d\u662f\u81ea\u5df1\u7684\uff0c\u6240\u4ee5\u53ef\u4ee5\u987a\u5229\u5730\u8df3\u8fc7\u8be5\u6d88\u606f\u3002<\/p>\n<p>\u901a\u8fc7\u5728\u521d\u59cb\u9636\u6bb5\u8fdb\u884c500\u6beb\u79d2\u7684ping\u7b49\u5f85\u548c\u62db\u52df\uff0c\u65e0\u8bba\u662f\u5de5\u4f5c\u8fdb\u7a0b\uff08\u5bb9\u5668\uff09\u5d29\u6e83\u8fd8\u662f\u624b\u52a8\u91cd\u65b0\u542f\u52a8\uff0cWeb\u670d\u52a1\u5668\u8fdb\u7a0b\u90fd\u4e0d\u9700\u8981\u6bcf\u6b21\u90fd\u53bb\u4e86\u89e3\u8fd9\u4e9b\u60c5\u51b5\uff0c\u8fd9\u4e5f\u662f\u8fd9\u4e2a\u8bbe\u8ba1\u7684\u5173\u952e\u4e4b\u5904\u3002\u8fd9\u4e2a\u8bbe\u8ba1\u501f\u9274\u4e86\u65e7\u5f0f\u4ee5\u592a\u7f51LAN\u7684CSMA\uff08\u8f7d\u6ce2\u4fa6\u542c\u591a\u8def\u8bbf\u95ee\uff09\u673a\u5236\u3002<\/p>\n<p>\u597d\u7684\uff0c\u90a3\u6211\u4eec\u73b0\u5728\u5f00\u59cb\u4ecb\u7ecd\u5b9e\u9645\u7684\u4ee3\u7801\u5185\u5bb9\u3002<\/p>\n<h2>\u521b\u5efaDocker\u5bb9\u5668<\/h2>\n<pre class=\"post-pre\"><code><span class=\"k\">FROM<\/span><span class=\"s\"> python:2<\/span>\r\n\r\n<span class=\"k\">WORKDIR<\/span><span class=\"s\"> \/usr\/src\/app<\/span>\r\n\r\n<span class=\"k\">RUN <\/span>apt-get update <span class=\"se\">\\\r\n<\/span>    <span class=\"o\">&amp;&amp;<\/span> apt-get <span class=\"nb\">install<\/span> <span class=\"nt\">-y<\/span> <span class=\"nt\">--no-install-recommends<\/span> <span class=\"se\">\\\r\n<\/span>        build-essential <span class=\"se\">\\\r\n<\/span>        libzmq-dev \r\n\r\n<span class=\"k\">COPY<\/span><span class=\"s\"> requirements.txt .\/<\/span>\r\n<span class=\"k\">RUN <\/span>pip <span class=\"nb\">install<\/span> <span class=\"nt\">--no-cache-dir<\/span> <span class=\"nt\">-r<\/span> requirements.txt\r\n\r\n<span class=\"k\">RUN <\/span><span class=\"nb\">mkdir<\/span> .\/work\r\n<span class=\"k\">COPY<\/span><span class=\"s\"> . .\/work<\/span>\r\n\r\n<span class=\"k\">RUN <\/span>useradd <span class=\"nt\">-u<\/span> 1000 isobe\r\n<span class=\"k\">USER<\/span><span class=\"s\"> isobe<\/span>\r\n\r\n<span class=\"k\">CMD<\/span><span class=\"s\"> [ \"python\", \".\/engine.py\" ]<\/span>\r\n\r\n<\/code><\/pre>\n<p>\u6309\u7167\u4e0a\u8ff0\u7684Dockerfile\u7f16\u5199\u9700\u6c42\uff08\u5728requirements.txt\u4e2d\u5199\u5165\u9700\u8981\u7684\u5e93\uff0c\u5982scikit-learn\u548cpandas\uff09\uff0c\u4f7f\u7528docker\u547d\u4ee4\u521b\u5efa\u955c\u50cf\u3002<\/p>\n<pre class=\"post-pre\"><code>% docker run -d -v \/var\/data:\/var\/data my-engine\r\n<\/code><\/pre>\n<p>\/var\/data\u662f\u6302\u8f7d\u5728\uff08\u5bb9\u5668\u4e3b\u673a\uff09\u865a\u62df\u673a\u4e0a\u7684\u5171\u4eab\u5b58\u50a8\u8def\u5f84\u3002<\/p>\n<p>\u987a\u4fbf\u63d0\u4e00\u4e0b\uff0c\u5f00\u53d1\u8fc7\u7a0b\u4e2d\u7684\u4e00\u4e2a\u95ee\u9898\u662f\uff0c\u5373\u4f7f\u7528\u6237\u540d\u79f0\u76f8\u540c\uff0c\u5bb9\u5668\u4e0a\u7684UserID\u4e0e\u5f00\u53d1\u673a\u5668\u6216\u865a\u62df\u673a\u4e0a\u7684UserID\u53ef\u80fd\u4e0d\u540c\u3002\u5728\u8fd9\u79cd\u60c5\u51b5\u4e0b\uff0c\u5982\u679c\u5728\u521b\u5efa\u955c\u50cf\u65f6\u4e0d\u4f7f\u7528useradd\u547d\u4ee4\u7684-u\u9009\u9879\u6765\u4f7f\u5bb9\u5668\u5185\u7684UserID\u4e0e\u4e4b\u5339\u914d\uff0c\u90a3\u4e48\u5c31\u65e0\u6cd5\u5728\u6302\u8f7d\u7684\u76ee\u5f55\u4e0a\u8fdb\u884c\u8bfb\u5199\u64cd\u4f5c\uff0c\u56e0\u4e3a\u6ca1\u6709\u6743\u9650\u3002<\/p>\n<h2>\u5de5\u4f5c\u8fdb\u7a0b\uff08Python\uff09<\/h2>\n<pre class=\"post-pre\"><code><span class=\"kn\">import<\/span> <span class=\"nn\">sys<\/span>\r\n<span class=\"kn\">import<\/span> <span class=\"nn\">os<\/span>\r\n<span class=\"kn\">import<\/span> <span class=\"nn\">json<\/span>\r\n<span class=\"kn\">import<\/span> <span class=\"nn\">zmq<\/span>\r\n<span class=\"kn\">import<\/span> <span class=\"nn\">subprocess<\/span>\r\n\r\n<span class=\"k\">def<\/span> <span class=\"nf\">get_container_id<\/span><span class=\"p\">():<\/span>\r\n    <span class=\"k\">return<\/span> <span class=\"n\">os<\/span><span class=\"p\">.<\/span><span class=\"n\">uname<\/span><span class=\"p\">()[<\/span><span class=\"mi\">1<\/span><span class=\"p\">].<\/span><span class=\"n\">strip<\/span><span class=\"p\">()<\/span>\r\n\r\n<span class=\"k\">def<\/span> <span class=\"nf\">get_webserver_ip<\/span><span class=\"p\">():<\/span>\r\n    <span class=\"n\">cmd<\/span> <span class=\"o\">=<\/span> <span class=\"s\">\"ip route | awk 'NR==1 {print $3}'\"<\/span>\r\n    <span class=\"k\">return<\/span> <span class=\"n\">subprocess<\/span><span class=\"p\">.<\/span><span class=\"n\">check_output<\/span><span class=\"p\">(<\/span><span class=\"n\">cmd<\/span><span class=\"p\">,<\/span><span class=\"n\">shell<\/span><span class=\"o\">=<\/span><span class=\"bp\">True<\/span><span class=\"p\">).<\/span><span class=\"n\">strip<\/span><span class=\"p\">()<\/span>\r\n\r\n<span class=\"k\">if<\/span> <span class=\"n\">__name__<\/span><span class=\"o\">==<\/span><span class=\"s\">'__main__'<\/span><span class=\"p\">:<\/span>\r\n\r\n    <span class=\"n\">cid<\/span> <span class=\"o\">=<\/span> <span class=\"n\">get_container_id<\/span><span class=\"p\">()<\/span>\r\n    <span class=\"n\">ip<\/span> <span class=\"o\">=<\/span> <span class=\"n\">get_webserver_ip<\/span><span class=\"p\">()<\/span>\r\n\r\n    <span class=\"n\">context<\/span> <span class=\"o\">=<\/span> <span class=\"n\">zmq<\/span><span class=\"p\">.<\/span><span class=\"n\">Context<\/span><span class=\"p\">()<\/span>\r\n\r\n    <span class=\"n\">sub<\/span> <span class=\"o\">=<\/span> <span class=\"n\">context<\/span><span class=\"p\">.<\/span><span class=\"n\">socket<\/span><span class=\"p\">(<\/span><span class=\"n\">zmq<\/span><span class=\"p\">.<\/span><span class=\"n\">SUB<\/span><span class=\"p\">)<\/span>\r\n    <span class=\"n\">sub<\/span><span class=\"p\">.<\/span><span class=\"n\">connect<\/span><span class=\"p\">(<\/span><span class=\"s\">'tcp:\/\/'<\/span><span class=\"o\">+<\/span><span class=\"n\">ip<\/span><span class=\"o\">+<\/span><span class=\"s\">':5556'<\/span><span class=\"p\">)<\/span>\r\n    <span class=\"n\">sub<\/span><span class=\"p\">.<\/span><span class=\"n\">setsockopt<\/span><span class=\"p\">(<\/span><span class=\"n\">zmq<\/span><span class=\"p\">.<\/span><span class=\"n\">SUBSCRIBE<\/span><span class=\"p\">,<\/span> <span class=\"s\">'*'<\/span><span class=\"p\">)<\/span>\r\n    <span class=\"n\">sub<\/span><span class=\"p\">.<\/span><span class=\"n\">setsockopt<\/span><span class=\"p\">(<\/span><span class=\"n\">zmq<\/span><span class=\"p\">.<\/span><span class=\"n\">SUBSCRIBE<\/span><span class=\"p\">,<\/span> <span class=\"n\">cid<\/span><span class=\"p\">)<\/span>\r\n\r\n    <span class=\"n\">push<\/span> <span class=\"o\">=<\/span> <span class=\"n\">context<\/span><span class=\"p\">.<\/span><span class=\"n\">socket<\/span><span class=\"p\">(<\/span><span class=\"n\">zmq<\/span><span class=\"p\">.<\/span><span class=\"n\">PUSH<\/span><span class=\"p\">)<\/span>\r\n    <span class=\"n\">push<\/span><span class=\"p\">.<\/span><span class=\"n\">connect<\/span><span class=\"p\">(<\/span><span class=\"s\">'tcp:\/\/'<\/span><span class=\"o\">+<\/span><span class=\"n\">ip<\/span><span class=\"o\">+<\/span><span class=\"s\">':5557'<\/span><span class=\"p\">)<\/span>\r\n\r\n    <span class=\"n\">pong<\/span> <span class=\"o\">=<\/span> <span class=\"n\">json<\/span><span class=\"p\">.<\/span><span class=\"n\">dumps<\/span><span class=\"p\">({<\/span>\r\n        <span class=\"s\">'cid'<\/span><span class=\"p\">:<\/span> <span class=\"n\">cid<\/span><span class=\"p\">,<\/span>\r\n        <span class=\"s\">'type'<\/span><span class=\"p\">:<\/span> <span class=\"s\">'pong'<\/span>\r\n    <span class=\"p\">})<\/span>\r\n    <span class=\"n\">push<\/span><span class=\"p\">.<\/span><span class=\"n\">send<\/span><span class=\"p\">(<\/span><span class=\"n\">pong<\/span><span class=\"p\">)<\/span>\r\n\r\n    <span class=\"k\">while<\/span> <span class=\"bp\">True<\/span><span class=\"p\">:<\/span>\r\n        <span class=\"k\">print<\/span> <span class=\"s\">\"wait\"<\/span>\r\n        <span class=\"n\">s<\/span> <span class=\"o\">=<\/span> <span class=\"n\">sub<\/span><span class=\"p\">.<\/span><span class=\"n\">recv<\/span><span class=\"p\">()<\/span>\r\n        <span class=\"n\">index<\/span> <span class=\"o\">=<\/span> <span class=\"n\">s<\/span><span class=\"p\">.<\/span><span class=\"n\">find<\/span><span class=\"p\">(<\/span><span class=\"s\">' '<\/span><span class=\"p\">)<\/span>\r\n        <span class=\"n\">topic<\/span> <span class=\"o\">=<\/span> <span class=\"n\">s<\/span><span class=\"p\">[:<\/span><span class=\"n\">index<\/span><span class=\"p\">]<\/span>\r\n        <span class=\"n\">msg<\/span> <span class=\"o\">=<\/span> <span class=\"n\">s<\/span><span class=\"p\">[<\/span><span class=\"n\">index<\/span><span class=\"o\">+<\/span><span class=\"mi\">1<\/span><span class=\"p\">:]<\/span>\r\n        <span class=\"k\">if<\/span> <span class=\"n\">msg<\/span><span class=\"o\">==<\/span><span class=\"s\">'ping'<\/span><span class=\"p\">:<\/span>\r\n            <span class=\"n\">push<\/span><span class=\"p\">.<\/span><span class=\"n\">send<\/span><span class=\"p\">(<\/span><span class=\"n\">pong<\/span><span class=\"p\">)<\/span>\r\n            <span class=\"k\">continue<\/span>\r\n\r\n        <span class=\"n\">command<\/span> <span class=\"o\">=<\/span> <span class=\"n\">json<\/span><span class=\"p\">.<\/span><span class=\"n\">loads<\/span><span class=\"p\">(<\/span><span class=\"n\">msg<\/span><span class=\"p\">)<\/span>\r\n\r\n        <span class=\"n\">\u4ee5\u964d<\/span><span class=\"err\">\u3001<\/span><span class=\"n\">\u51e6\u7406\u672c\u4f53<\/span>\r\n\r\n<\/code><\/pre>\n<p>\u8fd9\u662f\u5c06\u4e0a\u9762\u5c55\u793a\u7684\u5e8f\u5217\u56fe\u76f4\u63a5\u5b9e\u65bd\u7684\u7248\u672c\u3002\u5982\u679c\u4e3aWeb\u670d\u52a1\u5668 VM \u548c Worker VM \u5171\u4eab\u4e86 Docker \u7f51\u7edc\uff0c\u90a3\u4e48\u53ef\u4ee5\u4f7f\u7528\u4e0a\u8ff0 Python \u4ee3\u7801\u4e2d\u7684 get_webserver_ip() \u6765\u7b80\u5355\u5730\u901a\u8fc7 ip route \u547d\u4ee4\u83b7\u53d6 Web \u670d\u52a1\u5668\u7684 IP\u3002<\/p>\n<p>Web\u670d\u52a1\u5668\u5728\u521b\u5efa\u5957\u63a5\u5b57\u65f6\u5df2\u7ecf\u5c06\u5176\u7ed1\u5b9a\u5230\u201c*\u201d\u4e0a\u3002\uff08\u8003\u8651\u5230\u4e91\u57fa\u7840\u8bbe\u65bd\u7684\u5185\u90e8\u6027\u8d28\uff0c\u66f4\u6ce8\u91cd\u5b9e\u73b0\u7684\u7b80\u4fbf\u6027\u800c\u975e\u5b89\u5168\u6027\uff09<\/p>\n<h2>\u5728Web\u670d\u52a1\u5668\u7aef<\/h2>\n<p>\u4e0b\u9762\u5c06\u63d0\u4f9b\u4e00\u79cd\u8f83\u957f\u7684\u5b9e\u73b0\u65b9\u5f0f\u3002\u5728nodejs\u4e2d\uff0c\u63a7\u5236Docker\u5bb9\u5668\u6700\u5e38\u89c1\u7684\u5e93\u4f3c\u4e4e\u662fdockerode\u3002<\/p>\n<p>\u5c31\u96be\u70b9\u800c\u8a00\uff0c\u8fd9\u4e2aJS\u6a21\u5757\u53ea\u66b4\u9732\u4e86\u4e00\u4e2aasync\u65b9\u6cd5\uff0c\u5728\u4f7f\u7528\u8be5\u6a21\u5757\u7684Web\u670d\u52a1\u7aef\uff08Node-Express\uff09\u6765\u770b\uff0c\u5c31\u50cf\u662f\u4e00\u4e2a\u540c\u6b65\u7684\u7b80\u5355API\uff0c\u4ece\u800c\u5b9e\u73b0\u4e86\u9690\u85cf\u8fd9\u79cd\u590d\u6742\u7684\u5f02\u6b65\u5904\u7406\uff08\u5728\u8fd9\u79cd\u60c5\u51b5\u4e0b\uff0cPromise\u548cES2017\u7684async\/await\u975e\u5e38\u65b9\u4fbf\uff09\u3002<\/p>\n<p>\u9996\u5148\u662f\u4f7f\u7528\u6b64\u6a21\u5757\uff08Node-Express\uff09\u7684\u4ee3\u7801\u3002\u8c03\u7528\u5de5\u4f5c\u8fdb\u7a0b\uff08\u8ba1\u7b97\u5f15\u64ce\uff09\u53ea\u9700\u8c03\u7528engine\u6a21\u5757\u7684\u65b9\u6cd5\u5e76\u8fdb\u884cawait\u64cd\u4f5c\u3002\u975e\u5e38\u7b80\u5355\u800c\u6e05\u6670\u3002<\/p>\n<pre class=\"post-pre\"><code><span class=\"kd\">var<\/span> <span class=\"nx\">express<\/span> <span class=\"o\">=<\/span> <span class=\"nx\">require<\/span><span class=\"p\">(<\/span><span class=\"dl\">'<\/span><span class=\"s1\">express<\/span><span class=\"dl\">'<\/span><span class=\"p\">)<\/span>\r\n<span class=\"kd\">const<\/span> <span class=\"nx\">router<\/span> <span class=\"o\">=<\/span> <span class=\"nx\">express<\/span><span class=\"p\">.<\/span><span class=\"nx\">Router<\/span><span class=\"p\">()<\/span>      \r\n\r\n<span class=\"kd\">var<\/span> <span class=\"nx\">engine<\/span> <span class=\"o\">=<\/span> <span class=\"nx\">require<\/span><span class=\"p\">(<\/span><span class=\"dl\">'<\/span><span class=\"s1\">.\/engine<\/span><span class=\"dl\">'<\/span><span class=\"p\">)<\/span>\r\n\r\n<span class=\"p\">(<\/span><span class=\"nx\">\u4e2d\u7565<\/span><span class=\"p\">)<\/span>\r\n\r\n<span class=\"nx\">router<\/span><span class=\"p\">.<\/span><span class=\"nx\">post<\/span><span class=\"p\">(<\/span><span class=\"dl\">'<\/span><span class=\"s1\">\/some_rest_api<\/span><span class=\"dl\">'<\/span><span class=\"p\">,<\/span> <span class=\"k\">async<\/span> <span class=\"p\">(<\/span><span class=\"nx\">req<\/span><span class=\"p\">,<\/span><span class=\"nx\">res<\/span><span class=\"p\">)<\/span> <span class=\"o\">=&gt;<\/span> <span class=\"p\">{<\/span>                                                                                                                                                      \r\n\r\n  <span class=\"c1\">\/\/ Do some web parameter process,<\/span>\r\n  <span class=\"c1\">\/\/ to make JSON as commands for engines.<\/span>\r\n  <span class=\"kd\">var<\/span> <span class=\"nx\">cmd<\/span> <span class=\"o\">=<\/span> <span class=\"p\">...<\/span>\r\n\r\n  <span class=\"k\">try<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                                            \r\n    <span class=\"kd\">var<\/span> <span class=\"nx\">result<\/span> <span class=\"o\">=<\/span> <span class=\"k\">await<\/span> <span class=\"nx\">engine<\/span><span class=\"p\">(<\/span><span class=\"nx\">cmd<\/span><span class=\"p\">)<\/span> <span class=\"c1\">\/\/ awesome!! what a beautiful implementation!!                                                                                                                                                                                 <\/span>\r\n\r\n    <span class=\"kd\">var<\/span> <span class=\"nx\">api_response_data<\/span> <span class=\"o\">=<\/span> <span class=\"p\">...<\/span> <span class=\"c1\">\/\/ some post process<\/span>\r\n\r\n    <span class=\"nx\">res<\/span><span class=\"p\">.<\/span><span class=\"nx\">send<\/span><span class=\"p\">(<\/span><span class=\"nx\">api_response_data<\/span><span class=\"p\">)<\/span>                        \r\n  <span class=\"p\">}<\/span> <span class=\"k\">catch<\/span> <span class=\"p\">(<\/span><span class=\"nx\">e<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                                             \r\n    <span class=\"nx\">res<\/span><span class=\"p\">.<\/span><span class=\"nx\">status<\/span><span class=\"p\">(<\/span><span class=\"mi\">500<\/span><span class=\"p\">)<\/span>                                                                                                                                                                                         \r\n    <span class=\"nx\">res<\/span><span class=\"p\">.<\/span><span class=\"nx\">send<\/span><span class=\"p\">(<\/span><span class=\"nx\">e<\/span><span class=\"p\">)<\/span>                                                                                                                                                                                             \r\n  <span class=\"p\">}<\/span>                                                                                                                                                                                                         \r\n<span class=\"p\">})<\/span>                                                                                                                                                                                                          \r\n<\/code><\/pre>\n<p>\u4ee5\u4e0b\u662fengine\u7684\u63a7\u5236\u6a21\u5757\u3002<br \/>\n\uff08\u76ee\u524d\u53ea\u662f\u590d\u5236\u7c98\u8d34\u4e86\u4ee3\u7801\uff0c\u4f46\u7a0d\u540e\u6211\u4f1a\u5199\u6bcf\u4e2a\u65b9\u6cd5\u7684\u8bf4\u660e\u3002\uff09<\/p>\n<pre class=\"post-pre\"><code><span class=\"kd\">const<\/span> <span class=\"nx\">zmq<\/span> <span class=\"o\">=<\/span> <span class=\"nx\">require<\/span><span class=\"p\">(<\/span><span class=\"dl\">'<\/span><span class=\"s1\">zmq<\/span><span class=\"dl\">'<\/span><span class=\"p\">);<\/span>                                                                                                                                                                                 \r\n<span class=\"kd\">const<\/span> <span class=\"nx\">pub<\/span> <span class=\"o\">=<\/span> <span class=\"nx\">zmq<\/span><span class=\"p\">.<\/span><span class=\"nx\">socket<\/span><span class=\"p\">(<\/span><span class=\"dl\">'<\/span><span class=\"s1\">pub<\/span><span class=\"dl\">'<\/span><span class=\"p\">);<\/span>                                                                                                                                                                              \r\n<span class=\"kd\">const<\/span> <span class=\"nx\">pull<\/span> <span class=\"o\">=<\/span> <span class=\"nx\">zmq<\/span><span class=\"p\">.<\/span><span class=\"nx\">socket<\/span><span class=\"p\">(<\/span><span class=\"dl\">'<\/span><span class=\"s1\">pull<\/span><span class=\"dl\">'<\/span><span class=\"p\">);<\/span>                                                                                                                                                                            \r\n\r\n<span class=\"kd\">const<\/span> <span class=\"nx\">moment<\/span> <span class=\"o\">=<\/span> <span class=\"nx\">require<\/span><span class=\"p\">(<\/span><span class=\"dl\">'<\/span><span class=\"s1\">moment<\/span><span class=\"dl\">'<\/span><span class=\"p\">)<\/span>                                                                                                                                                                            \r\n\r\n<span class=\"kd\">const<\/span> <span class=\"nx\">Docker<\/span>  <span class=\"o\">=<\/span> <span class=\"nx\">require<\/span><span class=\"p\">(<\/span><span class=\"dl\">'<\/span><span class=\"s1\">dockerode<\/span><span class=\"dl\">'<\/span><span class=\"p\">)<\/span>                                                                                                                                                                        \r\n<span class=\"kd\">const<\/span> <span class=\"nx\">docker<\/span> <span class=\"o\">=<\/span> <span class=\"k\">new<\/span> <span class=\"nx\">Docker<\/span><span class=\"p\">({<\/span><span class=\"na\">socketPath<\/span><span class=\"p\">:<\/span> <span class=\"dl\">'<\/span><span class=\"s1\">\/var\/run\/docker.sock<\/span><span class=\"dl\">'<\/span><span class=\"p\">});<\/span>                                                                                                                                            \r\n\r\n<span class=\"kd\">const<\/span> <span class=\"nx\">production<\/span> <span class=\"o\">=<\/span> <span class=\"nx\">process<\/span><span class=\"p\">.<\/span><span class=\"nx\">env<\/span><span class=\"p\">.<\/span><span class=\"nx\">NODE_ENV<\/span><span class=\"o\">==<\/span><span class=\"dl\">'<\/span><span class=\"s1\">production<\/span><span class=\"dl\">'<\/span>                                                                                                                                                       \r\n<span class=\"kd\">const<\/span> <span class=\"nx\">config<\/span> <span class=\"o\">=<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                                            \r\n  <span class=\"na\">INITIAL_WAIT<\/span><span class=\"p\">:<\/span> <span class=\"mi\">1000<\/span><span class=\"p\">,<\/span>                                                                                                                                                                                       \r\n  <span class=\"na\">MONITOR_INTERVAL<\/span><span class=\"p\">:<\/span> <span class=\"nx\">production<\/span> <span class=\"p\">?<\/span> <span class=\"mi\">30000<\/span> <span class=\"p\">:<\/span> <span class=\"mi\">10000<\/span><span class=\"p\">,<\/span> <span class=\"c1\">\/\/ milli seconds                                                                                                                                            <\/span>\r\n  <span class=\"na\">PING_TIMEOUT<\/span><span class=\"p\">:<\/span> <span class=\"mi\">500<\/span><span class=\"p\">,<\/span> <span class=\"c1\">\/\/ milli seconds                                                                                                                                                                       <\/span>\r\n  <span class=\"na\">IDLE_LIMIT<\/span><span class=\"p\">:<\/span> <span class=\"mi\">60<\/span><span class=\"p\">,<\/span> <span class=\"c1\">\/\/ seconds                                                                                                                                                                                <\/span>\r\n  <span class=\"na\">MINIMUM_IDLE_WORKERS<\/span><span class=\"p\">:<\/span> <span class=\"nx\">production<\/span> <span class=\"p\">?<\/span> <span class=\"mi\">3<\/span> <span class=\"p\">:<\/span> <span class=\"mi\">1<\/span><span class=\"p\">,<\/span>                                                                                                                                                                 \r\n  <span class=\"na\">AUTO_SCALE<\/span><span class=\"p\">:<\/span> <span class=\"nx\">production<\/span>                                                                                                                                                                                    \r\n<span class=\"p\">}<\/span>                                                                                                                                                                                                           \r\n\r\n<span class=\"kd\">const<\/span> <span class=\"nx\">workers<\/span> <span class=\"o\">=<\/span> <span class=\"p\">{}<\/span>                                                                                                                                                                                          \r\n\r\n<span class=\"kd\">const<\/span> <span class=\"nx\">state_char<\/span> <span class=\"o\">=<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                                        \r\n  <span class=\"na\">ready<\/span><span class=\"p\">:<\/span><span class=\"dl\">'<\/span><span class=\"s1\">.<\/span><span class=\"dl\">'<\/span><span class=\"p\">,<\/span><span class=\"na\">reserved<\/span><span class=\"p\">:<\/span><span class=\"dl\">'<\/span><span class=\"s1\">o<\/span><span class=\"dl\">'<\/span><span class=\"p\">,<\/span><span class=\"na\">running<\/span><span class=\"p\">:<\/span><span class=\"dl\">'<\/span><span class=\"s1\">O<\/span><span class=\"dl\">'<\/span><span class=\"p\">,<\/span><span class=\"na\">stopping<\/span><span class=\"p\">:<\/span><span class=\"dl\">'<\/span><span class=\"s1\">x<\/span><span class=\"dl\">'<\/span><span class=\"p\">,<\/span>                                                                                                                                                          \r\n<span class=\"p\">}<\/span>                                                                                                                                                                                                           \r\n<span class=\"kd\">function<\/span> <span class=\"nx\">show_workers_string<\/span><span class=\"p\">()<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                            \r\n  <span class=\"k\">return<\/span> <span class=\"nb\">Object<\/span><span class=\"p\">.<\/span><span class=\"nx\">values<\/span><span class=\"p\">(<\/span><span class=\"nx\">workers<\/span><span class=\"p\">)<\/span>                                                                                                                                                                             \r\n        <span class=\"p\">.<\/span><span class=\"nx\">sort<\/span><span class=\"p\">((<\/span><span class=\"nx\">a<\/span><span class=\"p\">,<\/span><span class=\"nx\">b<\/span><span class=\"p\">)<\/span><span class=\"o\">=&gt;<\/span><span class=\"p\">(<\/span><span class=\"nx\">a<\/span><span class=\"p\">.<\/span><span class=\"nx\">discovered<\/span><span class=\"o\">&gt;<\/span><span class=\"nx\">b<\/span><span class=\"p\">.<\/span><span class=\"nx\">discovered<\/span><span class=\"p\">?<\/span><span class=\"o\">+<\/span><span class=\"mi\">1<\/span><span class=\"p\">:<\/span><span class=\"o\">-<\/span><span class=\"mi\">1<\/span><span class=\"p\">))<\/span>                                                                                                                                                     \r\n        <span class=\"p\">.<\/span><span class=\"nx\">reduce<\/span><span class=\"p\">((<\/span><span class=\"nx\">ss<\/span><span class=\"p\">,<\/span><span class=\"nx\">w<\/span><span class=\"p\">)<\/span><span class=\"o\">=&gt;<\/span><span class=\"p\">(<\/span><span class=\"nx\">ss<\/span><span class=\"o\">+<\/span><span class=\"nx\">state_char<\/span><span class=\"p\">[<\/span><span class=\"nx\">w<\/span><span class=\"p\">.<\/span><span class=\"nx\">state<\/span><span class=\"p\">]),<\/span><span class=\"dl\">''<\/span><span class=\"p\">)<\/span>                                                                                                                                                        \r\n<span class=\"p\">}<\/span>                                                                                                                                                                                                           \r\n<span class=\"kd\">function<\/span> <span class=\"nx\">show_workers<\/span><span class=\"p\">()<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                                   \r\n  <span class=\"kd\">const<\/span> <span class=\"nx\">ss<\/span> <span class=\"o\">=<\/span> <span class=\"nx\">show_workers_string<\/span><span class=\"p\">()<\/span>                                                                                                                                                                          \r\n  <span class=\"nx\">console<\/span><span class=\"p\">.<\/span><span class=\"nx\">log<\/span><span class=\"p\">(<\/span><span class=\"s2\">`workers: [<\/span><span class=\"p\">${<\/span><span class=\"nx\">ss<\/span><span class=\"p\">}<\/span><span class=\"s2\">]`<\/span><span class=\"p\">)<\/span>                                                                                                                                                                           \r\n<span class=\"p\">}<\/span>                                                                                                                                                                                                           \r\n\r\n<span class=\"nx\">pub<\/span><span class=\"p\">.<\/span><span class=\"nx\">bind<\/span><span class=\"p\">(<\/span><span class=\"dl\">'<\/span><span class=\"s1\">tcp:\/\/*:5556<\/span><span class=\"dl\">'<\/span><span class=\"p\">,()<\/span><span class=\"o\">=&gt;<\/span><span class=\"p\">{<\/span>                                                                                                                                                                               \r\n  <span class=\"nx\">console<\/span><span class=\"p\">.<\/span><span class=\"nx\">log<\/span><span class=\"p\">(<\/span><span class=\"dl\">'<\/span><span class=\"s1\">engine(pub): bound<\/span><span class=\"dl\">'<\/span><span class=\"p\">)<\/span>                                                                                                                                                                         \r\n  <span class=\"nx\">setTimeout<\/span><span class=\"p\">(<\/span><span class=\"nx\">init<\/span><span class=\"p\">,<\/span><span class=\"nx\">config<\/span><span class=\"p\">.<\/span><span class=\"nx\">INITIAL_WAIT<\/span><span class=\"p\">)<\/span>                                                                                                                                                                      \r\n  <span class=\"nx\">monitor<\/span><span class=\"p\">()<\/span>                                                                                                                                                                                                 \r\n<span class=\"p\">})<\/span>                                                                                                                                                                                                          \r\n\r\n<span class=\"nx\">pull<\/span><span class=\"p\">.<\/span><span class=\"nx\">bind<\/span><span class=\"p\">(<\/span><span class=\"dl\">'<\/span><span class=\"s1\">tcp:\/\/*:5557<\/span><span class=\"dl\">'<\/span><span class=\"p\">,()<\/span><span class=\"o\">=&gt;<\/span><span class=\"p\">{<\/span>                                                                                                                                                                              \r\n  <span class=\"nx\">console<\/span><span class=\"p\">.<\/span><span class=\"nx\">log<\/span><span class=\"p\">(<\/span><span class=\"dl\">'<\/span><span class=\"s1\">engine(pull): bound<\/span><span class=\"dl\">'<\/span><span class=\"p\">)<\/span>                                                                                                                                                                        \r\n  <span class=\"nx\">pull<\/span><span class=\"p\">.<\/span><span class=\"nx\">on<\/span><span class=\"p\">(<\/span><span class=\"dl\">'<\/span><span class=\"s1\">message<\/span><span class=\"dl\">'<\/span><span class=\"p\">,<\/span><span class=\"nx\">handle_response<\/span><span class=\"p\">)<\/span>                                                                                                                                                                        \r\n<span class=\"p\">})<\/span>                                     \r\n\r\n<span class=\"k\">async<\/span> <span class=\"kd\">function<\/span> <span class=\"nx\">start_worker<\/span><span class=\"p\">()<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                             \r\n  <span class=\"kd\">const<\/span> <span class=\"nx\">container<\/span> <span class=\"o\">=<\/span> <span class=\"k\">await<\/span> <span class=\"nx\">docker<\/span><span class=\"p\">.<\/span><span class=\"nx\">createContainer<\/span><span class=\"p\">({<\/span>                                                                                                                                                          \r\n    <span class=\"na\">Image<\/span><span class=\"p\">:<\/span> <span class=\"dl\">'<\/span><span class=\"s1\">datarecipe-eng<\/span><span class=\"dl\">'<\/span><span class=\"p\">,<\/span>                                                                                                                                                                                \r\n    <span class=\"na\">AttachStdin<\/span><span class=\"p\">:<\/span> <span class=\"kc\">false<\/span><span class=\"p\">,<\/span>                                                                                                                                                                                     \r\n    <span class=\"na\">AttachStdout<\/span><span class=\"p\">:<\/span> <span class=\"kc\">true<\/span><span class=\"p\">,<\/span>                                                                                                                                                                                     \r\n    <span class=\"na\">AttachStderr<\/span><span class=\"p\">:<\/span> <span class=\"kc\">true<\/span><span class=\"p\">,<\/span>                                                                                                                                                                                     \r\n    <span class=\"na\">Tty<\/span><span class=\"p\">:<\/span> <span class=\"kc\">false<\/span><span class=\"p\">,<\/span>                                                                                                                                                                                             \r\n    <span class=\"na\">OpenStdin<\/span><span class=\"p\">:<\/span> <span class=\"kc\">false<\/span><span class=\"p\">,<\/span>                                                                                                                                                                                       \r\n    <span class=\"na\">StdinOnce<\/span><span class=\"p\">:<\/span> <span class=\"kc\">false<\/span><span class=\"p\">,<\/span>                                                                                                                                                                                       \r\n    <span class=\"na\">HostConfig<\/span><span class=\"p\">:<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                                           \r\n      <span class=\"na\">Binds<\/span><span class=\"p\">:<\/span> <span class=\"p\">[<\/span><span class=\"dl\">'<\/span><span class=\"s1\">\/var\/data:\/var\/data<\/span><span class=\"dl\">'<\/span><span class=\"p\">]<\/span>                                                                                                                                                                        \r\n    <span class=\"p\">}<\/span>                                                                                                                                                                                                       \r\n  <span class=\"p\">})<\/span>                                                                                                                                                                                                        \r\n  <span class=\"k\">await<\/span> <span class=\"nx\">container<\/span><span class=\"p\">.<\/span><span class=\"nx\">start<\/span><span class=\"p\">()<\/span>                                                                                                                                                                                   \r\n<span class=\"p\">}<\/span>                                                                                                                                                                                                           \r\n\r\n<span class=\"k\">async<\/span> <span class=\"kd\">function<\/span> <span class=\"nx\">stop_worker<\/span><span class=\"p\">(<\/span><span class=\"nx\">cid<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                           \r\n  <span class=\"nx\">workers<\/span><span class=\"p\">[<\/span><span class=\"nx\">cid<\/span><span class=\"p\">].<\/span><span class=\"nx\">state<\/span> <span class=\"o\">=<\/span> <span class=\"dl\">'<\/span><span class=\"s1\">stopping<\/span><span class=\"dl\">'<\/span>                                                                                                                                                                           \r\n  <span class=\"kd\">const<\/span> <span class=\"nx\">container<\/span> <span class=\"o\">=<\/span> <span class=\"nx\">docker<\/span><span class=\"p\">.<\/span><span class=\"nx\">getContainer<\/span><span class=\"p\">(<\/span><span class=\"nx\">cid<\/span><span class=\"p\">)<\/span>                                                                                                                                                                \r\n  <span class=\"k\">if<\/span> <span class=\"p\">(<\/span><span class=\"nx\">container<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                                          \r\n    <span class=\"k\">await<\/span> <span class=\"nx\">container<\/span><span class=\"p\">.<\/span><span class=\"nx\">stop<\/span><span class=\"p\">()<\/span>                                                                                                                                                                                  \r\n    <span class=\"k\">await<\/span> <span class=\"nx\">container<\/span><span class=\"p\">.<\/span><span class=\"nx\">remove<\/span><span class=\"p\">()<\/span>                                                                                                                                                                                \r\n    <span class=\"nx\">console<\/span><span class=\"p\">.<\/span><span class=\"nx\">log<\/span><span class=\"p\">(<\/span><span class=\"s2\">`conatiner <\/span><span class=\"p\">${<\/span><span class=\"nx\">cid<\/span><span class=\"p\">}<\/span><span class=\"s2\"> stopped\/removed.`<\/span><span class=\"p\">)<\/span>                                                                                                                                                        \r\n  <span class=\"p\">}<\/span>                                                                                                                                                                                                         \r\n  <span class=\"k\">delete<\/span> <span class=\"nx\">workers<\/span><span class=\"p\">[<\/span><span class=\"nx\">cid<\/span><span class=\"p\">]<\/span>                                                                                                                                                                                       \r\n<span class=\"p\">}<\/span>                               \r\n\r\n<span class=\"kd\">function<\/span> <span class=\"nx\">init<\/span><span class=\"p\">()<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                                           \r\n  <span class=\"nx\">console<\/span><span class=\"p\">.<\/span><span class=\"nx\">log<\/span><span class=\"p\">(<\/span><span class=\"dl\">'<\/span><span class=\"s1\">ping<\/span><span class=\"dl\">'<\/span><span class=\"p\">)<\/span>                                                                                                                                                                                       \r\n  <span class=\"nx\">pub<\/span><span class=\"p\">.<\/span><span class=\"nx\">send<\/span><span class=\"p\">([<\/span><span class=\"dl\">'<\/span><span class=\"s1\">* ping<\/span><span class=\"dl\">'<\/span><span class=\"p\">],<\/span><span class=\"mi\">0<\/span><span class=\"p\">,()<\/span><span class=\"o\">=&gt;<\/span><span class=\"p\">{<\/span>                                                                                                                                                                               \r\n    <span class=\"nx\">setTimeout<\/span><span class=\"p\">(()<\/span><span class=\"o\">=&gt;<\/span><span class=\"p\">{<\/span>                                                                                                                                                                                        \r\n      <span class=\"kd\">const<\/span> <span class=\"nx\">ready<\/span> <span class=\"o\">=<\/span> <span class=\"nb\">Object<\/span><span class=\"p\">.<\/span><span class=\"nx\">keys<\/span><span class=\"p\">(<\/span><span class=\"nx\">workers<\/span><span class=\"p\">).<\/span><span class=\"nx\">length<\/span>                                                                                                                                                             \r\n      <span class=\"kd\">const<\/span> <span class=\"nx\">shortage<\/span> <span class=\"o\">=<\/span> <span class=\"nx\">config<\/span><span class=\"p\">.<\/span><span class=\"nx\">MINIMUM_IDLE_WORKERS<\/span><span class=\"o\">-<\/span><span class=\"nx\">ready<\/span>                                                                                                                                                    \r\n      <span class=\"k\">if<\/span> <span class=\"p\">(<\/span><span class=\"nx\">shortage<\/span><span class=\"o\">&gt;<\/span><span class=\"mi\">0<\/span> <span class=\"o\">&amp;&amp;<\/span> <span class=\"nx\">config<\/span><span class=\"p\">.<\/span><span class=\"nx\">AUTO_SCALE<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                \r\n        <span class=\"nx\">console<\/span><span class=\"p\">.<\/span><span class=\"nx\">log<\/span><span class=\"p\">(<\/span><span class=\"s2\">`shortage <\/span><span class=\"p\">${<\/span><span class=\"nx\">shortage<\/span><span class=\"p\">}<\/span><span class=\"s2\"> workers.`<\/span><span class=\"p\">)<\/span>                                                                                                                                                        \r\n        <span class=\"k\">for<\/span> <span class=\"p\">(<\/span><span class=\"kd\">var<\/span> <span class=\"nx\">i<\/span><span class=\"o\">=<\/span><span class=\"mi\">0<\/span><span class=\"p\">;<\/span> <span class=\"nx\">i<\/span><span class=\"o\">&lt;<\/span><span class=\"nx\">shortage<\/span><span class=\"p\">;<\/span> <span class=\"nx\">i<\/span><span class=\"o\">++<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                    \r\n          <span class=\"nx\">start_worker<\/span><span class=\"p\">()<\/span>                                                                                                                                                                                    \r\n        <span class=\"p\">}<\/span>                                                                                                                                                                                                   \r\n      <span class=\"p\">}<\/span>                                                                                                                                                                                                     \r\n    <span class=\"p\">},<\/span><span class=\"nx\">config<\/span><span class=\"p\">.<\/span><span class=\"nx\">PING_TIMEOUT<\/span><span class=\"p\">)<\/span>                                                                                                                                                                                  \r\n  <span class=\"p\">})<\/span>                                                                                                                                                                                                        \r\n<span class=\"p\">}<\/span>                                                                                                                                                                                                           \r\n\r\n<span class=\"kd\">function<\/span> <span class=\"nx\">monitor<\/span><span class=\"p\">()<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                                        \r\n  <span class=\"nx\">setInterval<\/span><span class=\"p\">(()<\/span><span class=\"o\">=&gt;<\/span><span class=\"p\">{<\/span>                                                                                                                                                                                         \r\n    <span class=\"kd\">const<\/span> <span class=\"nx\">limit<\/span> <span class=\"o\">=<\/span> <span class=\"nx\">moment<\/span><span class=\"p\">().<\/span><span class=\"nx\">subtract<\/span><span class=\"p\">(<\/span><span class=\"nx\">config<\/span><span class=\"p\">.<\/span><span class=\"nx\">IDLE_LIMIT<\/span><span class=\"p\">,<\/span><span class=\"dl\">'<\/span><span class=\"s1\">s<\/span><span class=\"dl\">'<\/span><span class=\"p\">)<\/span>                                                                                                                                                  \r\n    <span class=\"kd\">const<\/span> <span class=\"nx\">idle_workers<\/span> <span class=\"o\">=<\/span> <span class=\"nb\">Object<\/span><span class=\"p\">.<\/span><span class=\"nx\">entries<\/span><span class=\"p\">(<\/span><span class=\"nx\">workers<\/span><span class=\"p\">).<\/span><span class=\"nx\">filter<\/span><span class=\"p\">(([<\/span><span class=\"nx\">cid<\/span><span class=\"p\">,<\/span><span class=\"nx\">worker<\/span><span class=\"p\">])<\/span><span class=\"o\">=&gt;<\/span><span class=\"p\">{<\/span>                                                                                                                                   \r\n      <span class=\"k\">return<\/span> <span class=\"nx\">worker<\/span><span class=\"p\">.<\/span><span class=\"nx\">state<\/span><span class=\"o\">==<\/span><span class=\"dl\">'<\/span><span class=\"s1\">ready<\/span><span class=\"dl\">'<\/span> <span class=\"o\">&amp;&amp;<\/span> <span class=\"nx\">worker<\/span><span class=\"p\">.<\/span><span class=\"nx\">moment<\/span><span class=\"o\">&lt;=<\/span><span class=\"nx\">limit<\/span>                                                                                                                                                  \r\n    <span class=\"p\">})<\/span>                                                                                                                                                                                                      \r\n    <span class=\"c1\">\/\/console.log(`${idle_workers.length} idle workers.`)                                                                                                                                                   <\/span>\r\n    <span class=\"kd\">const<\/span> <span class=\"nx\">excess<\/span> <span class=\"o\">=<\/span> <span class=\"nx\">idle_workers<\/span><span class=\"p\">.<\/span><span class=\"nx\">length<\/span> <span class=\"o\">-<\/span> <span class=\"nx\">config<\/span><span class=\"p\">.<\/span><span class=\"nx\">MINIMUM_IDLE_WORKERS<\/span>                                                                                                                                        \r\n    <span class=\"k\">if<\/span> <span class=\"p\">(<\/span><span class=\"nx\">excess<\/span><span class=\"o\">&gt;<\/span><span class=\"mi\">0<\/span> <span class=\"o\">&amp;&amp;<\/span> <span class=\"nx\">config<\/span><span class=\"p\">.<\/span><span class=\"nx\">AUTO_SCALE<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                    \r\n      <span class=\"nx\">console<\/span><span class=\"p\">.<\/span><span class=\"nx\">log<\/span><span class=\"p\">(<\/span><span class=\"s2\">`extra <\/span><span class=\"p\">${<\/span><span class=\"nx\">excess<\/span><span class=\"p\">}<\/span><span class=\"s2\"> workers.`<\/span><span class=\"p\">)<\/span>                                                                                                                                                               \r\n      <span class=\"k\">for<\/span> <span class=\"p\">(<\/span><span class=\"kd\">var<\/span> <span class=\"nx\">i<\/span><span class=\"o\">=<\/span><span class=\"mi\">0<\/span><span class=\"p\">;<\/span> <span class=\"nx\">i<\/span><span class=\"o\">&lt;<\/span><span class=\"nx\">excess<\/span><span class=\"p\">;<\/span> <span class=\"nx\">i<\/span><span class=\"o\">++<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                        \r\n        <span class=\"kd\">const<\/span> <span class=\"p\">[<\/span><span class=\"nx\">cid<\/span><span class=\"p\">,<\/span><span class=\"nx\">worker<\/span><span class=\"p\">]<\/span> <span class=\"o\">=<\/span> <span class=\"nx\">idle_workers<\/span><span class=\"p\">[<\/span><span class=\"nx\">i<\/span><span class=\"p\">]<\/span>                                                                                                                                                                \r\n        <span class=\"nx\">stop_worker<\/span><span class=\"p\">(<\/span><span class=\"nx\">cid<\/span><span class=\"p\">)<\/span>                                                                                                                                                                                    \r\n      <span class=\"p\">}<\/span>                                                                                                                                                                                                     \r\n    <span class=\"p\">}<\/span>                                                                                                                                                                                                       \r\n    <span class=\"nx\">show_workers<\/span><span class=\"p\">()<\/span>                                                                                                                                                                                          \r\n  <span class=\"p\">},<\/span><span class=\"nx\">config<\/span><span class=\"p\">.<\/span><span class=\"nx\">MONITOR_INTERVAL<\/span><span class=\"p\">)<\/span>                                                                                                                                                                                \r\n<span class=\"p\">}<\/span>                                                                                                                                                                                                           \r\n\r\n<span class=\"kd\">function<\/span> <span class=\"nx\">handle_response<\/span><span class=\"p\">(<\/span><span class=\"nx\">msg<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                             \r\n  <span class=\"kd\">const<\/span> <span class=\"nx\">info<\/span> <span class=\"o\">=<\/span> <span class=\"nx\">JSON<\/span><span class=\"p\">.<\/span><span class=\"nx\">parse<\/span><span class=\"p\">(<\/span><span class=\"nx\">msg<\/span><span class=\"p\">);<\/span>                                                                                                                                                                             \r\n  <span class=\"nx\">console<\/span><span class=\"p\">.<\/span><span class=\"nx\">log<\/span><span class=\"p\">(<\/span><span class=\"s2\">`engine(<\/span><span class=\"p\">${<\/span><span class=\"nx\">info<\/span><span class=\"p\">.<\/span><span class=\"nx\">cid<\/span><span class=\"p\">}<\/span><span class=\"s2\">): <\/span><span class=\"p\">${<\/span><span class=\"nx\">info<\/span><span class=\"p\">.<\/span><span class=\"nx\">type<\/span><span class=\"p\">}<\/span><span class=\"s2\">`<\/span><span class=\"p\">);<\/span>                                                                                                                                                         \r\n  <span class=\"k\">if<\/span> <span class=\"p\">(<\/span><span class=\"o\">!<\/span><span class=\"p\">(<\/span><span class=\"nx\">info<\/span><span class=\"p\">.<\/span><span class=\"nx\">cid<\/span> <span class=\"k\">in<\/span> <span class=\"nx\">workers<\/span><span class=\"p\">))<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                             \r\n    <span class=\"nx\">workers<\/span><span class=\"p\">[<\/span><span class=\"nx\">info<\/span><span class=\"p\">.<\/span><span class=\"nx\">cid<\/span><span class=\"p\">]<\/span> <span class=\"o\">=<\/span> <span class=\"p\">{<\/span><span class=\"na\">cid<\/span><span class=\"p\">:<\/span><span class=\"nx\">info<\/span><span class=\"p\">.<\/span><span class=\"nx\">cid<\/span><span class=\"p\">,<\/span><span class=\"na\">discovered<\/span><span class=\"p\">:<\/span><span class=\"nx\">moment<\/span><span class=\"p\">()}<\/span>                                                                                                                                                  \r\n  <span class=\"p\">}<\/span>                                                                                                                                                                                                         \r\n  <span class=\"nx\">worker<\/span> <span class=\"o\">=<\/span> <span class=\"nx\">workers<\/span><span class=\"p\">[<\/span><span class=\"nx\">info<\/span><span class=\"p\">.<\/span><span class=\"nx\">cid<\/span><span class=\"p\">]<\/span>                                                                                                                                                                                \r\n  <span class=\"k\">if<\/span> <span class=\"p\">(<\/span><span class=\"nx\">info<\/span><span class=\"p\">.<\/span><span class=\"nx\">type<\/span><span class=\"o\">==<\/span><span class=\"dl\">'<\/span><span class=\"s1\">pong<\/span><span class=\"dl\">'<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                                  \r\n    <span class=\"nx\">worker<\/span><span class=\"p\">.<\/span><span class=\"nx\">state<\/span> <span class=\"o\">=<\/span> <span class=\"dl\">'<\/span><span class=\"s1\">ready<\/span><span class=\"dl\">'<\/span>                                                                                                                                                                                  \r\n    <span class=\"k\">if<\/span> <span class=\"p\">(<\/span><span class=\"nx\">worker<\/span><span class=\"p\">.<\/span><span class=\"nx\">cb<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                                        \r\n      <span class=\"kd\">const<\/span> <span class=\"nx\">err<\/span> <span class=\"o\">=<\/span> <span class=\"dl\">'<\/span><span class=\"s1\">worker restarted<\/span><span class=\"dl\">'<\/span>                                                                                                                                                                        \r\n      <span class=\"nx\">worker<\/span><span class=\"p\">.<\/span><span class=\"nx\">cb<\/span><span class=\"p\">(<\/span><span class=\"nx\">err<\/span><span class=\"p\">,<\/span><span class=\"kc\">null<\/span><span class=\"p\">)<\/span>                                                                                                                                                                                   \r\n    <span class=\"p\">}<\/span>                                                                                                                                                                                                       \r\n  <span class=\"p\">}<\/span> <span class=\"k\">else<\/span> <span class=\"k\">if<\/span> <span class=\"p\">(<\/span><span class=\"nx\">info<\/span><span class=\"p\">.<\/span><span class=\"nx\">type<\/span><span class=\"o\">==<\/span><span class=\"dl\">'<\/span><span class=\"s1\">start<\/span><span class=\"dl\">'<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                          \r\n    <span class=\"nx\">worker<\/span><span class=\"p\">.<\/span><span class=\"nx\">state<\/span> <span class=\"o\">=<\/span> <span class=\"dl\">'<\/span><span class=\"s1\">running<\/span><span class=\"dl\">'<\/span>                                                                                                                                                                                \r\n  <span class=\"p\">}<\/span> <span class=\"k\">else<\/span> <span class=\"k\">if<\/span> <span class=\"p\">(<\/span><span class=\"nx\">info<\/span><span class=\"p\">.<\/span><span class=\"nx\">type<\/span><span class=\"o\">==<\/span><span class=\"dl\">'<\/span><span class=\"s1\">finish<\/span><span class=\"dl\">'<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                         \r\n    <span class=\"k\">if<\/span> <span class=\"p\">(<\/span><span class=\"dl\">'<\/span><span class=\"s1\">cb<\/span><span class=\"dl\">'<\/span> <span class=\"k\">in<\/span> <span class=\"nx\">worker<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                                   \r\n      <span class=\"nx\">worker<\/span><span class=\"p\">.<\/span><span class=\"nx\">cb<\/span><span class=\"p\">(<\/span><span class=\"nx\">info<\/span><span class=\"p\">.<\/span><span class=\"nx\">error<\/span><span class=\"p\">,<\/span><span class=\"nx\">info<\/span><span class=\"p\">.<\/span><span class=\"nx\">result<\/span><span class=\"p\">)<\/span>                                                                                                                                                                     \r\n      <span class=\"k\">delete<\/span> <span class=\"nx\">worker<\/span><span class=\"p\">.<\/span><span class=\"nx\">cb<\/span>                                                                                                                                                                                      \r\n    <span class=\"p\">}<\/span>                                                                                                                                                                                                       \r\n    <span class=\"nx\">worker<\/span><span class=\"p\">.<\/span><span class=\"nx\">state<\/span> <span class=\"o\">=<\/span> <span class=\"dl\">'<\/span><span class=\"s1\">ready<\/span><span class=\"dl\">'<\/span>                                                                                                                                                                                  \r\n  <span class=\"p\">}<\/span>                                                                                                                                                                                                         \r\n  <span class=\"nx\">worker<\/span><span class=\"p\">.<\/span><span class=\"nx\">moment<\/span> <span class=\"o\">=<\/span> <span class=\"nx\">moment<\/span><span class=\"p\">()<\/span>                                                                                                                                                                                  \r\n  <span class=\"nx\">show_workers<\/span><span class=\"p\">()<\/span>                                                                                                                                                                                            \r\n<span class=\"p\">}<\/span>                             \r\n\r\n<span class=\"kd\">function<\/span> <span class=\"nx\">select_worker<\/span><span class=\"p\">()<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                                  \r\n  <span class=\"k\">return<\/span> <span class=\"k\">new<\/span> <span class=\"nb\">Promise<\/span><span class=\"p\">(<\/span><span class=\"nx\">cb<\/span><span class=\"o\">=&gt;<\/span><span class=\"p\">{<\/span>                                                                                                                                                                                  \r\n    <span class=\"kd\">const<\/span> <span class=\"nx\">now<\/span> <span class=\"o\">=<\/span> <span class=\"nx\">moment<\/span><span class=\"p\">()<\/span>                                                                                                                                                                                    \r\n    <span class=\"nx\">console<\/span><span class=\"p\">.<\/span><span class=\"nx\">log<\/span><span class=\"p\">(<\/span><span class=\"dl\">'<\/span><span class=\"s1\">ping<\/span><span class=\"dl\">'<\/span><span class=\"p\">)<\/span>                                                                                                                                                                                     \r\n    <span class=\"nx\">pub<\/span><span class=\"p\">.<\/span><span class=\"nx\">send<\/span><span class=\"p\">([<\/span><span class=\"dl\">'<\/span><span class=\"s1\">* ping<\/span><span class=\"dl\">'<\/span><span class=\"p\">],<\/span><span class=\"mi\">0<\/span><span class=\"p\">,()<\/span><span class=\"o\">=&gt;<\/span><span class=\"p\">{<\/span>                                                                                                                                                                             \r\n      <span class=\"nx\">setTimeout<\/span><span class=\"p\">(()<\/span><span class=\"o\">=&gt;<\/span><span class=\"p\">{<\/span>                                                                                                                                                                                      \r\n        <span class=\"kd\">const<\/span> <span class=\"nx\">found<\/span> <span class=\"o\">=<\/span> <span class=\"nb\">Object<\/span><span class=\"p\">.<\/span><span class=\"nx\">values<\/span><span class=\"p\">(<\/span><span class=\"nx\">workers<\/span><span class=\"p\">)<\/span>                                                                                                                                                                \r\n              <span class=\"p\">.<\/span><span class=\"nx\">find<\/span><span class=\"p\">(<\/span><span class=\"nx\">w<\/span><span class=\"o\">=&gt;<\/span><span class=\"p\">(<\/span><span class=\"nx\">w<\/span><span class=\"p\">.<\/span><span class=\"nx\">state<\/span><span class=\"o\">==<\/span><span class=\"dl\">'<\/span><span class=\"s1\">ready<\/span><span class=\"dl\">'<\/span> <span class=\"o\">&amp;&amp;<\/span> <span class=\"nx\">w<\/span><span class=\"p\">.<\/span><span class=\"nx\">moment<\/span><span class=\"o\">&gt;=<\/span><span class=\"nx\">now<\/span><span class=\"p\">))<\/span>                                                                                                                                                 \r\n        <span class=\"k\">if<\/span> <span class=\"p\">(<\/span><span class=\"nx\">found<\/span><span class=\"p\">)<\/span> <span class=\"nx\">found<\/span><span class=\"p\">.<\/span><span class=\"nx\">state<\/span> <span class=\"o\">=<\/span> <span class=\"dl\">'<\/span><span class=\"s1\">reserved<\/span><span class=\"dl\">'<\/span>                                                                                                                                                                 \r\n        <span class=\"nx\">cb<\/span><span class=\"p\">(<\/span><span class=\"nx\">found<\/span><span class=\"p\">)<\/span>                                                                                                                                                                                           \r\n      <span class=\"p\">},<\/span><span class=\"nx\">config<\/span><span class=\"p\">.<\/span><span class=\"nx\">PING_TIMEOUT<\/span><span class=\"p\">)<\/span>                                                                                                                                                                                \r\n    <span class=\"p\">})<\/span>                                                                                                                                                                                                      \r\n  <span class=\"p\">})<\/span>                                                                                                                                                                                                        \r\n<span class=\"p\">}<\/span>          \r\n\r\n<span class=\"k\">async<\/span> <span class=\"kd\">function<\/span> <span class=\"nx\">request<\/span><span class=\"p\">(<\/span><span class=\"nx\">cmd<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                               \r\n  <span class=\"kd\">var<\/span> <span class=\"nx\">worker<\/span> <span class=\"o\">=<\/span> <span class=\"k\">await<\/span> <span class=\"nx\">select_worker<\/span><span class=\"p\">()<\/span>                                                                                                                                                                        \r\n  <span class=\"k\">if<\/span> <span class=\"p\">(<\/span><span class=\"o\">!<\/span><span class=\"nx\">worker<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                                            \r\n    <span class=\"k\">if<\/span> <span class=\"p\">(<\/span><span class=\"nx\">config<\/span><span class=\"p\">.<\/span><span class=\"nx\">AUTO_SCALE<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                                \r\n      <span class=\"nx\">console<\/span><span class=\"p\">.<\/span><span class=\"nx\">log<\/span><span class=\"p\">(<\/span><span class=\"dl\">'<\/span><span class=\"s1\">not found ready worker, so create one.<\/span><span class=\"dl\">'<\/span><span class=\"p\">)<\/span>                                                                                                                                                 \r\n      <span class=\"k\">await<\/span> <span class=\"nx\">start_worker<\/span><span class=\"p\">()<\/span>                                                                                                                                                                                  \r\n      <span class=\"nx\">worker<\/span> <span class=\"o\">=<\/span> <span class=\"k\">await<\/span> <span class=\"nx\">select_worker<\/span><span class=\"p\">()<\/span>                                                                                                                                                                        \r\n    <span class=\"p\">}<\/span>                                                                                                                                                                                                       \r\n    <span class=\"k\">if<\/span> <span class=\"p\">(<\/span><span class=\"o\">!<\/span><span class=\"nx\">worker<\/span><span class=\"p\">)<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                                          \r\n      <span class=\"kd\">const<\/span> <span class=\"nx\">err<\/span> <span class=\"o\">=<\/span> <span class=\"dl\">'<\/span><span class=\"s1\">cannot assign worker.<\/span><span class=\"dl\">'<\/span>                                                                                                                                                                   \r\n      <span class=\"nx\">console<\/span><span class=\"p\">.<\/span><span class=\"nx\">log<\/span><span class=\"p\">(<\/span><span class=\"nx\">err<\/span><span class=\"p\">)<\/span>                                                                                                                                                                                      \r\n      <span class=\"k\">throw<\/span> <span class=\"nx\">err<\/span>                                                                                                                                                                                             \r\n    <span class=\"p\">}<\/span>                                                                                                                                                                                                       \r\n  <span class=\"p\">}<\/span>                                                                                                                                                                                                         \r\n\r\n  <span class=\"nx\">console<\/span><span class=\"p\">.<\/span><span class=\"nx\">log<\/span><span class=\"p\">(<\/span><span class=\"s2\">`worker <\/span><span class=\"p\">${<\/span><span class=\"nx\">worker<\/span><span class=\"p\">.<\/span><span class=\"nx\">cid<\/span><span class=\"p\">}<\/span><span class=\"s2\">: selected`<\/span><span class=\"p\">)<\/span>                                                                                                                                                             \r\n\r\n  <span class=\"k\">return<\/span> <span class=\"k\">await<\/span> <span class=\"k\">new<\/span> <span class=\"nb\">Promise<\/span><span class=\"p\">((<\/span><span class=\"nx\">ok<\/span><span class=\"p\">,<\/span><span class=\"nx\">ng<\/span><span class=\"p\">)<\/span> <span class=\"o\">=&gt;<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                     \r\n    <span class=\"kd\">const<\/span> <span class=\"nx\">msg<\/span> <span class=\"o\">=<\/span> <span class=\"nx\">JSON<\/span><span class=\"p\">.<\/span><span class=\"nx\">stringify<\/span><span class=\"p\">(<\/span><span class=\"nx\">cmd<\/span><span class=\"p\">)<\/span>                                                                                                                                                                         \r\n    <span class=\"nx\">pub<\/span><span class=\"p\">.<\/span><span class=\"nx\">send<\/span><span class=\"p\">([<\/span><span class=\"nx\">worker<\/span><span class=\"p\">.<\/span><span class=\"nx\">cid<\/span><span class=\"o\">+<\/span><span class=\"dl\">'<\/span> <span class=\"dl\">'<\/span><span class=\"o\">+<\/span><span class=\"nx\">msg<\/span><span class=\"p\">],<\/span><span class=\"mi\">0<\/span><span class=\"p\">,()<\/span> <span class=\"o\">=&gt;<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                 \r\n      <span class=\"nx\">console<\/span><span class=\"p\">.<\/span><span class=\"nx\">log<\/span><span class=\"p\">(<\/span><span class=\"dl\">'<\/span><span class=\"s1\">engine: sent <\/span><span class=\"dl\">'<\/span><span class=\"p\">);<\/span>                                                                                                                                                                         \r\n      <span class=\"nx\">worker<\/span><span class=\"p\">.<\/span><span class=\"nx\">cb<\/span> <span class=\"o\">=<\/span> <span class=\"p\">(<\/span><span class=\"nx\">err<\/span><span class=\"p\">,<\/span><span class=\"nx\">ret<\/span><span class=\"p\">)<\/span> <span class=\"o\">=&gt;<\/span> <span class=\"p\">{<\/span>                                                                                                                                                                            \r\n        <span class=\"k\">if<\/span> <span class=\"p\">(<\/span><span class=\"nx\">err<\/span><span class=\"p\">)<\/span> <span class=\"nx\">ng<\/span><span class=\"p\">(<\/span><span class=\"nx\">err<\/span><span class=\"p\">);<\/span> <span class=\"k\">else<\/span> <span class=\"nx\">ok<\/span><span class=\"p\">(<\/span><span class=\"nx\">ret<\/span><span class=\"p\">)<\/span>                                                                                                                                                                      \r\n      <span class=\"p\">}<\/span>                                                                                                                                                                                                     \r\n      <span class=\"nx\">show_workers<\/span><span class=\"p\">()<\/span>                                                                                                                                                                                        \r\n    <span class=\"p\">})<\/span>                                                                                                                                                                                                      \r\n  <span class=\"p\">})<\/span>                                                                                                                                                                                                        \r\n<span class=\"p\">}<\/span>                                                                                                                                                                                                           \r\n\r\n<span class=\"nx\">module<\/span><span class=\"p\">.<\/span><span class=\"nx\">exports<\/span> <span class=\"o\">=<\/span> <span class=\"nx\">request<\/span>            \r\n<\/code><\/pre>\n","protected":false},"excerpt":{"rendered":"<p>\u9996\u5148 \u6211\u73b0\u5728\u6b63\u5728\u5f00\u53d1\u4e00\u79cd\u6240\u8c13\u7684\u81ea\u52a9\u6570\u636e\u79d1\u5b66\u5e73\u53f0\uff0c\u7c7b\u4f3c\u4e8e\u5728\u5e38\u89c4\u7684BI\u5de5\u5177\u4e0a\u6dfb\u52a0\u4e86\u6570\u636e\u9884\u5904\u7406\u548c\u673a\u5668\u5b66\u4e60\u529f\u80fd\u7684\u4ea7\u54c1\u3002 [&hellip;]<\/p>\n","protected":false},"author":7,"featured_media":0,"comment_status":"closed","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[],"class_list":["post-32292","post","type-post","status-publish","format-standard","hentry","category-uncategorized"],"yoast_head":"<!-- This site is optimized with the Yoast SEO Premium plugin v21.5 (Yoast SEO v21.5) - https:\/\/yoast.com\/wordpress\/plugins\/seo\/ -->\n<title>\u4f7f\u7528ZeroMQ+NodeJS\u81ea\u5df1\u5b9e\u73b0Docker\u5bb9\u5668\u7684\u81ea\u52a8\u7f29\u653e\u529f\u80fd - Blog - Silicon Cloud<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.silicloud.com\/zh\/blog\/\u4f7f\u7528zeromqnodejs\u81ea\u5df1\u5b9e\u73b0docker\u5bb9\u5668\u7684\u81ea\u52a8\u7f29\u653e\u529f\u80fd\/\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"\u4f7f\u7528ZeroMQ+NodeJS\u81ea\u5df1\u5b9e\u73b0Docker\u5bb9\u5668\u7684\u81ea\u52a8\u7f29\u653e\u529f\u80fd\" \/>\n<meta property=\"og:description\" content=\"\u9996\u5148 \u6211\u73b0\u5728\u6b63\u5728\u5f00\u53d1\u4e00\u79cd\u6240\u8c13\u7684\u81ea\u52a9\u6570\u636e\u79d1\u5b66\u5e73\u53f0\uff0c\u7c7b\u4f3c\u4e8e\u5728\u5e38\u89c4\u7684BI\u5de5\u5177\u4e0a\u6dfb\u52a0\u4e86\u6570\u636e\u9884\u5904\u7406\u548c\u673a\u5668\u5b66\u4e60\u529f\u80fd\u7684\u4ea7\u54c1\u3002 [&hellip;]\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.silicloud.com\/zh\/blog\/\u4f7f\u7528zeromqnodejs\u81ea\u5df1\u5b9e\u73b0docker\u5bb9\u5668\u7684\u81ea\u52a8\u7f29\u653e\u529f\u80fd\/\" \/>\n<meta property=\"og:site_name\" content=\"Blog - Silicon Cloud\" \/>\n<meta property=\"article:published_time\" content=\"2023-03-21T19:32:24+00:00\" \/>\n<meta property=\"article:modified_time\" content=\"2024-05-03T19:58:14+00:00\" \/>\n<meta property=\"og:image\" content=\"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d113837434c4406bf2f76\/4-0.jpeg\" \/>\n<meta name=\"author\" content=\"\u79d1, \u9896\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"\u79d1, \u9896\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"5 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8zeromqnodejs%e8%87%aa%e5%b7%b1%e5%ae%9e%e7%8e%b0docker%e5%ae%b9%e5%99%a8%e7%9a%84%e8%87%aa%e5%8a%a8%e7%bc%a9%e6%94%be%e5%8a%9f%e8%83%bd\/\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8zeromqnodejs%e8%87%aa%e5%b7%b1%e5%ae%9e%e7%8e%b0docker%e5%ae%b9%e5%99%a8%e7%9a%84%e8%87%aa%e5%8a%a8%e7%bc%a9%e6%94%be%e5%8a%9f%e8%83%bd\/\",\"name\":\"\u4f7f\u7528ZeroMQ+NodeJS\u81ea\u5df1\u5b9e\u73b0Docker\u5bb9\u5668\u7684\u81ea\u52a8\u7f29\u653e\u529f\u80fd - Blog - Silicon Cloud\",\"isPartOf\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\"},\"datePublished\":\"2023-03-21T19:32:24+00:00\",\"dateModified\":\"2024-05-03T19:58:14+00:00\",\"author\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/8ca01ba7f7362ad4edb7da206a12f29e\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8zeromqnodejs%e8%87%aa%e5%b7%b1%e5%ae%9e%e7%8e%b0docker%e5%ae%b9%e5%99%a8%e7%9a%84%e8%87%aa%e5%8a%a8%e7%bc%a9%e6%94%be%e5%8a%9f%e8%83%bd\/#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8zeromqnodejs%e8%87%aa%e5%b7%b1%e5%ae%9e%e7%8e%b0docker%e5%ae%b9%e5%99%a8%e7%9a%84%e8%87%aa%e5%8a%a8%e7%bc%a9%e6%94%be%e5%8a%9f%e8%83%bd\/\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8zeromqnodejs%e8%87%aa%e5%b7%b1%e5%ae%9e%e7%8e%b0docker%e5%ae%b9%e5%99%a8%e7%9a%84%e8%87%aa%e5%8a%a8%e7%bc%a9%e6%94%be%e5%8a%9f%e8%83%bd\/#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.silicloud.com\/zh\/blog\/\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"\u4f7f\u7528ZeroMQ+NodeJS\u81ea\u5df1\u5b9e\u73b0Docker\u5bb9\u5668\u7684\u81ea\u52a8\u7f29\u653e\u529f\u80fd\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#website\",\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/\",\"name\":\"Blog - Silicon Cloud\",\"description\":\"\",\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/8ca01ba7f7362ad4edb7da206a12f29e\",\"name\":\"\u79d1, \u9896\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/secure.gravatar.com\/avatar\/8a6fb3cc7ba2f69d2189ba532aec4633ea7ed75ac0af162ec367cb3abc0fb2af?s=96&d=mm&r=g\",\"contentUrl\":\"https:\/\/secure.gravatar.com\/avatar\/8a6fb3cc7ba2f69d2189ba532aec4633ea7ed75ac0af162ec367cb3abc0fb2af?s=96&d=mm&r=g\",\"caption\":\"\u79d1, \u9896\"},\"url\":\"https:\/\/www.silicloud.com\/zh\/blog\/author\/keying\/\"},{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8zeromqnodejs%e8%87%aa%e5%b7%b1%e5%ae%9e%e7%8e%b0docker%e5%ae%b9%e5%99%a8%e7%9a%84%e8%87%aa%e5%8a%a8%e7%bc%a9%e6%94%be%e5%8a%9f%e8%83%bd\/#local-main-organization-logo\",\"url\":\"\",\"contentUrl\":\"\",\"caption\":\"Blog - Silicon Cloud\"}]}<\/script>\n<!-- \/ Yoast SEO Premium plugin. -->","yoast_head_json":{"title":"\u4f7f\u7528ZeroMQ+NodeJS\u81ea\u5df1\u5b9e\u73b0Docker\u5bb9\u5668\u7684\u81ea\u52a8\u7f29\u653e\u529f\u80fd - Blog - Silicon Cloud","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.silicloud.com\/zh\/blog\/\u4f7f\u7528zeromqnodejs\u81ea\u5df1\u5b9e\u73b0docker\u5bb9\u5668\u7684\u81ea\u52a8\u7f29\u653e\u529f\u80fd\/","og_locale":"zh_CN","og_type":"article","og_title":"\u4f7f\u7528ZeroMQ+NodeJS\u81ea\u5df1\u5b9e\u73b0Docker\u5bb9\u5668\u7684\u81ea\u52a8\u7f29\u653e\u529f\u80fd","og_description":"\u9996\u5148 \u6211\u73b0\u5728\u6b63\u5728\u5f00\u53d1\u4e00\u79cd\u6240\u8c13\u7684\u81ea\u52a9\u6570\u636e\u79d1\u5b66\u5e73\u53f0\uff0c\u7c7b\u4f3c\u4e8e\u5728\u5e38\u89c4\u7684BI\u5de5\u5177\u4e0a\u6dfb\u52a0\u4e86\u6570\u636e\u9884\u5904\u7406\u548c\u673a\u5668\u5b66\u4e60\u529f\u80fd\u7684\u4ea7\u54c1\u3002 [&hellip;]","og_url":"https:\/\/www.silicloud.com\/zh\/blog\/\u4f7f\u7528zeromqnodejs\u81ea\u5df1\u5b9e\u73b0docker\u5bb9\u5668\u7684\u81ea\u52a8\u7f29\u653e\u529f\u80fd\/","og_site_name":"Blog - Silicon Cloud","article_published_time":"2023-03-21T19:32:24+00:00","article_modified_time":"2024-05-03T19:58:14+00:00","og_image":[{"url":"https:\/\/cdn.silicloud.com\/blog-img\/blog\/img\/657d113837434c4406bf2f76\/4-0.jpeg"}],"author":"\u79d1, \u9896","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"\u79d1, \u9896","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"5 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8zeromqnodejs%e8%87%aa%e5%b7%b1%e5%ae%9e%e7%8e%b0docker%e5%ae%b9%e5%99%a8%e7%9a%84%e8%87%aa%e5%8a%a8%e7%bc%a9%e6%94%be%e5%8a%9f%e8%83%bd\/","url":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8zeromqnodejs%e8%87%aa%e5%b7%b1%e5%ae%9e%e7%8e%b0docker%e5%ae%b9%e5%99%a8%e7%9a%84%e8%87%aa%e5%8a%a8%e7%bc%a9%e6%94%be%e5%8a%9f%e8%83%bd\/","name":"\u4f7f\u7528ZeroMQ+NodeJS\u81ea\u5df1\u5b9e\u73b0Docker\u5bb9\u5668\u7684\u81ea\u52a8\u7f29\u653e\u529f\u80fd - Blog - Silicon Cloud","isPartOf":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website"},"datePublished":"2023-03-21T19:32:24+00:00","dateModified":"2024-05-03T19:58:14+00:00","author":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/8ca01ba7f7362ad4edb7da206a12f29e"},"breadcrumb":{"@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8zeromqnodejs%e8%87%aa%e5%b7%b1%e5%ae%9e%e7%8e%b0docker%e5%ae%b9%e5%99%a8%e7%9a%84%e8%87%aa%e5%8a%a8%e7%bc%a9%e6%94%be%e5%8a%9f%e8%83%bd\/#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8zeromqnodejs%e8%87%aa%e5%b7%b1%e5%ae%9e%e7%8e%b0docker%e5%ae%b9%e5%99%a8%e7%9a%84%e8%87%aa%e5%8a%a8%e7%bc%a9%e6%94%be%e5%8a%9f%e8%83%bd\/"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8zeromqnodejs%e8%87%aa%e5%b7%b1%e5%ae%9e%e7%8e%b0docker%e5%ae%b9%e5%99%a8%e7%9a%84%e8%87%aa%e5%8a%a8%e7%bc%a9%e6%94%be%e5%8a%9f%e8%83%bd\/#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.silicloud.com\/zh\/blog\/"},{"@type":"ListItem","position":2,"name":"\u4f7f\u7528ZeroMQ+NodeJS\u81ea\u5df1\u5b9e\u73b0Docker\u5bb9\u5668\u7684\u81ea\u52a8\u7f29\u653e\u529f\u80fd"}]},{"@type":"WebSite","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#website","url":"https:\/\/www.silicloud.com\/zh\/blog\/","name":"Blog - Silicon Cloud","description":"","inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/8ca01ba7f7362ad4edb7da206a12f29e","name":"\u79d1, \u9896","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/#\/schema\/person\/image\/","url":"https:\/\/secure.gravatar.com\/avatar\/8a6fb3cc7ba2f69d2189ba532aec4633ea7ed75ac0af162ec367cb3abc0fb2af?s=96&d=mm&r=g","contentUrl":"https:\/\/secure.gravatar.com\/avatar\/8a6fb3cc7ba2f69d2189ba532aec4633ea7ed75ac0af162ec367cb3abc0fb2af?s=96&d=mm&r=g","caption":"\u79d1, \u9896"},"url":"https:\/\/www.silicloud.com\/zh\/blog\/author\/keying\/"},{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.silicloud.com\/zh\/blog\/%e4%bd%bf%e7%94%a8zeromqnodejs%e8%87%aa%e5%b7%b1%e5%ae%9e%e7%8e%b0docker%e5%ae%b9%e5%99%a8%e7%9a%84%e8%87%aa%e5%8a%a8%e7%bc%a9%e6%94%be%e5%8a%9f%e8%83%bd\/#local-main-organization-logo","url":"","contentUrl":"","caption":"Blog - Silicon Cloud"}]}},"_links":{"self":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/32292","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/users\/7"}],"replies":[{"embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/comments?post=32292"}],"version-history":[{"count":2,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/32292\/revisions"}],"predecessor-version":[{"id":95978,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/posts\/32292\/revisions\/95978"}],"wp:attachment":[{"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/media?parent=32292"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/categories?post=32292"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.silicloud.com\/zh\/blog\/wp-json\/wp\/v2\/tags?post=32292"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}