暂时摘除mq,转移到mq服务中

package-lock.json

@@ -16,14 +16,11 @@
         "@midwayjs/jwt": "^3.16.1",
         "@midwayjs/koa": "^3.12.0",
         "@midwayjs/logger": "^3.1.0",
-        "@midwayjs/rabbitmq": "^3.16.5",
         "@midwayjs/redis": "^3.16.0",
         "@midwayjs/swagger": "^3.16.1",
         "@midwayjs/typeorm": "^3.16.0",
         "@midwayjs/upload": "^3.16.8",
         "@midwayjs/validate": "^3.12.0",
-        "amqp-connection-manager": "^4.1.14",
-        "amqplib": "^0.10.4",
         "axios": "^1.7.4",
         "bcryptjs": "^2.4.3",
         "crypto-js": "^4.2.0",
@@ -35,7 +32,6 @@
       },
       "devDependencies": {
         "@midwayjs/mock": "^3.12.0",
-        "@types/amqplib": "^0.10.5",
         "@types/crypto-js": "^4.2.2",
         "@types/jest": "^29.2.0",
         "@types/lodash": "^4.17.4",
@@ -52,24 +48,6 @@
         "node": ">=12.0.0"
       }
     },
-    "node_modules/@acuminous/bitsyntax": {
-      "version": "0.1.2",
-      "resolved": "https://registry.npmmirror.com/@acuminous/bitsyntax/-/bitsyntax-0.1.2.tgz",
-      "integrity": "sha512-29lUK80d1muEQqiUsSo+3A0yP6CdspgC95EnKBMi22Xlwt79i/En4Vr67+cXhU+cZjbti3TgGGC5wy1stIywVQ==",
-      "dependencies": {
-        "buffer-more-ints": "~1.0.0",
-        "debug": "^4.3.4",
-        "safe-buffer": "~5.1.2"
-      },
-      "engines": {
-        "node": ">=0.8"
-      }
-    },
-    "node_modules/@acuminous/bitsyntax/node_modules/safe-buffer": {
-      "version": "5.1.2",
-      "resolved": "https://registry.npmmirror.com/safe-buffer/-/safe-buffer-5.1.2.tgz",
-      "integrity": "sha512-Gd2UZBJDkXlY7GbJxfsE8/nvKkUEU1G38c1siN6QP6a9PT9MmHB8GnpscSmMJSoF8LOIrt8ud/wPtojys4G6+g=="
-    },
     "node_modules/@ampproject/remapping": {
       "version": "2.3.0",
       "resolved": "https://registry.npmmirror.com/@ampproject/remapping/-/remapping-2.3.0.tgz",
@@ -1443,22 +1421,6 @@
         "node": ">=12"
       }
     },
-    "node_modules/@midwayjs/rabbitmq": {
-      "version": "3.16.5",
-      "resolved": "https://registry.npmmirror.com/@midwayjs/rabbitmq/-/rabbitmq-3.16.5.tgz",
-      "integrity": "sha512-8A8mTORtcUriAL4+PniRHNlY2pX9RE3Ucx5qYvTvVsmSW/OGSlnKswWAFgBmCaHDRUoGCyzAwryz6nOlrB9qRQ==",
-      "dependencies": {
-        "@midwayjs/core": "^3.16.2",
-        "amqp-connection-manager": "4.1.14"
-      },
-      "engines": {
-        "node": ">=12"
-      },
-      "peerDependencies": {
-        "@types/amqplib": "*",
-        "amqplib": "*"
-      }
-    },
     "node_modules/@midwayjs/redis": {
       "version": "3.16.0",
       "resolved": "https://registry.npmmirror.com/@midwayjs/redis/-/redis-3.16.0.tgz",
@@ -1646,14 +1608,6 @@
         "@types/node": "*"
       }
     },
