shiganluo/skill/ai-agent-skill-architecture

public interface Skill {
    String getName();
    String getDescription();
    String getTriggerDescription();      // when to use
    String getUsageHint();               // how to use
    String getSystemPromptFragment();    // dynamic context (schema, etc.)
    int getPriority();                   // ordering
}
 
public interface Tool extends Skill {
    Map<String, Object> getParameters();  // JSON Schema
    String execute(Map<String, String> args);
}

@Component
public class SkillRegistry {
    public SkillRegistry(List<Skill> skills, ...) {
        // Spring auto-discovers all @Component Skills
        // + loads DB-created skills (skill:* config keys)
    }
 
    public String buildSystemPrompt() {
        // = base prompt + each skill's trigger/hint + global rules + dynamic fragments
    }
}

// Store as JSON in system_config with key = "skill:<name>"
// SkillRegistry loads on next conversation

@Override
public String getSystemPromptFragment() {
    // Query information_schema → formatted table schema
    // Eliminates SHOW TABLES + DESCRIBE exploration rounds
}

while (response.hasToolCalls() && rounds < MAX_ROUNDS) {
    rounds++;
    messages.add(ChatMessage.assistantWithToolCalls(content, toolCallRefs));
    for (ToolCall tc : response.getToolCalls()) {
        messages.add(ChatMessage.tool(tc.id(), executeTool(tc)));
    }
    response = llmClient.chatWithTools(messages, systemPrompt, tools);
}
// Fallback: rounds exhausted → no-tool LLM call for text response

SseEmitter emitter = new SseEmitter(5 * 60 * 1000L);
 
// Heartbeat: array wrapper solves Java lambda reference-before-assignment
ScheduledFuture<?>[] holder = new ScheduledFuture<?>[1];
holder[0] = heartbeat.scheduleAtFixedRate(() -> {
    try { emitter.send(SseEmitter.event().comment("keepalive")); }
    catch (Exception e) { holder[0].cancel(false); heartbeat.shutdown(); }
}, 15, 15, TimeUnit.SECONDS);
 
// Disconnect detection: stop tool loop when client gone
AtomicBoolean disconnected = new AtomicBoolean(false);
emitter.onCompletion(() -> { holder[0].cancel(false); disconnected.set(true); });
emitter.onTimeout(() -> { holder[0].cancel(false); disconnected.set(true); });
emitter.onError(e -> { holder[0].cancel(false); disconnected.set(true); });
 
// In tool loop: check disconnected before each tool call
if (disconnected.get()) { return null; }

proxy_buffering off;        # MUST — buffering blocks SSE push
proxy_read_timeout 300s;    # Tool calls + LLM can take >60s

@ExceptionHandler(IOException.class)
public void handleIOException(IOException ex) {
    log.debug("SSE连接断开: {}", ex.getMessage());
}