@@ -120,6 +120,12 @@
< icon-down / >
< / a-button >
< template # content >
< a-doption : disabled = "isCollecting(record) || !record.server_identity" @click ="handleCollectNow(record)" >
< template # icon >
< icon-refresh / >
< / template >
{ { isCollecting ( record ) ? '采集中' : '立即采集' } }
< / a-doption >
< a-doption @click ="handleQuickConfig(record)" >
< template # icon >
< icon-settings / >
@@ -200,13 +206,7 @@ import ServerFormDialog from './components/ServerFormDialog.vue'
import QuickConfigDialog from './components/QuickConfigDialog.vue'
import HardwareDeviceConfigDialog from './components/HardwareDeviceConfigDialog.vue'
import { columns as columnsConfig } from './config/columns'
import { fetchServerList , deleteServer } from '@/api/ops/server'
import axios from 'axios'
// 创建独立的 axios 实例用于请求外部 agent，
const agentAxios = axios . create ( {
timeout : 5000 ,
} )
import { fetchServerList , deleteServer , fetchServerMetricsSummary , collectServerMetricsNow , type HostMetricsSummary } from '@/api/ops/server'
const router = useRouter ( )
@@ -217,6 +217,7 @@ const formDialogVisible = ref(false)
const quickConfigVisible = ref ( false )
const hardwareConfigVisible = ref ( false )
const currentRecord = ref < any > ( null )
const collectingMap = reactive < Record < string , boolean > > ( { } )
const formModel = ref ( {
keyword : '' ,
collect _on : undefined as boolean | undefined ,
@@ -394,6 +395,13 @@ const handleHardwareConfigSuccess = () => {
fetchServers ( )
}
const getCollectingKey = ( record : any ) => record . server _identity || String ( record . id || '' )
const isCollecting = ( record : any ) => {
const key = getCollectingKey ( record )
return ! ! collectingMap [ key ]
}
// 编辑服务器
const handleEdit = ( record : any ) => {
currentRecord . value = record
@@ -465,74 +473,86 @@ const handleDelete = async (record: any) => {
} )
}
/** dc-host `GET agent_config`（一般为 `/dc-host/stats`）返回裸 Metrics JSON */
// 获取所有服务器的监控指标
const getAllMetrics = async ( ) => {
try {
// 遍历每个服务器记录
const metricsPromises = tableData . value . map ( async ( record ) => {
// 检查是否有 agent_config 配置
if ( record . agent _config ) {
try {
// 从 agent_config 中解析 URL
let metricsUrl = record . agent _config
// 验证 URL 是否合法
try {
new URL ( metricsUrl )
} catch ( urlError ) {
console . warn ( ` 服务器 ${ record . name } 的 agent_config 不是合法的 URL: ` , metricsUrl )
// 设置默认值 0
const resetMetrics = ( record : any ) => {
record . cpu _info = { value : 0 , total : '' , used : '' }
record . memory _info = { value : 0 , total : '' , used : '' }
record . disk _info = { value : 0 , total : '' , used : '' }
}
const applyMetricsSummary = ( record : any , summary ? : HostMetricsSummary ) => {
if ( ! summary || ! summary . has _data ) {
resetMetrics ( record )
return
}
// 使用独立的 axios 实例请求外部 agent，
const response = await agentAxios . get ( metricsUrl )
console . log ( '获取指标数据:' , response . data )
if ( response . data ) {
// 更新记录的监控数据
record . cpu _info = {
value : Number ( ( response . data . cpu _ usage|| 0 ) . toFixed ( 2 ) ) ,
total : response . data . cpu ? . length ? ` ${ response . data . cpu . length } 核 ` : '' ,
value : Number ( ( summary . cpu ? . usage _percent || 0 ) . toFixed ( 2 ) ) ,
total : summary . cpu ? . logical _cores _total ? ` ${ summary . cpu . logical _cores _total } 核 ` : '' ,
used : '' ,
}
record . memory _info = {
value : Number ( ( response . data . mem _usage ? . used _percent || 0 ) . toFixed ( 2 ) ) ,
total : response . data . mem _usage ? . total ? ` ${ ( response . data . mem _usage . total / 1024 / 1024 / 1024 ) . toFixed ( 1 ) } GB ` : '' ,
used : response . data . mem _usage ? . used ? ` ${ ( response . data . mem _usage . used / 1024 / 1024 / 1024 ) . toFixed ( 1 ) } GB ` : '' ,
value : Number ( ( summary . memory ? . used _percent || 0 ) . toFixed ( 2 ) ) ,
total : summary . memory ? . total _bytes ? ` ${ ( summary . memory . total _bytes / 1024 / 1024 / 1024 ) . toFixed ( 1 ) } GB ` : '' ,
used : summary . memory ? . used _bytes ? ` ${ ( summary . memory . used _bytes / 1024 / 1024 / 1024 ) . toFixed ( 1 ) } GB ` : '' ,
}
record . disk _info = {
value : Number ( ( summary . disk _root ? . used _percent || 0 ) . toFixed ( 2 ) ) ,
total : summary . disk _root ? . total _bytes ? ` ${ ( summary . disk _root . total _bytes / 1024 / 1024 / 1024 ) . toFixed ( 0 ) } GB ` : '' ,
used : summary . disk _root ? . used _bytes ? ` ${ ( summary . disk _root . used _bytes / 1024 / 1024 / 1024 ) . toFixed ( 0 ) } GB ` : '' ,
}
if ( summary . timestamp ) {
record . last _check _time = summary . timestamp
}
}
record . disk _info = {
value : Number ( ( response . data . disk _usage ? . used _percent || 0 ) . toFixed ( 2 ) ) ,
total : response . data . disk _usage ? . total ? ` ${ ( response . data . disk _usage . total / 1024 / 1024 / 1024 ) . toFixed ( 0 ) } GB ` : '' ,
used : response . data . disk _usage ? . used ? ` ${ ( response . data . disk _usage . used / 1024 / 1024 / 1024 ) . toFixed ( 0 ) } GB ` : '' ,
}
// 从 dc-control 获取所有服务器最新时序指标
const getAllMetrics = async ( ) => {
try {
const metricsPromises = tableData . value . map ( async ( record ) => {
if ( ! record . server _identity ) {
resetMetrics ( record )
return
}
try {
const response = await fetchServerMetricsSummary ( record . server _identity )
applyMetricsSummary ( record , response . details )
} catch ( error ) {
console . warn ( ` 获取服务器 ${ record . name } 的监控指标失败: ` , error )
// 初始化默认值
record . cpu _info = { value : 0 , total : '' , used : '' }
record . memory _info = { value : 0 , total : '' , used : '' }
record . disk _info = { value : 0 , total : '' , used : '' }
}
} else {
// 没有配置 agent，
record . cpu _info = { value : 0 , total : '' , used : '' }
record . memory _info = { value : 0 , total : '' , used : '' }
record . disk _info = { value : 0 , total : '' , used : '' }
resetMetrics ( record )
}
} )
// 等待所有请求完成
await Promise . all ( metricsPromises )
} catch ( error ) {
console . error ( '获取所有服务器监控指标失败:' , error )
}
}
const handleCollectNow = async ( record : any ) => {
if ( ! record . server _identity ) {
Message . warning ( '缺少服务器唯一标识，无法采集' )
return
}
const key = getCollectingKey ( record )
if ( collectingMap [ key ] ) {
return
}
collectingMap [ key ] = true
try {
const response = await collectServerMetricsNow ( record . server _identity )
if ( response . code === 0 ) {
applyMetricsSummary ( record , response . details )
Message . success ( '采集完成' )
} else {
Message . error ( response . message || '采集失败' )
}
} catch ( error ) {
console . error ( '立即采集失败:' , error )
Message . error ( '采集失败' )
} finally {
collectingMap [ key ] = false
}
}
onMounted ( ( ) => {
fetchServers ( )
} )
