diff --git a/frontend/src/common/config.ts b/frontend/src/common/config.ts
index b3262f5d..84f66fec 100644
--- a/frontend/src/common/config.ts
+++ b/frontend/src/common/config.ts
@@ -15,7 +15,7 @@ const config = {
     baseWsUrl: `${(window as any).globalConfig.BaseWsUrl || `${location.protocol == 'https:' ? 'wss:' : 'ws:'}//${getBaseApiUrl()}`}/api`,
 
     // 系统版本
-    version: 'v1.10.7',
+    version: 'v1.10.8',
 };
 
 export default config;
diff --git a/frontend/src/layout/navBars/breadcrumb/setings.vue b/frontend/src/layout/navBars/breadcrumb/setings.vue
index 128dd121..daa1fe30 100644
--- a/frontend/src/layout/navBars/breadcrumb/setings.vue
+++ b/frontend/src/layout/navBars/breadcrumb/setings.vue
@@ -308,17 +308,7 @@
 
                 <!-- 其它设置 -->
                 <el-divider content-position="left">{{ $t('layout.config.otherSetting') }}</el-divider>
-                <div class="layout-breadcrumb-seting-bar-flex !mt-3.5">
-                    <div class="layout-breadcrumb-seting-bar-flex-label">{{ $t('layout.config.tagsStyle') }}</div>
-                    <div class="layout-breadcrumb-seting-bar-flex-value">
-                        <el-select v-model="themeConfig.tagsStyle" placeholder="请选择" size="small" style="width: 90px">
-                            <el-option label="风格1" value="tags-style-one"></el-option>
-                            <el-option label="风格2" value="tags-style-two"></el-option>
-                            <el-option label="风格3" value="tags-style-three"></el-option>
-                        </el-select>
-                    </div>
-                </div>
-                <div class="layout-breadcrumb-seting-bar-flex !mt-3.5">
+                <div class="layout-breadcrumb-seting-bar-flex mt-3.5!">
                     <div class="layout-breadcrumb-seting-bar-flex-label">{{ $t('layout.config.animation') }}</div>
                     <div class="layout-breadcrumb-seting-bar-flex-value">
                         <el-select v-model="themeConfig.animation" size="small" style="width: 90px">
@@ -328,7 +318,7 @@
                         </el-select>
                     </div>
                 </div>
-                <div class="layout-breadcrumb-seting-bar-flex !mt-3.5 !mb-5.5">
+                <div class="layout-breadcrumb-seting-bar-flex mt-3.5! mb-5.5!">
                     <div class="layout-breadcrumb-seting-bar-flex-label">
                         {{ $t('layout.config.columnsAsideStyle') }}
                     </div>
diff --git a/frontend/src/layout/navBars/tagsView/tagsView.vue b/frontend/src/layout/navBars/tagsView/tagsView.vue
index 02e78334..0ef93a58 100644
--- a/frontend/src/layout/navBars/tagsView/tagsView.vue
+++ b/frontend/src/layout/navBars/tagsView/tagsView.vue
@@ -1,7 +1,7 @@
 <template>
     <div class="layout-navbars-tagsview" :class="{ 'layout-navbars-tagsview-shadow': themeConfig.layout === 'classic' }">
         <el-scrollbar ref="scrollbarRef" @wheel.prevent="onHandleScroll">
-            <ul class="layout-navbars-tagsview-ul" :class="setTagsStyle" ref="tagsUlRef">
+            <ul class="layout-navbars-tagsview-ul" ref="tagsUlRef">
                 <li
                     v-for="(v, k) in tagsViews"
                     :key="k"
@@ -18,26 +18,20 @@
                 >
                     <SvgIcon :name="v.icon" class="layout-navbars-tagsview-ul-li-iconfont" v-if="themeConfig.isTagsviewIcon" />
                     <span>{{ $t(v.title) }}</span>
+
                     <template v-if="isActive(v)">
                         <SvgIcon
                             name="RefreshRight"
-                            class="!text-[14px] ml-1 layout-navbars-tagsview-ul-li-refresh"
+                            class="text-[14px]! ml-1 layout-navbars-tagsview-ul-li-icon layout-navbars-tagsview-ul-li-refresh"
                             @click.stop="refreshCurrentTagsView($route.fullPath)"
                         />
                         <SvgIcon
                             name="Close"
-                            class="!text-[14px] layout-navbars-tagsview-ul-li-icon layout-icon-active"
+                            class="text-[14px]! layout-navbars-tagsview-ul-li-icon layout-navbars-tagsview-ul-li-close layout-icon-active"
                             v-if="!v.isAffix"
                             @click.stop="closeCurrentTagsView(themeConfig.isShareTagsView ? v.path : v.path)"
                         />
                     </template>
-
-                    <SvgIcon
-                        name="Close"
-                        class="!text-[14px] layout-navbars-tagsview-ul-li-icon layout-icon-three"
-                        v-if="!v.isAffix"
-                        @click.stop="closeCurrentTagsView(themeConfig.isShareTagsView ? v.path : v.path)"
-                    />
                 </li>
             </ul>
         </el-scrollbar>
@@ -46,7 +40,7 @@
 </template>
 
 <script lang="ts" setup name="layoutTagsView">
-import { reactive, onMounted, computed, ref, nextTick, onBeforeUpdate, getCurrentInstance, watch } from 'vue';
+import { reactive, onMounted, ref, nextTick, onBeforeUpdate, getCurrentInstance, watch } from 'vue';
 import { useRoute, useRouter, onBeforeRouteUpdate } from 'vue-router';
 import screenfull from 'screenfull';
 import { storeToRefs } from 'pinia';
@@ -105,11 +99,6 @@ const state = reactive({
     },
 });
 