-    "node_modules/@types/amqplib": {
-      "version": "0.10.5",
-      "resolved": "https://registry.npmmirror.com/@types/amqplib/-/amqplib-0.10.5.tgz",
-      "integrity": "sha512-/cSykxROY7BWwDoi4Y4/jLAuZTshZxd8Ey1QYa/VaXriMotBDoou7V/twJiOSHzU6t1Kp1AHAUXGCgqq+6DNeg==",
-      "dependencies": {
-        "@types/node": "*"
-      }
-    },
     "node_modules/@types/babel__core": {
       "version": "7.20.5",
       "resolved": "https://registry.npmmirror.com/@types/babel__core/-/babel__core-7.20.5.tgz",
@@ -2233,56 +2187,6 @@
         "url": "https://github.com/sponsors/epoberezkin"
       }
     },
-    "node_modules/amqp-connection-manager": {
-      "version": "4.1.14",
-      "resolved": "https://registry.npmmirror.com/amqp-connection-manager/-/amqp-connection-manager-4.1.14.tgz",
-      "integrity": "sha512-1km47dIvEr0HhMUazqovSvNwIlSvDX2APdUpULaINtHpiki1O+cLRaTeXb/jav4OLtH+k6GBXx5gsKOT9kcGKQ==",
-      "dependencies": {
-        "promise-breaker": "^6.0.0"
-      },
-      "engines": {
-        "node": ">=10.0.0",
-        "npm": ">5.0.0"
-      },
-      "peerDependencies": {
-        "amqplib": "*"
-      }
-    },
-    "node_modules/amqplib": {
-      "version": "0.10.4",
-      "resolved": "https://registry.npmmirror.com/amqplib/-/amqplib-0.10.4.tgz",
-      "integrity": "sha512-DMZ4eCEjAVdX1II2TfIUpJhfKAuoCeDIo/YyETbfAqehHTXxxs7WOOd+N1Xxr4cKhx12y23zk8/os98FxlZHrw==",
-      "dependencies": {
-        "@acuminous/bitsyntax": "^0.1.2",
-        "buffer-more-ints": "~1.0.0",
-        "readable-stream": "1.x >=1.1.9",
-        "url-parse": "~1.5.10"
-      },
-      "engines": {
-        "node": ">=10"
-      }
-    },
-    "node_modules/amqplib/node_modules/isarray": {
-      "version": "0.0.1",
-      "resolved": "https://registry.npmmirror.com/isarray/-/isarray-0.0.1.tgz",
-      "integrity": "sha512-D2S+3GLxWH+uhrNEcoh/fnmYeP8E8/zHl644d/jdA0g2uyXvy3sb0qxotE+ne0LtccHknQzWwZEzhak7oJ0COQ=="
-    },
-    "node_modules/amqplib/node_modules/readable-stream": {
-      "version": "1.1.14",
-      "resolved": "https://registry.npmmirror.com/readable-stream/-/readable-stream-1.1.14.tgz",
-      "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"
-      }
-    },
-    "node_modules/amqplib/node_modules/string_decoder": {
-      "version": "0.10.31",
-      "resolved": "https://registry.npmmirror.com/string_decoder/-/string_decoder-0.10.31.tgz",
-      "integrity": "sha512-ev2QzSzWPYmy9GuqfIVildA4OdcGLeFZQrq5ys6RtiuF+RQQiZWr8TZNyAcuVXyQRYfEO+MsoB/1BuQVhOJuoQ=="
-    },
     "node_modules/ansi-align": {
       "version": "3.0.1",
       "resolved": "https://registry.npmmirror.com/ansi-align/-/ansi-align-3.0.1.tgz",
@@ -2863,11 +2767,6 @@
         "node": ">=0.10"
       }
     },
