简介本资源为基于Java的丰富组件企业级多媒体信息发布系统设计源码面向具备一定Java基础、希望深入理解企业级信息发布平台架构与终端适配方案的开发者。系统支持图片与视频轮播、滚动字幕、日期时间显示等多媒体展示能力并集成设备管理、监控、远程控制及定时节目发布功能可适配Android、Windows、Linux及国产统信系统适合用于商业场景下的信息发布终端开发与二次扩展。资源包共23个文件约4.38MB以13个PNG界面截图与1个JPG框架图为主辅以txt说明、yml与cnf配置文件、Dockerfile、Shell脚本及许可证文件便于快速了解系统结构与部署方式。目前已有324人学习下载读者可从中获取组件化设计思路、终端适配策略及数据库容器化部署参考适合作为企业级多媒体发布系统的学习与开发起点。1. 从一块广告屏的崩溃说起这套 Java 多媒体信息发布系统到底解决什么商场里那块循环播放促销海报的竖屏某天突然黑屏运维跑过去发现是播放器进程挂了重启后内容又对不上——这种场景在企业级多媒体信息发布里太常见了。这套基于 Java 的源码包核心要解决的就是「内容集中管、终端分散跑、组件按需拼」这三件事。它不是简单的轮播 Demo而是把素材管理、节目单编排、终端分组、播放调度拆成独立组件用 Spring Boot 做服务端骨架终端侧通过 HTTP 拉取节目单和素材清单。适合谁做 Java 课程设计想拿高分的学生、需要给客户交付一套可二次开发发布平台的外包团队以及想研究组件化架构在企业级系统里怎么落地的后端工程师。源码里能看到完整的 Maven 多模块划分不是那种一个 main 方法跑到底的玩具工程。2. 组件化拆解Maven 多模块与 Spring Boot 服务端骨架2.1 模块划分逻辑与依赖关系拿到源码先别急着跑打开根pom.xml看modules列表这是理解整个系统架构的入口。常见做法是按职责切成四到五个模块media-common放工具类和统一返回体media-core放素材、节目单、终端三个领域模型和 Servicemedia-admin是后台管理接口层media-terminal-api专门给终端设备提供拉取接口media-web是前端静态资源打包入口。这样切的好处是终端接口和管理接口的鉴权策略可以完全隔离终端用设备密钥后台用 JWT。!-- 根 pom.xml 片段模块聚合 -- modules modulemedia-common/module !-- 通用工具、常量、异常 -- modulemedia-core/module !-- 领域模型 业务 Service -- modulemedia-admin/module !-- 后台管理 REST 接口 -- modulemedia-terminal-api/module !-- 终端拉取接口独立鉴权 -- modulemedia-web/module !-- 打包前端产物 -- /modules依赖方向上media-admin和media-terminal-api都依赖media-core但两者之间不互相依赖。这个约束很重要一旦终端接口里 import 了 admin 的类说明分层被破坏了后期拆微服务会非常痛苦。media-common被所有模块依赖所以它里面不能出现任何 Spring Web 相关的类否则会污染终端模块的依赖树。2.2 核心领域模型与数据库表映射media-core里的实体类对应几张关键表理解字段含义比背代码重要。素材表t_media_material存文件路径、MD5、时长、分辨率节目单表t_program存编排好的播放序列用 JSON 字段存素材 ID 数组和每个素材的播放时长终端表t_terminal存设备编号、分组 ID、最后心跳时间、当前节目单版本号。版本号这个字段是整套系统的调度核心——终端每次心跳上报自己持有的节目单版本服务端比对后发现不一致就下发新版本。// Program.java 关键字段节目单版本控制 public class Program { private Long id; private String name; private String contentJson; // [{materialId:1,duration:10},...] private Integer version; // 每次编辑 1终端据此判断是否更新 private Integer status; // 0草稿 1已发布 2已下线 private LocalDateTime publishTime; }contentJson用字符串存而不是拆成关联表是为了终端拉取时一次查询就能拿到完整播放序列减少 JOIN。代价是后台编辑节目单时要在应用层做校验比如素材 ID 是否存在、总时长是否超限。version字段的递增必须放在同一个事务里配合乐观锁或UPDATE ... SET version version 1 WHERE id ? AND version ?否则并发编辑会出现版本覆盖。2.3 服务端启动与配置项说明启动前先改application.yml几个参数不改跑不起来。数据库连接、文件存储根路径、终端心跳超时时间、节目单下发间隔。文件存储默认走本地磁盘生产环境一般换成 MinIO 或对象存储源码里留了StorageService接口实现类换一下就行。server: port: 8080 media: storage: type: local # local / minio切换实现类 local-path: /data/media/files terminal: heartbeat-timeout: 120 # 秒超过判定离线 program-pull-interval: 30 # 终端轮询间隔建议值 spring: datasource: url: jdbc:mysql://localhost:3306/media_db?useSSLfalseserverTimezoneAsia/Shanghai username: root password: your_passwordheartbeat-timeout设太小会导致网络抖动时终端被误判离线设太大则故障发现慢120 秒是常见折中。program-pull-interval只是下发给终端的建议值终端实际可以自己调整但服务端在响应里会带上这个字段。启动命令用mvn clean package -DskipTests打包后java -jar media-admin/target/*.jar或者直接在 IDE 里跑MediaAdminApplication。第一次启动会自动建表前提是spring.jpa.hibernate.ddl-auto设成了update生产环境记得改成none并手动执行 SQL 脚本。3. 终端适配与节目单下发HTTP 接口设计与轮询实现3.1 终端鉴权与心跳接口终端不是浏览器没有 Cookie 和 Session常见做法是设备首次激活时分配deviceNo和deviceSecret之后每次请求在 Header 里带X-Device-No和签名。签名算法一般是MD5(deviceNo timestamp deviceSecret)服务端用同样的方式算一遍比对同时校验 timestamp 与服务器时间差不超过 5 分钟防止重放。// TerminalAuthInterceptor.java 核心校验逻辑 String deviceNo request.getHeader(X-Device-No); String timestamp request.getHeader(X-Timestamp); String sign request.getHeader(X-Sign); // 1. 校验时间戳偏移 long diff Math.abs(System.currentTimeMillis() - Long.parseLong(timestamp)); if (diff 5 * 60 * 1000) return false; // 2. 查库拿 secret重算签名 Terminal terminal terminalMapper.selectByDeviceNo(deviceNo); String expect DigestUtils.md5Hex(deviceNo timestamp terminal.getDeviceSecret()); return expect.equalsIgnoreCase(sign);心跳接口POST /terminal/heartbeat接收终端上报的当前节目单版本、播放状态、磁盘剩余空间。服务端在响应里返回needUpdate布尔值和最新版本号。这个设计把「是否更新」的判断放在服务端终端逻辑就很简单收到needUpdatetrue就去调节目单接口。磁盘空间上报是为了防止终端存满素材后播放失败服务端可以据此触发清理指令。3.2 节目单拉取接口与增量更新节目单接口GET /terminal/program?version当前版本支持增量返回。如果终端版本和服务端一致返回 304 或空内容不一致则返回完整节目单加素材下载地址列表。素材地址不是直接给文件路径而是给一个带签名的临时 URL有效期比如 10 分钟终端拿着 URL 去下载。{ code: 0, data: { version: 12, programName: 一楼大厅促销, items: [ {materialId: 101, duration: 15, url: /terminal/material/101?tokenxxx}, {materialId: 102, duration: 10, url: /terminal/material/102?tokenyyy} ], pullInterval: 30 } }items数组的顺序就是播放顺序duration单位是秒。终端下载完所有素材后本地生成一个播放列表文件播放器按这个文件循环。这里有个坑如果某个素材下载失败终端不能直接跳过否则播放序列会错位。常见做法是下载失败时保留旧版本节目单继续播放同时上报错误等服务端下次下发时重试。3.3 终端侧轮询与本地缓存策略终端程序可以用 Java 写源码里带了一个media-terminal-client示例也可以用其他语言实现只要遵循接口协议。轮询逻辑不复杂但缓存策略要设计好。素材文件按materialId命名存在本地目录下载前先检查本地是否已存在且 MD5 匹配匹配就跳过下载。// TerminalClient.java 轮询主循环 while (running) { HeartbeatResp resp heartbeatService.report(currentVersion); if (resp.isNeedUpdate()) { ProgramResp program programService.pull(currentVersion); for (Item item : program.getItems()) { File local new File(cacheDir, item.getMaterialId() .mp4); if (!local.exists() || !md5Match(local, item.getMd5())) { download(item.getUrl(), local); // 下载失败抛异常不更新版本号 } } currentVersion program.getVersion(); // 全部成功后才更新本地版本 player.reload(program); // 通知播放器重载列表 } Thread.sleep(resp.getPullInterval() * 1000L); }currentVersion的更新必须放在所有素材下载成功之后这是保证播放一致性的关键。如果中途失败版本号不变下次心跳服务端还会返回needUpdatetrue终端重新拉取。player.reload的实现取决于播放器常见做法是写一个playlist.json然后给播放器进程发信号或者用 VLC 的 HTTP 接口控制。4. 素材管理与存储抽象从本地上传到对象存储切换4.1 素材上传接口与 MD5 去重素材上传走POST /admin/material/upload接收MultipartFile。上传前先算 MD5查库看是否已存在相同 MD5 的素材存在就直接返回已有记录不重复存文件。这个去重逻辑在大批量上传同一批海报时能省很多磁盘。// MaterialServiceImpl.java 上传去重 String md5 DigestUtils.md5Hex(file.getInputStream()); Material exist materialMapper.selectByMd5(md5); if (exist ! null) { return Result.ok(exist); // 秒传不写磁盘 } String path storageService.save(file); // 实际存储 Material material new Material(); material.setMd5(md5); material.setFilePath(path); material.setFileSize(file.getSize()); materialMapper.insert(material);storageService.save返回的是相对路径比如2024/06/abc123.mp4数据库只存相对路径不存绝对路径。这样迁移存储根目录时不用改数据。MD5 计算用DigestUtils流式计算大文件不会一次性读进内存。4.2 StorageService 接口与 MinIO 实现切换StorageService接口只有三个方法save、delete、getUrl。本地实现类把文件写到local-path下getUrl返回一个由 Controller 处理的下载地址。MinIO 实现类用minio-javaSDKgetUrl返回预签名 URL。public interface StorageService { String save(MultipartFile file); // 返回相对路径 void delete(String path); String getUrl(String path, int expireSeconds); // 临时访问地址 }切换实现只需要在application.yml里改media.storage.type配合ConditionalOnProperty注解让 Spring 注入对应的 Bean。这个模式在企业级系统里很常见核心是把「存哪里」和「怎么存」解耦。注意 MinIO 的预签名 URL 有效期不能设太长一般 10 到 30 分钟终端下载完就失效避免链接被转发盗用。4.3 素材格式校验与转码触发上传接口要校验文件类型不能只看扩展名要读文件头。常见做法是用Apache Tika检测 MIME 类型只允许video/mp4、image/jpeg、image/png等白名单类型。视频素材如果分辨率超过终端支持范围需要触发转码。源码里转码部分留了钩子实际转码一般调ffmpeg命令行。# 转码为 1080x1920 竖屏H.264 编码 ffmpeg -i input.mp4 -vf scale1080:1920:force_original_aspect_ratiodecrease,pad1080:1920:(ow-iw)/2:(oh-ih)/2 \ -c:v libx264 -preset medium -crf 23 -c:a aac -b:a 128k output.mp4force_original_aspect_ratiodecrease加pad保证不拉伸变形黑边填充。crf 23是画质和体积的平衡点数值越小画质越好体积越大。转码是异步任务上传接口返回后由后台线程处理处理完更新素材状态。终端拉取时只拿status1已就绪的素材。5. 排错与进阶版本冲突、心跳丢失与灰度发布技巧5.1 节目单版本冲突的排查路径终端播放内容和后台不一致九成是版本号问题。排查顺序先查t_terminal表里该设备的program_version字段再查t_program表里该终端所属分组绑定的节目单version两者不一致说明下发没成功。看服务端日志里needUpdate的返回值如果一直是 false 但版本确实不同检查心跳接口里比对逻辑是不是用了错误的字段。-- 查终端当前版本与目标节目单版本 SELECT t.device_no, t.program_version AS terminal_ver, p.version AS program_ver FROM t_terminal t JOIN t_program p ON p.group_id t.group_id AND p.status 1 WHERE t.device_no DEV001;如果terminal_ver小于program_ver但终端没更新检查终端本地磁盘是否满了或者素材下载是否一直失败。终端日志里一般会打下载失败的 HTTP 状态码403 说明签名过期404 说明素材被删了但节目单没更新。5.2 心跳丢失与离线判定调优终端被误判离线先看heartbeat-timeout和终端实际轮询间隔的比值。如果终端 30 秒轮询一次超时设 60 秒网络稍微抖一下就离线。合理比值是 3 到 4 倍即 30 秒轮询配 90 到 120 秒超时。另外心跳接口本身要轻量不要在里面做重查询否则终端并发高时接口响应慢也会导致超时。参数建议值说明终端轮询间隔30s太短增加服务端压力太长更新不及时心跳超时120s轮询间隔的 4 倍容忍网络抖动节目单拉取超时10s含素材列表比心跳稍长素材下载超时300s大视频文件需要更长时间5.3 灰度发布按终端分组逐步更新节目单一次性给所有终端推新节目单风险大万一素材有问题全屏黑。常见做法是按分组灰度先推一个测试组观察 10 分钟无异常再推其他组。实现上就是在节目单发布时选择目标分组服务端只更新这些分组下终端的program_version。// 灰度发布只更新指定分组 public void publish(Long programId, ListLong groupIds) { Program program programMapper.selectById(programId); program.setStatus(1); program.setVersion(program.getVersion() 1); programMapper.updateById(program); // 只更新选中分组下的终端 terminalMapper.updateVersionByGroups(groupIds, program.getVersion()); }updateVersionByGroups是一条批量 UPDATE把选中分组下所有终端的program_version改成新版本。终端下次心跳就会发现版本不一致并拉取。灰度期间如果发现问题把节目单status改回 0终端拉取时发现没有已发布节目单会继续播放本地缓存的旧版本不会黑屏。这个回滚机制比重新推一个旧节目单更快。本文还有配套的精品资源点击获取
简介本资源为基于Java的丰富组件企业级多媒体信息发布系统设计源码面向具备一定Java基础、希望深入理解企业级信息发布平台架构与终端适配方案的开发者。系统支持图片与视频轮播、滚动字幕、日期时间显示等多媒体展示能力并集成设备管理、监控、远程控制及定时节目发布功能可适配Android、Windows、Linux及国产统信系统适合用于商业场景下的信息发布终端开发与二次扩展。资源包共23个文件约4.38MB以13个PNG界面截图与1个JPG框架图为主辅以txt说明、yml与cnf配置文件、Dockerfile、Shell脚本及许可证文件便于快速了解系统结构与部署方式。目前已有324人学习下载读者可从中获取组件化设计思路、终端适配策略及数据库容器化部署参考适合作为企业级多媒体发布系统的学习与开发起点。1. 从一块广告屏的崩溃说起这套 Java 多媒体信息发布系统到底解决什么商场里那块循环播放促销海报的竖屏某天突然黑屏运维跑过去发现是播放器进程挂了重启后内容又对不上——这种场景在企业级多媒体信息发布里太常见了。这套基于 Java 的源码包核心要解决的就是「内容集中管、终端分散跑、组件按需拼」这三件事。它不是简单的轮播 Demo而是把素材管理、节目单编排、终端分组、播放调度拆成独立组件用 Spring Boot 做服务端骨架终端侧通过 HTTP 拉取节目单和素材清单。适合谁做 Java 课程设计想拿高分的学生、需要给客户交付一套可二次开发发布平台的外包团队以及想研究组件化架构在企业级系统里怎么落地的后端工程师。源码里能看到完整的 Maven 多模块划分不是那种一个 main 方法跑到底的玩具工程。2. 组件化拆解Maven 多模块与 Spring Boot 服务端骨架2.1 模块划分逻辑与依赖关系拿到源码先别急着跑打开根pom.xml看modules列表这是理解整个系统架构的入口。常见做法是按职责切成四到五个模块media-common放工具类和统一返回体media-core放素材、节目单、终端三个领域模型和 Servicemedia-admin是后台管理接口层media-terminal-api专门给终端设备提供拉取接口media-web是前端静态资源打包入口。这样切的好处是终端接口和管理接口的鉴权策略可以完全隔离终端用设备密钥后台用 JWT。!-- 根 pom.xml 片段模块聚合 -- modules modulemedia-common/module !-- 通用工具、常量、异常 -- modulemedia-core/module !-- 领域模型 业务 Service -- modulemedia-admin/module !-- 后台管理 REST 接口 -- modulemedia-terminal-api/module !-- 终端拉取接口独立鉴权 -- modulemedia-web/module !-- 打包前端产物 -- /modules依赖方向上media-admin和media-terminal-api都依赖media-core但两者之间不互相依赖。这个约束很重要一旦终端接口里 import 了 admin 的类说明分层被破坏了后期拆微服务会非常痛苦。media-common被所有模块依赖所以它里面不能出现任何 Spring Web 相关的类否则会污染终端模块的依赖树。2.2 核心领域模型与数据库表映射media-core里的实体类对应几张关键表理解字段含义比背代码重要。素材表t_media_material存文件路径、MD5、时长、分辨率节目单表t_program存编排好的播放序列用 JSON 字段存素材 ID 数组和每个素材的播放时长终端表t_terminal存设备编号、分组 ID、最后心跳时间、当前节目单版本号。版本号这个字段是整套系统的调度核心——终端每次心跳上报自己持有的节目单版本服务端比对后发现不一致就下发新版本。// Program.java 关键字段节目单版本控制 public class Program { private Long id; private String name; private String contentJson; // [{materialId:1,duration:10},...] private Integer version; // 每次编辑 1终端据此判断是否更新 private Integer status; // 0草稿 1已发布 2已下线 private LocalDateTime publishTime; }contentJson用字符串存而不是拆成关联表是为了终端拉取时一次查询就能拿到完整播放序列减少 JOIN。代价是后台编辑节目单时要在应用层做校验比如素材 ID 是否存在、总时长是否超限。version字段的递增必须放在同一个事务里配合乐观锁或UPDATE ... SET version version 1 WHERE id ? AND version ?否则并发编辑会出现版本覆盖。2.3 服务端启动与配置项说明启动前先改application.yml几个参数不改跑不起来。数据库连接、文件存储根路径、终端心跳超时时间、节目单下发间隔。文件存储默认走本地磁盘生产环境一般换成 MinIO 或对象存储源码里留了StorageService接口实现类换一下就行。server: port: 8080 media: storage: type: local # local / minio切换实现类 local-path: /data/media/files terminal: heartbeat-timeout: 120 # 秒超过判定离线 program-pull-interval: 30 # 终端轮询间隔建议值 spring: datasource: url: jdbc:mysql://localhost:3306/media_db?useSSLfalseserverTimezoneAsia/Shanghai username: root password: your_passwordheartbeat-timeout设太小会导致网络抖动时终端被误判离线设太大则故障发现慢120 秒是常见折中。program-pull-interval只是下发给终端的建议值终端实际可以自己调整但服务端在响应里会带上这个字段。启动命令用mvn clean package -DskipTests打包后java -jar media-admin/target/*.jar或者直接在 IDE 里跑MediaAdminApplication。第一次启动会自动建表前提是spring.jpa.hibernate.ddl-auto设成了update生产环境记得改成none并手动执行 SQL 脚本。3. 终端适配与节目单下发HTTP 接口设计与轮询实现3.1 终端鉴权与心跳接口终端不是浏览器没有 Cookie 和 Session常见做法是设备首次激活时分配deviceNo和deviceSecret之后每次请求在 Header 里带X-Device-No和签名。签名算法一般是MD5(deviceNo timestamp deviceSecret)服务端用同样的方式算一遍比对同时校验 timestamp 与服务器时间差不超过 5 分钟防止重放。// TerminalAuthInterceptor.java 核心校验逻辑 String deviceNo request.getHeader(X-Device-No); String timestamp request.getHeader(X-Timestamp); String sign request.getHeader(X-Sign); // 1. 校验时间戳偏移 long diff Math.abs(System.currentTimeMillis() - Long.parseLong(timestamp)); if (diff 5 * 60 * 1000) return false; // 2. 查库拿 secret重算签名 Terminal terminal terminalMapper.selectByDeviceNo(deviceNo); String expect DigestUtils.md5Hex(deviceNo timestamp terminal.getDeviceSecret()); return expect.equalsIgnoreCase(sign);心跳接口POST /terminal/heartbeat接收终端上报的当前节目单版本、播放状态、磁盘剩余空间。服务端在响应里返回needUpdate布尔值和最新版本号。这个设计把「是否更新」的判断放在服务端终端逻辑就很简单收到needUpdatetrue就去调节目单接口。磁盘空间上报是为了防止终端存满素材后播放失败服务端可以据此触发清理指令。3.2 节目单拉取接口与增量更新节目单接口GET /terminal/program?version当前版本支持增量返回。如果终端版本和服务端一致返回 304 或空内容不一致则返回完整节目单加素材下载地址列表。素材地址不是直接给文件路径而是给一个带签名的临时 URL有效期比如 10 分钟终端拿着 URL 去下载。{ code: 0, data: { version: 12, programName: 一楼大厅促销, items: [ {materialId: 101, duration: 15, url: /terminal/material/101?tokenxxx}, {materialId: 102, duration: 10, url: /terminal/material/102?tokenyyy} ], pullInterval: 30 } }items数组的顺序就是播放顺序duration单位是秒。终端下载完所有素材后本地生成一个播放列表文件播放器按这个文件循环。这里有个坑如果某个素材下载失败终端不能直接跳过否则播放序列会错位。常见做法是下载失败时保留旧版本节目单继续播放同时上报错误等服务端下次下发时重试。3.3 终端侧轮询与本地缓存策略终端程序可以用 Java 写源码里带了一个media-terminal-client示例也可以用其他语言实现只要遵循接口协议。轮询逻辑不复杂但缓存策略要设计好。素材文件按materialId命名存在本地目录下载前先检查本地是否已存在且 MD5 匹配匹配就跳过下载。// TerminalClient.java 轮询主循环 while (running) { HeartbeatResp resp heartbeatService.report(currentVersion); if (resp.isNeedUpdate()) { ProgramResp program programService.pull(currentVersion); for (Item item : program.getItems()) { File local new File(cacheDir, item.getMaterialId() .mp4); if (!local.exists() || !md5Match(local, item.getMd5())) { download(item.getUrl(), local); // 下载失败抛异常不更新版本号 } } currentVersion program.getVersion(); // 全部成功后才更新本地版本 player.reload(program); // 通知播放器重载列表 } Thread.sleep(resp.getPullInterval() * 1000L); }currentVersion的更新必须放在所有素材下载成功之后这是保证播放一致性的关键。如果中途失败版本号不变下次心跳服务端还会返回needUpdatetrue终端重新拉取。player.reload的实现取决于播放器常见做法是写一个playlist.json然后给播放器进程发信号或者用 VLC 的 HTTP 接口控制。4. 素材管理与存储抽象从本地上传到对象存储切换4.1 素材上传接口与 MD5 去重素材上传走POST /admin/material/upload接收MultipartFile。上传前先算 MD5查库看是否已存在相同 MD5 的素材存在就直接返回已有记录不重复存文件。这个去重逻辑在大批量上传同一批海报时能省很多磁盘。// MaterialServiceImpl.java 上传去重 String md5 DigestUtils.md5Hex(file.getInputStream()); Material exist materialMapper.selectByMd5(md5); if (exist ! null) { return Result.ok(exist); // 秒传不写磁盘 } String path storageService.save(file); // 实际存储 Material material new Material(); material.setMd5(md5); material.setFilePath(path); material.setFileSize(file.getSize()); materialMapper.insert(material);storageService.save返回的是相对路径比如2024/06/abc123.mp4数据库只存相对路径不存绝对路径。这样迁移存储根目录时不用改数据。MD5 计算用DigestUtils流式计算大文件不会一次性读进内存。4.2 StorageService 接口与 MinIO 实现切换StorageService接口只有三个方法save、delete、getUrl。本地实现类把文件写到local-path下getUrl返回一个由 Controller 处理的下载地址。MinIO 实现类用minio-javaSDKgetUrl返回预签名 URL。public interface StorageService { String save(MultipartFile file); // 返回相对路径 void delete(String path); String getUrl(String path, int expireSeconds); // 临时访问地址 }切换实现只需要在application.yml里改media.storage.type配合ConditionalOnProperty注解让 Spring 注入对应的 Bean。这个模式在企业级系统里很常见核心是把「存哪里」和「怎么存」解耦。注意 MinIO 的预签名 URL 有效期不能设太长一般 10 到 30 分钟终端下载完就失效避免链接被转发盗用。4.3 素材格式校验与转码触发上传接口要校验文件类型不能只看扩展名要读文件头。常见做法是用Apache Tika检测 MIME 类型只允许video/mp4、image/jpeg、image/png等白名单类型。视频素材如果分辨率超过终端支持范围需要触发转码。源码里转码部分留了钩子实际转码一般调ffmpeg命令行。# 转码为 1080x1920 竖屏H.264 编码 ffmpeg -i input.mp4 -vf scale1080:1920:force_original_aspect_ratiodecrease,pad1080:1920:(ow-iw)/2:(oh-ih)/2 \ -c:v libx264 -preset medium -crf 23 -c:a aac -b:a 128k output.mp4force_original_aspect_ratiodecrease加pad保证不拉伸变形黑边填充。crf 23是画质和体积的平衡点数值越小画质越好体积越大。转码是异步任务上传接口返回后由后台线程处理处理完更新素材状态。终端拉取时只拿status1已就绪的素材。5. 排错与进阶版本冲突、心跳丢失与灰度发布技巧5.1 节目单版本冲突的排查路径终端播放内容和后台不一致九成是版本号问题。排查顺序先查t_terminal表里该设备的program_version字段再查t_program表里该终端所属分组绑定的节目单version两者不一致说明下发没成功。看服务端日志里needUpdate的返回值如果一直是 false 但版本确实不同检查心跳接口里比对逻辑是不是用了错误的字段。-- 查终端当前版本与目标节目单版本 SELECT t.device_no, t.program_version AS terminal_ver, p.version AS program_ver FROM t_terminal t JOIN t_program p ON p.group_id t.group_id AND p.status 1 WHERE t.device_no DEV001;如果terminal_ver小于program_ver但终端没更新检查终端本地磁盘是否满了或者素材下载是否一直失败。终端日志里一般会打下载失败的 HTTP 状态码403 说明签名过期404 说明素材被删了但节目单没更新。5.2 心跳丢失与离线判定调优终端被误判离线先看heartbeat-timeout和终端实际轮询间隔的比值。如果终端 30 秒轮询一次超时设 60 秒网络稍微抖一下就离线。合理比值是 3 到 4 倍即 30 秒轮询配 90 到 120 秒超时。另外心跳接口本身要轻量不要在里面做重查询否则终端并发高时接口响应慢也会导致超时。参数建议值说明终端轮询间隔30s太短增加服务端压力太长更新不及时心跳超时120s轮询间隔的 4 倍容忍网络抖动节目单拉取超时10s含素材列表比心跳稍长素材下载超时300s大视频文件需要更长时间5.3 灰度发布按终端分组逐步更新节目单一次性给所有终端推新节目单风险大万一素材有问题全屏黑。常见做法是按分组灰度先推一个测试组观察 10 分钟无异常再推其他组。实现上就是在节目单发布时选择目标分组服务端只更新这些分组下终端的program_version。// 灰度发布只更新指定分组 public void publish(Long programId, ListLong groupIds) { Program program programMapper.selectById(programId); program.setStatus(1); program.setVersion(program.getVersion() 1); programMapper.updateById(program); // 只更新选中分组下的终端 terminalMapper.updateVersionByGroups(groupIds, program.getVersion()); }updateVersionByGroups是一条批量 UPDATE把选中分组下所有终端的program_version改成新版本。终端下次心跳就会发现版本不一致并拉取。灰度期间如果发现问题把节目单status改回 0终端拉取时发现没有已发布节目单会继续播放本地缓存的旧版本不会黑屏。这个回滚机制比重新推一个旧节目单更快。本文还有配套的精品资源点击获取
