以下是一个基于Java搭建心理健康问答咨询平台的源码解析及搭建指南,涵盖核心功能实现、技术选型和关键代码示例:
一、核心功能模块
- 用户管理
- 注册/登录(含角色区分:普通用户、咨询师、管理员)
- 个人信息修改与权限控制
- 问答咨询
- 智能匹配:基于用户问题与知识库的语义相似度匹配
- 多轮对话:支持上下文关联的追问与澄清
- 人工干预:咨询师可接入对话并提供专业建议
- 心理测评
- 标准量表集成(如PHQ-9抑郁量表、GAD-7焦虑量表)
- 自动评分与风险等级划分
- 测评报告生成与历史记录追踪
- 资源管理
- 心理知识库:文章、视频、音频等资源分类管理
- 咨询师排班:时间表管理与预约冲突检测
- 数据安全
- 匿名咨询模式
- 敏感信息加密存储(如AES-256)
- 访问日志审计
二、技术选型
| 层级 | 技术组件 | 作用 |
|---|---|---|
| 前端 | Vue.js + Element UI | 构建响应式用户界面 |
| 后端 | Spring Boot 2.7 | 提供RESTful API服务 |
| 安全 | Spring Security + JWT | 认证授权与会话管理 |
| 数据层 | MySQL + Redis + MongoDB | 结构化/非结构化数据存储 |
| NLP | HanLP(轻量级)或腾讯云NLP | 语义相似度计算与情感分析 |
| 部署 | Docker + Nginx | 容器化部署与负载均衡 |
三、关键代码实现
1. 用户认证(JWT生成与验证)
java
// JwtTokenUtil.java public class JwtTokenUtil { private static final String SECRET_KEY = "your-256-bit-secret"; private static final long EXPIRATION_TIME = 864_000_000; // 10天 public static String generateToken(UserDetails userDetails) { return Jwts.builder() .setSubject(userDetails.getUsername()) .claim("roles", userDetails.getAuthorities()) .setIssuedAt(new Date()) .setExpiration(new Date(System.currentTimeMillis() + EXPIRATION_TIME)) .signWith(SignatureAlgorithm.HS256, SECRET_KEY) .compact(); } public static boolean validateToken(String token) { try { Jwts.parser().setSigningKey(SECRET_KEY).parseClaimsJws(token); return true; } catch (Exception e) { return false; } } }2. 问答匹配逻辑(多级策略)
java
// QuestionAnswerService.java @Service public class QuestionAnswerService { @Autowired private QuestionRepository questionRepo; @Autowired private RedisTemplate<String, String> redisTemplate; public String getAnswer(String userQuestion) { // 1. 缓存检查 String cachedAnswer = redisTemplate.opsForValue().get("qa:" + userQuestion); if (cachedAnswer != null) return cachedAnswer; // 2. 精确匹配 Optional<Question> exactMatch = questionRepo.findByQuestion(userQuestion); if (exactMatch.isPresent()) { return cacheAndReturn(userQuestion, exactMatch.get().getAnswer()); } // 3. 语义相似度匹配 List<Question> candidates = questionRepo.findAll(); Question bestMatch = candidates.stream() .max(Comparator.comparingDouble(q -> calculateSimilarity(userQuestion, q.getQuestion()))) .orElse(null); if (bestMatch != null && calculateSimilarity(userQuestion, bestMatch.getQuestion()) > 0.7) { return cacheAndReturn(userQuestion, bestMatch.getAnswer()); } // 4. 默认回复 return "您的问题需要专业咨询师分析,是否需要预约咨询?"; } private double calculateSimilarity(String s1, String s2) { // 调用HanLP或腾讯云NLP接口 return externalNlpService.computeSimilarity(s1, s2); } private String cacheAndReturn(String key, String value) { redisTemplate.opsForValue().set("qa:" + key, value, 1, TimeUnit.DAYS); return value; } }3. PHQ-9测评评分逻辑
java
// AssessmentService.java @Service public class AssessmentService { @Transactional public AssessmentResult evaluatePHQ9(Map<Integer, Integer> answers, Long userId) { int totalScore = answers.values().stream().mapToInt(Integer::intValue).sum(); String riskLevel = switch (totalScore) { case 0 -> "无抑郁症状"; case 1, 2, 3, 4 -> "轻度抑郁"; case 5, 6, 7, 8, 9 -> "中度抑郁"; default -> "重度抑郁"; }; AssessmentResult result = new AssessmentResult(); result.setUserId(userId); result.setType("PHQ-9"); result.setScore(totalScore); result.setRiskLevel(riskLevel); result.setCreatedAt(LocalDateTime.now()); assessmentRepository.save(result); if (totalScore >= 15) { alertService.notifyCounselors(userId, "PHQ-9高风险: " + totalScore); } return result; } }四、部署与优化建议
- 性能优化
- 缓存策略:高频问题缓存24小时,测评结果缓存7天。
- 异步处理:测评报告生成、通知发送等非实时任务使用消息队列(如RabbitMQ)。
- 数据库优化:为
questions表的question字段添加全文索引。
- 安全加固
- 数据脱敏:日志中隐藏用户敏感信息(如手机号、咨询内容)。
- CSRF防护:启用Spring Security的CSRF保护。
- 输入验证:对用户输入进行XSS过滤和长度限制。
- 扩展性设计
- 插件化NLP引擎:通过接口抽象不同NLP服务(如本地HanLP与腾讯云NLP切换)。
- 微服务拆分:将问答、测评、咨询等模块拆分为独立服务,通过API网关通信。