diff --git a/im-manager/package.json b/im-manager/package.json index 819c54a..294eae4 100644 --- a/im-manager/package.json +++ b/im-manager/package.json @@ -11,6 +11,7 @@ "lint": "eslint . --ext .vue,.js,.jsx,.cjs,.mjs,.ts,.tsx,.cts,.mts --fix --ignore-path .gitignore" }, "dependencies": { + "amqplib": "^0.10.3", "pinia": "^2.1.6", "vue": "^3.3.4", "vue-router": "^4.2.4" diff --git a/im-manager/src/amqp/Send.js b/im-manager/src/amqp/Send.js new file mode 100644 index 0000000..c8a728d --- /dev/null +++ b/im-manager/src/amqp/Send.js @@ -0,0 +1,25 @@ +const amqp = require('amqplib/callback_api.js'); + +amqp.connect('amqp://test:test@114.115.203.60:8071/test', function(error0, connection) { + if (error0) { + throw error0; + } + connection.createChannel(function(error1, channel) { + if (error1) { + throw error1; + } + var exchange = 'ex.test'; + var msg = process.argv.slice(2).join(' ') || 'Hello World!'; + + channel.assertExchange(exchange, 'topic', { + durable: true + }); + channel.publish(exchange, 'test3', Buffer.from(msg)); + console.log(" [x] Sent %s", msg); + }); + + setTimeout(function() { + connection.close(); + process.exit(0); + }, 500); +}); diff --git a/im-manager/src/amqp/receive_logs_topic.js b/im-manager/src/amqp/receive_logs_topic.js new file mode 100644 index 0000000..ca50999 --- /dev/null +++ b/im-manager/src/amqp/receive_logs_topic.js @@ -0,0 +1,34 @@ +const amqp = require('amqplib/callback_api'); + +amqp.connect('amqp://test2:test2@114.115.203.60:8071/test', function (error0, connection) { + if (error0) { + throw error0; + } + connection.createChannel(function (error1, channel) { + if (error1) { + throw error1; + } + const exchange = 'ex.test'; + + channel.assertExchange(exchange, 'topic', { + durable: true + }); + + channel.assertQueue('', { + exclusive: true + }, function (error2, q) { + if (error2) { + throw error2; + } + console.log(' [*] Waiting for logs. To exit press CTRL+C'); + + channel.bindQueue(q.queue, exchange, 'test3'); + + channel.consume(q.queue, function (msg) { + console.log(" [x] %s:'%s'", msg.fields.routingKey, msg.content.toString()); + }, { + noAck: true + }); + }); + }); +}); diff --git a/im-manager/yarn.lock b/im-manager/yarn.lock index ef3666e..7d83b64 100644 --- a/im-manager/yarn.lock +++ b/im-manager/yarn.lock @@ -7,6 +7,15 @@ resolved "http://127.0.0.1:1022/repository/npm/@aashutoshrathi/word-wrap/-/word-wrap-1.2.6.tgz#bd9154aec9983f77b3a034ecaa015c2e4201f6cf" integrity sha512-1Yjs2SvM8TflER/OD3cOjhWWOZb58A2t7wpE2S9XfBYTiIl+XFhQG2bjy4Pu1I+EAlCNUzRDYDdFwFYUKvXcIA== +"@acuminous/bitsyntax@^0.1.2": + version "0.1.2" + resolved "http://127.0.0.1:1022/repository/npm/@acuminous/bitsyntax/-/bitsyntax-0.1.2.tgz#e0b31b9ee7ad1e4dd840c34864327c33d9f1f653" + integrity sha512-29lUK80d1muEQqiUsSo+3A0yP6CdspgC95EnKBMi22Xlwt79i/En4Vr67+cXhU+cZjbti3TgGGC5wy1stIywVQ== + dependencies: + buffer-more-ints "~1.0.0" + debug "^4.3.4" + safe-buffer "~5.1.2" + "@ampproject/remapping@^2.2.0": version "2.2.1" resolved "http://127.0.0.1:1022/repository/npm/@ampproject/remapping/-/remapping-2.2.1.tgz#99e8e11851128b8702cd57c33684f1d0f260b630" @@ -804,6 +813,16 @@ ajv@^6.12.4: json-schema-traverse "^0.4.1" uri-js "^4.2.2" +amqplib@^0.10.3: + version "0.10.3" + resolved "http://127.0.0.1:1022/repository/npm/amqplib/-/amqplib-0.10.3.tgz#e186a2f74521eb55ec54db6d25ae82c29c1f911a" + integrity sha512-UHmuSa7n8vVW/a5HGh2nFPqAEr8+cD4dEZ6u9GjP91nHfr1a54RyAKyra7Sb5NH7NBKOUlyQSMXIp0qAixKexw== + dependencies: + "@acuminous/bitsyntax" "^0.1.2" + buffer-more-ints "~1.0.0" + readable-stream "1.x >=1.1.9" + url-parse "~1.5.10" + ansi-regex@^5.0.1: version "5.0.1" resolved "http://127.0.0.1:1022/repository/npm/ansi-regex/-/ansi-regex-5.0.1.tgz#082cb2c89c9fe8659a311a53bd6a4dc5301db304" @@ -901,6 +920,11 @@ browserslist@^4.21.9: node-releases "^2.0.13" update-browserslist-db "^1.0.11" +buffer-more-ints@~1.0.0: + version "1.0.0" + resolved "http://127.0.0.1:1022/repository/npm/buffer-more-ints/-/buffer-more-ints-1.0.0.tgz#ef4f8e2dddbad429ed3828a9c55d44f05c611422" + integrity sha512-EMetuGFz5SLsT0QTnXzINh4Ksr+oo4i+UGTXEshiGCQWnsgSs7ZhJ8fzlwQ+OzEMs0MpDAMr1hxnblp5a4vcHg== + call-bind@^1.0.0, call-bind@^1.0.2: version "1.0.2" resolved "http://127.0.0.1:1022/repository/npm/call-bind/-/call-bind-1.0.2.tgz#b1d4e89e688119c3c9a903ad30abb2f6a919be3c" @@ -975,6 +999,11 @@ convert-source-map@^1.7.0: resolved "http://127.0.0.1:1022/repository/npm/convert-source-map/-/convert-source-map-1.9.0.tgz#7faae62353fb4213366d0ca98358d22e8368b05f" integrity sha512-ASFBup0Mz1uyiIjANan1jzLQami9z1PoYSZCiiYW2FczPbenXc45FZdBZLzOT+r6+iciuEModtmCti+hjaAk0A== +core-util-is@~1.0.0: + version "1.0.3" + resolved "http://127.0.0.1:1022/repository/npm/core-util-is/-/core-util-is-1.0.3.tgz#a6042d3634c2b27e9328f837b965fac83808db85" + integrity sha512-ZQBvi1DcpJ4GDqanjucZ2Hj3wEO5pZDS89BWbkcrvdxksJorwUDDZamX9ldFkp9aw2lmBDLgkObEA4DWNJ9FYQ== + cross-spawn@^6.0.5: version "6.0.5" resolved "http://127.0.0.1:1022/repository/npm/cross-spawn/-/cross-spawn-6.0.5.tgz#4a5ec7c64dfae22c3a14124dbacdee846d80cbc4" @@ -1572,7 +1601,7 @@ inflight@^1.0.4: once "^1.3.0" wrappy "1" -inherits@2: +inherits@2, inherits@~2.0.1: version "2.0.4" resolved "http://127.0.0.1:1022/repository/npm/inherits/-/inherits-2.0.4.tgz#0fa2c64f932917c3433a0ded55363aae37416b7c" integrity sha512-k/vGaX4/Yla3WzyMCvTQOXYeIHvqOKtnqBduzTHpzpQZzAskKMhZ2K+EnBiSM9zGSoIFeMpXKxa4dYeZIQqewQ== @@ -1711,6 +1740,11 @@ is-weakref@^1.0.2: dependencies: call-bind "^1.0.2" +isarray@0.0.1: + version "0.0.1" + resolved "http://127.0.0.1:1022/repository/npm/isarray/-/isarray-0.0.1.tgz#8a18acfca9a8f4177e09abfc6038939b05d1eedf" + integrity sha512-D2S+3GLxWH+uhrNEcoh/fnmYeP8E8/zHl644d/jdA0g2uyXvy3sb0qxotE+ne0LtccHknQzWwZEzhak7oJ0COQ== + isarray@^2.0.5: version "2.0.5" resolved "http://127.0.0.1:1022/repository/npm/isarray/-/isarray-2.0.5.tgz#8af1e4c1221244cc62459faf38940d4e644a5723" @@ -2085,6 +2119,11 @@ punycode@^2.1.0: resolved "http://127.0.0.1:1022/repository/npm/punycode/-/punycode-2.3.0.tgz#f67fa67c94da8f4d0cfff981aee4118064199b8f" integrity sha512-rRV+zQD8tVFys26lAGR9WUuS4iUAngJScM+ZRSKtvl5tKeZ2t5bvdNFdNHBW9FWR4guGHlgmsZ1G7BSm2wTbuA== +querystringify@^2.1.1: + version "2.2.0" + resolved "http://127.0.0.1:1022/repository/npm/querystringify/-/querystringify-2.2.0.tgz#3345941b4153cb9d082d8eee4cda2016a9aef7f6" + integrity sha512-FIqgj2EUvTa7R50u0rGsyTftzjYmv/a3hO345bZNrqabNqjtgiDMgmo4mkUjd+nzU5oF3dClKqFIPUKybUyqoQ== + queue-microtask@^1.2.2: version "1.2.3" resolved "http://127.0.0.1:1022/repository/npm/queue-microtask/-/queue-microtask-1.2.3.tgz#4929228bbc724dfac43e0efb058caf7b6cfb6243" @@ -2099,6 +2138,16 @@ read-pkg@^3.0.0: normalize-package-data "^2.3.2" path-type "^3.0.0" +"readable-stream@1.x >=1.1.9": + version "1.1.14" + resolved "http://127.0.0.1:1022/repository/npm/readable-stream/-/readable-stream-1.1.14.tgz#7cf4c54ef648e3813084c636dd2079e166c081d9" + integrity sha512-+MeVjFf4L44XUkhM1eYbD8fyEsxcV81pqMSR5gblfcLCHfZvbrqy4/qYHE+/R5HoBUT11WV5O08Cr1n3YXkWVQ== + dependencies: + core-util-is "~1.0.0" + inherits "~2.0.1" + isarray "0.0.1" + string_decoder "~0.10.x" + regexp.prototype.flags@^1.5.0: version "1.5.0" resolved "http://127.0.0.1:1022/repository/npm/regexp.prototype.flags/-/regexp.prototype.flags-1.5.0.tgz#fe7ce25e7e4cca8db37b6634c8a2c7009199b9cb" @@ -2108,6 +2157,11 @@ regexp.prototype.flags@^1.5.0: define-properties "^1.2.0" functions-have-names "^1.2.3" +requires-port@^1.0.0: + version "1.0.0" + resolved "http://127.0.0.1:1022/repository/npm/requires-port/-/requires-port-1.0.0.tgz#925d2601d39ac485e091cf0da5c6e694dc3dcaff" + integrity sha512-KigOCHcocU3XODJxsu8i/j8T9tzT4adHiecwORRQ0ZZFcp7ahwXuRU1m+yuO90C5ZUyGeGfocHDI14M3L3yDAQ== + resolve-from@^4.0.0: version "4.0.0" resolved "http://127.0.0.1:1022/repository/npm/resolve-from/-/resolve-from-4.0.0.tgz#4abcd852ad32dd7baabfe9b40e00a36db5f392e6" @@ -2158,6 +2212,11 @@ safe-array-concat@^1.0.0: has-symbols "^1.0.3" isarray "^2.0.5" +safe-buffer@~5.1.2: + version "5.1.2" + resolved "http://127.0.0.1:1022/repository/npm/safe-buffer/-/safe-buffer-5.1.2.tgz#991ec69d296e0313747d59bdfd2b745c35f8828d" + integrity sha512-Gd2UZBJDkXlY7GbJxfsE8/nvKkUEU1G38c1siN6QP6a9PT9MmHB8GnpscSmMJSoF8LOIrt8ud/wPtojys4G6+g== + safe-regex-test@^1.0.0: version "1.0.0" resolved "http://127.0.0.1:1022/repository/npm/safe-regex-test/-/safe-regex-test-1.0.0.tgz#793b874d524eb3640d1873aad03596db2d4f2295" @@ -2294,6 +2353,11 @@ string.prototype.trimstart@^1.0.6: define-properties "^1.2.0" es-abstract "^1.22.1" +string_decoder@~0.10.x: + version "0.10.31" + resolved "http://127.0.0.1:1022/repository/npm/string_decoder/-/string_decoder-0.10.31.tgz#62e203bc41766c6c28c9fc84301dab1c5310fa94" + integrity sha512-ev2QzSzWPYmy9GuqfIVildA4OdcGLeFZQrq5ys6RtiuF+RQQiZWr8TZNyAcuVXyQRYfEO+MsoB/1BuQVhOJuoQ== + strip-ansi@^6.0.1: version "6.0.1" resolved "http://127.0.0.1:1022/repository/npm/strip-ansi/-/strip-ansi-6.0.1.tgz#9e26c63d30f53443e9489495b2105d37b67a85d9" @@ -2445,6 +2509,14 @@ uri-js@^4.2.2: dependencies: punycode "^2.1.0" +url-parse@~1.5.10: + version "1.5.10" + resolved "http://127.0.0.1:1022/repository/npm/url-parse/-/url-parse-1.5.10.tgz#9d3c2f736c1d75dd3bd2be507dcc111f1e2ea9c1" + integrity sha512-WypcfiRhfeUP9vvF0j6rw0J3hrWrw6iZv3+22h6iRMJ/8z1Tj6XfLP4DsUix5MhMPnXpiHDoKyoZ/bdCkwBCiQ== + dependencies: + querystringify "^2.1.1" + requires-port "^1.0.0" + util-deprecate@^1.0.2: version "1.0.2" resolved "http://127.0.0.1:1022/repository/npm/util-deprecate/-/util-deprecate-1.0.2.tgz#450d4dc9fa70de732762fbd2d4a28981419a0ccf" diff --git a/条件结构流程图.pdf b/条件结构流程图.pdf deleted file mode 100644 index 802e5a3..0000000 Binary files a/条件结构流程图.pdf and /dev/null differ