任务函数包装 异常处理

build/job/worker.js

@@ -58,6 +58,16 @@ function loadAllJSFiles(dirPaths, options = {}) {
     });
     return loadedModules;
 }
+function wrapper_task(func) {
+    return async function (...args) {
+        try {
+            return await func(...args);
+        }
+        catch (error) {
+            return { error: error.message };
+        }
+    };
+}
 (() => {
     const modules = loadAllJSFiles(['./build/job'], {
         ignoreNodeModules: true,
@@ -72,7 +82,7 @@ function loadAllJSFiles(dirPaths, options = {}) {
                     console.log(key2 + '已存在');
                     continue;
                 }
-                job_handlers.set(key2, m[key2]);
+                job_handlers.set(key2, wrapper_task(m[key2]));
                 // console.log(key2)
             }
         }

package.json

@@ -4,7 +4,7 @@
   "description": "",
   "main": "build/index.js",
   "scripts": {
-    "start": "node ./build/index.js ",
+    "start": "node ./build/index.js",
     "watch": "tsc -w",
     "compile": "tsc"
   },

src/job/worker.ts

@@ -74,6 +74,17 @@ function loadAllJSFiles(dirPaths, options: any = {}) {
   return loadedModules;
 }
 
+
+function wrapper_task(func) {
+  return async function (...args) {
+    try {
+      return await func(...args);
+    } catch (error) {
+      return { error: error.message };
+    }
+  };
+}
+
 (() => {
 
   const modules = loadAllJSFiles(['./build/job'], {
@@ -91,7 +102,8 @@ function loadAllJSFiles(dirPaths, options: any = {}) {
           console.log(key2 + '已存在')
           continue;
         }
-        job_handlers.set(key2, m[key2])
+
+        job_handlers.set(key2, wrapper_task(m[key2]))
         // console.log(key2)
       }
     }