融入通义千问的步骤

后端集成

1. 在若依微服务的api-module中新增通义千问API调用接口，使用阿里云SDK或HTTP直接调用通义千问的RESTful API。示例核心代码：

// 使用阿里云SDK调用通义千问
DefaultProfile profile = DefaultProfile.getProfile("cn-shanghai", "accessKeyId", "accessKeySecret");
IAcsClient client = new DefaultAcsClient(profile);

ChatRequest request = new ChatRequest();
request.setPrompt("用户问题文本");
request.setModel("qwen-turbo");

ChatResponse response = client.getAcsResponse(request);
return response.getOutputText();

1. 配置API密钥管理，通过若依的config-module动态加载阿里云AccessKey，建议使用Nacos配置中心实现热更新。

前端对接

1. 在若依前端ruoyi-ui中扩展智能客服组件，通过WebSocket或Axios与后端接口通信。关键Vue代码：

<template>
  <div class="chat-container">
    <el-input v-model="userInput" @keyup.enter="sendQuery"/>
    <div v-html="formattedResponse"></div>
  </div>
</template>

<script>
export default {
  data() {
    return {
      userInput: '',
      aiResponse: ''
    }
  },
  methods: {
    async sendQuery() {
      const res = await axios.post('/api/ai/qwen', { query: this.userInput });
      this.aiResponse = res.data;
    }
  }
}
</script>

数据流设计

1. 建立对话上下文缓存，使用Redis存储最近5轮对话历史，键值设计为ai:session:{userId}:history，JSON格式存储消息数组。
2. 实现敏感词过滤拦截层，在调用通义千问前通过若依的security-module进行内容审查。

性能优化建议

异步处理
对耗时响应启用@Async注解，配置线程池隔离AI调用任务，避免阻塞主业务线程。在application.yml中配置：

spring:
  task:
    execution:
      pool:
        core-size: 10
        max-size: 50
        queue-capacity: 100

限流保护
通过Sentinel为通义千问接口配置QPS限流规则，示例控制台配置：

@SentinelResource(value = "qwenAPI", blockHandler = "handleBlock")
public String callQwen(String prompt) {
  // API调用逻辑
}

监控实现方案

1. 接入Prometheus监控指标：

@RestController
@RequiredArgsConstructor
public class QwenController {
  private final MeterRegistry registry;

  @PostMapping("/api/ai/qwen")
  public String query(@RequestBody QueryDTO dto) {
    registry.counter("ai.qwen.requests").increment();
    long start = System.currentTimeMillis();
    // 业务逻辑
    registry.timer("ai.qwen.latency").record(System.currentTimeMillis() - start);
  }
}

1. 在Grafana中创建看板，监控关键指标：

• 请求成功率
• 平均响应时间
• 令牌消耗量

异常处理机制

1. 实现分级降级策略：

• 当通义千问API不可用时，自动切换至本地知识库应答
• 连续3次调用超时后触发熔断，通过@CircuitBreaker注解实现

1. 错误日志收集：

@Slf4j
@Aspect
public class QwenLogAspect {
  @AfterThrowing(pointcut = "execution(* com.ruoyi.ai.qwen..*(..))", throwing = "ex")
  public void logException(JoinPoint jp, Exception ex) {
    log.error("Qwen调用异常 - 方法:{} 参数:{}", jp.getSignature(), jp.getArgs(), ex);
  }
}