大家好我是Java1234_小锋老师分享一套锋哥原创的基于Spark实时医疗健康数据监测与疾病预测系统(Java版本可视化大屏KafkaSpringBootVue3)项目介绍随着医疗信息化与物联网可穿戴设备的快速发展医院与健康管理机构面临着体征数据规模大、产生速度快、分析时效性要求高的挑战。传统以事后统计为主的信息系统难以满足实时监测与早期预警需求。本文设计并实现了一套基于Spark的实时医疗健康数据监测与疾病预测系统围绕“数据采集—消息传输—流式聚合—风险预测—可视化展示”的完整链路开展研究与开发。系统后端采用Java 17与Spring Boot 3构建RESTful服务结合Spring Security与JWT完成管理员身份认证数据访问层使用MyBatis-Plus操作MySQL数据库db_health实时事件通过Apache Kafka主题health_vitals进行解耦传输计算层引入Apache Spark SQL与Spark MLlib对按小时窗口聚合的风险指数序列进行线性回归预测并计算RMSE、MAE、MAPE误差指标。前端采用Vue 3、Vite、Element Plus与ECharts实现管理后台与数据大屏支持患者档案管理、体征记录查询、实时统计分析、疾病风险预测对比以及个人中心头像上传、资料修改、密码修改等功能。测试结果表明系统能够稳定完成模拟体征数据的持续接入与入库实时统计与预测结果可在前端动态刷新功能完整性与交互可用性满足本科毕业设计要求。本课题将大数据流处理、机器学习预测与Web工程实践相结合对智慧医疗场景下的实时健康管理具有一定参考价值。源码下载链接: https://pan.baidu.com/s/1hNYZ5_11TXkswBhGGYhZHg?pwd1234提取码: 1234系统展示核心代码package com.java1234.controller; import com.java1234.common.PageResult; import com.java1234.common.Result; import com.java1234.dto.PatientCreateRequest; import com.java1234.dto.PatientUpdateRequest; import com.java1234.service.PatientService; import com.java1234.vo.PatientVo; import lombok.RequiredArgsConstructor; import org.springframework.web.bind.annotation.DeleteMapping; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.PutMapping; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; import java.util.List; import java.util.Map; /** * 患者管理控制器 */ RestController RequestMapping(/api/patient) RequiredArgsConstructor public class PatientController { private final PatientService patientService; /** * 分页查询患者列表 */ GetMapping(/list) public ResultPageResultPatientVo list( RequestParam(defaultValue 1) int page, RequestParam(defaultValue 10) int size, RequestParam(required false) String keyword) { return Result.success(patientService.listPatients(page, size, keyword)); } /** * 新增患者 */ PostMapping(/create) public ResultPatientVo create(RequestBody PatientCreateRequest request) { return Result.success(patientService.createPatient(request)); } /** * 更新患者信息 */ PutMapping(/update/{patientId}) public ResultPatientVo update(PathVariable Integer patientId, RequestBody PatientUpdateRequest request) { return Result.success(patientService.updatePatient(patientId, request)); } /** * 删除患者 */ DeleteMapping(/delete/{patientId}) public ResultVoid delete(PathVariable Integer patientId) { patientService.deletePatient(patientId); return Result.success(删除成功); } /** * 获取疾病类型列表 */ GetMapping(/diseases) public ResultListMapString, Object diseases() { return Result.success(patientService.listDiseases()); } }template div classpage-container div classpage-card div classpage-title患者管理/div div stylemargin-bottom:16px;display:flex;gap:12px el-input v-modelkeyword placeholder搜索患者姓名 clearable stylewidth:240px clearloadData keyup.enterloadData / el-button typeprimary clickloadData搜索/el-button el-button typesuccess clickopenDialog()新增患者/el-button /div el-table :datatableData stripe border stylewidth:100% el-table-column propid labelID min-width60 / el-table-column propname label姓名 min-width100 / el-table-column propgender label性别 min-width70 / el-table-column propage label年龄 min-width70 / el-table-column propcity label城市 min-width100 / el-table-column propdisease_name label疾病类型 min-width120 / el-table-column propphone label联系电话 min-width130 / el-table-column propcreate_time label创建时间 min-width170 template #default{ row }{{ formatDateTime(row.create_time) }}/template /el-table-column el-table-column label操作 min-width160 fixedright template #default{ row } el-button typeprimary link sizesmall clickopenDialog(row)编辑/el-button el-button typedanger link sizesmall clickhandleDelete(row.id)删除/el-button /template /el-table-column /el-table el-pagination stylemargin-top:16px;justify-content:flex-end v-model:current-pagepage v-model:page-sizesize :totaltotal :page-sizes[10, 20, 50] layouttotal, sizes, prev, pager, next changeloadData / /div el-dialog v-modeldialogVisible :titleeditId ? 编辑患者 : 新增患者 width500px el-form :modelform label-width90px el-form-item label姓名el-input v-modelform.name //el-form-item el-form-item label性别 el-select v-modelform.gender stylewidth:100% el-option label男 value男 /el-option label女 value女 /el-option label未知 value未知 / /el-select /el-form-item el-form-item label年龄el-input-number v-modelform.age :min0 :max120 stylewidth:100% //el-form-item el-form-item label城市el-input v-modelform.city //el-form-item el-form-item label疾病类型 el-select v-modelform.disease_id stylewidth:100% el-option v-ford in diseases :keyd.id :labeld.name :valued.id / /el-select /el-form-item el-form-item label联系电话el-input v-modelform.phone //el-form-item /el-form template #footer el-button clickdialogVisible false取消/el-button el-button typeprimary clickhandleSave保存/el-button /template /el-dialog /div /template script setup /** * 患者管理页面 */ import { ref, reactive, onMounted } from vue import request from /utils/request import { formatDateTime } from /utils/format import { ElMessage, ElMessageBox } from element-plus const tableData ref([]) const diseases ref([]) const page ref(1) const size ref(10) const total ref(0) const keyword ref() const dialogVisible ref(false) const editId ref(null) const form reactive({ name: , gender: 未知, age: 0, city: , disease_id: null, phone: }) async function loadData() { const res await request.get(/patient/list, { params: { page: page.value, size: size.value, keyword: keyword.value || undefined } }) tableData.value res.data.items total.value res.data.total } async function loadDiseases() { const res await request.get(/patient/diseases) diseases.value res.data } function openDialog(row) { editId.value row?.id || null form.name row?.name || form.gender row?.gender || 未知 form.age row?.age || 0 form.city row?.city || form.disease_id row?.disease_id || null form.phone row?.phone || dialogVisible.value true } async function handleSave() { if (editId.value) { await request.put(/patient/update/${editId.value}, form) } else { await request.post(/patient/create, form) } ElMessage.success(保存成功) dialogVisible.value false loadData() } async function handleDelete(id) { await ElMessageBox.confirm(确定删除该患者, 提示, { type: warning }) await request.delete(/patient/delete/${id}) ElMessage.success(删除成功) loadData() } onMounted(() { loadData(); loadDiseases() }) /script