- \n
- \u2022 \u65b9\u6cd5\u8c03\u7528\u6b21\u6570\uff1a\u7edf\u8ba1\u67d0\u65b9\u6cd5\u88ab\u8c03\u7528\u4e86\u591a\u5c11\u6b21<\/li>\n\n\n\n
- \u2022 \u8017\u65f6\u6307\u6807\uff1a\u5e73\u5747\u8017\u65f6\u3001\u6700\u5927\u8017\u65f6\u3001\u6700\u5c0f\u8017\u65f6<\/li>\n\n\n\n
- \u2022 \u6210\u529f\/\u5931\u8d25\u6b21\u6570\uff1a\u533a\u5206\u6b63\u5e38\u4e0e\u5f02\u5e38\u8c03\u7528<\/li>\n\n\n\n
- \u2022 \u591a\u7ef4\u6392\u5e8f\uff1a\u652f\u6301\u6309\u8c03\u7528\u6b21\u6570\u3001\u5e73\u5747\u8017\u65f6\u3001\u5931\u8d25\u6b21\u6570\u7b49\u7ef4\u5ea6\u6392\u5e8f<\/li>\n<\/ul>\n\n\n\n
\u8fdb\u9636\u529f\u80fd\uff1a<\/strong><\/p>\n\n\n\n
- \n
- \u2022 \u65f6\u95f4\u6bb5\u8fc7\u6ee4\uff1a\u9009\u62e9\u65f6\u95f4\u8303\u56f4\uff08\u5982\u6700\u8fd1 5 \u5206\u949f\u30011 \u5c0f\u65f6\u30011 \u5929\uff09\u67e5\u770b\u6570\u636e<\/li>\n\n\n\n
- \u2022 \u63a5\u53e3\u641c\u7d22\uff1a\u5feb\u901f\u5b9a\u4f4d\u7279\u5b9a\u63a5\u53e3\u7684\u6027\u80fd\u6570\u636e<\/li>\n\n\n\n
- \u2022 \u53ef\u89c6\u5316\u63a7\u5236\u53f0\uff1a\u5b9e\u65f6\u5c55\u793a\u63a5\u53e3\u8c03\u7528\u7edf\u8ba1<\/li>\n<\/ul>\n\n\n\n
\u4e09\u3001\u6280\u672f\u8bbe\u8ba1<\/h1>\n\n\n\n
\u6574\u4f53\u601d\u8def<\/h3>\n\n\n\n
\u65b9\u6cd5\u5207\u9762\u91c7\u96c6<\/strong>
\u4f7f\u7528 SpringAOP\uff08\u57fa\u4e8e\u62e6\u622a\u5668\u4ea6\u53ef\uff09 \u62e6\u622a Controller \u65b9\u6cd5\uff0c\u5728\u65b9\u6cd5\u6267\u884c\u524d\u540e\u8bb0\u5f55\u65f6\u95f4\u5dee\u3001\u6267\u884c\u7ed3\u679c\uff08\u6210\u529f\/\u5931\u8d25\uff09\u3002<\/p>\n\n\n\n\u5206\u7ea7\u6570\u636e\u5b58\u50a8<\/strong>
\u91c7\u7528\u5206\u7ea7\u65f6\u95f4\u6876\u7b56\u7565\uff1a<\/p>\n\n\n\n- \n
- \u2022 \u6700\u8fd15\u5206\u949f\uff1a\u79d2\u7ea7\u7cbe\u5ea6\u7edf\u8ba1<\/li>\n\n\n\n
- \u2022 \u6700\u8fd11\u5c0f\u65f6\uff1a\u5206\u949f\u7ea7\u805a\u5408<\/li>\n\n\n\n
- \u2022 \u6700\u8fd124\u5c0f\u65f6\uff1a\u5c0f\u65f6\u7ea7\u805a\u5408<\/li>\n\n\n\n
- \u2022 \u6700\u8fd17\u5929\uff1a\u5929\u7ea7\u805a\u5408<\/li>\n<\/ul>\n\n\n\n
\u667a\u80fd\u67e5\u8be2<\/strong>
\u6839\u636e\u67e5\u8be2\u65f6\u95f4\u8303\u56f4\uff0c\u81ea\u52a8\u9009\u62e9\u6700\u9002\u5408\u7684\u6570\u636e\u7c92\u5ea6\u8fdb\u884c\u805a\u5408\u8ba1\u7b97\u3002<\/p>\n\n\n\n\u63a5\u53e3\u5c55\u793a<\/strong>
\u63d0\u4f9b REST API \u8f93\u51fa\u7edf\u8ba1\u6570\u636e\uff0c\u524d\u7aef\u4f7f\u7528 TailwindCSS + Alpine.js \u6e32\u67d3\u754c\u9762\u3002<\/p>\n\n\n\n\u56db\u3001\u6838\u5fc3\u5b9e\u73b0<\/h1>\n\n\n\n
1. \u65f6\u95f4\u6876\u6570\u636e\u6a21\u578b<\/h3>\n\n\n\n
@Data
publicclassTimeBucket {
privatefinalAtomicLongtotalCount=newAtomicLong(0);
privatefinalAtomicLongsuccessCount=newAtomicLong(0);
privatefinalAtomicLongfailCount=newAtomicLong(0);
privatefinalLongAddertotalTime=newLongAdder();
privatevolatilelongmaxTime=0;
privatevolatilelongminTime= Long.MAX_VALUE;
privatefinallong bucketStartTime;
privatevolatilelong lastUpdateTime;
publicTimeBucket(long bucketStartTime) {
this.bucketStartTime = bucketStartTime;
this.lastUpdateTime = System.currentTimeMillis();
}
publicsynchronizedvoidrecord(long duration, boolean success) {
totalCount.incrementAndGet();
if (success) {
successCount.incrementAndGet();
} else {
failCount.incrementAndGet();
}
totalTime.add(duration);
maxTime = Math.max(maxTime, duration);
minTime = Math.min(minTime, duration);
lastUpdateTime = System.currentTimeMillis();
}
publicdoublegetAvgTime() {
longtotal= totalCount.get();
return total == 0 ? 0.0 : (double) totalTime.sum() \/ total;
}
publicdoublegetSuccessRate() {
longtotal= totalCount.get();
return total == 0 ? 0.0 : (double) successCount.get() \/ total * 100;
}
}<\/code><\/pre>\n\n\n\n2. \u5206\u7ea7\u91c7\u6837\u6307\u6807\u6a21\u578b<\/h3>\n\n\n\n
@Data
publicclassHierarchicalMethodMetrics {
\/\/ \u57fa\u7840\u7edf\u8ba1\u4fe1\u606f
privatefinalAtomicLongtotalCount=newAtomicLong(0);
privatefinalAtomicLongsuccessCount=newAtomicLong(0);
privatefinalAtomicLongfailCount=newAtomicLong(0);
privatefinalLongAddertotalTime=newLongAdder();
privatevolatilelongmaxTime=0;
privatevolatilelongminTime= Long.MAX_VALUE;
privatefinal String methodName;
\/\/ \u5206\u7ea7\u65f6\u95f4\u6876
privatefinal ConcurrentHashMap<Long, TimeBucket> secondBuckets = newConcurrentHashMap<>(); \/\/ \u6700\u8fd15\u5206\u949f\uff0c\u79d2\u7ea7
privatefinal ConcurrentHashMap<Long, TimeBucket> minuteBuckets = newConcurrentHashMap<>(); \/\/ \u6700\u8fd11\u5c0f\u65f6\uff0c\u5206\u949f\u7ea7
privatefinal ConcurrentHashMap<Long, TimeBucket> hourBuckets = newConcurrentHashMap<>(); \/\/ \u6700\u8fd124\u5c0f\u65f6\uff0c\u5c0f\u65f6\u7ea7
privatefinal ConcurrentHashMap<Long, TimeBucket> dayBuckets = newConcurrentHashMap<>(); \/\/ \u6700\u8fd17\u5929\uff0c\u5929\u7ea7
publicsynchronizedvoidrecord(long duration, boolean success) {
longcurrentTime= System.currentTimeMillis();
\/\/ \u66f4\u65b0\u57fa\u7840\u7edf\u8ba1
totalCount.incrementAndGet();
if (success) {
successCount.incrementAndGet();
} else {
failCount.incrementAndGet();
}
totalTime.add(duration);
maxTime = Math.max(maxTime, duration);
minTime = Math.min(minTime, duration);
\/\/ \u5206\u7ea7\u8bb0\u5f55\u5230\u4e0d\u540c\u65f6\u95f4\u6876
recordToTimeBuckets(currentTime, duration, success);
\/\/ \u6e05\u7406\u8fc7\u671f\u6876
cleanupExpiredBuckets(currentTime);
}
public TimeRangeMetrics queryTimeRange(long startTime, long endTime) {
List<TimeBucket.TimeBucketSnapshot> buckets = selectBucketsForTimeRange(startTime, endTime);
return aggregateSnapshots(buckets, startTime, endTime);
}
}<\/code><\/pre>\n\n\n\n3. AOP \u5207\u9762\u7edf\u8ba1<\/h3>\n\n\n\n
@Slf4j
@Aspect
@Component
publicclassMethodMetricsAspect {
privatefinal ConcurrentHashMap<String, HierarchicalMethodMetrics> metricsMap = newConcurrentHashMap<>();
@Around(\"@within(org.springframework.web.bind.annotation.RestController) || \" +
\"@within(org.springframework.stereotype.Controller)\")
public Object recordMetrics(ProceedingJoinPoint joinPoint)throws Throwable {
StringmethodName= buildMethodName(joinPoint);
longstartTime= System.nanoTime();
booleansuccess=true;
try {
Objectresult= joinPoint.proceed();
return result;
} catch (Throwable throwable) {
success = false;
throw throwable;
} finally {
longduration= (System.nanoTime() - startTime) \/ 1_000_000; \/\/ Convert to milliseconds
metricsMap.computeIfAbsent(methodName, HierarchicalMethodMetrics::new)
.record(duration, success);
}
}
private String buildMethodName(ProceedingJoinPoint joinPoint) {
StringclassName= joinPoint.getTarget().getClass().getSimpleName();
StringmethodName= joinPoint.getSignature().getName();
return className + \".\" + methodName + \"()\";
}
public Map<String, HierarchicalMethodMetrics> getMetricsSnapshot() {
returnnewConcurrentHashMap<>(metricsMap);
}
}<\/code><\/pre>\n\n\n\n4. \u6570\u636e\u67e5\u8be2\u63a5\u53e3<\/h3>\n\n\n\n
@RestController
@RequestMapping(\"\/api\/metrics\")
@RequiredArgsConstructor
publicclassMetricsController {
privatefinal MethodMetricsAspect metricsAspect;
@GetMapping
public Map<String, Object> getMetrics(
@RequestParam(required = false) Long startTime,
@RequestParam(required = false) Long endTime,
@RequestParam(required = false) String methodFilter) {
Map<String, Object> result = newHashMap<>();
Map<String, HierarchicalMethodMetrics> snapshot = metricsAspect.getMetricsSnapshot();
\/\/ \u5e94\u7528\u63a5\u53e3\u540d\u8fc7\u6ee4
if (StringUtils.hasText(methodFilter)) {
snapshot = snapshot.entrySet().stream()
.filter(entry -> entry.getKey().toLowerCase().contains(methodFilter.toLowerCase()))
.collect(Collectors.toMap(Map.Entry::getKey, Map.Entry::getValue));
}
\/\/ \u65f6\u95f4\u8303\u56f4\u67e5\u8be2
if (startTime != null && endTime != null) {
snapshot.forEach((methodName, metrics) -> {
HierarchicalMethodMetrics.TimeRangeMetricstimeRangeMetrics=
metrics.queryTimeRange(startTime, endTime);
Map<String, Object> metricData = buildTimeRangeMetricData(timeRangeMetrics);
result.put(methodName, metricData);
});
} else {
\/\/ \u5168\u91cf\u6570\u636e
snapshot.forEach((methodName, metrics) -> {
Map<String, Object> metricData = buildMetricData(metrics);
result.put(methodName, metricData);
});
}
return result;
}
@GetMapping(\"\/recent\/{minutes}\")
public Map<String, Object> getRecentMetrics(
@PathVariable int minutes,
@RequestParam(required = false) String methodFilter) {
longendTime= System.currentTimeMillis();
longstartTime= endTime - (minutes * 60L * 1000L);
return getMetrics(startTime, endTime, methodFilter);
}
@GetMapping(\"\/summary\")
public Map<String, Object> getSummary(
@RequestParam(required = false) Long startTime,
@RequestParam(required = false) Long endTime,
@RequestParam(required = false) String methodFilter) {
\/\/ \u6c47\u603b\u7edf\u8ba1\u903b\u8f91
Map<String, HierarchicalMethodMetrics> snapshot = metricsAspect.getMetricsSnapshot();
\/\/ ... \u6c47\u603b\u8ba1\u7b97
return summary;
}
}<\/code><\/pre>\n\n\n\n5. \u5b9a\u65f6\u6e05\u7406\u670d\u52a1<\/h3>\n\n\n\n
@Service
@RequiredArgsConstructor
publicclassMetricsCleanupService {
privatefinal MethodMetricsAspect metricsAspect;
@Value(\"${dashboard.metrics.max-age:3600000}\")
privatelong maxAge;
@Scheduled(fixedRateString = \"${dashboard.metrics.cleanup-interval:300000}\")
publicvoidcleanupStaleMetrics() {
try {
metricsAspect.removeStaleMetrics(maxAge);
intcurrentMethodCount= metricsAspect.getMetricsSnapshot().size();
log.info(\"Metrics cleanup completed. Current methods being monitored: {}\", currentMethodCount);
} catch (Exception e) {
log.error(\"Error during metrics cleanup\", e);
}
}
}<\/code><\/pre>\n\n\n\n\u4e94\u3001\u524d\u7aef\u53ef\u89c6\u5316\u754c\u9762<\/h1>\n\n\n\n
\u6838\u5fc3\u529f\u80fd\u5b9e\u73b0\uff1a<\/p>\n\n\n\n
function metricsApp() {
return {
metrics: {},
summary: {},
timeRange: 'all',
methodFilter: '',
\/\/ \u65f6\u95f4\u8303\u56f4\u8bbe\u7f6e
setTimeRange(range) {
this.timeRange = range;
this.updateTimeRangeText();
if (range !== 'custom') {
this.fetchMetrics();
this.fetchSummary();
}
},
\/\/ \u6784\u5efaAPI\u67e5\u8be2URL
buildApiUrl(endpoint) {
let url = `\/api\/metrics${endpoint}`;
const params = newURLSearchParams();
\/\/ \u6dfb\u52a0\u65f6\u95f4\u53c2\u6570
if (this.timeRange !== 'all') {
if (this.timeRange === 'custom') {
if (this.customStartTime && this.customEndTime) {
params.append('startTime', newDate(this.customStartTime).getTime());
params.append('endTime', newDate(this.customEndTime).getTime());
}
} else {
const endTime = Date.now();
const startTime = endTime - (this.timeRange * 60 * 1000);
params.append('startTime', startTime);
params.append('endTime', endTime);
}
}
\/\/ \u6dfb\u52a0\u641c\u7d22\u53c2\u6570
if (this.methodFilter.trim()) {
params.append('methodFilter', this.methodFilter.trim());
}
return params.toString() ? url + '?' + params.toString() : url;
},
\/\/ \u83b7\u53d6\u76d1\u63a7\u6570\u636e
asyncfetchMetrics() {
this.loading = true;
try {
const response = awaitfetch(this.buildApiUrl(''));
this.metrics = await response.json();
this.lastUpdate = newDate().toLocaleTimeString();
} catch (error) {
console.error('Failed to fetch metrics:', error);
} finally {
this.loading = false;
}
}
};
}<\/code><\/pre>\n\n\n\n\u516d\u3001\u914d\u7f6e\u8bf4\u660e<\/h1>\n\n\n\n
application.yml \u914d\u7f6e<\/h3>\n\n\n\n
server:
port:8080
spring:
application:
name:springboot-api-dashboard
aop:
auto:true
proxy-target-class:true
# \u76d1\u63a7\u914d\u7f6e
dashboard:
metrics:
cleanup-interval:300000# \u6e05\u7406\u95f4\u9694\uff1a5\u5206\u949f
max-age:3600000 # \u6700\u5927\u5b58\u6d3b\u65f6\u95f4\uff1a1\u5c0f\u65f6
debug-enabled:false # \u8c03\u8bd5\u6a21\u5f0f
logging:
level:
com.example.dashboard: INFO<\/code><\/pre>\n\n\n\nMaven \u4f9d\u8d56<\/h3>\n\n\n\n
<dependencies>
<dependency>
<groupId>org.springframework.boot<\/groupId>
<artifactId>spring-boot-starter-web<\/artifactId>
<\/dependency>
<dependency>
<groupId>org.springframework.boot<\/groupId>
<artifactId>spring-boot-starter-aop<\/artifactId>
<\/dependency>
<dependency>
<groupId>org.projectlombok<\/groupId>
<artifactId>lombok<\/artifactId>
<optional>true<\/optional>
<\/dependency>
<\/dependencies><\/code><\/pre>\n\n\n\n\u4e03\u3001\u4f7f\u7528\u793a\u4f8b<\/h1>\n\n\n\n
\u542f\u52a8\u5e94\u7528<\/h3>\n\n\n\n
mvn clean install
mvn spring-boot:run<\/code><\/pre>\n\n\n\n\u8bbf\u95ee\u754c\u9762<\/h3>\n\n\n\n
http:\/\/localhost:8080\/index.html<\/p>\n\n\n\n
![\"\"](\"https:\/\/wp-moto-1258805347.cos.ap-shanghai.myqcloud.com\/2025\/09\/20250929053327556-1024x425.png\")