-    "node_modules/buffer-more-ints": {
-      "version": "1.0.0",
-      "resolved": "https://registry.npmmirror.com/buffer-more-ints/-/buffer-more-ints-1.0.0.tgz",
-      "integrity": "sha512-EMetuGFz5SLsT0QTnXzINh4Ksr+oo4i+UGTXEshiGCQWnsgSs7ZhJ8fzlwQ+OzEMs0MpDAMr1hxnblp5a4vcHg=="
-    },
     "node_modules/buffers": {
       "version": "0.1.1",
       "resolved": "https://registry.npmmirror.com/buffers/-/buffers-0.1.1.tgz",
@@ -7692,11 +7591,6 @@
         "node": ">=0.4.0"
       }
     },
-    "node_modules/promise-breaker": {
-      "version": "6.0.0",
-      "resolved": "https://registry.npmmirror.com/promise-breaker/-/promise-breaker-6.0.0.tgz",
-      "integrity": "sha512-BthzO9yTPswGf7etOBiHCVuugs2N01/Q/94dIPls48z2zCmrnDptUUZzfIb+41xq0MnYZ/BzmOd6ikDR4ibNZA=="
-    },
     "node_modules/prompts": {
       "version": "2.4.2",
       "resolved": "https://registry.npmmirror.com/prompts/-/prompts-2.4.2.tgz",
@@ -7776,11 +7670,6 @@
         "url": "https://github.com/sponsors/ljharb"
       }
     },
-    "node_modules/querystringify": {
-      "version": "2.2.0",
-      "resolved": "https://registry.npmmirror.com/querystringify/-/querystringify-2.2.0.tgz",
-      "integrity": "sha512-FIqgj2EUvTa7R50u0rGsyTftzjYmv/a3hO345bZNrqabNqjtgiDMgmo4mkUjd+nzU5oF3dClKqFIPUKybUyqoQ=="
-    },
     "node_modules/queue-lit": {
       "version": "1.5.2",
       "resolved": "https://registry.npmmirror.com/queue-lit/-/queue-lit-1.5.2.tgz",
@@ -8103,11 +7992,6 @@
         "node": ">=0.10.0"
       }
     },
-    "node_modules/requires-port": {
-      "version": "1.0.0",
-      "resolved": "https://registry.npmmirror.com/requires-port/-/requires-port-1.0.0.tgz",
-      "integrity": "sha512-KigOCHcocU3XODJxsu8i/j8T9tzT4adHiecwORRQ0ZZFcp7ahwXuRU1m+yuO90C5ZUyGeGfocHDI14M3L3yDAQ=="
-    },
     "node_modules/resolve": {
       "version": "1.22.8",
       "resolved": "https://registry.npmmirror.com/resolve/-/resolve-1.22.8.tgz",
@@ -9401,15 +9285,6 @@
         "punycode": "^2.1.0"
       }
     },
-    "node_modules/url-parse": {
-      "version": "1.5.10",
-      "resolved": "https://registry.npmmirror.com/url-parse/-/url-parse-1.5.10.tgz",
-      "integrity": "sha512-WypcfiRhfeUP9vvF0j6rw0J3hrWrw6iZv3+22h6iRMJ/8z1Tj6XfLP4DsUix5MhMPnXpiHDoKyoZ/bdCkwBCiQ==",
-      "dependencies": {
-        "querystringify": "^2.1.1",
-        "requires-port": "^1.0.0"
-      }
-    },
     "node_modules/url-parse-lax": {
       "version": "3.0.0",
       "resolved": "https://registry.npmmirror.com/url-parse-lax/-/url-parse-lax-3.0.0.tgz",
@@ -9696,23 +9571,6 @@
     }
   },
   "dependencies": {
-    "@acuminous/bitsyntax": {
-      "version": "0.1.2",
-      "resolved": "https://registry.npmmirror.com/@acuminous/bitsyntax/-/bitsyntax-0.1.2.tgz",
-      "integrity": "sha512-29lUK80d1muEQqiUsSo+3A0yP6CdspgC95EnKBMi22Xlwt79i/En4Vr67+cXhU+cZjbti3TgGGC5wy1stIywVQ==",
-      "requires": {
-        "buffer-more-ints": "~1.0.0",
-        "debug": "^4.3.4",
-        "safe-buffer": "~5.1.2"
-      },
-      "dependencies": {
-        "safe-buffer": {
-          "version": "5.1.2",
-          "resolved": "https://registry.npmmirror.com/safe-buffer/-/safe-buffer-5.1.2.tgz",
-          "integrity": "sha512-Gd2UZBJDkXlY7GbJxfsE8/nvKkUEU1G38c1siN6QP6a9PT9MmHB8GnpscSmMJSoF8LOIrt8ud/wPtojys4G6+g=="
-        }
-      }
-    },
     "@ampproject/remapping": {
       "version": "2.3.0",
       "resolved": "https://registry.npmmirror.com/@ampproject/remapping/-/remapping-2.3.0.tgz",
@@ -10770,15 +10628,6 @@
         "supertest": "6.3.3"
       }
     },
