internal/runtime/llm.go

@@ -200,7 +200,8 @@ func (l *LLMRunner) Execute(rc RunCtx) error {
 	stream := l.Stream
 	if stream == nil {
 		client := openLLMClient(route.Base, route.Key)
-		stream = client.Stream
+		retries := int(eff.GetNumber("runtime.llmRetries", 2))
+		stream = agentllm.WithRetry(client.Stream, retries, nil)
 	}
 
 	// 知识注入：当前消息包含 @knowledge 引用时检索注入（最小实现：显式引用）。

internal/settings/settings.go

@@ -36,6 +36,7 @@ func SystemDefaults() map[string]any {
 			"rateLimitPerMin": 0,        // 租户限流（次/分；0 = 不限）
 			"redisAddr":       "",       // 限流共享后端（原生 Redis addr；空 = 进程内）
 			"verify":          true,     // 终轮确定性检查与独立验证
+			"llmRetries":      2,        // 直连模型在尚未输出时的额外重试次数
 		},
 		"storage": map[string]any{
 			"dataDir": "./data", // 启动注入实际值（--data）
@@ -81,6 +82,7 @@ func Schema() []core.SettingDesc {
 		{Key: "runtime.rateLimitPerMin", Group: "runtime", Label: "租户限流（次/分）", Type: core.SettingNumber, Default: 0, Effect: core.EffectHot, Description: "0 = 不限；多用户建议 300–1200"},
 		{Key: "runtime.redisAddr", Group: "runtime", Label: "Redis 地址（限流共享）", Type: core.SettingString, Default: "", Effect: core.EffectRestart, Description: "原生 Redis（如 127.0.0.1:6379）；空 = 进程内限流（单实例）"},
 		{Key: "runtime.verify", Group: "runtime", Label: "终轮结果检查", Type: core.SettingBool, Default: true, Effect: core.EffectNewRun, Description: "终轮确定性检查与独立验证"},
+		{Key: "runtime.llmRetries", Group: "runtime", Label: "模型重试次数", Type: core.SettingNumber, Default: 2, Effect: core.EffectNewRun, Description: "直连模型在还没有任何输出时，遇到超时、限流或服务端错误的额外重试次数。0 = 不重试。已经开始输出后不再重试"},
 		{Key: "runtime.composeFinal", Group: "runtime", Label: "终轮整理回复", Type: core.SettingBool, Default: true, Effect: core.EffectNewRun, Description: "用过工具的回合结束后，再用主模型写一段直接回答用户的最终回复"},
 		{Key: "context.maxHistoryMessages", Group: "context", Label: "历史窗口条数", Type: core.SettingNumber, Default: 40, Effect: core.EffectNewRun},
 		{Key: "context.maxToolResultChars", Group: "context", Label: "工具结果上限（字符）", Type: core.SettingNumber, Default: 20000, Effect: core.EffectNewRun},

internal/settings/settings_test.go

@@ -2,6 +2,22 @@ package settings
 
 import "testing"
 
+func TestLLMRetriesDefault(t *testing.T) {
+	block := SystemDefaults()["runtime"].(map[string]any)
+	if block["llmRetries"] != 2 {
+		t.Fatalf("llmRetries = %#v", block["llmRetries"])
+	}
+	var found bool
+	for _, desc := range Schema() {
+		if desc.Key == "runtime.llmRetries" && desc.Default == 2 {
+			found = true
+		}
+	}
+	if !found {
+		t.Fatal("schema missing runtime.llmRetries default 2")
+	}
+}
+
 func TestDeliverableSettingsPresent(t *testing.T) {
 	defaults := SystemDefaults()
 	block, ok := defaults["deliverables"].(map[string]any)