SpringBoot整合TinyRadius实战：如何用Java实现商场WiFi计费系统？
SpringBoot整合TinyRadius实战：商场WiFi计费系统开发指南
在商业WiFi运营场景中，计费认证系统是核心基础设施。传统方案往往需要采购昂贵的专业设备，而基于Java生态的轻量级Radius解决方案正在改变这一局面。本文将带您从零构建一个商场WiFi计费系统，结合SpringBoot的便捷性和TinyRadius的灵活性，实现包括用户认证、时长控制、流量统计等完整功能。
1. 系统架构设计与技术选型
商场WiFi系统需要应对高并发认证请求，同时要满足灵活的计费策略配置。我们采用三层架构设计：
- 接入层：使用TinyRadius处理Radius协议通信
- 业务层：SpringBoot实现计费规则和用户管理
- 数据层：MySQL存储用户信息，Redis缓存会话状态
技术栈对比：
| 组件 | 选型理由 | 替代方案 |
|---|---|---|
| Radius库 | TinyRadius（轻量级，Java原生） | JRadius |
| Web框架 | SpringBoot 2.7 | Quarkus |
| 数据库 | MySQL 8.0 | PostgreSQL |
| 缓存 | Redis 6 | Memcached |
提示：商场场景建议使用Redis集群方案，确保会话状态的高可用性
2. 开发环境搭建
2.1 基础依赖配置
在pom.xml中添加关键依赖：
<dependencies> <!-- SpringBoot基础依赖 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <!-- TinyRadius核心库 --> <dependency> <groupId>org.tinyradius</groupId> <artifactId>tinyradius</artifactId> <version>1.1.1</version> </dependency> <!-- 数据库相关 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-jpa</artifactId> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <scope>runtime</scope> </dependency> </dependencies>2.2 Radius服务器配置
创建Radius服务器配置类：
@Configuration public class RadiusConfig { @Value("${radius.secret}") private String sharedSecret; @Bean public RadiusServer radiusServer() { return new RadiusServer() { @Override public RadiusPacket handlePacket(RadiusPacket request) { // 认证请求处理逻辑 if(request.getPacketType() == AccessRequest.ACCESS_REQUEST) { return handleAccessRequest(request); } // 计费请求处理 else if(request.getPacketType() == AccountingRequest.ACCOUNTING_REQUEST) { return handleAccountingRequest(request); } return null; } }; } private RadiusPacket handleAccessRequest(RadiusPacket request) { // 实现认证逻辑 } }3. 核心功能实现
3.1 用户认证模块
商场WiFi系统需要支持多种认证方式：
- 手机号验证码登录
- 微信一键登录
- 优惠券兑换码认证
认证流程关键代码示例：
public AuthResult authenticate(String username, String password) { // 1. 验证用户状态 User user = userRepository.findByUsername(username); if(user == null || user.isDisabled()) { return AuthResult.fail("用户不存在或已禁用"); } // 2. 检查套餐有效期 if(user.getPackageExpireTime().before(new Date())) { return AuthResult.fail("套餐已过期"); } // 3. 验证凭证 if(user.getAuthType() == AuthType.PASSWORD) { if(!passwordEncoder.matches(password, user.getPassword())) { return AuthResult.fail("密码错误"); } } // 其他认证方式处理... // 4. 生成会话 String sessionId = generateSessionId(); redisTemplate.opsForValue().set( "radius:session:" + sessionId, user.getId(), 30, TimeUnit.MINUTES); return AuthResult.success(sessionId); }3.2 计费策略引擎
商场通常需要灵活的计费规则：
public class BillingEngine { // 计费规则缓存 private final Map<String, BillingRule> ruleCache = new ConcurrentHashMap<>(); public BillingResult calculate(BillingRequest request) { // 1. 获取适用规则 BillingRule rule = getApplicableRule(request.getUserType()); // 2. 计算费用 long usedTime = request.getOnlineTime(); // 分钟 double amount = 0; if(rule.getType() == RuleType.TIME_BASED) { amount = usedTime * rule.getUnitPrice(); } else if(rule.getType() == RuleType.TRAFFIC_BASED) { amount = request.getUsedTraffic() * rule.getUnitPrice() / 1024; // MB转KB } // 3. 应用优惠 amount = applyDiscounts(amount, request.getCouponCode()); return new BillingResult(amount, rule.getCurrency()); } }4. 高级功能实现
4.1 实时流量统计
使用Netty实现高性能流量采集：
public class TrafficCollectorHandler extends ChannelInboundHandlerAdapter { @Override public void channelRead(ChannelHandlerContext ctx, Object msg) { if (msg instanceof AccountingRequest) { AccountingRequest request = (AccountingRequest) msg; // 获取流量属性 long inputOctets = request.getAttributeValue("Acct-Input-Octets"); long outputOctets = request.getAttributeValue("Acct-Output-Octets"); // 更新实时统计 String sessionId = request.getAttributeValue("Acct-Session-Id"); trafficService.updateSessionTraffic( sessionId, inputOctets, outputOctets); } ctx.fireChannelRead(msg); } }4.2 优惠券营销系统
商场促销活动常用优惠券发放：
-- 优惠券数据表设计 CREATE TABLE `coupon` ( `id` bigint NOT NULL AUTO_INCREMENT, `code` varchar(32) NOT NULL COMMENT '兑换码', `type` tinyint NOT NULL COMMENT '1-时长券 2-流量券', `value` int NOT NULL COMMENT '面值', `expire_time` datetime NOT NULL, `status` tinyint DEFAULT '0' COMMENT '0-未使用 1-已使用', PRIMARY KEY (`id`), UNIQUE KEY `idx_code` (`code`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;Java实现优惠券核销：
@Transactional public CouponResult redeemCoupon(String code, Long userId) { // 1. 验证优惠券 Coupon coupon = couponRepository.findByCode(code); if(coupon == null) { return CouponResult.fail("优惠券不存在"); } if(coupon.getStatus() == 1) { return CouponResult.fail("优惠券已使用"); } if(coupon.getExpireTime().before(new Date())) { return CouponResult.fail("优惠券已过期"); } // 2. 更新用户套餐 User user = userRepository.findById(userId).orElseThrow(); if(coupon.getType() == CouponType.TIME) { user.setPackageExpireTime( DateUtils.addMinutes(user.getPackageExpireTime(), coupon.getValue())); } else if(coupon.getType() == CouponType.TRAFFIC) { user.setRemainingTraffic( user.getRemainingTraffic() + coupon.getValue()); } // 3. 标记优惠券为已使用 coupon.setStatus(1); coupon.setUsedTime(new Date()); coupon.setUserId(userId); return CouponResult.success(user); }5. 系统部署与优化
5.1 性能调优建议
商场WiFi系统需要应对节假日高峰流量：
线程池配置：
# Radius服务器线程池 radius.server.thread.min=20 radius.server.thread.max=200 radius.server.queue-capacity=1000Redis缓存策略：
@Configuration @EnableCaching public class CacheConfig { @Bean public RedisCacheManager cacheManager(RedisConnectionFactory factory) { RedisCacheConfiguration config = RedisCacheConfiguration.defaultCacheConfig() .entryTtl(Duration.ofMinutes(30)) .disableCachingNullValues() .serializeValuesWith(SerializationPair.fromSerializer( new GenericJackson2JsonRedisSerializer())); return RedisCacheManager.builder(factory) .cacheDefaults(config) .transactionAware() .build(); } }
5.2 监控与告警
集成Prometheus监控关键指标：
@RestController public class MetricsController { private final Counter authRequests = Counter.build() .name("radius_auth_requests_total") .help("Total authentication requests") .register(); private final Summary responseTime = Summary.build() .name("radius_response_time_seconds") .help("Response time in seconds") .quantile(0.5, 0.05) .quantile(0.9, 0.01) .register(); @PostMapping("/radius/auth") public ResponseEntity<?> handleAuth(@RequestBody AuthRequest request) { Summary.Timer timer = responseTime.startTimer(); try { authRequests.inc(); // 处理认证逻辑... return ResponseEntity.ok(response); } finally { timer.observeDuration(); } } }在实际部署中，我们发现TinyRadius的UDP通信模型在Linux环境下需要特别优化内核参数：
# 调整UDP缓冲区大小 sysctl -w net.core.rmem_max=16777216 sysctl -w net.core.wmem_max=16777216 sysctl -w net.ipv4.udp_mem='16777216 16777216 16777216'