-// 动态设置 tagsView 风格样式
-const setTagsStyle = computed(() => {
-    return themeConfig.value.tagsStyle;
-});
-
 // 存储 tagsViewList 到浏览器临时缓存中，页面刷新时，保留记录
 const addBrowserSetSession = (tagsViewList: Array<object>) => {
     setTagViews(tagsViewList);
@@ -403,163 +392,120 @@ onBeforeRouteUpdate((to) => {
 });
 </script>
 
-<style scoped lang="scss">
+<style scoped lang="css">
 .layout-navbars-tagsview {
     background-color: var(--bg-main-color);
     border-bottom: 1px solid var(--el-border-color-light, #ebeef5);
     position: relative;
     z-index: 4;
+    box-shadow: 0 1px 2px rgba(0, 0, 0, 0.05);
+}
 
-    :deep(.el-scrollbar__wrap) {
-        overflow-x: auto !important;
-    }
+.layout-navbars-tagsview :deep(.el-scrollbar__wrap) {
+    overflow-x: auto !important;
+}
 
-    &-ul {
-        list-style: none;
-        margin: 0;
-        padding: 0;
-        height: 34px;
-        display: flex;
-        align-items: center;
-        color: var(--el-text-color-regular);
-        font-size: 12px;
-        white-space: nowrap;
-        padding: 0 15px;
+.layout-navbars-tagsview-ul {
+    list-style: none;
+    margin: 0;
+    padding: 0;
+    height: 38px;
+    display: flex;
+    align-items: center;
+    color: var(--el-text-color-regular);
+    font-size: 13px;
+    white-space: nowrap;
+    padding: 0 15px;
+}
 
-        &-li {
-            height: 26px;
-            line-height: 26px;
-            display: flex;
-            align-items: center;
-            border: 1px solid var(--el-border-color-lighter);
-            padding: 0 15px;
-            margin-right: 5px;
-            border-radius: 2px;
-            position: relative;
-            z-index: 0;
-            cursor: pointer;
-            justify-content: space-between;
+.layout-navbars-tagsview-ul-li {
+    height: 30px;
+    line-height: 30px;
+    display: flex;
+    align-items: center;
+    border-radius: 6px;
+    padding: 0 12px;
+    margin-right: 8px;
+    position: relative;
+    z-index: 0;
+    cursor: pointer;
+    justify-content: space-between;
+    transition: all 0.3s ease;
+    border: 1px solid var(--el-border-color, #dcdfe6);
+    box-sizing: border-box;
+    background-color: var(--el-bg-color, #fafafa);
+    color: var(--el-text-color-regular, #606266);
+    box-shadow: 0 1px 2px rgba(0, 0, 0, 0.05);
+}
 
-            &:hover {
-                background-color: var(--el-color-primary-light-9);
-                color: var(--el-color-primary);
-                border-color: var(--el-color-primary-light-5);
-            }
+.layout-navbars-tagsview-ul-li:not(.is-active):hover {
+    background-color: var(--el-fill-color-blank, #f5f7fa);
+    color: var(--el-text-color-primary, #303133);
+    border-color: var(--el-color-primary-light-7, #c6e2ff);
+    transform: translateY(-1px);
+}
 
-            &-iconfont {
-                position: relative;
-                left: -5px;
-                font-size: 12px;
-            }
+.layout-navbars-tagsview-ul-li-iconfont {
+    position: relative;
+    left: -3px;
+    font-size: 12px;
+    margin-right: 4px;
+}
 
-            &-icon {
-                border-radius: 100%;
-                position: relative;
-                height: 14px;
-                width: 14px;
-                text-align: center;
-                line-height: 14px;
-                right: -5px;
+.layout-navbars-tagsview-ul-li-icon {
+    border-radius: 4px;
+    position: relative;
+    height: 18px;
+    width: 18px;
+    text-align: center;
+    line-height: 18px;
+    right: -3px;
+    margin-left: 4px;
+    transition: all 0.25s ease;
+    color: var(--el-text-color-secondary, #909399);
+    display: flex;
+    align-items: center;
+    justify-content: center;
+}
 
-                &:hover {
-                    color: var(--el-color-white);
-                    background-color: var(--el-color-primary-light-3);
-                }
-            }
+.layout-navbars-tagsview-ul-li-icon:hover {
+    background-color: var(--el-color-info-light-7);
+    border-radius: 4px;
+}
 
-            .layout-icon-active {
-                display: block;
-            }
+.layout-icon-active {
+    display: flex;
+    align-items: center;
+    justify-content: center;
+}
 
-            .layout-icon-three {
-                display: none;
-            }
-        }
+.layout-navbars-tagsview-ul .is-active {
+    color: var(--el-color-primary, #409eff);
+    background: var(--el-color-primary-light-9, #ecf5ff);
+    border-color: var(--el-color-primary-light-5, #409eff);
+    box-shadow: 0 2px 4px rgba(64, 158, 255, 0.2);
+}
 
-        .is-active {
-            color: var(--el-color-white);
-            background: var(--el-color-primary);
-            border-color: var(--el-color-primary);
-            transition: border-color 3s ease;
-        }
-    }
+.layout-navbars-tagsview-ul .is-active .layout-navbars-tagsview-ul-li-icon {
+    color: var(--el-color-primary, #409eff);
+}
 
-    // 风格2
-    .tags-style-two {
-        .layout-navbars-tagsview-ul-li {
-            margin-right: 0 !important;
-            border: none !important;
-            position: relative;
-            border-radius: 3px !important;
+.layout-navbars-tagsview-ul .is-active .layout-navbars-tagsview-ul-li-icon:hover {
+    background-color: var(--el-color-primary);
+    color: var(--el-color-white);
+    transform: scale(1.1);
+}
 
-            .layout-icon-active {
-                display: none;
-            }
+.layout-navbars-tagsview-ul .is-active .layout-navbars-tagsview-ul-li-close:hover {
+    background-color: var(--el-color-danger);
+    color: var(--el-color-white);
+    border-radius: 4px;
+}
 
-            .layout-icon-three {
-                display: block;
-            }
-
-            &:hover {
-                background: none !important;
-            }
-        }
-
-        .is-active {
-            background: none !important;
-            color: var(--el-color-primary) !important;
-        }
-    }
-
-    // 风格3
-    .tags-style-three {
-        align-items: flex-end;
-
-        .tgs-style-three-svg {
-            -webkit-mask-image:
-                url('data:image/svg+xml;base64,PHN2ZyB3aWR0aD0iNzAiIGhlaWdodD0iNzAiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgZmlsbD0ibm9uZSI+CgogPGc+CiAgPHRpdGxlPkxheWVyIDE8L3RpdGxlPgogIDxwYXRoIHRyYW5zZm9ybT0icm90YXRlKC0wLjEzMzUwNiA1MC4xMTkyIDUwKSIgaWQ9InN2Z18xIiBkPSJtMTAwLjExOTE5LDEwMGMtNTUuMjI4LDAgLTEwMCwtNDQuNzcyIC0xMDAsLTEwMGwwLDEwMGwxMDAsMHoiIG9wYWNpdHk9InVuZGVmaW5lZCIgc3Ryb2tlPSJudWxsIiBmaWxsPSIjRjhFQUU3Ii8+CiAgPHBhdGggZD0ibS0wLjYzNzY2LDcuMzEyMjhjMC4xMTkxOSwwIDAuMjE3MzcsMC4wNTc5NiAwLjQ3Njc2LDAuMTE5MTljMC4yMzIsMC4wNTQ3NyAwLjI3MzI5LDAuMDM0OTEgMC4zNTc1NywwLjExOTE5YzAuMDg0MjgsMC4wODQyOCAwLjM1NzU3LDAgMC40NzY3NiwwbDAuMTE5MTksMGwwLjIzODM4LDAiIGlkPSJzdmdfMiIgc3Ryb2tlPSJudWxsIiBmaWxsPSJub25lIi8+CiAgPHBhdGggZD0ibTI4LjkyMTM0LDY5LjA1MjQ0YzAsMC4xMTkxOSAwLDAuMjM4MzggMCwwLjM1NzU3bDAsMC4xMTkxOWwwLDAuMTE5MTkiIGlkPSJzdmdfMyIgc3Ryb2tlPSJudWxsIiBmaWxsPSJub25lIi8+CiAgPHJlY3QgaWQ9InN2Z180IiBoZWlnaHQ9IjAiIHdpZHRoPSIxLjMxMTA4IiB5PSI2LjgzNTUyIiB4PSItMC4wNDE3MSIgc3Ryb2tlPSJudWxsIiBmaWxsPSJub25lIi8+CiAgPHJlY3QgaWQ9InN2Z181IiBoZWlnaHQ9IjEuNzg3ODQiIHdpZHRoPSIwLjExOTE5IiB5PSI2OC40NTY1IiB4PSIyOC45MjEzNCIgc3Ryb2tlPSJudWxsIiBmaWxsPSJub25lIi8+CiAgPHJlY3QgaWQ9InN2Z182IiBoZWlnaHQ9IjQuODg2NzciIHdpZHRoPSIxOS4wNzAzMiIgeT0iNTEuMjkzMjEiIHg9IjM2LjY2ODY2IiBzdHJva2U9Im51bGwiIGZpbGw9Im5vbmUiLz4KIDwvZz4KPC9zdmc+'),
-                url('data:image/svg+xml;base64,PHN2ZyB3aWR0aD0iNzAiIGhlaWdodD0iNzAiIHhtbG5zPSJodHRwOi8vd3d3LnczLm9yZy8yMDAwL3N2ZyIgZmlsbD0ibm9uZSI+CiA8Zz4KICA8dGl0bGU+TGF5ZXIgMTwvdGl0bGU+CiAgPHBhdGggdHJhbnNmb3JtPSJyb3RhdGUoLTg5Ljc2MjQgNy4zMzAxNCA1NS4xMjUyKSIgc3Ryb2tlPSJudWxsIiBpZD0ic3ZnXzEiIGZpbGw9IiNGOEVBRTciIGQ9Im02Mi41NzQ0OSwxMTcuNTIwODZjLTU1LjIyOCwwIC0xMDAsLTQ0Ljc3MiAtMTAwLC0xMDBsMCwxMDBsMTAwLDB6IiBjbGlwLXJ1bGU9ImV2ZW5vZGQiIGZpbGwtcnVsZT0iZXZlbm9kZCIvPgogIDxwYXRoIGQ9Im0tMC42Mzc2Niw3LjMxMjI4YzAuMTE5MTksMCAwLjIxNzM3LDAuMDU3OTYgMC40NzY3NiwwLjExOTE5YzAuMjMyLDAuMDU0NzcgMC4yNzMyOSwwLjAzNDkxIDAuMzU3NTcsMC4xMTkxOWMwLjA4NDI4LDAuMDg0MjggMC4zNTc1NywwIDAuNDc2NzYsMGwwLjExOTE5LDBsMC4yMzgzOCwwIiBpZD0ic3ZnXzIiIHN0cm9rZT0ibnVsbCIgZmlsbD0ibm9uZSIvPgogIDxwYXRoIGQ9Im0yOC45MjEzNCw2OS4wNTI0NGMwLDAuMTE5MTkgMCwwLjIzODM4IDAsMC4zNTc1N2wwLDAuMTE5MTlsMCwwLjExOTE5IiBpZD0ic3ZnXzMiIHN0cm9rZT0ibnVsbCIgZmlsbD0ibm9uZSIvPgogIDxyZWN0IGlkPSJzdmdfNCIgaGVpZ2h0PSIwIiB3aWR0aD0iMS4zMTEwOCIgeT0iNi44MzU1MiIgeD0iLTAuMDQxNzEiIHN0cm9rZT0ibnVsbCIgZmlsbD0ibm9uZSIvPgogIDxyZWN0IGlkPSJzdmdfNSIgaGVpZ2h0PSIxLjc4Nzg0IiB3aWR0aD0iMC4xMTkxOSIgeT0iNjguNDU2NSIgeD0iMjguOTIxMzQiIHN0cm9rZT0ibnVsbCIgZmlsbD0ibm9uZSIvPgogIDxyZWN0IGlkPSJzdmdfNiIgaGVpZ2h0PSI0Ljg4Njc3IiB3aWR0aD0iMTkuMDcwMzIiIHk9IjUxLjI5MzIxIiB4PSIzNi42Njg2NiIgc3Ryb2tlPSJudWxsIiBmaWxsPSJub25lIi8+CiA8L2c+Cjwvc3ZnPg=='),
-                url("data:image/svg+xml,<svg xmlns='http://www.w3.org/2000/svg'><rect rx='8' width='100%' height='100%' fill='%23F8EAE7'/></svg>");
-            -webkit-mask-size:
-                18px 30px,
-                20px 30px,
-                calc(100% - 30px) calc(100% + 17px);
-            -webkit-mask-position:
-                right bottom,
-                left bottom,
-                center top;
-            -webkit-mask-repeat: no-repeat;
-        }
-
-        .layout-navbars-tagsview-ul-li {
-            padding: 0 5px;
-            border-width: 15px 27px 15px;
-            border-style: solid;
-            border-color: transparent;
-            margin: 0 -15px;
-
-            .layout-icon-active {
-                display: none;
-            }
-
-            .layout-icon-three {
-                display: block;
-            }
-
-            &:hover {
-                @extend .tgs-style-three-svg;
-                background: var(--tagsview3-active-background-color);
-                color: unset;
-            }
-        }
-
-        .is-active {
-            @extend .tgs-style-three-svg;
-            background: var(--tagsview3-active-background-color) !important;
-            color: var(--el-color-primary) !important;
-            z-index: 1;
-        }
-    }
+.layout-navbars-tagsview-ul .is-active .layout-navbars-tagsview-ul-li-refresh:hover {
+    background-color: var(--el-color-primary);
+    color: var(--el-color-white);
+    border-radius: 4px;
 }
 
 .layout-navbars-tagsview-shadow {
diff --git a/frontend/src/store/themeConfig.ts b/frontend/src/store/themeConfig.ts
index f27eadfa..122a33c2 100644
--- a/frontend/src/store/themeConfig.ts
+++ b/frontend/src/store/themeConfig.ts
@@ -98,8 +98,6 @@ export const useThemeConfig = defineStore('themeConfig', {
 
             /* 其它设置
             ------------------------------- */
-            // 默认 Tagsview 风格，可选 1、 tags-style-one 2、 tags-style-two 3、 tags-style-three
-            tagsStyle: 'tags-style-three',
             // 默认主页面切换动画，可选 1、 slide-right 2、 slide-left 3、 opacitys
             animation: 'slide-right',
             // 默认分栏高亮风格，可选 1、 圆角 columns-round 2、 卡片 columns-card
diff --git a/frontend/src/types/pinia.d.ts b/frontend/src/types/pinia.d.ts
index 686ecce2..186f5364 100644
--- a/frontend/src/types/pinia.d.ts
+++ b/frontend/src/types/pinia.d.ts
@@ -40,7 +40,6 @@ declare interface ThemeConfigState {
         isInvert: boolean;
         isWatermark: boolean;
         watermarkText: Array<string>;
-        tagsStyle: string;
         animation: string;
         columnsAsideStyle: string;
         layout: string;
diff --git a/frontend/src/views/ops/db/component/sqleditor/DbSqlEditor.vue b/frontend/src/views/ops/db/component/sqleditor/DbSqlEditor.vue
index 317a3ded..d0671b3f 100644
--- a/frontend/src/views/ops/db/component/sqleditor/DbSqlEditor.vue
+++ b/frontend/src/views/ops/db/component/sqleditor/DbSqlEditor.vue
@@ -39,7 +39,7 @@
             </div>
         </div>
 
-        <el-splitter style="height: calc(100vh - 215px)" layout="vertical" @resize-end="onResizeTableHeight">
+        <el-splitter style="height: calc(100vh - 220px)" layout="vertical" @resize-end="onResizeTableHeight">
             <el-splitter-panel :size="state.editorSize" max="80%">
                 <MonacoEditor ref="monacoEditorRef" class="mt-1" v-model="state.sql" language="sql" height="100%" :id="'MonacoTextarea-' + getKey()" />
             </el-splitter-panel>
@@ -289,7 +289,7 @@ const onResizeTableHeight = (index: number, sizes: number[]) => {
         editorHeight = plitpaneHeight / 2;
     }
 
-    let tableDataHeight = plitpaneHeight - editorHeight - 43;
+    let tableDataHeight = plitpaneHeight - editorHeight - 47;
 
     state.editorSize = editorHeight;
     state.tableDataHeight = tableDataHeight + 'px';
diff --git a/server/internal/ai/agent/agent.go b/server/internal/ai/agent/agent.go
index 4bd9c103..00e4b2df 100644
--- a/server/internal/ai/agent/agent.go
+++ b/server/internal/ai/agent/agent.go
@@ -76,9 +76,12 @@ func (aiAgent *AiAgent) Chat(ctx context.Context, sysPrompt string, question str
 	agentOption := []agent.AgentOption{}
 
 	go func() {
-		defer gox.RecoverPanic()
 		defer close(ch)
 		defer close(errCh)
+		defer gox.Recover(func(err error) {
+			errCh <- err
+		})
+
 		sr, err := aiAgent.Stream(ctx, []*schema.Message{
 			{
 				Role:    schema.System,
diff --git a/server/internal/auth/api/common.go b/server/internal/auth/api/common.go
index 1e834385..147b4a45 100644
--- a/server/internal/auth/api/common.go
+++ b/server/internal/auth/api/common.go
@@ -13,6 +13,7 @@ import (
 	"mayfly-go/pkg/biz"
 	"mayfly-go/pkg/cache"
 	"mayfly-go/pkg/global"
+	"mayfly-go/pkg/gox"
 	"mayfly-go/pkg/req"
 	"mayfly-go/pkg/utils/collx"
 	"mayfly-go/pkg/utils/netx"
@@ -57,7 +58,9 @@ func LastLoginCheck(ctx context.Context, account *sysentity.Account, accountLogi
 		res["refresh_token"] = refreshToken
 		// 不进行otp二次校验则直接返回accessToken
 		// 保存登录消息
-		go saveLogin(ctx, account, loginIp)
+		gox.Go(func() {
+			saveLogin(ctx, account, loginIp)
+		})
 	}
 
 	// 赋值otp状态
diff --git a/server/internal/db/api/db_transfer.go b/server/internal/db/api/db_transfer.go
index 6f5d200b..53704515 100644
--- a/server/internal/db/api/db_transfer.go
+++ b/server/internal/db/api/db_transfer.go
@@ -151,13 +151,13 @@ func (d *DbTransferTask) FileRun(rc *req.Ctx) {
 
 	filename, reader, err := d.fileApp.GetReader(context.TODO(), tFile.FileKey)
 	biz.ErrIsNil(err)
-	go func() {
-		defer gox.RecoverPanic()
-		biz.ErrIsNil(d.dbSqlExecApp.ExecReader(rc.MetaCtx, &dto.SqlReaderExec{
+
+	gox.GoCtx(rc.MetaCtx, func(ctx context.Context) {
+		biz.ErrIsNil(d.dbSqlExecApp.ExecReader(ctx, &dto.SqlReaderExec{
 			Reader:   reader,
 			Filename: filename,
 			DbConn:   targetDbConn,
 			ClientId: fm.ClientId,
 		}))
-	}()
+	})
 }
diff --git a/server/internal/db/application/db_data_sync.go b/server/internal/db/application/db_data_sync.go
index ec08af13..d0c7b9b8 100644
--- a/server/internal/db/application/db_data_sync.go
+++ b/server/internal/db/application/db_data_sync.go
@@ -129,7 +129,7 @@ func (app *dataSyncAppImpl) Run(ctx context.Context, id uint64) error {
 		}
 		
 		defer app.endRunning(task, syncLog)
-		defer gox.RecoverPanic(func(err error) {
+		defer gox.Recover(func(err error) {
 			syncLog.ErrText = i18n.T(imsg.DataSyncFailMsg, "msg", err.Error())
 			logx.ErrorContext(ctx, syncLog.ErrText)
 			syncLog.Status = entity.DataSyncTaskStateFail
diff --git a/server/internal/db/application/db_transfer.go b/server/internal/db/application/db_transfer.go
index be913d31..8d66d2e7 100644
--- a/server/internal/db/application/db_transfer.go
+++ b/server/internal/db/application/db_transfer.go
@@ -143,8 +143,7 @@ func (app *dbTransferAppImpl) Run(ctx context.Context, taskId uint64) (uint64, e
 	// 标记该任务开始执行
 	app.MarkRunning(taskId)
 
-	go func() {
-		defer gox.RecoverPanic()
+	gox.Go(func() {
 		// 获取源库连接、目标库连接，判断连接可用性，否则记录日志：xx连接不可用
 		// 获取源库表信息
 		srcConn, err := app.dbApp.GetDbConn(ctx, uint64(task.SrcDbId), task.SrcDbName)
@@ -180,7 +179,7 @@ func (app *dbTransferAppImpl) Run(ctx context.Context, taskId uint64) (uint64, e
 			app.EndTransfer(ctx, logId, taskId, "error in transfer mode, only migrating to files or databases is currently supported", err, nil)
 			return
 		}
-	}()
+	})
 
 	return logId, nil
 }
@@ -207,7 +206,7 @@ func (app *dbTransferAppImpl) transfer2Db(ctx context.Context, logId uint64, tas
 
 	for _, tables := range tableGroups {
 		errGroup.Go(func() error {
-			defer gox.RecoverPanic()
+			defer gox.Recover()
 			
 			if !app.IsRunning(taskId) {
 				return errorx.NewBiz("transfer stopped")
@@ -217,8 +216,7 @@ func (app *dbTransferAppImpl) transfer2Db(ctx context.Context, logId uint64, tas
 			pr, pw := io.Pipe()
 			defer pr.Close()
 
-			go func() {
-				defer gox.RecoverPanic()
+			gox.Go(func ()  {
 				defer pw.Close()
 				err := app.dbApp.DumpDb(ctx, &dto.DumpDb{
 					LogId:        logId,
@@ -254,7 +252,7 @@ func (app *dbTransferAppImpl) transfer2Db(ctx context.Context, logId uint64, tas
 					pr.CloseWithError(err)
 					return
 				}
-			}()
+			})
 
 			tx, _ := targetConn.Begin()
 			err = sqlparser.SQLSplit(pr, ';', func(stmt string) error {
@@ -317,7 +315,7 @@ func (app *dbTransferAppImpl) transfer2File(ctx context.Context, logId uint64, t
 		defer closeFunc(&err)
 		defer app.MarkStop(taskId)
 		defer app.logApp.Flush(logId, true)
-		defer gox.RecoverPanic(func(e error) {
+		defer gox.Recover(func(e error) {
 			err = e
 			app.EndTransfer(ctx, logId, taskId, "transfer to file panic", e, nil)
 			tFile.Status = entity.DbTransferFileStatusFail
@@ -385,7 +383,7 @@ func (app *dbTransferAppImpl) Stop(ctx context.Context, taskId uint64) error {
 func (d *dbTransferAppImpl) TimerDeleteTransferFile() {
 	logx.Debug("start deleting transfer files periodically...")
 	scheduler.AddFun("@every 100m", func() {
-		defer gox.RecoverPanic()
+		defer gox.Recover()
 		dts, err := d.ListByCond(model.NewCond().Eq("mode", entity.DbTransferTaskModeFile).Ge("file_save_days", 1))
 		if err != nil {
 			logx.Errorf("the task to periodically get database transfer to file failed: %s", err.Error())
diff --git a/server/internal/db/dbm/dbi/conn.go b/server/internal/db/dbm/dbi/conn.go
index fa2d539b..05c33f6b 100644
--- a/server/internal/db/dbm/dbi/conn.go
+++ b/server/internal/db/dbm/dbi/conn.go
@@ -49,7 +49,7 @@ func (d *DbConn) Ping() error {
 	stats := d.db.Stats()
 	logx.Debugf("[%s] db stats -> open: %d, idle: %d,  inUse: %d, maxOpen: %d", d.Info.Name, stats.OpenConnections, stats.Idle, stats.InUse, stats.MaxOpenConnections)
 	if stats.OpenConnections == 0 {
-		logx.Infof("[%s] db stats: no open connections", d.Info.Name)
+		logx.Infof("[%s]-[%s] db stats: no open connections", d.Info.Name, d.Info.Database)
 	}
 
 	return d.db.Ping()
diff --git a/server/internal/db/dbm/dm/dialect.go b/server/internal/db/dbm/dm/dialect.go
index ab864b66..bd3966ff 100644
--- a/server/internal/db/dbm/dm/dialect.go
+++ b/server/internal/db/dbm/dm/dialect.go
@@ -39,8 +39,7 @@ func (dd *DMDialect) CopyTable(copy *dbi.DbCopyTable) error {
 
 	// 复制数据
 	if copy.CopyData {
-		go func() {
-			defer gox.RecoverPanic()
+		gox.Go(func() {
 			// 设置允许填充自增列之后，显示指定列名可以插入自增列\
 			identityInsert := fmt.Sprintf("set identity_insert \"%s\" on", newTableName)
 			// 获取列名
@@ -52,8 +51,7 @@ func (dd *DMDialect) CopyTable(copy *dbi.DbCopyTable) error {
 			columnStr := strings.Join(columnArr, ",")
 			// 插入新数据并显示指定列
 			_, _ = dd.dc.Exec(fmt.Sprintf("%s insert into \"%s\" (%s) select %s from \"%s\"", identityInsert, newTableName, columnStr, columnStr, tableName))
-
-		}()
+		})
 	}
 	return err
 }
diff --git a/server/internal/db/dbm/mssql/dialect.go b/server/internal/db/dbm/mssql/dialect.go
index eee2f189..4162fccf 100644
--- a/server/internal/db/dbm/mssql/dialect.go
+++ b/server/internal/db/dbm/mssql/dialect.go
@@ -43,8 +43,7 @@ func (md *MssqlDialect) CopyTable(copy *dbi.DbCopyTable) error {
 	}
 	// 复制数据
 	if copy.CopyData {
-		go func() {
-			defer gox.RecoverPanic()
+		gox.Go(func() {
 			// 查询所有的列
 			columns, err := msMetadata.GetColumns(copy.TableName)
 			if err != nil {
@@ -73,7 +72,7 @@ func (md *MssqlDialect) CopyTable(copy *dbi.DbCopyTable) error {
 			if err != nil {
 				logx.Warnf("复制表[%s]数据失败: %s", copy.TableName, err.Error())
 			}
-		}()
+		})
 	}
 
 	return err
diff --git a/server/internal/db/dbm/mysql/dialect.go b/server/internal/db/dbm/mysql/dialect.go
index 52051a43..b4f99169 100644
--- a/server/internal/db/dbm/mysql/dialect.go
+++ b/server/internal/db/dbm/mysql/dialect.go
@@ -43,10 +43,9 @@ func (md *MysqlDialect) CopyTable(copy *dbi.DbCopyTable) error {
 
 	// 复制数据
 	if copy.CopyData {
-		go func() {
-			defer gox.RecoverPanic()
+		gox.Go(func() {
 			_, _ = md.dc.Exec(fmt.Sprintf("insert into %s select * from %s", newTableName, tableName))
-		}()
+		})
 	}
 	return err
 }
diff --git a/server/internal/db/dbm/postgres/dialect.go b/server/internal/db/dbm/postgres/dialect.go
index 60f1b0fa..a367a3df 100644
--- a/server/internal/db/dbm/postgres/dialect.go
+++ b/server/internal/db/dbm/postgres/dialect.go
@@ -27,10 +27,9 @@ func (pd *PgsqlDialect) CopyTable(copy *dbi.DbCopyTable) error {
 
 	// 复制数据
 	if copy.CopyData {
-		go func() {
-			defer gox.RecoverPanic()
+		gox.Go(func() {
 			_, _ = pd.dc.Exec(fmt.Sprintf("insert into %s select * from %s", newTableName, tableName))
-		}()
+		})
 	}
 
 	// 查询旧表的自增字段名 重新设置新表的序列序列器
diff --git a/server/internal/db/dbm/sqlite/dialect.go b/server/internal/db/dbm/sqlite/dialect.go
index fc6e066e..f5cacb2e 100644
--- a/server/internal/db/dbm/sqlite/dialect.go
+++ b/server/internal/db/dbm/sqlite/dialect.go
@@ -37,11 +37,10 @@ func (sd *SqliteDialect) CopyTable(copy *dbi.DbCopyTable) error {
 
 	// 使用异步线程插入数据
 	if copy.CopyData {
-		go func() {
-			defer gox.RecoverPanic()
+		gox.Go(func() {
 			// 执行插入语句
 			_, _ = sd.dc.Exec(fmt.Sprintf("INSERT INTO \"%s\" SELECT * FROM \"%s\"", newTableName, tableName))
-		}()
+		})
 	}
 
 	return err
diff --git a/server/internal/docker/api/container.go b/server/internal/docker/api/container.go
index 04a44cb5..1277d3cc 100644
--- a/server/internal/docker/api/container.go
+++ b/server/internal/docker/api/container.go
@@ -98,10 +98,9 @@ func (d *Container) GetContainersStats(rc *req.Ctx) {
 	var mu sync.Mutex
 	allStats := make([]vo.ContainerStats, 0)
 	for _, c := range cs {
-		go func(item container.Summary) {
-			defer gox.RecoverPanic()
+		gox.Go(func() {
 			defer wg.Done()
-			if item.State != "running" {
+			if c.State != "running" {
 				return
 			}
 
@@ -127,7 +126,7 @@ func (d *Container) GetContainersStats(rc *req.Ctx) {
 			mu.Lock()
 			allStats = append(allStats, cs)
 			mu.Unlock()
-		}(c)
+		})
 	}
 
 	wg.Wait()
@@ -224,8 +223,7 @@ func (d *Container) ContainerLogs(rc *req.Ctx) {
 	biz.ErrIsNil(err)
 	defer logs.Close()
 
-	go func() {
-		defer gox.RecoverPanic()
+	gox.Go(func() {
 		for {
 			select {
 			case <-ctx.Done():
@@ -239,7 +237,7 @@ func (d *Container) ContainerLogs(rc *req.Ctx) {
 				}
 			}
 		}
-	}()
+	})
 
 	buf := make([]byte, 1024)
 	for {
diff --git a/server/internal/docker/dkm/client.go b/server/internal/docker/dkm/client.go
index d41f628b..599c25bc 100644
--- a/server/internal/docker/dkm/client.go
+++ b/server/internal/docker/dkm/client.go
@@ -150,8 +150,7 @@ func (c Client) ContainerAttach(containerID string, wsConn *websocket.Conn, rows
 	wsConn.WriteMessage(websocket.TextMessage, []byte("\033[2J\033[3J\033[1;1H")) // 清屏
 
 	// 转发容器输出到前端
-	go func() {
-		defer gox.RecoverPanic()
+	gox.Go(func() {
 		buf := make([]byte, 1024)
 		for {
 			select {
@@ -171,7 +170,7 @@ func (c Client) ContainerAttach(containerID string, wsConn *websocket.Conn, rows
 				wsConn.WriteMessage(websocket.TextMessage, buf[:n])
 			}
 		}
-	}()
+	})
 
 	for {
 		select {
diff --git a/server/internal/flow/application/execution.go b/server/internal/flow/application/execution.go
index e0016f7e..94775fb2 100644
--- a/server/internal/flow/application/execution.go
+++ b/server/internal/flow/application/execution.go
@@ -184,12 +184,11 @@ func (e *executionAppImpl) executeNode(ctx *ExecutionCtx) error {
 
 	// 执行节点逻辑
 	if node.IsAsync() {
-		go func() {
-			defer gox.RecoverPanic()
+		gox.Go(func() {
 			if err := node.Execute(ctx); err != nil {
 				logx.Errorf("async execute node error: %v, procinst_id: %d, node_key: %s", err, ctx.Procinst.Id, flowNode.Key)
 			}
-		}()
+		})
 		return nil
 	}
 
diff --git a/server/internal/machine/api/machine.go b/server/internal/machine/api/machine.go
index 4c187446..c27351ad 100644
--- a/server/internal/machine/api/machine.go
+++ b/server/internal/machine/api/machine.go
@@ -16,6 +16,7 @@ import (
 	tagentity "mayfly-go/internal/tag/domain/entity"
 	"mayfly-go/pkg/biz"
 	"mayfly-go/pkg/global"
+	"mayfly-go/pkg/gox"
 	"mayfly-go/pkg/logx"
 	"mayfly-go/pkg/model"
 	"mayfly-go/pkg/req"
@@ -378,7 +379,9 @@ func (m *Machine) WsGuacamole(rc *req.Ctx) {
 	defer tunnel.ReleaseWriter()
 	defer tunnel.ReleaseReader()
 
-	go guac.WsToGuacd(wsConn, tunnel, writer)
+	gox.Go(func() {
+		guac.WsToGuacd(wsConn, tunnel, writer)
+	})
 	guac.GuacdToWs(wsConn, tunnel, reader)
 
 	//OnConnect
diff --git a/server/internal/machine/application/machine.go b/server/internal/machine/application/machine.go
index 6195dd6c..c2edb3bb 100644
--- a/server/internal/machine/application/machine.go
+++ b/server/internal/machine/application/machine.go
@@ -256,13 +256,11 @@ func (m *machineAppImpl) GetSshTunnelMachine(ctx context.Context, machineId int)
 func (m *machineAppImpl) TimerUpdateStats() {
 	logx.Debug("start collecting and caching machine state information periodically...")
 	scheduler.AddFun("@every 2m", func() {
-		defer gox.RecoverPanic()
+		defer gox.Recover()
 		machineIds, _ := m.ListByCond(model.NewModelCond(&entity.Machine{Status: entity.MachineStatusEnable, Protocol: entity.MachineProtocolSsh}).Columns("id"))
 		for _, ma := range machineIds {
-			go func(mid uint64) {
-				defer gox.RecoverPanic(func(err error) {
-					logx.ErrorTrace(fmt.Sprintf("failed to get machine [id=%d] status information on time", mid), err)
-				})
+			gox.Go(func() {
+				mid := ma.Id
 				logx.Debugf("time to get machine [id=%d] status information start", mid)
 				ctx, cancelFunc := context.WithCancel(context.Background())
 				defer cancelFunc()
@@ -273,7 +271,9 @@ func (m *machineAppImpl) TimerUpdateStats() {
 				}
 				cache.SaveMachineStats(mid, cli.GetAllStats())
 				logx.Debugf("time to get the machine [id=%d] status information end", mid)
-			}(ma.Id)
+			}, func(err error) {
+				logx.ErrorTrace(fmt.Sprintf("failed to get machine [id=%d] status information on time", ma.Id), err)
+			})
 		}
 	})
 }
diff --git a/server/internal/machine/application/machine_cronjob.go b/server/internal/machine/application/machine_cronjob.go
index 65c0af8d..4cd2e58a 100644
--- a/server/internal/machine/application/machine_cronjob.go
+++ b/server/internal/machine/application/machine_cronjob.go
@@ -136,7 +136,9 @@ func (m *machineCronJobAppImpl) RunCronJob(key string) {
 	})), "id")
 
 	for _, machine := range machines {
-		go m.runCronJob0(machine.Id, cronJob)
+		gox.Go(func() {
+			m.runCronJob0(machine.Id, cronJob)
+		})
 	}
 }
 
@@ -150,7 +152,7 @@ func (m *machineCronJobAppImpl) addCronJob(mcj *entity.MachineCronJob) {
 	}
 
 	if err := scheduler.AddFunByKey(key, mcj.Cron, func() {
-		defer gox.RecoverPanic()
+		defer gox.Recover()
 		m.RunCronJob(key)
 	}); err != nil {
 		logx.ErrorTrace("add machine cron job failed", err)
diff --git a/server/internal/machine/application/machine_term_op.go b/server/internal/machine/application/machine_term_op.go
index 1de3e5b8..447c09c0 100644
--- a/server/internal/machine/application/machine_term_op.go
+++ b/server/internal/machine/application/machine_term_op.go
@@ -118,7 +118,7 @@ func (m *machineTermOpAppImpl) GetPageList(condition *entity.MachineTermOp, page
 func (m *machineTermOpAppImpl) TimerDeleteTermOp() {
 	logx.Debug("start deleting machine terminal playback records every hour...")
 	scheduler.AddFun("@every 60m", func() {
-		defer gox.RecoverPanic()
+		defer gox.Recover()
 		startDate := time.Now().AddDate(0, 0, -config.GetMachine().TermOpSaveDays)
 		cond := &entity.MachineTermOpQuery{
 			StartCreateTime: &startDate,
diff --git a/server/internal/machine/guac/tunnel_map.go b/server/internal/machine/guac/tunnel_map.go
index 7fd67763..a1379879 100644
--- a/server/internal/machine/guac/tunnel_map.go
+++ b/server/internal/machine/guac/tunnel_map.go
@@ -1,6 +1,7 @@
 package guac
 
 import (
+	"mayfly-go/pkg/gox"
 	"mayfly-go/pkg/logx"
 	"sync"
 	"time"
@@ -72,7 +73,9 @@ func NewTunnelMap() *TunnelMap {
 		tunnelMap:     make(map[string]*LastAccessedTunnel),
 		tunnelTimeout: TunnelTimeout,
 	}
-	go tunnelMap.tunnelTimeoutTask()
+	gox.Go(func() {
+		tunnelMap.tunnelTimeoutTask()
+	})
 	return tunnelMap
 }
 
@@ -116,7 +119,6 @@ func (m *TunnelMap) tunnelTimeoutTaskRun() {
 		}
 	}
 	m.Unlock()
-	return
 }
 
 // Get returns the Tunnel having the given UUID, wrapped within a LastAccessedTunnel.
diff --git a/server/internal/machine/mcm/sshtunnel.go b/server/internal/machine/mcm/sshtunnel.go
index 02fd8f6d..59993bfe 100644
--- a/server/internal/machine/mcm/sshtunnel.go
+++ b/server/internal/machine/mcm/sshtunnel.go
@@ -5,6 +5,7 @@ import (
 	"errors"
 	"fmt"
 	"io"
+	"mayfly-go/pkg/gox"
 	"mayfly-go/pkg/logx"
 	"mayfly-go/pkg/pool"
 	"mayfly-go/pkg/utils/netx"
@@ -107,7 +108,9 @@ func (stm *SshTunnelMachine) OpenSshTunnel(id string, ip string, port int) (expo
 		remotePort: port,
 		listener:   listener,
 	}
-	go tunnel.Open(stm.SshClient)
+	gox.Go(func() {
+		tunnel.Open(stm.SshClient)
+	})
 	stm.tunnels[tunnel.id] = tunnel
 
 	return localHost, localPort, nil
diff --git a/server/internal/machine/mcm/terminal_session.go b/server/internal/machine/mcm/terminal_session.go
index 2167295f..a351c3cb 100644
--- a/server/internal/machine/mcm/terminal_session.go
+++ b/server/internal/machine/mcm/terminal_session.go
@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"io"
 	"mayfly-go/pkg/errorx"
+	"mayfly-go/pkg/gox"
 	"mayfly-go/pkg/logx"
 
 	"github.com/spf13/cast"
@@ -95,8 +96,12 @@ func NewTerminalSession(param *CreateTerminalSessionParam) (*TerminalSession, er
 }
 
 func (r TerminalSession) Start() {
-	go r.readFromTerminal()
-	go r.writeToWebsocket()
+	gox.Go(func() {
+		r.readFromTerminal()
+	})
+	gox.Go(func() {
+		r.writeToWebsocket()
+	})
 	r.receiveWsMsg()
 }
 
diff --git a/server/internal/msg/application/msg_tmpl.go b/server/internal/msg/application/msg_tmpl.go
index c784b312..294690d8 100644
--- a/server/internal/msg/application/msg_tmpl.go
+++ b/server/internal/msg/application/msg_tmpl.go
@@ -195,9 +195,9 @@ func (m *msgTmplAppImpl) SendMsg(ctx context.Context, mts *dto.MsgTmplSend) erro
 			logx.Warnf("channel is disabled => %s", channel.Code)
 			continue
 		}
-
-		go func(ch entity.MsgChannel) {
-			defer gox.RecoverPanic()
+		
+		gox.Go(func() {
+			ch := *channel
 			if err := msgx.Send(ctx, &msgx.Channel{
 				Type:  ch.Type,
 				Name:  ch.Name,
@@ -206,7 +206,7 @@ func (m *msgTmplAppImpl) SendMsg(ctx context.Context, mts *dto.MsgTmplSend) erro
 			}, msg); err != nil {
 				logx.Errorf("send msg error => channel=%s, msg=%s, err -> %v", ch.Code, msg.Content, err)
 			}
-		}(*channel)
+		})
 	}
 
 	return nil
diff --git a/server/internal/pkg/config/app.go b/server/internal/pkg/config/app.go
index 4f7f5fbc..bdcebae2 100644
--- a/server/internal/pkg/config/app.go
+++ b/server/internal/pkg/config/app.go
@@ -4,7 +4,7 @@ import "fmt"
 
 const (
 	AppName = "mayfly-go"
-	Version = "v1.10.7"
+	Version = "v1.10.8"
 )
 
 func GetAppInfo() string {
diff --git a/server/internal/pkg/starter/web-server.go b/server/internal/pkg/starter/web-server.go
index f32da74f..ffc2abfa 100644
--- a/server/internal/pkg/starter/web-server.go
+++ b/server/internal/pkg/starter/web-server.go
@@ -66,7 +66,7 @@ func runWebServer(ctx context.Context) {
 	}
 
 	go func() {
-		defer gox.RecoverPanic()
+		defer gox.Recover()
 		<-ctx.Done()
 		logx.Info("Shutdown HTTP Server ...")
 		timeout, cancel := context.WithTimeout(context.Background(), 5*time.Second)
diff --git a/server/pkg/gox/gox.go b/server/pkg/gox/gox.go
index 4fdf7651..dbbc7095 100644
--- a/server/pkg/gox/gox.go
+++ b/server/pkg/gox/gox.go
@@ -1,13 +1,47 @@
 package gox
 
 import (
+	"context"
 	"errors"
 	"mayfly-go/pkg/logx"
 	"runtime/debug"
 )
 
-// RecoverPanic 捕获panic日志, 可选传入panic时的回调函数
-func RecoverPanic(onPanic ...func(error)) {
+// Go 启动安全协程，自动捕获并处理panic
+// 该函数会在协程中执行传入的函数f，并使用recover捕获可能发生的panic
+// 如果发生panic，会记录错误日志，同时执行传入的回调函数（如果有）
+//
+// 参数:
+//   - f: 要在协程中执行的函数
+//   - onPanic: 可选的panic回调函数，当发生panic时会被调用，可传入多个回调函数
+func Go(f func(), onPanic ...func(error)) {
+	go func() {
+		defer Recover(onPanic...)
+		f()
+	}()
+}
+
+// GoCtx 启动安全协程（带上下文）
+// 该函数会在协程中执行传入的函数fn，并使用recover捕获可能发生的panic
+// 如果发生panic，会记录错误日志，同时执行传入的回调函数（如果有）
+//
+// 参数:
+//   - ctx: 上下文对象，用于传递取消信号、超时等
+//   - fn: 要在协程中执行的函数，接收上下文参数
+//   - onPanic: 可选的panic回调函数，当发生panic时会被调用，可传入多个回调函数
+func GoCtx(ctx context.Context, fn func(context.Context), onPanic ...func(error)) {
+	go func() {
+		defer Recover(onPanic...)
+		fn(ctx)
+	}()
+}
+
+// Recover 捕获panic日志, 可选传入panic时的回调函数
+// 该函数应作为defer调用的一部分，用于捕获并处理panic
+//
+// 参数:
+//   - onPanic: 可选的panic回调函数，当发生panic时会被调用，可传入多个回调函数
+func Recover(onPanic ...func(error)) {
 	if r := recover(); r != nil {
 		logx.ErrorTrace("PANIC: ", r)
 
diff --git a/server/pkg/pool/cache_pool.go b/server/pkg/pool/cache_pool.go
index 5220b0a1..cadee3a3 100644
--- a/server/pkg/pool/cache_pool.go
+++ b/server/pkg/pool/cache_pool.go
@@ -3,6 +3,7 @@ package pool
 import (
 	"context"
 	"math/rand"
+	"mayfly-go/pkg/gox"
 	"mayfly-go/pkg/logx"
 	"mayfly-go/pkg/utils/stringx"
 	"sync"
@@ -44,7 +45,9 @@ func NewCachePool[T Conn](factory func() (T, error), opts ...Option[T]) *CachePo
 		closeCh: make(chan struct{}),
 	}
 
-	go p.backgroundMaintenance()
+	gox.Go(func() {
+		p.backgroundMaintenance()
+	})
 	
 	return p
 }
@@ -253,14 +256,14 @@ func (p *CachePool[T]) cleanupIdle() {
 func (p *CachePool[T]) ping(conn T) bool {
 	done := make(chan struct{})
 	var result bool
-	go func() {
+	gox.Go(func ()  {
 		err := conn.Ping()
 		if err != nil {
 			logx.Errorf("conn pool - ping failed: %s", err.Error())
 		}
 		result = err == nil
 		close(done)
-	}()
+	})
 	select {
 	case <-done:
 		return result
diff --git a/server/pkg/req/log_handler.go b/server/pkg/req/log_handler.go
index 81be7baf..755259fd 100644
--- a/server/pkg/req/log_handler.go
+++ b/server/pkg/req/log_handler.go
@@ -4,6 +4,7 @@ import (
 	"fmt"
 	"mayfly-go/pkg/contextx"
 	"mayfly-go/pkg/errorx"
+	"mayfly-go/pkg/gox"
 	"mayfly-go/pkg/i18n"
 	"mayfly-go/pkg/logx"
 	"mayfly-go/pkg/utils/anyx"
@@ -73,7 +74,9 @@ func LogHandler(rc *Ctx) error {
 
 	// 如果需要保存日志，并且保存日志处理函数存在则执行保存日志函数
 	if li.save && saveLog != nil {
-		go saveLog(rc)
+		gox.Go(func() {
+			saveLog(rc)
+		})
 	}
 
 	logMsg := li.Description
diff --git a/server/pkg/ws/client.go b/server/pkg/ws/client.go
index 7a6a0c6a..7a46ac1a 100644
--- a/server/pkg/ws/client.go
+++ b/server/pkg/ws/client.go
@@ -3,6 +3,7 @@ package ws
 import (
 	"encoding/json"
 	"errors"
+	"mayfly-go/pkg/gox"
 	"mayfly-go/pkg/logx"
 	"time"
 
@@ -40,7 +41,7 @@ func (c *Client) WithReadHandlerFunc(readMsgHandlerFunc ReadMsgHandlerFunc) *Cli
 
 // 读取ws客户端消息
 func (c *Client) Read() {
-	go func() {
+	gox.Go(func() {
 		for {
 			if c.WsConn == nil {
 				return
@@ -59,7 +60,7 @@ func (c *Client) Read() {
 				c.ReadMsgHandler(data)
 			}
 		}
-	}()
+	})
 }
 
 // 向客户端写入消息
diff --git a/server/pkg/ws/client_manager.go b/server/pkg/ws/client_manager.go
index c297c38c..e9997d67 100644
--- a/server/pkg/ws/client_manager.go
+++ b/server/pkg/ws/client_manager.go
@@ -97,6 +97,10 @@ func (manager *ClientManager) CloseClient(client *Client) {
 // 根据用户id关闭客户端连接
 func (manager *ClientManager) CloseByUid(userId UserId) {
 	userClient := manager.GetByUid(userId)
+	if userClient == nil {
+		return
+	}
+
 	for _, client := range userClient.AllClients() {
 		manager.CloseClient(client)
 	}
@@ -140,8 +144,7 @@ func (manager *ClientManager) SendJsonMsg(userId UserId, clientId string, data a
 
 // 监听并发送给客户端信息
 func (manager *ClientManager) WriteMessage() {
-	go func() {
-		defer gox.RecoverPanic()
+	gox.Go(func() {
 		for {
 			msg := <-manager.MsgChan
 			uid := msg.ToUserId
@@ -169,13 +172,12 @@ func (manager *ClientManager) WriteMessage() {
 				}
 			}
 		}
-	}()
+	})
 }
 
 // 启动定时器进行心跳检测
 func (manager *ClientManager) HeartbeatTimer() {
-	go func() {
-		defer gox.RecoverPanic()
+	gox.Go(func() {
 		ticker := time.NewTicker(heartbeatInterval)
 		defer ticker.Stop()
 		for {
@@ -196,7 +198,7 @@ func (manager *ClientManager) HeartbeatTimer() {
 				return true
 			})
 		}
-	}()
+	})
 }
 
 // 处理建立连接