简介一套基于Java开发的智能电表远程抄表缴费管理平台源码适用于物业、房东及写字楼场景面向物联网应用开发者或能源管理系统学习者。平台兼容正泰、人民、天正、许继等主流电表借助GPRS、LoRa、NB-IoT等通信方式实现远程自动抄表并整合数据处理、在线缴费、用户权限、异常报警与报表生成等功能形成完整业务闭环。资源压缩包共86个文件以77个Java源文件、8个XML配置文件和1个工程配置文件为主整体仅67KB代码结构紧凑方便快速定位远程抄表、支付接口、统计报表等核心模块。源码中的wwby-worker-ammeter工作组件承担定时采集与任务调度职责是理解系统运行机制的关键入口同时预留API接口可对接物业管理软件或楼宇自动化系统。目前已有2174人在CSDN学习浏览该资源适合用于二次开发、毕业设计或智能能源项目参考能够帮助开发者深入掌握物联网后台开发、远程通信及大数据处理实战技巧。1. 智能电表远程抄表缴费管理平台JAVA源码先看通信再看 CRUD拿到这份智能电表远程抄表缴费管理平台JAVA源码你第一眼会觉得它就是一个普通后台用户管理、电表档案、充值缴费、报表导出。但真正让它值钱的是另外两条线——一条是下行通过 Netty 长连接和 DL/T 645 协议把几千块电表的电量报文收回来一条是上行把充值、扣费、欠费拉闸串成一个能对账的资金闭环。这两条线恰好覆盖了 java 课程设计案例源码里最难自证的部分通信解析和金额一致性。这套代码适合正在做课程设计、毕设选型或者公司要快速搭一个预付费抄表平台的人不适合单表直连调试场景——那是嵌入式工程师的活。下面按抄表、缴费、避坑的顺序把这份源码里最值得改的几段讲透。2. 抄表链路Netty 收集中器报文DL/T 645 解析出电量2.1 为什么选 Netty 长连接而不是定时 HTTP 轮询抄表系统的采集端本质是“集中器主动上报”和“平台定时召测”两种模式的混合。集中器下面挂着一块或多块表它按 15 分钟抄表周期把电量、电压、电流等数据主动推到平台。如果用 HTTP 轮询每个集中器都要求平台定时发起请求几千个连接意味着每秒几十甚至上百次握手加上网关 NAT 超时、服务端线程池吃紧稳定性很快会崩。用 Netty 长连接是最常见的做法集中器主动建立 TCP 连接并保持平台侧被动解码数据到了就处理不需要反反复复创建连接。这套源码走的就是 Netty 路线采集端口独立于 Web 应用的 Tomcat 端口目的就是让通信负载和业务负载互不干扰。我一般会在部署时把采集端口固定在 5010Web 端继续用 8080两边进程都在同一个 Spring Boot 应用里但监听不同端口。这样做的好处是排查故障时能一眼区分是“电表报文没到”还是“业务接口报错”而不是两个问题混在一起查。Netty 本身是事件驱动模型Boss 线程负责 accept 新连接Worker 线程负责读写平台侧不需要给每个集中器分配一个专门线程。连接数多、报文频率高的场景下这种模型能把 CPU 利用率吃满内存却不会跟着连接数线性涨。这也是它成为物联网接入层首选的原因抄表、充电桩、水表燃气表基本都是同一套路。2.2 DL/T 645 帧结构68 开头、16 结尾的报文拆解拿到电表报文第一件事不是写代码而是认帧。DL/T 645 是国标电表通信协议07 版是现在用得最多的版本。一帧完整报文长这样字段长度说明起始符1 字节固定 0x68地址域6 字节表号BCD 编码低字节在前起始符1 字节固定 0x68控制码1 字节0x11 读数据请求0x91 读数据响应0x03 写数据请求0x83 写数据响应数据域长度1 字节数据域的字节数数据域L 字节数据标识 数据内容校验和1 字节从帧首到数据域末字节累加取低 8 位结束符1 字节固定 0x16读正向有功电能的请求数据域只有 4 字节数据标识比如00 01 00 00表示“正向有功总电能”。对应请求帧大致是68 01 02 03 04 05 06 68 11 04 00 01 00 00 CS 16。其中01 02 03 04 05 06是表号地址域11是读数据控制码04表示后面有 4 字节。电表响应时控制码变成91数据域是 4 字节数据标识加 4 字节 BCD 电量。难点全在这 4 字节 BCD 上它按低字节在前传输且每个字节拆成两个十进制位后才是真实数值。很多新手第一次抄表读出来的电量为 78563412 而不是 12345678就是没做字节序反转。2.3 电量解析代码BCD 字节序反转与小数位我在这份源码里最常改的就是电量解析函数。下面这段是从响应数据域里提取正向有功电能的 Java 方法按 645 协议处理了字节序反转public BigDecimal parseElectricity(byte[] bcdBytes) { // bcdBytes: 电表返回的正向有功电能低位字节在前 // 例如 {0x78, 0x56, 0x34, 0x12} 表示 123456.78 kWh byte[] reversed new byte[bcdBytes.length]; for (int i 0; i bcdBytes.length; i) { reversed[i] bcdBytes[bcdBytes.length - 1 - i]; } StringBuilder sb new StringBuilder(); for (byte b : reversed) { int hi (b 4) 0x0F; // BCD 高四位 int lo b 0x0F; // BCD 低四位 sb.append(hi).append(lo); } // 电表默认两位小数单位 kWh return new BigDecimal(sb.toString()).movePointLeft(2); }解析逻辑分三步先把字节数组整体反序再逐字节拆 BCD 位拼成字符串最后把字符串转成 BigDecimal 并左移两位小数。这里的参数bcdBytes是帧解码后从数据域里按数据标识偏移截取的 4 字节长度为 4。如果某块表显示 5 位整数 3 位小数直接把movePointLeft(2)改成 3 就行。实际项目中这个小数位不该写死我会建议把它做成表计档案字段每块表按厂家规约配置。原因很简单居民表、工商业表、老式机械表改制后的电子表小数位可能都不一样写死等于埋雷。更稳妥的做法是解析时先查表档案拿到scale参数再决定移几位。2.4 Spring Boot 集成 Netty 服务端的启动骨架Netty 接入层在 Spring Boot 里通常做成一个独立组件应用启动时自动拉起采集端口。核心骨架代码如下EventLoopGroup bossGroup new NioEventLoopGroup(1); EventLoopGroup workerGroup new NioEventLoopGroup(Runtime.getRuntime().availableProcessors() * 2); ServerBootstrap bootstrap new ServerBootstrap(); bootstrap.group(bossGroup, workerGroup) .channel(NioServerSocketChannel.class) .childHandler(new ChannelInitializerSocketChannel() { Override protected void initChannel(SocketChannel ch) { ChannelPipeline pipeline ch.pipeline(); pipeline.addLast(new MeterFrameDecoder()); // 自定义拆帧处理器 pipeline.addLast(new MeterMessageHandler()); // 业务处理器解析、入库、扣费 } }) .option(ChannelOption.SO_BACKLOG, 1024) .childOption(ChannelOption.SO_KEEPALIVE, true); ChannelFuture future bootstrap.bind(5010).sync();这段代码里的MeterFrameDecoder是自定义的ByteToMessageDecoder负责把 TCP 流里粘包、拆包的字节流切成完整帧逻辑就是找 0x68 开头、0x16 结尾的有效帧期间校验控制码、长度和校验和。MeterMessageHandler拿到完整帧后调用 2.3 里的解析方法再把结果写库。参数上要关注两处SO_BACKLOG设 1024 表示等待连接的队列长度集中器数量多时可以调大SO_KEEPALIVE开启后TCP 层会定期探活防止集中器掉线后服务端感知不到。这里有个经验值一条连接如果 90 秒内没有数据交互TCP 保活探测就开始工作但对于抄表这种 15 分钟才来一次报文的场景光靠内核保活不够应用层还要自己做超时判断这放到第 4 章讲。3. 缴费与销账余额账户、乐观锁扣费与充值幂等3.1 预付费模式的账户表设计抄表缴费平台的资金核心是“预付费”模型用户先充值平台再按实际用电量扣费余额不足时触发告警甚至拉闸。这种模型下账户表设计比普通用户表复杂至少需要“总余额”和“冻结金额”两个概念。冻结金额常见于阶梯电价调整、退款处理或异常复核期扣费时优先扣可用余额。账户表的 SQL 我建议这么建CREATE TABLE account ( id BIGINT PRIMARY KEY AUTO_INCREMENT, user_id BIGINT NOT NULL COMMENT 用户ID, total_balance DECIMAL(12,2) NOT NULL DEFAULT 0.00 COMMENT 可用余额, freeze_balance DECIMAL(12,2) NOT NULL DEFAULT 0.00 COMMENT 冻结金额, status TINYINT NOT NULL DEFAULT 1 COMMENT 1正常 2停用, version INT NOT NULL DEFAULT 0 COMMENT 乐观锁版本号, update_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, UNIQUE KEY uk_user (user_id) ) ENGINEInnoDB;字段逻辑很直白user_id加唯一索引防止同一用户建出多个账户total_balance用 DECIMAL(12,2) 而不是 DOUBLE因为金额字段一旦用浮点类型累计几千笔后就会出精度差这是财务系统的底线。version字段是给乐观锁用的第 3.2 节会详细讲。这里有个容易被忽略的点账户表单独建不要和用户信息表混在一起。用户的姓名、手机号、地址是低频变更数据账户余额是高频变更数据混在一张表里会导致用户资料每次余额变动都跟着锁行业务高峰期数据库连接很容易打满。3.2 扣费事务乐观锁版本号防止余额扣成负数扣费是抄表平台里并发最高的写操作。同一时刻可能有多笔扣费请求打到同一个账户上比如实时抄表扣费、手动补扣、异常追补电费同时发生。如果不做并发控制两笔扣费都读到余额 50 元各自扣掉 30 元最后余额变成 20 元而不是 -10 元账就平不上。用悲观锁SELECT ... FOR UPDATE能解决但性能差高并发场景下会把账户行锁死。我一般采用乐观锁在扣费 SQL 里带版本号条件Transactional public boolean deduct(Integer userId, BigDecimal amount) { Account account accountMapper.selectByUserId(userId); if (account.getTotalBalance().compareTo(amount) 0) { return false; // 余额不足返回给业务层提示 } BigDecimal newBalance account.getTotalBalance().subtract(amount); int rows accountMapper.deduct(userId, newBalance, account.getVersion()); return rows 1; }对应的 Mapper SQLUPDATE account SET total_balance #{newBalance}, version version 1 WHERE user_id #{userId} AND version #{version}这个设计的要点在WHERE version #{version}如果两条并发扣费同时读到了同一版本号只有先执行的那条能把行数更新成 1后执行的那条影响行数为 0deduct返回 false业务层就知道需要重试或提示余额不足。version每次加 1天然形成了一个乐观锁版本链。扣费方法必须加Transactional而且事务要确保“查询余额”和“更新余额”在同一个事务里否则查询和更新之间被其他线程插进来版本号判断就白做了。这块在第 4 章会作为典型踩坑案例重点讲。3.3 充值回调幂等同一笔订单不能到账两次充值链路比扣费更容易出资金事故。用户通过支付通道付款后支付平台回调你的接口告诉你订单已支付成功。回调可能自动重试、网络抖动导致重复投递如果接口没有幂等处理同一订单被处理两次用户余额就翻倍了。充值到账方法我一般这么写Transactional public void recharge(RechargeOrder order) { // 先按订单号查状态已成功直接返回 RechargeOrder exist orderMapper.selectByOrderNo(order.getOrderNo()); if (SUCCESS.equals(exist.getStatus())) { return; } // 同一事务内更新订单状态并给账户加钱 orderMapper.updateStatus(order.getOrderNo(), SUCCESS); accountMapper.increaseBalance(order.getUserId(), order.getAmount()); }这里有两个保护层第一层是业务幂等订单状态为 SUCCESS 就直接返回第二层是数据库约束order_no字段加唯一索引即使两个事务同时通过状态判断第二个事务插入或更新时会撞唯一索引直接报错。两层一起用才称得上真正幂等。需要注意的是updateStatus和increaseBalance必须在同一个事务里。如果订单状态先改成 SUCCESS账户加钱失败抛异常事务回滚会把状态改回未支付这样下次回调还能继续处理。事务顺序不能反过来否则加钱成功但状态没更新回调重试就会二次到账。3.4 日冻结与峰谷平计费抄表数据的二次加工实时抄表拿到的是瞬时电量但用户按的是“日冻结电量”计费。所谓日冻结就是每天零点把电表读数抓一次存到meter_daily_freeze表当天用量等于今日冻结读数减去昨日冻结读数。这套源码里如果没有独立冻结表建议自己加一张字段至少包含表号、冻结日期、总电量、尖峰平谷各时段电量。峰谷平计费的逻辑是先按梯度时间把一天切成尖、峰、平、谷四个时段然后分别用时段电量乘以对应电价。比如峰段电价 1.2 元/度谷段 0.4 元/度同样的日均用电量用户夜间用电占比高电费就明显低。计算时注意两点——时段边界要能配置不能写死跨月冻结要单独处理月底最后一天和月初第一天的读数差值要整月归集不然月末对账会差一笔。冻结表建议按表号加日期做联合唯一索引防止同一个表的同一天被写入两条记录。每天零点跑批时先删后插或者用INSERT ... ON DUPLICATE KEY UPDATE都是常见做法我倾向于后者保留原始数据的同时支持重跑。4. 抄表缴费平台避坑字节序、端口冲突与事务失效五连4.1 电表读数多一位BCD 高低位反转与小数位不匹配现象平台抄回来的电量比电表液晶屏上显示的大很多常见的是 78563412 对 12345678或者读数差 10 倍、100 倍。原因两处。一是 645 协议低字节在前没处理字节序反了二是电表内部设定的小数位是 1 位或 3 位代码里写死 2 位导致数值被放大或缩小。解决解析函数的字节反转逻辑按第 2.3 节处理小数位别写死从表计档案里读取。接新表型时用厂家规约文档里的示例报文做对拍测试把“原始 BCD 字节 → 期望读数”写成单元测试用例再上线。这种问题靠肉眼盯数据是盯不出来的必须自动化验证。4.2 采集端口起不来5010 被残留进程占用现象应用启动时 Tomcat 8080 正常Netty 采集服务报Address already in use或者启动后集中器连接全部失败。原因上次服务异常退出采集进程没被杀干净或者同一台机器上部署了两套实例都抢 5010 端口。解决启动前先查端口占用。Linux 用lsof -i:5010找到 PID 再kill -9Windows 用netstat -ano | findstr 5010查 PID 后到任务管理器结束。更彻底的办法是把采集端口写进application.yml通过环境变量注入避免代码里写死。部署多实例时每个实例用不同采集端口同时保证集中器侧的下发地址配置能区分。4.3 充值到账但余额没变update 把累加写成了覆盖现象支付回调日志显示成功订单状态也变成了 SUCCESS但用户余额纹丝不动再调一次余额居然变负数。原因账户加钱的 SQL 写成了SET total_balance #{amount}直接把余额覆盖成充值金额而不是balance amount。第二次充值又覆盖一次之前余额彻底丢了扣费同理。解决加钱用SET total_balance total_balance #{amount}扣费用SET total_balance total_balance - #{amount}并且永远不要在代码里先查出余额再算新余额写回——那样做又会引入并发覆盖问题。如果底层用了乐观锁那新余额计算必须基于查询到的原值和版本号不能拿一个游离的 BigDecimal 做值覆盖。4.4 峰谷平电费对不上电表时钟漂移导致冻结时刻错位现象月末结算的峰谷平电费和人工抄表算出来差一截有些时段电量明显偏高偏低。原因电表内部时钟用了半年之后漂移几分钟甚至十几分钟平台零点去冻结读数时表端可能已经走到 00:12数据被记入了错误的计费时段。解决第一每天定时给电表下发对时命令用服务器时间校准表端时钟第二日冻结任务不要只在零点跑一次而是零点前后各跑一次取最接近零点整的读数第三时段电量统计以服务器接收到的数据标识里的“时段标记”为准不要用表内的当日时段自行切分。做过一轮对时之后这类问题基本能消除但每季度还是要抽检几块表复核。4.5 启动报源发行版 17 错误JAVA_HOME 和 Maven 编译级别不一致现象项目启动时控制台打印警告: 源发行版 17 需要目标发行版 17或者直接编译失败提示无效的源发行版。原因环境变量 JAVA_HOME 指向 JDK 8但 pom.xml 里配置了maven.compiler.source/target为 17或者反过来IDE 的 Project SDK 和 Maven 用的 JDK 不是同一个。这是 java 环境变量配置里最常见的问题一般刚拿到源码的新手必踩。解决三步对齐——命令行执行java -version确认 JAVA_HOME查看 pom.xml 里 compiler 插件或 properties 里的版本号IDEA 里Project Structure → Project SDK选同一个 JDK。三个地方的版本号必须一致Maven 才会按同一套 JDK 编译。建议直接把JAVA_HOME配成 JDK 17同时在~/.bashrc或系统环境变量里固定避免每次换终端重新配。5. 跑通之后再加三样压测、掉线告警与远程拉闸5.1 用测试帧对采集端口做简单压测项目能跑通不代表能扛得住真实负载。我习惯在接入大量集中器之前先对采集端口做一轮冒烟压测。写一个极简的发送脚本用 Linuxnc命令模拟集中器往 5010 端口发帧for i in $(seq 1 2000); do echo -ne \x68\x01\x02\x03\x04\x05\x06\x68\x11\x04\x00\x01\x00\x00\xa0\x16 | nc -w 1 127.0.0.1 5010 sleep 0.05 done脚本每 50 毫秒发一个读数据请求帧持续约 100 秒。观察两个指标Netty 服务端有没有 Basic日志报解码错误以及 Worker 线程的 CPU 占用是否稳定。2000 个连接里如果出现大量Failed to decode多半是帧切分逻辑有边界条件问题比如粘包场景下第二个帧的起始符被前一个帧吃掉。压测参数参考单条消息处理耗时小于 20 毫秒2000 条消息全部入库无积压CPU 单核占用低于 70%基本可以认为接入层合格。如果 CPU 打满优先检查数据库写入是否有批量插入逐条 insert 很容易把瓶颈压在 JDBC 上。5.2 掉线告警15 分钟未上报的设备自动进 Redis 延迟队列集中器掉线是抄表平台的常态问题不是“会不会掉”而是“多久能发现”。抄表周期是 15 分钟意味着如果哪个表超过 15 分钟没上报它可能已经离线了。一个不依赖定时扫描的办法是每台设备建立心跳时间戳用一个 Redis ZSET 保存所有设备的最后上报时间每隔 1 分钟用ZADD更新再用ZRANGEBYSCORE查出超过 20 分钟没上报的设备列表推给运维。延迟队列的做法更适合大量设备上报时把设备号塞进 Redis 延迟队列设置 15 分钟后执行检查如果期间有新报文直接删除旧任务重新投放。这样可以做到秒级发现掉线又不会每台设备都占用一个定时器。告警消息推给企业微信或者短信通道都行关键是别在服务端打印日志就当通知了生产环境日志没人盯着看。5.3 远程拉闸写命令控制码与数据标识的注意事项预付费系统的最后一步是欠费拉闸。远程拉闸本质是向电表下发一条写数据命令控制码固定为 0x03响应是 0x83。写命令的数据域除了数据标识还要带操作内容比如继电器分闸操作。发送前要确认三件事表端是否支持远程拉闸功能该功能是否在用户合同里有约定写命令下发后电表会返回执行结果必须先解析响应再更新平台侧的开关状态不能发完就认为闸已经拉了拉闸命令漏发任一字节都有可能导致控制失败所以校验和计算一定要用封装好的工具类不要手算。从安全角度我多说一句涉及用户用电安全的操作拉闸、合闸、保电设置必须在平台侧留操作日志并做二次确认。哪怕用户欠费系统自动拉闸也要保证只拉单块表不能因为地址域写错把整条回路的表全断了。这也是这套源码交付到生产环境之前必须补强的地方。我第一次部署这类平台时就因为没做报文返回值解析把拉闸失败的表当成了已跳闸接着又发了合闸命令结果两套指令在链路里打架。从那以后我每次接新表型都会先把写命令的响应码、执行状态偏移整理成测试用例通过了才让采集链路跑真实指令。通讯这种事翻车多了你会发现没有玄学全是协议管着的数据位和时序。希望帮到你。本文还有配套的精品资源点击获取 智能电表远程抄表缴费平台Java源码：Netty通信与DL/T645解析
简介一套基于Java开发的智能电表远程抄表缴费管理平台源码适用于物业、房东及写字楼场景面向物联网应用开发者或能源管理系统学习者。平台兼容正泰、人民、天正、许继等主流电表借助GPRS、LoRa、NB-IoT等通信方式实现远程自动抄表并整合数据处理、在线缴费、用户权限、异常报警与报表生成等功能形成完整业务闭环。资源压缩包共86个文件以77个Java源文件、8个XML配置文件和1个工程配置文件为主整体仅67KB代码结构紧凑方便快速定位远程抄表、支付接口、统计报表等核心模块。源码中的wwby-worker-ammeter工作组件承担定时采集与任务调度职责是理解系统运行机制的关键入口同时预留API接口可对接物业管理软件或楼宇自动化系统。目前已有2174人在CSDN学习浏览该资源适合用于二次开发、毕业设计或智能能源项目参考能够帮助开发者深入掌握物联网后台开发、远程通信及大数据处理实战技巧。1. 智能电表远程抄表缴费管理平台JAVA源码先看通信再看 CRUD拿到这份智能电表远程抄表缴费管理平台JAVA源码你第一眼会觉得它就是一个普通后台用户管理、电表档案、充值缴费、报表导出。但真正让它值钱的是另外两条线——一条是下行通过 Netty 长连接和 DL/T 645 协议把几千块电表的电量报文收回来一条是上行把充值、扣费、欠费拉闸串成一个能对账的资金闭环。这两条线恰好覆盖了 java 课程设计案例源码里最难自证的部分通信解析和金额一致性。这套代码适合正在做课程设计、毕设选型或者公司要快速搭一个预付费抄表平台的人不适合单表直连调试场景——那是嵌入式工程师的活。下面按抄表、缴费、避坑的顺序把这份源码里最值得改的几段讲透。2. 抄表链路Netty 收集中器报文DL/T 645 解析出电量2.1 为什么选 Netty 长连接而不是定时 HTTP 轮询抄表系统的采集端本质是“集中器主动上报”和“平台定时召测”两种模式的混合。集中器下面挂着一块或多块表它按 15 分钟抄表周期把电量、电压、电流等数据主动推到平台。如果用 HTTP 轮询每个集中器都要求平台定时发起请求几千个连接意味着每秒几十甚至上百次握手加上网关 NAT 超时、服务端线程池吃紧稳定性很快会崩。用 Netty 长连接是最常见的做法集中器主动建立 TCP 连接并保持平台侧被动解码数据到了就处理不需要反反复复创建连接。这套源码走的就是 Netty 路线采集端口独立于 Web 应用的 Tomcat 端口目的就是让通信负载和业务负载互不干扰。我一般会在部署时把采集端口固定在 5010Web 端继续用 8080两边进程都在同一个 Spring Boot 应用里但监听不同端口。这样做的好处是排查故障时能一眼区分是“电表报文没到”还是“业务接口报错”而不是两个问题混在一起查。Netty 本身是事件驱动模型Boss 线程负责 accept 新连接Worker 线程负责读写平台侧不需要给每个集中器分配一个专门线程。连接数多、报文频率高的场景下这种模型能把 CPU 利用率吃满内存却不会跟着连接数线性涨。这也是它成为物联网接入层首选的原因抄表、充电桩、水表燃气表基本都是同一套路。2.2 DL/T 645 帧结构68 开头、16 结尾的报文拆解拿到电表报文第一件事不是写代码而是认帧。DL/T 645 是国标电表通信协议07 版是现在用得最多的版本。一帧完整报文长这样字段长度说明起始符1 字节固定 0x68地址域6 字节表号BCD 编码低字节在前起始符1 字节固定 0x68控制码1 字节0x11 读数据请求0x91 读数据响应0x03 写数据请求0x83 写数据响应数据域长度1 字节数据域的字节数数据域L 字节数据标识 数据内容校验和1 字节从帧首到数据域末字节累加取低 8 位结束符1 字节固定 0x16读正向有功电能的请求数据域只有 4 字节数据标识比如00 01 00 00表示“正向有功总电能”。对应请求帧大致是68 01 02 03 04 05 06 68 11 04 00 01 00 00 CS 16。其中01 02 03 04 05 06是表号地址域11是读数据控制码04表示后面有 4 字节。电表响应时控制码变成91数据域是 4 字节数据标识加 4 字节 BCD 电量。难点全在这 4 字节 BCD 上它按低字节在前传输且每个字节拆成两个十进制位后才是真实数值。很多新手第一次抄表读出来的电量为 78563412 而不是 12345678就是没做字节序反转。2.3 电量解析代码BCD 字节序反转与小数位我在这份源码里最常改的就是电量解析函数。下面这段是从响应数据域里提取正向有功电能的 Java 方法按 645 协议处理了字节序反转public BigDecimal parseElectricity(byte[] bcdBytes) { // bcdBytes: 电表返回的正向有功电能低位字节在前 // 例如 {0x78, 0x56, 0x34, 0x12} 表示 123456.78 kWh byte[] reversed new byte[bcdBytes.length]; for (int i 0; i bcdBytes.length; i) { reversed[i] bcdBytes[bcdBytes.length - 1 - i]; } StringBuilder sb new StringBuilder(); for (byte b : reversed) { int hi (b 4) 0x0F; // BCD 高四位 int lo b 0x0F; // BCD 低四位 sb.append(hi).append(lo); } // 电表默认两位小数单位 kWh return new BigDecimal(sb.toString()).movePointLeft(2); }解析逻辑分三步先把字节数组整体反序再逐字节拆 BCD 位拼成字符串最后把字符串转成 BigDecimal 并左移两位小数。这里的参数bcdBytes是帧解码后从数据域里按数据标识偏移截取的 4 字节长度为 4。如果某块表显示 5 位整数 3 位小数直接把movePointLeft(2)改成 3 就行。实际项目中这个小数位不该写死我会建议把它做成表计档案字段每块表按厂家规约配置。原因很简单居民表、工商业表、老式机械表改制后的电子表小数位可能都不一样写死等于埋雷。更稳妥的做法是解析时先查表档案拿到scale参数再决定移几位。2.4 Spring Boot 集成 Netty 服务端的启动骨架Netty 接入层在 Spring Boot 里通常做成一个独立组件应用启动时自动拉起采集端口。核心骨架代码如下EventLoopGroup bossGroup new NioEventLoopGroup(1); EventLoopGroup workerGroup new NioEventLoopGroup(Runtime.getRuntime().availableProcessors() * 2); ServerBootstrap bootstrap new ServerBootstrap(); bootstrap.group(bossGroup, workerGroup) .channel(NioServerSocketChannel.class) .childHandler(new ChannelInitializerSocketChannel() { Override protected void initChannel(SocketChannel ch) { ChannelPipeline pipeline ch.pipeline(); pipeline.addLast(new MeterFrameDecoder()); // 自定义拆帧处理器 pipeline.addLast(new MeterMessageHandler()); // 业务处理器解析、入库、扣费 } }) .option(ChannelOption.SO_BACKLOG, 1024) .childOption(ChannelOption.SO_KEEPALIVE, true); ChannelFuture future bootstrap.bind(5010).sync();这段代码里的MeterFrameDecoder是自定义的ByteToMessageDecoder负责把 TCP 流里粘包、拆包的字节流切成完整帧逻辑就是找 0x68 开头、0x16 结尾的有效帧期间校验控制码、长度和校验和。MeterMessageHandler拿到完整帧后调用 2.3 里的解析方法再把结果写库。参数上要关注两处SO_BACKLOG设 1024 表示等待连接的队列长度集中器数量多时可以调大SO_KEEPALIVE开启后TCP 层会定期探活防止集中器掉线后服务端感知不到。这里有个经验值一条连接如果 90 秒内没有数据交互TCP 保活探测就开始工作但对于抄表这种 15 分钟才来一次报文的场景光靠内核保活不够应用层还要自己做超时判断这放到第 4 章讲。3. 缴费与销账余额账户、乐观锁扣费与充值幂等3.1 预付费模式的账户表设计抄表缴费平台的资金核心是“预付费”模型用户先充值平台再按实际用电量扣费余额不足时触发告警甚至拉闸。这种模型下账户表设计比普通用户表复杂至少需要“总余额”和“冻结金额”两个概念。冻结金额常见于阶梯电价调整、退款处理或异常复核期扣费时优先扣可用余额。账户表的 SQL 我建议这么建CREATE TABLE account ( id BIGINT PRIMARY KEY AUTO_INCREMENT, user_id BIGINT NOT NULL COMMENT 用户ID, total_balance DECIMAL(12,2) NOT NULL DEFAULT 0.00 COMMENT 可用余额, freeze_balance DECIMAL(12,2) NOT NULL DEFAULT 0.00 COMMENT 冻结金额, status TINYINT NOT NULL DEFAULT 1 COMMENT 1正常 2停用, version INT NOT NULL DEFAULT 0 COMMENT 乐观锁版本号, update_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, UNIQUE KEY uk_user (user_id) ) ENGINEInnoDB;字段逻辑很直白user_id加唯一索引防止同一用户建出多个账户total_balance用 DECIMAL(12,2) 而不是 DOUBLE因为金额字段一旦用浮点类型累计几千笔后就会出精度差这是财务系统的底线。version字段是给乐观锁用的第 3.2 节会详细讲。这里有个容易被忽略的点账户表单独建不要和用户信息表混在一起。用户的姓名、手机号、地址是低频变更数据账户余额是高频变更数据混在一张表里会导致用户资料每次余额变动都跟着锁行业务高峰期数据库连接很容易打满。3.2 扣费事务乐观锁版本号防止余额扣成负数扣费是抄表平台里并发最高的写操作。同一时刻可能有多笔扣费请求打到同一个账户上比如实时抄表扣费、手动补扣、异常追补电费同时发生。如果不做并发控制两笔扣费都读到余额 50 元各自扣掉 30 元最后余额变成 20 元而不是 -10 元账就平不上。用悲观锁SELECT ... FOR UPDATE能解决但性能差高并发场景下会把账户行锁死。我一般采用乐观锁在扣费 SQL 里带版本号条件Transactional public boolean deduct(Integer userId, BigDecimal amount) { Account account accountMapper.selectByUserId(userId); if (account.getTotalBalance().compareTo(amount) 0) { return false; // 余额不足返回给业务层提示 } BigDecimal newBalance account.getTotalBalance().subtract(amount); int rows accountMapper.deduct(userId, newBalance, account.getVersion()); return rows 1; }对应的 Mapper SQLUPDATE account SET total_balance #{newBalance}, version version 1 WHERE user_id #{userId} AND version #{version}这个设计的要点在WHERE version #{version}如果两条并发扣费同时读到了同一版本号只有先执行的那条能把行数更新成 1后执行的那条影响行数为 0deduct返回 false业务层就知道需要重试或提示余额不足。version每次加 1天然形成了一个乐观锁版本链。扣费方法必须加Transactional而且事务要确保“查询余额”和“更新余额”在同一个事务里否则查询和更新之间被其他线程插进来版本号判断就白做了。这块在第 4 章会作为典型踩坑案例重点讲。3.3 充值回调幂等同一笔订单不能到账两次充值链路比扣费更容易出资金事故。用户通过支付通道付款后支付平台回调你的接口告诉你订单已支付成功。回调可能自动重试、网络抖动导致重复投递如果接口没有幂等处理同一订单被处理两次用户余额就翻倍了。充值到账方法我一般这么写Transactional public void recharge(RechargeOrder order) { // 先按订单号查状态已成功直接返回 RechargeOrder exist orderMapper.selectByOrderNo(order.getOrderNo()); if (SUCCESS.equals(exist.getStatus())) { return; } // 同一事务内更新订单状态并给账户加钱 orderMapper.updateStatus(order.getOrderNo(), SUCCESS); accountMapper.increaseBalance(order.getUserId(), order.getAmount()); }这里有两个保护层第一层是业务幂等订单状态为 SUCCESS 就直接返回第二层是数据库约束order_no字段加唯一索引即使两个事务同时通过状态判断第二个事务插入或更新时会撞唯一索引直接报错。两层一起用才称得上真正幂等。需要注意的是updateStatus和increaseBalance必须在同一个事务里。如果订单状态先改成 SUCCESS账户加钱失败抛异常事务回滚会把状态改回未支付这样下次回调还能继续处理。事务顺序不能反过来否则加钱成功但状态没更新回调重试就会二次到账。3.4 日冻结与峰谷平计费抄表数据的二次加工实时抄表拿到的是瞬时电量但用户按的是“日冻结电量”计费。所谓日冻结就是每天零点把电表读数抓一次存到meter_daily_freeze表当天用量等于今日冻结读数减去昨日冻结读数。这套源码里如果没有独立冻结表建议自己加一张字段至少包含表号、冻结日期、总电量、尖峰平谷各时段电量。峰谷平计费的逻辑是先按梯度时间把一天切成尖、峰、平、谷四个时段然后分别用时段电量乘以对应电价。比如峰段电价 1.2 元/度谷段 0.4 元/度同样的日均用电量用户夜间用电占比高电费就明显低。计算时注意两点——时段边界要能配置不能写死跨月冻结要单独处理月底最后一天和月初第一天的读数差值要整月归集不然月末对账会差一笔。冻结表建议按表号加日期做联合唯一索引防止同一个表的同一天被写入两条记录。每天零点跑批时先删后插或者用INSERT ... ON DUPLICATE KEY UPDATE都是常见做法我倾向于后者保留原始数据的同时支持重跑。4. 抄表缴费平台避坑字节序、端口冲突与事务失效五连4.1 电表读数多一位BCD 高低位反转与小数位不匹配现象平台抄回来的电量比电表液晶屏上显示的大很多常见的是 78563412 对 12345678或者读数差 10 倍、100 倍。原因两处。一是 645 协议低字节在前没处理字节序反了二是电表内部设定的小数位是 1 位或 3 位代码里写死 2 位导致数值被放大或缩小。解决解析函数的字节反转逻辑按第 2.3 节处理小数位别写死从表计档案里读取。接新表型时用厂家规约文档里的示例报文做对拍测试把“原始 BCD 字节 → 期望读数”写成单元测试用例再上线。这种问题靠肉眼盯数据是盯不出来的必须自动化验证。4.2 采集端口起不来5010 被残留进程占用现象应用启动时 Tomcat 8080 正常Netty 采集服务报Address already in use或者启动后集中器连接全部失败。原因上次服务异常退出采集进程没被杀干净或者同一台机器上部署了两套实例都抢 5010 端口。解决启动前先查端口占用。Linux 用lsof -i:5010找到 PID 再kill -9Windows 用netstat -ano | findstr 5010查 PID 后到任务管理器结束。更彻底的办法是把采集端口写进application.yml通过环境变量注入避免代码里写死。部署多实例时每个实例用不同采集端口同时保证集中器侧的下发地址配置能区分。4.3 充值到账但余额没变update 把累加写成了覆盖现象支付回调日志显示成功订单状态也变成了 SUCCESS但用户余额纹丝不动再调一次余额居然变负数。原因账户加钱的 SQL 写成了SET total_balance #{amount}直接把余额覆盖成充值金额而不是balance amount。第二次充值又覆盖一次之前余额彻底丢了扣费同理。解决加钱用SET total_balance total_balance #{amount}扣费用SET total_balance total_balance - #{amount}并且永远不要在代码里先查出余额再算新余额写回——那样做又会引入并发覆盖问题。如果底层用了乐观锁那新余额计算必须基于查询到的原值和版本号不能拿一个游离的 BigDecimal 做值覆盖。4.4 峰谷平电费对不上电表时钟漂移导致冻结时刻错位现象月末结算的峰谷平电费和人工抄表算出来差一截有些时段电量明显偏高偏低。原因电表内部时钟用了半年之后漂移几分钟甚至十几分钟平台零点去冻结读数时表端可能已经走到 00:12数据被记入了错误的计费时段。解决第一每天定时给电表下发对时命令用服务器时间校准表端时钟第二日冻结任务不要只在零点跑一次而是零点前后各跑一次取最接近零点整的读数第三时段电量统计以服务器接收到的数据标识里的“时段标记”为准不要用表内的当日时段自行切分。做过一轮对时之后这类问题基本能消除但每季度还是要抽检几块表复核。4.5 启动报源发行版 17 错误JAVA_HOME 和 Maven 编译级别不一致现象项目启动时控制台打印警告: 源发行版 17 需要目标发行版 17或者直接编译失败提示无效的源发行版。原因环境变量 JAVA_HOME 指向 JDK 8但 pom.xml 里配置了maven.compiler.source/target为 17或者反过来IDE 的 Project SDK 和 Maven 用的 JDK 不是同一个。这是 java 环境变量配置里最常见的问题一般刚拿到源码的新手必踩。解决三步对齐——命令行执行java -version确认 JAVA_HOME查看 pom.xml 里 compiler 插件或 properties 里的版本号IDEA 里Project Structure → Project SDK选同一个 JDK。三个地方的版本号必须一致Maven 才会按同一套 JDK 编译。建议直接把JAVA_HOME配成 JDK 17同时在~/.bashrc或系统环境变量里固定避免每次换终端重新配。5. 跑通之后再加三样压测、掉线告警与远程拉闸5.1 用测试帧对采集端口做简单压测项目能跑通不代表能扛得住真实负载。我习惯在接入大量集中器之前先对采集端口做一轮冒烟压测。写一个极简的发送脚本用 Linuxnc命令模拟集中器往 5010 端口发帧for i in $(seq 1 2000); do echo -ne \x68\x01\x02\x03\x04\x05\x06\x68\x11\x04\x00\x01\x00\x00\xa0\x16 | nc -w 1 127.0.0.1 5010 sleep 0.05 done脚本每 50 毫秒发一个读数据请求帧持续约 100 秒。观察两个指标Netty 服务端有没有 Basic日志报解码错误以及 Worker 线程的 CPU 占用是否稳定。2000 个连接里如果出现大量Failed to decode多半是帧切分逻辑有边界条件问题比如粘包场景下第二个帧的起始符被前一个帧吃掉。压测参数参考单条消息处理耗时小于 20 毫秒2000 条消息全部入库无积压CPU 单核占用低于 70%基本可以认为接入层合格。如果 CPU 打满优先检查数据库写入是否有批量插入逐条 insert 很容易把瓶颈压在 JDBC 上。5.2 掉线告警15 分钟未上报的设备自动进 Redis 延迟队列集中器掉线是抄表平台的常态问题不是“会不会掉”而是“多久能发现”。抄表周期是 15 分钟意味着如果哪个表超过 15 分钟没上报它可能已经离线了。一个不依赖定时扫描的办法是每台设备建立心跳时间戳用一个 Redis ZSET 保存所有设备的最后上报时间每隔 1 分钟用ZADD更新再用ZRANGEBYSCORE查出超过 20 分钟没上报的设备列表推给运维。延迟队列的做法更适合大量设备上报时把设备号塞进 Redis 延迟队列设置 15 分钟后执行检查如果期间有新报文直接删除旧任务重新投放。这样可以做到秒级发现掉线又不会每台设备都占用一个定时器。告警消息推给企业微信或者短信通道都行关键是别在服务端打印日志就当通知了生产环境日志没人盯着看。5.3 远程拉闸写命令控制码与数据标识的注意事项预付费系统的最后一步是欠费拉闸。远程拉闸本质是向电表下发一条写数据命令控制码固定为 0x03响应是 0x83。写命令的数据域除了数据标识还要带操作内容比如继电器分闸操作。发送前要确认三件事表端是否支持远程拉闸功能该功能是否在用户合同里有约定写命令下发后电表会返回执行结果必须先解析响应再更新平台侧的开关状态不能发完就认为闸已经拉了拉闸命令漏发任一字节都有可能导致控制失败所以校验和计算一定要用封装好的工具类不要手算。从安全角度我多说一句涉及用户用电安全的操作拉闸、合闸、保电设置必须在平台侧留操作日志并做二次确认。哪怕用户欠费系统自动拉闸也要保证只拉单块表不能因为地址域写错把整条回路的表全断了。这也是这套源码交付到生产环境之前必须补强的地方。我第一次部署这类平台时就因为没做报文返回值解析把拉闸失败的表当成了已跳闸接着又发了合闸命令结果两套指令在链路里打架。从那以后我每次接新表型都会先把写命令的响应码、执行状态偏移整理成测试用例通过了才让采集链路跑真实指令。通讯这种事翻车多了你会发现没有玄学全是协议管着的数据位和时序。希望帮到你。本文还有配套的精品资源点击获取