-    "@midwayjs/rabbitmq": {
-      "version": "3.16.5",
-      "resolved": "https://registry.npmmirror.com/@midwayjs/rabbitmq/-/rabbitmq-3.16.5.tgz",
-      "integrity": "sha512-8A8mTORtcUriAL4+PniRHNlY2pX9RE3Ucx5qYvTvVsmSW/OGSlnKswWAFgBmCaHDRUoGCyzAwryz6nOlrB9qRQ==",
-      "requires": {
-        "@midwayjs/core": "^3.16.2",
-        "amqp-connection-manager": "4.1.14"
-      }
-    },
     "@midwayjs/redis": {
       "version": "3.16.0",
       "resolved": "https://registry.npmmirror.com/@midwayjs/redis/-/redis-3.16.0.tgz",
@@ -10930,14 +10779,6 @@
         "@types/node": "*"
       }
     },
-    "@types/amqplib": {
-      "version": "0.10.5",
-      "resolved": "https://registry.npmmirror.com/@types/amqplib/-/amqplib-0.10.5.tgz",
-      "integrity": "sha512-/cSykxROY7BWwDoi4Y4/jLAuZTshZxd8Ey1QYa/VaXriMotBDoou7V/twJiOSHzU6t1Kp1AHAUXGCgqq+6DNeg==",
-      "requires": {
-        "@types/node": "*"
-      }
-    },
     "@types/babel__core": {
       "version": "7.20.5",
       "resolved": "https://registry.npmmirror.com/@types/babel__core/-/babel__core-7.20.5.tgz",
@@ -11401,48 +11242,6 @@
         "uri-js": "^4.2.2"
       }
     },
