fix:修复lm studio不支持http/2的问题

Author: joey-zhou

src/main/java/com/xiaozhi/dialogue/llm/factory/ChatModelFactory.java

@@ -4,6 +4,10 @@
 import com.xiaozhi.dialogue.llm.providers.DifyChatModel;
 import com.xiaozhi.entity.SysConfig;
 import com.xiaozhi.service.SysConfigService;
+
+import java.net.http.HttpClient;
+import java.time.Duration;
+
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.ai.chat.model.ChatModel;
@@ -20,29 +24,36 @@
 import org.springframework.ai.zhipuai.ZhiPuAiChatOptions;
 import org.springframework.ai.zhipuai.api.ZhiPuAiApi;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.client.JdkClientHttpRequestFactory;
+import org.springframework.http.client.reactive.JdkClientHttpConnector;
 import org.springframework.stereotype.Component;
 import org.springframework.util.Assert;
 import org.springframework.util.LinkedMultiValueMap;
 import org.springframework.util.MultiValueMap;
 import org.springframework.util.StringUtils;
+import org.springframework.web.client.RestClient;
+import org.springframework.web.reactive.function.client.WebClient;
 
 /**
  * ChatModel工厂
  * 根据配置的模型ID，创建对应的ChatModel
  */
 @Component
 public class ChatModelFactory {
-    @Autowired private SysConfigService configService;
-    @Autowired private ToolCallingManager toolCallingManager;
+    @Autowired
+    private SysConfigService configService;
+    @Autowired
+    private ToolCallingManager toolCallingManager;
     private final Logger logger = LoggerFactory.getLogger(ChatModelFactory.class);
 
     /**
      * 根据配置ID创建ChatModel，首次调用时缓存，缓存key为配置ID。
-     * @see SysConfigService#selectConfigById(Integer)  已经进行了Cacheable,所以此处没有必要缓存
+     * 
+     * @see SysConfigService#selectConfigById(Integer) 已经进行了Cacheable,所以此处没有必要缓存
      * @param configId 配置ID，实际是模型ID。
      * @return
      */
-    public ChatModel takeChatModel(Integer configId){
+    public ChatModel takeChatModel(Integer configId) {
         Assert.notNull(configId, "配置ID不能为空");
         // 根据配置ID查询配置
         SysConfig config = configService.selectConfigById(configId);
@@ -51,6 +62,7 @@ public ChatModel takeChatModel(Integer configId){
 
     /**
      * 创建ChatModel
+     * 
      * @param config
      * @return
      */
@@ -87,19 +99,32 @@ private ChatModel newOllamaChatModel(String endpoint, String appId, String apiKe
                                 .model(model)
                                 .build())
                 .build();
-        logger.info( "Using Ollama model: {}" , model);
+        logger.info("Using Ollama model: {}", model);
         return chatModel;
     }
 
     private ChatModel newOpenAiChatModel(String endpoint, String appId, String apiKey, String apiSecret, String model) {
         MultiValueMap<String, String> headers = new LinkedMultiValueMap<>();
         headers.add("Content-Type", "application/json");
 
+        // LM Studio不支持Http/2，所以需要强制使用HTTP/1.1
         var openAiApi = OpenAiApi.builder()
                 .apiKey(StringUtils.hasText(apiKey) ? new SimpleApiKey(apiKey) : new NoopApiKey())
                 .baseUrl(endpoint)
                 .completionsPath("/chat/completions")
                 .headers(headers)
+                .webClientBuilder(WebClient.builder()
+                        // Force HTTP/1.1 for streaming
+                        .clientConnector(new JdkClientHttpConnector(HttpClient.newBuilder()
+                                .version(HttpClient.Version.HTTP_1_1)
+                                .connectTimeout(Duration.ofSeconds(30))
+                                .build())))
+                .restClientBuilder(RestClient.builder()
+                        // Force HTTP/1.1 for non-streaming
+                        .requestFactory(new JdkClientHttpRequestFactory(HttpClient.newBuilder()
+                                .version(HttpClient.Version.HTTP_1_1)
+                                .connectTimeout(Duration.ofSeconds(30))
+                                .build())))
                 .build();
         var openAiChatOptions = OpenAiChatOptions.builder()
                 .model(model)
@@ -110,17 +135,17 @@ private ChatModel newOpenAiChatModel(String endpoint, String appId, String apiKe
                 .defaultOptions(openAiChatOptions)
                 .toolCallingManager(toolCallingManager)
                 .build();
-        logger.info( "Using OpenAi model: {}" , model);
+        logger.info("Using OpenAi model: {}", model);
         return chatModel;
     }
 
     private ChatModel newZhipuChatModel(String endpoint, String appId, String apiKey, String apiSecret, String model) {
-        var zhiPuAiApi = new ZhiPuAiApi(endpoint,apiKey);
+        var zhiPuAiApi = new ZhiPuAiApi(endpoint, apiKey);
 
         var chatModel = new ZhiPuAiChatModel(zhiPuAiApi, ZhiPuAiChatOptions.builder()
                 .model(model)
                 .build());
-        logger.info( "Using zhiPu model: {}" , model);
+        logger.info("Using zhiPu model: {}", model);
         return chatModel;
     }
 }

web/src/views/page/Chat.vue

@@ -484,7 +484,7 @@ export default {
       
       // 如果已连接但配置改变，提示重新连接
       if (isConnected) {
-        message.info('配置已保存，需要重新连接才能生效');
+        this.$message.info('配置已保存，需要重新连接才能生效');
       } else {
         // 尝试连接
         this.connect();
@@ -518,7 +518,7 @@ export default {
       // 立即更新本地状态
       this.localIsConnected = false;
       this.localConnectionStatus = '已断开';
-      message.info('已断开连接');
+      this.message.info('已断开连接');
     },
   }
 };