\u4e0d\u5065\u5eb7：\u5fc3\u8df3\u95f4\u9694 > \u9884\u671f\u95f4\u9694 \u00d7 5，\u6216 status \u662f error，\u6216\u8fde\u7eed 3 \u6b21\u5fc3\u8df3\u7f3a\u5931<\/li>\n<\/ul>\n\u4e09\u3001\u751f\u4ea7\u7ea7\u4ee3\u7801\u5b9e\u73b0<\/h3>\n3.1 Agent \u5fc3\u8df3\u4e0a\u62a5\u5668<\/h4>\n
\/\/ agent-heartbeat.ts \u2014\u2014 Agent \u8fdb\u7a0b\u5fc3\u8df3\u4e0a\u62a5\u5668
\nimport { EventEmitter } from 'events';<\/p>\n
export enum AgentStatus {
\n IDLE = 'idle', \/\/ \u7b49\u5f85\u7528\u6237\u8f93\u5165
\n PROCESSING = 'processing', \/\/ \u6b63\u5728\u5904\u7406\u7528\u6237\u8bf7\u6c42
\n ERROR = 'error', \/\/ \u5904\u7406\u51fa\u9519，\u7b49\u5f85\u6062\u590d
\n TERMINATING = 'terminating', \/\/ \u6b63\u5728\u4f18\u96c5\u5173\u95ed
\n}<\/p>\n
export interface HeartbeatPayload {
\n agent_id: string;
\n session_id: string;
\n status: AgentStatus;
\n current_step: number;
\n total_steps: number;
\n cpu_percent: number;
\n memory_mb: number;
\n last_tool_call: string | null;
\n timestamp: number; \/\/ Unix \u65f6\u95f4\u6233（\u6beb\u79d2）
\n}<\/p>\n
export class AgentHeartbeat extends EventEmitter {
\n private agentId: string;
\n private sessionId: string;
\n private status: AgentStatus = AgentStatus.IDLE;
\n private currentStep: number = 0;
\n private totalSteps: number = 0;
\n private lastToolCall: string | null = null;<\/p>\n
private intervalMs: number; \/\/ \u5fc3\u8df3\u95f4\u9694
\n private maxMissedHeartbeats: number; \/\/ \u5141\u8bb8\u7f3a\u5931\u7684\u6700\u5927\u5fc3\u8df3\u6570
\n private heartbeatTimer: NodeJS.Timeout | null = null;<\/p>\n
\/\/ \u5fc3\u8df3\u53d1\u9001\u901a\u9053：WebSocket \/ HTTP \/ \u6d88\u606f\u961f\u5217
\n private sender: (payload: HeartbeatPayload) => Promise<void>;<\/p>\n
constructor(
\n agentId: string,
\n sessionId: string,
\n intervalMs: number = 5000, \/\/ \u9ed8\u8ba4 5 \u79d2\u5fc3\u8df3\u95f4\u9694
\n maxMissedHeartbeats: number = 3,
\n sender: (payload: HeartbeatPayload) => Promise<void>
\n ) {
\n super();
\n this.agentId = agentId;
\n this.sessionId = sessionId;
\n this.intervalMs = intervalMs;
\n this.maxMissedHeartbeats = maxMissedHeartbeats;
\n this.sender = sender;
\n }<\/p>\n
\/** \u542f\u52a8\u5fc3\u8df3\u5faa\u73af：\u5b9a\u65f6\u4e0a\u62a5\u72b6\u6001 *\/
\n start(): void {
\n if (this.heartbeatTimer) return; \/\/ \u5df2\u542f\u52a8\u5219\u4e0d\u91cd\u590d\u542f\u52a8<\/p>\n
\/\/ \u5b9a\u65f6\u53d1\u9001\u5fc3\u8df3：intervalMs \u95f4\u9694
\n \/\/ \u5fc3\u8df3\u662f"\u63a8"\u6a21\u5f0f，\u4e0d\u662f"\u62c9"\u6a21\u5f0f\u2014\u2014\u670d\u52a1\u7aef\u4e0d\u9700\u8981\u8f6e\u8be2\u68c0\u67e5 Agent \u72b6\u6001
\n this.heartbeatTimer = setInterval(() => {
\n this.sendHeartbeat();
\n }, this.intervalMs);<\/p>\n
\/\/ \u7acb\u5373\u53d1\u9001\u4e00\u6b21\u5fc3\u8df3：\u542f\u52a8\u65f6\u8ba9\u670d\u52a1\u7aef\u77e5\u9053 Agent \u5df2\u4e0a\u7ebf
\n this.sendHeartbeat();
\n }<\/p>\n
\/** \u505c\u6b62\u5fc3\u8df3\u5faa\u73af：\u4f18\u96c5\u5173\u95ed\u524d\u8c03\u7528 *\/
\n stop(): void {
\n if (this.heartbeatTimer) {
\n clearInterval(this.heartbeatTimer);
\n this.heartbeatTimer = null;
\n }<\/p>\n
\/\/ \u53d1\u9001\u6700\u7ec8\u5fc3\u8df3：\u6807\u8bb0\u4e3a terminating，\u670d\u52a1\u7aef\u77e5\u9053 Agent \u6b63\u5728\u5173\u95ed
\n this.status = AgentStatus.TERMINATING;
\n this.sendHeartbeat();
\n }<\/p>\n
\/** \u66f4\u65b0\u5904\u7406\u72b6\u6001：Agent \u6bcf\u5b8c\u6210\u4e00\u6b65\u8c03\u7528\u6b64\u65b9\u6cd5 *\/
\n updateProgress(currentStep: number, totalSteps: number, toolCall: string): void {
\n this.currentStep = currentStep;
\n this.totalSteps = totalSteps;
\n this.lastToolCall = toolCall;
\n this.status = AgentStatus.PROCESSING;<\/p>\n
\/\/ \u72b6\u6001\u53d8\u5316\u65f6\u7acb\u5373\u53d1\u9001\u4e00\u6b21\u5fc3\u8df3（\u4e0d\u7b49\u5b9a\u65f6\u5668）
\n \/\/ \u7528\u6237\u5728\u7b49\u5f85\u7ed3\u679c，\u72b6\u6001\u53d8\u5316\u5e94\u8be5\u7b2c\u4e00\u65f6\u95f4\u544a\u77e5\u670d\u52a1\u7aef
\n this.sendHeartbeat();
\n }<\/p>\n
\/** \u6807\u8bb0\u9519\u8bef\u72b6\u6001 *\/
\n markError(): void {
\n this.status = AgentStatus.ERROR;
\n this.sendHeartbeat();
\n }<\/p>\n
\/** \u6807\u8bb0\u7a7a\u95f2\u72b6\u6001 *\/
\n markIdle(): void {
\n this.status = AgentStatus.IDLE;
\n this.currentStep = 0;
\n this.totalSteps = 0;
\n this.lastToolCall = null;
\n this.sendHeartbeat();
\n }<\/p>\n
\/** \u53d1\u9001\u5fc3\u8df3：\u7ec4\u88c5 payload \u5e76\u8c03\u7528 sender *\/
\n private async sendHeartbeat(): void {
\n const payload: HeartbeatPayload = {
\n agent_id: this.agentId,
\n session_id: this.sessionId,
\n status: this.status,
\n current_step: this.currentStep,
\n total_steps: this.totalSteps,
\n cpu_percent: this.getCpuUsage(),
\n memory_mb: this.getMemoryUsage(),
\n last_tool_call: this.lastToolCall,
\n timestamp: Date.now(),
\n };<\/p>\n
try {
\n await this.sender(payload);
\n this.emit('heartbeat:sent', payload);
\n } catch (err) {
\n \/\/ \u5fc3\u8df3\u53d1\u9001\u5931\u8d25：\u4e0d\u4e2d\u65ad Agent \u5904\u7406\u6d41\u7a0b
\n \/\/ \u5fc3\u8df3\u662f\u8f85\u52a9\u529f\u80fd，\u6838\u5fc3\u4e1a\u52a1\u4e0d\u80fd\u56e0\u4e3a\u5fc3\u8df3\u901a\u9053\u6545\u969c\u800c\u505c\u6b62
\n this.emit('heartbeat:failed', { error: err, payload });
\n }
\n }<\/p>\n
\/** \u83b7\u53d6 CPU \u4f7f\u7528\u7387：\u7b80\u5316\u5b9e\u73b0，\u751f\u4ea7\u73af\u5883\u7528 process.cpuUsage() *\/
\n private getCpuUsage(): number {
\n \/\/ Node.js \u7684 process.cpuUsage() \u8fd4\u56de\u5fae\u79d2\u7ea7\u7684 CPU \u65f6\u95f4
\n const usage = process.cpuUsage();
\n const totalUsec = usage.user + usage.system;
\n \/\/ \u8f6c\u6362\u4e3a\u767e\u5206\u6bd4（\u8fd1\u4f3c\u503c，\u9700\u8981\u91c7\u6837\u95f4\u9694\u624d\u80fd\u7cbe\u786e\u8ba1\u7b97）
\n return Math.min(totalUsec \/ 1000 \/ this.intervalMs, 100);
\n }<\/p>\n
\/** \u83b7\u53d6\u5185\u5b58\u4f7f\u7528\u91cf *\/
\n private getMemoryUsage(): number {
\n return process.memoryUsage().heapUsed \/ 1024 \/ 1024; \/\/ MB
\n }
\n}<\/p>\n
3.2 \u670d\u52a1\u7aef\u5065\u5eb7\u68c0\u67e5\u76d1\u63a7\u5668<\/h4>\n
\/\/ health-monitor.ts \u2014\u2014 \u670d\u52a1\u7aef Agent \u5065\u5eb7\u68c0\u67e5\u76d1\u63a7\u5668
\n\/\/ \u76d1\u63a7\u6240\u6709 Agent \u5b9e\u4f8b\u7684\u5fc3\u8df3，\u5224\u65ad\u5065\u5eb7\u72b6\u6001，\u89e6\u53d1\u544a\u8b66\u548c\u4f1a\u8bdd\u6062\u590d<\/p>\n
export enum HealthStatus {
\n HEALTHY = 'healthy',
\n DEGRADED = 'degraded',
\n UNHEALTHY = 'unhealthy',
\n DEAD = 'dead',
\n}<\/p>\n
interface AgentHealthRecord {
\n agentId: string;
\n sessionId: string;
\n lastHeartbeat: HeartbeatPayload;
\n lastHeartbeatTime: number;
\n missedHeartbeats: number;
\n healthStatus: HealthStatus;
\n \/\/ \u505c\u6ede\u68c0\u6d4b：current_step \u8fde\u7eed N \u6b21\u5fc3\u8df3\u672a\u53d8\u5316
\n stagnantCount: number;
\n}<\/p>\n
export class AgentHealthMonitor extends EventEmitter {
\n private agents: Map<string, AgentHealthRecord> = new Map();
\n private intervalMs: number;
\n private maxMissed: number;
\n private stagnantThreshold: number; \/\/ \u5fc3\u8df3\u505c\u6ede\u9608\u503c：step \u4e0d\u53d8\u7684\u6b21\u6570
\n private checkTimer: NodeJS.Timeout | null = null;<\/p>\n
constructor(
\n intervalMs: number = 10000, \/\/ \u6bcf 10 \u79d2\u68c0\u67e5\u4e00\u6b21\u6240\u6709 Agent
\n maxMissed: number = 3,
\n stagnantThreshold: number = 5 \/\/ 5 \u6b21\u5fc3\u8df3 step \u4e0d\u53d8\u5224\u5b9a\u4e3a\u505c\u6ede
\n ) {
\n super();
\n this.intervalMs = intervalMs;
\n this.maxMissed = maxMissed;
\n this.stagnantThreshold = stagnantThreshold;
\n }<\/p>\n
\/** \u63a5\u6536 Agent \u5fc3\u8df3：\u66f4\u65b0\u5065\u5eb7\u8bb0\u5f55 *\/
\n receiveHeartbeat(payload: HeartbeatPayload): void {
\n const existing = this.agents.get(payload.agent_id);<\/p>\n
if (existing) {
\n \/\/ \u68c0\u67e5 current_step \u662f\u5426\u53d8\u5316：\u505c\u6ede\u68c0\u6d4b
\n if (payload.current_step === existing.lastHeartbeat.current_step
\n && payload.status === AgentStatus.PROCESSING) {
\n existing.stagnantCount++;
\n } else {
\n existing.stagnantCount = 0;
\n }<\/p>\n
\/\/ \u66f4\u65b0\u8bb0\u5f55
\n existing.lastHeartbeat = payload;
\n existing.lastHeartbeatTime = payload.timestamp;
\n existing.missedHeartbeats = 0;<\/p>\n
\/\/ \u91cd\u65b0\u8bc4\u4f30\u5065\u5eb7\u72b6\u6001
\n this.evaluateHealth(existing);
\n } else {
\n \/\/ \u65b0 Agent \u4e0a\u7ebf：\u521d\u59cb\u5316\u5065\u5eb7\u8bb0\u5f55
\n this.agents.set(payload.agent_id, {
\n agentId: payload.agent_id,
\n sessionId: payload.session_id,
\n lastHeartbeat: payload,
\n lastHeartbeatTime: payload.timestamp,
\n missedHeartbeats: 0,
\n healthStatus: HealthStatus.HEALTHY,
\n stagnantCount: 0,
\n });
\n this.emit('agent:registered', { agentId: payload.agent_id });
\n }
\n }<\/p>\n
\/** \u542f\u52a8\u5065\u5eb7\u68c0\u67e5\u5faa\u73af *\/
\n start(): void {
\n this.checkTimer = setInterval(() => {
\n this.checkAllAgents();
\n }, this.intervalMs);
\n }<\/p>\n
\/** \u68c0\u67e5\u6240\u6709 Agent \u7684\u5065\u5eb7\u72b6\u6001 *\/
\n private checkAllAgents(): void {
\n const now = Date.now();
\n const expectedInterval = 5000; \/\/ Agent \u5fc3\u8df3\u95f4\u9694<\/p>\n
for (const [agentId, record] of this.agents) {
\n const elapsed = now – record.lastHeartbeatTime;<\/p>\n
\/\/ \u5fc3\u8df3\u7f3a\u5931\u68c0\u6d4b：\u8d85\u8fc7\u9884\u671f\u95f4\u9694\u5219\u8ba1\u6570 +1
\n if (elapsed > expectedInterval * 2) {
\n record.missedHeartbeats++;
\n }<\/p>\n
\/\/ \u505c\u6ede\u68c0\u6d4b：step \u4e0d\u53d8\u7684\u6b21\u6570\u8d85\u8fc7\u9608\u503c
\n if (record.stagnantCount >= this.stagnantThreshold) {
\n \/\/ \u5de5\u5177\u8c03\u7528\u5361\u4f4f：Agent \u8fd8\u6d3b\u7740\u4f46\u5904\u7406\u505c\u6ede
\n this.emit('agent:stagnant', {
\n agentId,
\n sessionId: record.sessionId,
\n currentStep: record.lastHeartbeat.current_step,
\n lastToolCall: record.lastHeartbeat.last_tool_call,
\n });
\n }<\/p>\n
\/\/ \u91cd\u65b0\u8bc4\u4f30\u5065\u5eb7\u72b6\u6001
\n this.evaluateHealth(record);<\/p>\n
\/\/ \u4e0d\u5065\u5eb7\u6216\u6b7b\u4ea1：\u89e6\u53d1\u544a\u8b66
\n if (record.healthStatus === HealthStatus.UNHEALTHY) {
\n this.emit('agent:unhealthy', {
\n agentId,
\n sessionId: record.sessionId,
\n missedHeartbeats: record.missedHeartbeats,
\n });
\n }<\/p>\n
if (record.healthStatus === HealthStatus.DEAD) {
\n this.emit('agent:dead', {
\n agentId,
\n sessionId: record.sessionId,
\n });<\/p>\n
\/\/ \u6b7b\u4ea1 Agent \u4ece\u76d1\u63a7\u5217\u8868\u79fb\u9664：\u4e0d\u518d\u7b49\u5f85\u5fc3\u8df3
\n \/\/ \u4f46\u4f1a\u8bdd\u72b6\u6001\u4fdd\u7559，\u7528\u4e8e\u540e\u7eed\u6062\u590d
\n this.agents.delete(agentId);
\n }
\n }
\n }<\/p>\n
\/** \u8bc4\u4f30\u5355\u4e2a Agent \u7684\u5065\u5eb7\u72b6\u6001 *\/
\n private evaluateHealth(record: AgentHealthRecord): void {
\n const previousStatus = record.healthStatus;<\/p>\n
if (record.missedHeartbeats >= this.maxMissed * 2) {
\n \/\/ \u8fde\u7eed\u7f3a\u5931\u8d85\u8fc7 2 \u500d\u9608\u503c：\u5224\u5b9a\u6b7b\u4ea1
\n record.healthStatus = HealthStatus.DEAD;
\n } else if (record.missedHeartbeats >= this.maxMissed) {
\n \/\/ \u8fde\u7eed\u7f3a\u5931\u8d85\u8fc7\u9608\u503c：\u5224\u5b9a\u4e0d\u5065\u5eb7
\n record.healthStatus = HealthStatus.UNHEALTHY;
\n } else if (record.missedHeartbeats > 0 || record.stagnantCount >= this.stagnantThreshold) {
\n \/\/ \u6709\u7f3a\u5931\u4f46\u672a\u8d85\u9608\u503c，\u6216\u5904\u7406\u505c\u6ede：\u4e9a\u5065\u5eb7
\n record.healthStatus = HealthStatus.DEGRADED;
\n } else {
\n \/\/ \u6b63\u5e38\u5fc3\u8df3\u4e14\u5904\u7406\u63a8\u8fdb\u4e2d：\u5065\u5eb7
\n record.healthStatus = HealthStatus.HEALTHY;
\n }<\/p>\n
\/\/ \u72b6\u6001\u53d8\u5316\u65f6\u53d1\u51fa\u4e8b\u4ef6：\u5916\u90e8\u7cfb\u7edf\u53ef\u4ee5\u8ba2\u9605\u505a\u81ea\u52a8\u6062\u590d
\n if (previousStatus !== record.healthStatus) {
\n this.emit('health:changed', {
\n agentId: record.agentId,
\n from: previousStatus,
\n to: record.healthStatus,
\n });
\n }
\n }
\n}<\/p>\n
3.3 \u4f1a\u8bdd\u6062\u590d\u4e0e\u65ad\u70b9\u7eed\u4f20<\/h4>\n
# session_recovery.py \u2014\u2014 Agent \u5d29\u6e83\u540e\u7684\u4f1a\u8bdd\u6062\u590d\u4e0e\u65ad\u70b9\u7eed\u4f20
\nimport json
\nimport logging
\nimport time
\nfrom datetime import datetime<\/p>\n
logger = logging.getLogger('session-recovery')<\/p>\n
class SessionRecoveryManager:
\n """\u4f1a\u8bdd\u6062\u590d\u7ba1\u7406\u5668：Agent \u5d29\u6e83\u540e\u4ece\u65ad\u70b9\u7ee7\u7eed\u5904\u7406"""<\/p>\n
def __init__(self, storage_client, heartbeat_monitor):
\n self.storage = storage_client
\n self.monitor = heartbeat_monitor<\/p>\n
def save_checkpoint(self, session_id: str, step_index: int, step_results: dict):
\n """\u4fdd\u5b58\u68c0\u67e5\u70b9：\u6bcf\u5b8c\u6210\u4e00\u6b65\u5c31\u4fdd\u5b58，\u5d29\u6e83\u540e\u4ece\u68c0\u67e5\u70b9\u6062\u590d"""
\n checkpoint = {
\n 'session_id': session_id,
\n 'step_index': step_index,
\n 'step_results': step_results,
\n 'timestamp': datetime.utcnow().isoformat(),
\n }
\n # \u68c0\u67e5\u70b9\u5b58\u5230\u5bf9\u8c61\u5b58\u50a8：\u6bd4\u6570\u636e\u5e93\u66f4\u5feb，\u4e14\u4e0d\u5f71\u54cd\u4e1a\u52a1\u8868
\n key = f"checkpoints\/{session_id}\/step_{step_index}.json"
\n self.storage.put(key, json.dumps(checkpoint))<\/p>\n
def recover_session(self, session_id: str) -> dict:
\n """\u4ece\u6700\u65b0\u68c0\u67e5\u70b9\u6062\u590d\u4f1a\u8bdd"""
\n # \u67e5\u627e\u8be5\u4f1a\u8bdd\u7684\u6240\u6709\u68c0\u67e5\u70b9，\u53d6\u6700\u65b0\u7684
\n pattern = f"checkpoints\/{session_id}\/step_*.json"
\n checkpoints = self.storage.list(pattern)<\/p>\n
if not checkpoints:
\n logger.warning(f"No checkpoints found for session {session_id}")
\n return {'step_index': 0, 'step_results': {}}<\/p>\n
# \u53d6\u6700\u65b0\u7684\u68c0\u67e5\u70b9（step_index \u6700\u5927\u7684）
\n latest = max(checkpoints, key=lambda k: int(k.split('step_')[1].split('.')[0]))
\n checkpoint_data = self.storage.get(latest)<\/p>\n
checkpoint = json.loads(checkpoint_data)
\n logger.info(
\n f"Recovered session {session_id} from step {checkpoint['step_index']}"
\n )
\n return checkpoint<\/p>\n
def handle_dead_agent(self, agent_id: str, session_id: str):
\n """\u5904\u7406\u6b7b\u4ea1 Agent：\u6062\u590d\u4f1a\u8bdd\u5e76\u5206\u914d\u65b0 Agent"""
\n # 1. \u4ece\u68c0\u67e5\u70b9\u6062\u590d\u4f1a\u8bdd\u72b6\u6001
\n checkpoint = self.recover_session(session_id)<\/p>\n
# 2. \u521b\u5efa\u65b0 Agent \u5b9e\u4f8b，\u4f20\u5165\u6062\u590d\u7684\u68c0\u67e5\u70b9
\n # \u65b0 Agent \u4ece\u65ad\u70b9\u7ee7\u7eed，\u4e0d\u4ece\u7b2c 0 \u6b65\u91cd\u65b0\u5f00\u59cb
\n new_agent = self.create_agent_with_checkpoint(
\n session_id, checkpoint
\n )<\/p>\n
# 3. \u901a\u77e5\u7528\u6237：\u4f1a\u8bdd\u6062\u590d，\u4ece\u7b2c N \u6b65\u7ee7\u7eed
\n logger.info(
\n f"Session {session_id} recovered: "
\n f"new agent {new_agent.agent_id}, "
\n f"resuming from step {checkpoint['step_index']}"
\n )<\/p>\n
# 4. \u6e05\u7406\u65e7 Agent \u7684\u6b8b\u7559\u8d44\u6e90（\u5185\u5b58\u4e2d\u7684\u4f1a\u8bdd\u6570\u636e\u7b49）
\n self.cleanup_agent_resources(agent_id)<\/p>\n
return new_agent<\/p>\n
def create_agent_with_checkpoint(self, session_id: str, checkpoint: dict):
\n """\u521b\u5efa\u65b0 Agent \u5e76\u6ce8\u5165\u68c0\u67e5\u70b9\u6570\u636e"""
\n # \u65b0 Agent \u542f\u52a8\u65f6\u63a5\u6536\u68c0\u67e5\u70b9，
\n # \u4ece checkpoint['step_index'] + 1 \u5f00\u59cb\u6267\u884c
\n # \u524d\u9762\u6b65\u9aa4\u7684\u7ed3\u679c\u4ece checkpoint['step_results'] \u4e2d\u8bfb\u53d6
\n agent_config = {
\n 'session_id': session_id,
\n 'resume_from_step': checkpoint['step_index'] + 1,
\n 'previous_results': checkpoint['step_results'],
\n }
\n # \u8c03\u7528 Agent \u542f\u52a8\u63a5\u53e3
\n return self.start_new_agent(agent_config)<\/p>\n
def cleanup_agent_resources(self, agent_id: str):
\n """\u6e05\u7406\u6b7b\u4ea1 Agent \u7684\u6b8b\u7559\u8d44\u6e90"""
\n # \u91ca\u653e\u5185\u5b58\u4e2d\u7684\u4f1a\u8bdd\u7f13\u5b58\u3001\u5173\u95ed\u672a\u5b8c\u6210\u7684\u5de5\u5177\u8c03\u7528\u8fde\u63a5\u7b49
\n logger.info(f"Cleaning up resources for dead agent {agent_id}")<\/p>\n
\u56db\u3001\u8fb9\u754c\u5206\u6790\u4e0e\u67b6\u6784\u6743\u8861<\/h3>\n4.1 \u5fc3\u8df3\u95f4\u9694\u7684\u6743\u8861<\/h4>\n
\u5fc3\u8df3\u95f4\u9694\u592a\u77ed（1 \u79d2）：\u7f51\u7edc\u5f00\u9500\u5927，\u670d\u52a1\u7aef\u5904\u7406\u538b\u529b\u5927\u3002\u5fc3\u8df3\u95f4\u9694\u592a\u957f（30 \u79d2）：Agent \u6302\u4e86 30 \u79d2\u4f60\u624d\u77e5\u9053，\u7528\u6237\u5df2\u7ecf\u7b49\u4e86 30 \u79d2\u624d\u53d1\u73b0\u7cfb\u7edf\u6ca1\u54cd\u5e94\u3002<\/p>\n
\u6298\u4e2d：\u57fa\u7840\u5fc3\u8df3 5 \u79d2（\u8986\u76d6\u5927\u90e8\u5206\u573a\u666f），\u72b6\u6001\u53d8\u5316\u65f6\u7acb\u5373\u53d1\u9001\u4e00\u6b21\u5373\u65f6\u5fc3\u8df3\u3002\u8fd9\u6837\u6b63\u5e38\u60c5\u51b5\u4e0b\u6bcf 5 \u79d2\u4e00\u6b21\u5fc3\u8df3，\u72b6\u6001\u53d8\u5316\u65f6\u79d2\u7ea7\u611f\u77e5\u3002<\/p>\n
4.2 \u68c0\u67e5\u70b9\u7684\u5b58\u50a8\u9891\u7387<\/h4>\n
\u6bcf\u5b8c\u6210\u4e00\u6b65\u5c31\u4fdd\u5b58\u68c0\u67e5\u70b9，\u610f\u5473\u7740\u6bcf\u6b65\u90fd\u6709\u4e00\u6b21\u5b58\u50a8\u5199\u5165\u3002\u5982\u679c\u6b65\u9aa4\u6267\u884c\u5f88\u5feb（\u6bcf\u6b65 1 \u79d2），\u5199\u5165\u9891\u7387\u5c31\u662f\u6bcf\u79d2\u4e00\u6b21\u3002\u5bf9\u8c61\u5b58\u50a8\u7684\u5199\u5165\u5ef6\u8fdf\u7ea6 50-100ms，\u4e0d\u5f71\u54cd\u6b65\u9aa4\u6267\u884c\u3002<\/p>\n
\u4f46\u5982\u679c\u6b65\u9aa4\u6267\u884c\u5f88\u6162（\u6bcf\u6b65 10 \u79d2），\u4fdd\u5b58\u9891\u7387\u662f\u6bcf 10 \u79d2\u4e00\u6b21，\u5d29\u6e83\u540e\u6700\u591a\u4e22\u5931 10 \u79d2\u7684\u5de5\u4f5c\u91cf\u3002<\/p>\n
4.3 \u9002\u7528\u8fb9\u754c\u4e0e\u7981\u7528\u573a\u666f<\/h4>\n\n- \u9002\u7528：WebSocket\/SSE \u957f\u8fde\u63a5\u7684 Agent \u7cfb\u7edf\u3001\u591a\u6b65\u9aa4\u5de5\u5177\u8c03\u7528\u94fe\u8def\u3001\u9700\u8981\u4f1a\u8bdd\u6062\u590d\u7684\u4ed8\u8d39\u573a\u666f<\/li>\n
- \u7981\u7528：\u5355\u6b21\u8bf7\u6c42-\u54cd\u5e94\u7684\u7b80\u5355 Agent（\u4e0d\u9700\u8981\u5fc3\u8df3）\u3001\u77ed\u8fde\u63a5 HTTP API（\u4e0d\u9700\u8981\u957f\u8fde\u63a5\u76d1\u63a7）\u3001\u79bb\u7ebf\u6279\u5904\u7406 Agent（\u4e0d\u9700\u8981\u5b9e\u65f6\u72b6\u6001）<\/li>\n<\/ul>\n
4.4 \u5fc3\u8df3\u901a\u9053\u4e0e\u4e1a\u52a1\u901a\u9053\u7684\u9694\u79bb<\/h4>\n
\u5fc3\u8df3\u6d88\u606f\u548c\u4e1a\u52a1\u6d88\u606f\u8d70\u540c\u4e00\u4e2a WebSocket \u8fde\u63a5\u65f6，\u5982\u679c\u4e1a\u52a1\u6d88\u606f\u963b\u585e（\u6bd4\u5982\u5927\u7ed3\u679c\u4f20\u8f93），\u5fc3\u8df3\u4e5f\u4f1a\u5ef6\u8fdf\u3002\u89e3\u51b3\u65b9\u6848：\u5fc3\u8df3\u8d70\u72ec\u7acb\u8fde\u63a5\u6216\u72ec\u7acb\u7684\u6d88\u606f\u7c7b\u578b（WebSocket \u7684 ping \u5e27\u4e0e\u6570\u636e\u5e27\u662f\u72ec\u7acb\u7684）\u3002<\/p>\n
\u4e94\u3001\u603b\u7ed3<\/h3>\n
Agent \u957f\u8fde\u63a5\u573a\u666f\u7684\u5065\u5eb7\u68c0\u67e5\u9700\u8981\u4e09\u5c42\u5fc3\u8df3：\u8fde\u63a5\u5c42\u68c0\u6d4b\u7f51\u7edc\u53ef\u8fbe\u3001\u8fdb\u7a0b\u5c42\u68c0\u6d4b Agent \u5b58\u6d3b\u4e0e\u8d44\u6e90\u72b6\u6001\u3001\u4e1a\u52a1\u5c42\u68c0\u6d4b\u5904\u7406\u8fdb\u5ea6\u662f\u5426\u63a8\u8fdb\u3002\u5355\u9760\u8fde\u63a5\u5c42\u5fc3\u8df3\u65e0\u6cd5\u533a\u5206"\u5728\u601d\u8003"\u548c"\u5df2\u6302\u6389"\u3002\u6838\u5fc3\u8bbe\u8ba1：5 \u79d2\u57fa\u7840\u5fc3\u8df3 + \u72b6\u6001\u53d8\u5316\u5373\u65f6\u5fc3\u8df3\u3001\u505c\u6ede\u68c0\u6d4b（step \u4e0d\u53d8\u7684\u6b21\u6570\u8d85\u9608\u503c\u5224\u5b9a\u5361\u4f4f）\u3001\u7f3a\u5931\u68c0\u6d4b（\u8fde\u7eed N \u6b21\u5fc3\u8df3\u7f3a\u5931\u5224\u5b9a\u6b7b\u4ea1）\u3002\u68c0\u67e5\u70b9\u673a\u5236\u4fdd\u8bc1\u5d29\u6e83\u540e\u65ad\u70b9\u7eed\u4f20：\u6bcf\u5b8c\u6210\u4e00\u6b65\u4fdd\u5b58\u7ed3\u679c，\u6062\u590d\u65f6\u4ece\u6700\u65b0\u68c0\u67e5\u70b9\u7ee7\u7eed，\u4e0d\u4ece\u5934\u91cd\u8dd1\u3002\u5fc3\u8df3\u901a\u9053\u4e0e\u4e1a\u52a1\u901a\u9053\u9694\u79bb，\u907f\u514d\u4e1a\u52a1\u963b\u585e\u5f71\u54cd\u5fc3\u8df3\u5ef6\u8fdf\u3002<\/p>\n","protected":false},"excerpt":{"rendered":"
Agent \u5fc3\u8df3\u4e0e\u5065\u5eb7\u68c0\u67e5：\u957f\u8fde\u63a5\u573a\u666f\u4e0b\u7684\u4f1a\u8bdd\u72b6\u6001\u76d1\u63a7Agent \u8fde\u7740\u8fde\u7740\u5c31\u6ca1\u4e86\u53cd\u5e94\u2014\u2014\u4f60\u4e0d\u77e5\u9053\u5b83\u662f\u771f\u7684\u5728\u601d\u8003，\u8fd8\u662f\u5df2\u7ecf\u6084\u6084\u6302\u4e86\u3002\u4e00\u3001\u573a\u666f\u75db\u70b9
\n\u4f60\u7684 Agent \u7cfb\u7edf\u7528 WebSocket \u7ef4\u6301\u957f\u8fde\u63a5，\u7528\u6237\u53d1\u4e00\u6761\u6d88\u606f\u540e Agent \u9700\u8981\u8c03\u7528\u591a\u4e2a\u5de5\u5177，\u8017\u65f6\u53ef\u80fd 10-60 \u79d2\u3002\u95ee\u9898\u6765\u4e86：\u8fd9 60 \u79d2\u91cc，\u7528\u6237\u4e0d\u77e5\u9053 Agent \u662f\u5728\u5904\u7406\u8fd8\u662f\u5df2\u7ecf\u6302\u4e86\u3002\u5982\u679c Agent \u8fdb\u7a0b\u5d29\u6e83，Web<\/p>\n","protected":false},"author":2,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[1],"tags":[9680,120,763],"topic":[],"class_list":["post-86087","post","type-post","status-publish","format-standard","hentry","category-server","tag-k8","tag-kubernetes","tag-763"],"yoast_head":"\n
Agent \u5fc3\u8df3\u4e0e\u5065\u5eb7\u68c0\u67e5\uff1a\u957f\u8fde\u63a5\u573a\u666f\u4e0b\u7684\u4f1a\u8bdd\u72b6\u6001\u76d1\u63a7 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3<\/title>\n<meta name=\"robots\" content=\"index, follow, max-snippet:-1, max-image-preview:large, max-video-preview:-1\" \/>\n<link rel=\"canonical\" href=\"https:\/\/www.wsisp.com\/helps\/86087.html\" \/>\n<meta property=\"og:locale\" content=\"zh_CN\" \/>\n<meta property=\"og:type\" content=\"article\" \/>\n<meta property=\"og:title\" content=\"Agent \u5fc3\u8df3\u4e0e\u5065\u5eb7\u68c0\u67e5\uff1a\u957f\u8fde\u63a5\u573a\u666f\u4e0b\u7684\u4f1a\u8bdd\u72b6\u6001\u76d1\u63a7 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"og:description\" content=\"Agent \u5fc3\u8df3\u4e0e\u5065\u5eb7\u68c0\u67e5：\u957f\u8fde\u63a5\u573a\u666f\u4e0b\u7684\u4f1a\u8bdd\u72b6\u6001\u76d1\u63a7Agent \u8fde\u7740\u8fde\u7740\u5c31\u6ca1\u4e86\u53cd\u5e94\u2014\u2014\u4f60\u4e0d\u77e5\u9053\u5b83\u662f\u771f\u7684\u5728\u601d\u8003，\u8fd8\u662f\u5df2\u7ecf\u6084\u6084\u6302\u4e86\u3002\u4e00\u3001\u573a\u666f\u75db\u70b9 \u4f60\u7684 Agent \u7cfb\u7edf\u7528 WebSocket \u7ef4\u6301\u957f\u8fde\u63a5，\u7528\u6237\u53d1\u4e00\u6761\u6d88\u606f\u540e Agent \u9700\u8981\u8c03\u7528\u591a\u4e2a\u5de5\u5177，\u8017\u65f6\u53ef\u80fd 10-60 \u79d2\u3002\u95ee\u9898\u6765\u4e86：\u8fd9 60 \u79d2\u91cc，\u7528\u6237\u4e0d\u77e5\u9053 Agent \u662f\u5728\u5904\u7406\u8fd8\u662f\u5df2\u7ecf\u6302\u4e86\u3002\u5982\u679c Agent \u8fdb\u7a0b\u5d29\u6e83，Web\" \/>\n<meta property=\"og:url\" content=\"https:\/\/www.wsisp.com\/helps\/86087.html\" \/>\n<meta property=\"og:site_name\" content=\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\" \/>\n<meta property=\"article:published_time\" content=\"2026-07-27T20:40:54+00:00\" \/>\n<meta name=\"author\" content=\"admin\" \/>\n<meta name=\"twitter:card\" content=\"summary_large_image\" \/>\n<meta name=\"twitter:label1\" content=\"\u4f5c\u8005\" \/>\n\t<meta name=\"twitter:data1\" content=\"admin\" \/>\n\t<meta name=\"twitter:label2\" content=\"\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4\" \/>\n\t<meta name=\"twitter:data2\" content=\"6 \u5206\" \/>\n<script type=\"application\/ld+json\" class=\"yoast-schema-graph\">{\"@context\":\"https:\/\/schema.org\",\"@graph\":[{\"@type\":\"WebPage\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/86087.html\",\"url\":\"https:\/\/www.wsisp.com\/helps\/86087.html\",\"name\":\"Agent \u5fc3\u8df3\u4e0e\u5065\u5eb7\u68c0\u67e5\uff1a\u957f\u8fde\u63a5\u573a\u666f\u4e0b\u7684\u4f1a\u8bdd\u72b6\u6001\u76d1\u63a7 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"isPartOf\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\"},\"datePublished\":\"2026-07-27T20:40:54+00:00\",\"dateModified\":\"2026-07-27T20:40:54+00:00\",\"author\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\"},\"breadcrumb\":{\"@id\":\"https:\/\/www.wsisp.com\/helps\/86087.html#breadcrumb\"},\"inLanguage\":\"zh-Hans\",\"potentialAction\":[{\"@type\":\"ReadAction\",\"target\":[\"https:\/\/www.wsisp.com\/helps\/86087.html\"]}]},{\"@type\":\"BreadcrumbList\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/86087.html#breadcrumb\",\"itemListElement\":[{\"@type\":\"ListItem\",\"position\":1,\"name\":\"\u9996\u9875\",\"item\":\"https:\/\/www.wsisp.com\/helps\"},{\"@type\":\"ListItem\",\"position\":2,\"name\":\"Agent \u5fc3\u8df3\u4e0e\u5065\u5eb7\u68c0\u67e5\uff1a\u957f\u8fde\u63a5\u573a\u666f\u4e0b\u7684\u4f1a\u8bdd\u72b6\u6001\u76d1\u63a7\"}]},{\"@type\":\"WebSite\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#website\",\"url\":\"https:\/\/www.wsisp.com\/helps\/\",\"name\":\"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3\",\"description\":\"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b\",\"potentialAction\":[{\"@type\":\"SearchAction\",\"target\":{\"@type\":\"EntryPoint\",\"urlTemplate\":\"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}\"},\"query-input\":\"required name=search_term_string\"}],\"inLanguage\":\"zh-Hans\"},{\"@type\":\"Person\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41\",\"name\":\"admin\",\"image\":{\"@type\":\"ImageObject\",\"inLanguage\":\"zh-Hans\",\"@id\":\"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/\",\"url\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"contentUrl\":\"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery\",\"caption\":\"admin\"},\"sameAs\":[\"http:\/\/wp.wsisp.com\"],\"url\":\"https:\/\/www.wsisp.com\/helps\/author\/admin\"}]}<\/script>\n<!-- \/ Yoast SEO plugin. -->","yoast_head_json":{"title":"Agent \u5fc3\u8df3\u4e0e\u5065\u5eb7\u68c0\u67e5\uff1a\u957f\u8fde\u63a5\u573a\u666f\u4e0b\u7684\u4f1a\u8bdd\u72b6\u6001\u76d1\u63a7 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","robots":{"index":"index","follow":"follow","max-snippet":"max-snippet:-1","max-image-preview":"max-image-preview:large","max-video-preview":"max-video-preview:-1"},"canonical":"https:\/\/www.wsisp.com\/helps\/86087.html","og_locale":"zh_CN","og_type":"article","og_title":"Agent \u5fc3\u8df3\u4e0e\u5065\u5eb7\u68c0\u67e5\uff1a\u957f\u8fde\u63a5\u573a\u666f\u4e0b\u7684\u4f1a\u8bdd\u72b6\u6001\u76d1\u63a7 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","og_description":"Agent \u5fc3\u8df3\u4e0e\u5065\u5eb7\u68c0\u67e5：\u957f\u8fde\u63a5\u573a\u666f\u4e0b\u7684\u4f1a\u8bdd\u72b6\u6001\u76d1\u63a7Agent \u8fde\u7740\u8fde\u7740\u5c31\u6ca1\u4e86\u53cd\u5e94\u2014\u2014\u4f60\u4e0d\u77e5\u9053\u5b83\u662f\u771f\u7684\u5728\u601d\u8003，\u8fd8\u662f\u5df2\u7ecf\u6084\u6084\u6302\u4e86\u3002\u4e00\u3001\u573a\u666f\u75db\u70b9 \u4f60\u7684 Agent \u7cfb\u7edf\u7528 WebSocket \u7ef4\u6301\u957f\u8fde\u63a5，\u7528\u6237\u53d1\u4e00\u6761\u6d88\u606f\u540e Agent \u9700\u8981\u8c03\u7528\u591a\u4e2a\u5de5\u5177，\u8017\u65f6\u53ef\u80fd 10-60 \u79d2\u3002\u95ee\u9898\u6765\u4e86：\u8fd9 60 \u79d2\u91cc，\u7528\u6237\u4e0d\u77e5\u9053 Agent \u662f\u5728\u5904\u7406\u8fd8\u662f\u5df2\u7ecf\u6302\u4e86\u3002\u5982\u679c Agent \u8fdb\u7a0b\u5d29\u6e83，Web","og_url":"https:\/\/www.wsisp.com\/helps\/86087.html","og_site_name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","article_published_time":"2026-07-27T20:40:54+00:00","author":"admin","twitter_card":"summary_large_image","twitter_misc":{"\u4f5c\u8005":"admin","\u9884\u8ba1\u9605\u8bfb\u65f6\u95f4":"6 \u5206"},"schema":{"@context":"https:\/\/schema.org","@graph":[{"@type":"WebPage","@id":"https:\/\/www.wsisp.com\/helps\/86087.html","url":"https:\/\/www.wsisp.com\/helps\/86087.html","name":"Agent \u5fc3\u8df3\u4e0e\u5065\u5eb7\u68c0\u67e5\uff1a\u957f\u8fde\u63a5\u573a\u666f\u4e0b\u7684\u4f1a\u8bdd\u72b6\u6001\u76d1\u63a7 - \u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","isPartOf":{"@id":"https:\/\/www.wsisp.com\/helps\/#website"},"datePublished":"2026-07-27T20:40:54+00:00","dateModified":"2026-07-27T20:40:54+00:00","author":{"@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41"},"breadcrumb":{"@id":"https:\/\/www.wsisp.com\/helps\/86087.html#breadcrumb"},"inLanguage":"zh-Hans","potentialAction":[{"@type":"ReadAction","target":["https:\/\/www.wsisp.com\/helps\/86087.html"]}]},{"@type":"BreadcrumbList","@id":"https:\/\/www.wsisp.com\/helps\/86087.html#breadcrumb","itemListElement":[{"@type":"ListItem","position":1,"name":"\u9996\u9875","item":"https:\/\/www.wsisp.com\/helps"},{"@type":"ListItem","position":2,"name":"Agent \u5fc3\u8df3\u4e0e\u5065\u5eb7\u68c0\u67e5\uff1a\u957f\u8fde\u63a5\u573a\u666f\u4e0b\u7684\u4f1a\u8bdd\u72b6\u6001\u76d1\u63a7"}]},{"@type":"WebSite","@id":"https:\/\/www.wsisp.com\/helps\/#website","url":"https:\/\/www.wsisp.com\/helps\/","name":"\u7f51\u7855\u4e92\u8054\u5e2e\u52a9\u4e2d\u5fc3","description":"\u9999\u6e2f\u670d\u52a1\u5668_\u9999\u6e2f\u4e91\u670d\u52a1\u5668\u8d44\u8baf_\u670d\u52a1\u5668\u5e2e\u52a9\u6587\u6863_\u670d\u52a1\u5668\u6559\u7a0b","potentialAction":[{"@type":"SearchAction","target":{"@type":"EntryPoint","urlTemplate":"https:\/\/www.wsisp.com\/helps\/?s={search_term_string}"},"query-input":"required name=search_term_string"}],"inLanguage":"zh-Hans"},{"@type":"Person","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/358e386c577a3ab51c4493330a20ad41","name":"admin","image":{"@type":"ImageObject","inLanguage":"zh-Hans","@id":"https:\/\/www.wsisp.com\/helps\/#\/schema\/person\/image\/","url":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","contentUrl":"https:\/\/gravatar.wp-china-yes.net\/avatar\/?s=96&d=mystery","caption":"admin"},"sameAs":["http:\/\/wp.wsisp.com"],"url":"https:\/\/www.wsisp.com\/helps\/author\/admin"}]}},"_links":{"self":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/86087","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/comments?post=86087"}],"version-history":[{"count":0,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/posts\/86087\/revisions"}],"wp:attachment":[{"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/media?parent=86087"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/categories?post=86087"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/tags?post=86087"},{"taxonomy":"topic","embeddable":true,"href":"https:\/\/www.wsisp.com\/helps\/wp-json\/wp\/v2\/topic?post=86087"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}