-    "amqp-connection-manager": {
-      "version": "4.1.14",
-      "resolved": "https://registry.npmmirror.com/amqp-connection-manager/-/amqp-connection-manager-4.1.14.tgz",
-      "integrity": "sha512-1km47dIvEr0HhMUazqovSvNwIlSvDX2APdUpULaINtHpiki1O+cLRaTeXb/jav4OLtH+k6GBXx5gsKOT9kcGKQ==",
-      "requires": {
-        "promise-breaker": "^6.0.0"
-      }
-    },
-    "amqplib": {
-      "version": "0.10.4",
-      "resolved": "https://registry.npmmirror.com/amqplib/-/amqplib-0.10.4.tgz",
-      "integrity": "sha512-DMZ4eCEjAVdX1II2TfIUpJhfKAuoCeDIo/YyETbfAqehHTXxxs7WOOd+N1Xxr4cKhx12y23zk8/os98FxlZHrw==",
-      "requires": {
-        "@acuminous/bitsyntax": "^0.1.2",
-        "buffer-more-ints": "~1.0.0",
-        "readable-stream": "1.x >=1.1.9",
-        "url-parse": "~1.5.10"
-      },
-      "dependencies": {
-        "isarray": {
-          "version": "0.0.1",
-          "resolved": "https://registry.npmmirror.com/isarray/-/isarray-0.0.1.tgz",
-          "integrity": "sha512-D2S+3GLxWH+uhrNEcoh/fnmYeP8E8/zHl644d/jdA0g2uyXvy3sb0qxotE+ne0LtccHknQzWwZEzhak7oJ0COQ=="
-        },
-        "readable-stream": {
-          "version": "1.1.14",
-          "resolved": "https://registry.npmmirror.com/readable-stream/-/readable-stream-1.1.14.tgz",
-          "integrity": "sha512-+MeVjFf4L44XUkhM1eYbD8fyEsxcV81pqMSR5gblfcLCHfZvbrqy4/qYHE+/R5HoBUT11WV5O08Cr1n3YXkWVQ==",
-          "requires": {
-            "core-util-is": "~1.0.0",
-            "inherits": "~2.0.1",
-            "isarray": "0.0.1",
-            "string_decoder": "~0.10.x"
-          }
-        },
-        "string_decoder": {
-          "version": "0.10.31",
-          "resolved": "https://registry.npmmirror.com/string_decoder/-/string_decoder-0.10.31.tgz",
-          "integrity": "sha512-ev2QzSzWPYmy9GuqfIVildA4OdcGLeFZQrq5ys6RtiuF+RQQiZWr8TZNyAcuVXyQRYfEO+MsoB/1BuQVhOJuoQ=="
-        }
-      }
-    },
     "ansi-align": {
       "version": "3.0.1",
       "resolved": "https://registry.npmmirror.com/ansi-align/-/ansi-align-3.0.1.tgz",
@@ -11864,11 +11663,6 @@
       "resolved": "https://registry.npmmirror.com/buffer-indexof-polyfill/-/buffer-indexof-polyfill-1.0.2.tgz",
       "integrity": "sha512-I7wzHwA3t1/lwXQh+A5PbNvJxgfo5r3xulgpYDB5zckTu/Z9oUK9biouBKQUjEqzaz3HnAT6TYoovmE+GqSf7A=="
     },
-    "buffer-more-ints": {
-      "version": "1.0.0",
-      "resolved": "https://registry.npmmirror.com/buffer-more-ints/-/buffer-more-ints-1.0.0.tgz",
-      "integrity": "sha512-EMetuGFz5SLsT0QTnXzINh4Ksr+oo4i+UGTXEshiGCQWnsgSs7ZhJ8fzlwQ+OzEMs0MpDAMr1hxnblp5a4vcHg=="
-    },
     "buffers": {
       "version": "0.1.1",
       "resolved": "https://registry.npmmirror.com/buffers/-/buffers-0.1.1.tgz",
@@ -15493,11 +15287,6 @@
       "integrity": "sha512-7PiHtLll5LdnKIMw100I+8xJXR5gW2QwWYkT6iJva0bXitZKa/XMrSbdmg3r2Xnaidz9Qumd0VPaMrZlF9V9sA==",
       "dev": true
     },
-    "promise-breaker": {
-      "version": "6.0.0",
-      "resolved": "https://registry.npmmirror.com/promise-breaker/-/promise-breaker-6.0.0.tgz",
-      "integrity": "sha512-BthzO9yTPswGf7etOBiHCVuugs2N01/Q/94dIPls48z2zCmrnDptUUZzfIb+41xq0MnYZ/BzmOd6ikDR4ibNZA=="
-    },
     "prompts": {
       "version": "2.4.2",
       "resolved": "https://registry.npmmirror.com/prompts/-/prompts-2.4.2.tgz",
@@ -15552,11 +15341,6 @@
         "side-channel": "^1.0.6"
       }
     },
-    "querystringify": {
-      "version": "2.2.0",
-      "resolved": "https://registry.npmmirror.com/querystringify/-/querystringify-2.2.0.tgz",
-      "integrity": "sha512-FIqgj2EUvTa7R50u0rGsyTftzjYmv/a3hO345bZNrqabNqjtgiDMgmo4mkUjd+nzU5oF3dClKqFIPUKybUyqoQ=="
-    },
     "queue-lit": {
       "version": "1.5.2",
       "resolved": "https://registry.npmmirror.com/queue-lit/-/queue-lit-1.5.2.tgz",
@@ -15797,11 +15581,6 @@
       "integrity": "sha512-Xf0nWe6RseziFMu+Ap9biiUbmplq6S9/p+7w7YXP/JBHhrUDDUhwa+vANyubuqfZWTveU//DYVGsDG7RKL/vEw==",
       "dev": true
     },
-    "requires-port": {
-      "version": "1.0.0",
-      "resolved": "https://registry.npmmirror.com/requires-port/-/requires-port-1.0.0.tgz",
-      "integrity": "sha512-KigOCHcocU3XODJxsu8i/j8T9tzT4adHiecwORRQ0ZZFcp7ahwXuRU1m+yuO90C5ZUyGeGfocHDI14M3L3yDAQ=="
-    },
     "resolve": {
       "version": "1.22.8",
       "resolved": "https://registry.npmmirror.com/resolve/-/resolve-1.22.8.tgz",
@@ -16677,15 +16456,6 @@
         "punycode": "^2.1.0"
       }
     },
-    "url-parse": {
-      "version": "1.5.10",
-      "resolved": "https://registry.npmmirror.com/url-parse/-/url-parse-1.5.10.tgz",
-      "integrity": "sha512-WypcfiRhfeUP9vvF0j6rw0J3hrWrw6iZv3+22h6iRMJ/8z1Tj6XfLP4DsUix5MhMPnXpiHDoKyoZ/bdCkwBCiQ==",
-      "requires": {
-        "querystringify": "^2.1.1",
-        "requires-port": "^1.0.0"
-      }
-    },
     "url-parse-lax": {
       "version": "3.0.0",
       "resolved": "https://registry.npmmirror.com/url-parse-lax/-/url-parse-lax-3.0.0.tgz",

package.json

@@ -11,14 +11,11 @@
     "@midwayjs/jwt": "^3.16.1",
     "@midwayjs/koa": "^3.12.0",
     "@midwayjs/logger": "^3.1.0",
-    "@midwayjs/rabbitmq": "^3.16.5",
     "@midwayjs/redis": "^3.16.0",
     "@midwayjs/swagger": "^3.16.1",
     "@midwayjs/typeorm": "^3.16.0",
     "@midwayjs/upload": "^3.16.8",
     "@midwayjs/validate": "^3.12.0",
-    "amqp-connection-manager": "^4.1.14",
-    "amqplib": "^0.10.4",
     "axios": "^1.7.4",
     "bcryptjs": "^2.4.3",
     "crypto-js": "^4.2.0",
@@ -30,7 +27,6 @@
   },
   "devDependencies": {
     "@midwayjs/mock": "^3.12.0",
-    "@types/amqplib": "^0.10.5",
     "@types/crypto-js": "^4.2.2",
     "@types/jest": "^29.2.0",
     "@types/lodash": "^4.17.4",

src/config/config.default.ts

@@ -15,5 +15,6 @@ export default {
   },
   modulesConfig: {
     es: 'http://127.0.0.1:9701/cxyy/es',
+    mq: 'http://127.0.0.1:9702/cxyy/mq',
   },
 } as MidwayConfig;

src/config/config.local.ts

@@ -35,13 +35,6 @@ export default {
   swagger: {
     swaggerPath: '/doc/api',
   },
-  elasticsearch: {
-    node: 'http://192.168.1.197:9200',
-    auth: {
-      username: 'elastic',
-      password: 'NAjqFz_7tS2DkdpU7p*x',
-    },
-  },
   typeorm: {
     dataSource: {
       default: {

src/config/config.prod.ts

@@ -1,4 +1,5 @@
 import { MidwayConfig } from '@midwayjs/core';
+import { DbSubscriber } from '../event/dbSubscriber';
 /**数据库ip */
 const ip = '10.120.114.5';
 /**数据库名 */
@@ -35,13 +36,6 @@ export default {
   swagger: {
     swaggerPath: '/doc/api',
   },
-  elasticsearch: {
-    node: 'http://192.168.1.197:9200',
-    auth: {
-      username: 'elastic',
-      password: 'NAjqFz_7tS2DkdpU7p*x',
-    },
-  },
   typeorm: {
     dataSource: {
       default: {
@@ -54,6 +48,7 @@ export default {
         type: 'postgres',
         synchronize: false, // 如果第一次使用，不存在表，有同步的需求可以写 true，注意会丢数据
         logging: false,
+        subscribers: [DbSubscriber],
       },
       logs: {
         database: logsDB,

src/config/config.self.ts

@@ -18,19 +18,6 @@ const redisPwd = '1234qwer!@#$';
 const redisDB = 0;
 /**redis 记录登录的key */
 const loginSign = 'cxyy';
-/**mq设置 */
-const mqSetting = {
-  url: 'amqp://localhost',
-};
-/**elasticsearch ip */
-const esIp = '127.0.0.1'
-/**elasticsearch 端口 */
-const esPort= '9200'
-/**elasticsearch 用户名 */
-const esUserName = 'elastic'
-/**elasticsearch 密码 */
-const esPassword = 'NAjqFz_7tS2DkdpU7p*x'
-
 export default {
   // use for cookie sign key, should change to your own and keep security
   keys: '1697684406848_4978',
@@ -49,14 +36,6 @@ export default {
   swagger: {
     swaggerPath: '/doc/api',
   },
-  rabbitmq: mqSetting,
-  elasticsearch: {
-    node: `http://${esIp}:${esPort}`,
-    auth: {
-      username: esUserName,
-      password: esPassword,
-    },
-  },
   typeorm: {
     dataSource: {
       default: {

src/configuration.ts

@@ -13,7 +13,6 @@ import { DefaultErrorFilter } from './filter/defaultError.filter';
 import { CheckTokenMiddleware } from './middleware/checkToken.middleware';
 import { ResponseMiddleware } from './middleware/response.middleware';
 import * as axios from '@midwayjs/axios';
-import * as rabbitmq from '@midwayjs/rabbitmq';
 import * as upload from '@midwayjs/upload';
 @Configuration({
   imports: [
@@ -23,7 +22,6 @@ import * as upload from '@midwayjs/upload';
     redis,
     orm,
     axios,
-    rabbitmq,
     upload,
     {
       component: info,

src/service/mq/mq.service.ts

@@ -1,40 +0,0 @@
-// import { Provide, Scope, ScopeEnum, Init, Autoload, Destroy } from '@midwayjs/core';
-// import * as amqp from 'amqp-connection-manager'
-
-// @Autoload()
-// @Provide()
-// @Scope(ScopeEnum.Singleton) // Singleton 单例，全局唯一（进程级别）
-// export class RabbitmqService {
-
-//   private connection: amqp.AmqpConnectionManager;
-
-//   private channelWrapper;
-
-//   @Init()
-//   async connect() {
-//     // 创建连接，你可以把配置放在 Config 中，然后注入进来
-//     this.connection = await amqp.connect('amqp://localhost');
-
-//     // 创建 channel
-//     this.channelWrapper = this.connection.createChannel({
-//       json: true,
-//       setup: function(channel) {
-//         return Promise.all([
-//           // 绑定队列
-//             channel.assertQueue("tasks", { durable: true }),
-//         ]);
-//       }
-//     });
-//   }
-
-//   // 发送消息
-//   public async sendToQueue(queueName: string, data: any) {
-//     return this.channelWrapper.sendToQueue(queueName, data);
-//   }
-
-//   @Destroy()
-//   async close() {
-//     await this.channelWrapper.close();
-//     await this.connection.close();
-//   }
-// }