1. 项目背景与需求解析在短信营销和通知类业务场景中我们经常需要处理手机号码的批量发送需求。假设现在有1000个手机号码需要发送相同的营销内容如果采用单条发送的方式不仅效率低下还会对短信网关造成不必要的压力。这时候就需要一种高效的号码拼接方案。传统字符串拼接使用运算符会频繁创建新对象在数据量大的情况下将严重影响性能。而StringBuilder作为Java提供的可变字符序列类恰恰能解决这个问题。它通过维护一个可扩展的字符数组避免了中间对象的创建特别适合这种需要频繁修改字符串的场景。实际测试表明用拼接1000个手机号码耗时约120ms而StringBuilder仅需8ms性能提升15倍2. 核心技术实现方案2.1 StringBuilder基础用法StringBuilder的核心优势在于其可变性。与StringBuffer相比它放弃了线程安全换取更高性能在短信发送这种明确单线程操作的场景下是最佳选择。基础构造方法有三种// 默认构造初始容量16字符 StringBuilder sb1 new StringBuilder(); // 指定初始容量 StringBuilder sb2 new StringBuilder(100); // 基于已有字符串构造 StringBuilder sb3 new StringBuilder(138);关键操作方法包括append()追加内容insert()在指定位置插入delete()删除子串reverse()反转字符串2.2 手机号码拼接实现假设我们有一个手机号码列表List phoneNumbers标准实现如下public String buildPhoneNumberString(ListString phoneNumbers) { StringBuilder sb new StringBuilder(phoneNumbers.size() * 12); // 预分配空间 for (int i 0; i phoneNumbers.size(); i) { if (i 0) { sb.append(,); // 非首个元素添加分隔符 } sb.append(phoneNumbers.get(i)); } return sb.toString(); }几个优化点值得注意初始化时根据预估长度设置容量每个号码11位逗号≈12字符使用if判断避免首元素前出现多余逗号链式调用可进一步简化代码sb.append(...).append(...)2.3 短信平台对接实践获得拼接后的号码字符串后通常需要调用短信服务商API。以常见HTTP接口为例String url https://sms.api.com/send; String params mobile URLEncoder.encode(phoneStr, UTF-8) content URLEncoder.encode(content, UTF-8); HttpURLConnection conn (HttpURLConnection) new URL(url).openConnection(); conn.setRequestMethod(POST); conn.setDoOutput(true); try (OutputStream os conn.getOutputStream()) { os.write(params.getBytes(StandardCharsets.UTF_8)); } int code conn.getResponseCode(); // 处理响应...3. 性能优化与异常处理3.1 容量预分配策略StringBuilder内部使用char[]存储数据默认初始容量16。当超出容量时会触发扩容新容量旧容量*22频繁扩容将影响性能。通过统计分析得出纯数字手机号码11位/个分隔符1个逗号/号码建议初始容量号码数量×12实测不同初始化方式的性能对比拼接1万个号码初始化方式耗时(ms)默认16容量28精确预分配12超额预分配153.2 号码有效性校验在拼接前应进行基础校验避免无效请求public boolean isValidNumber(String phone) { if (phone null || phone.length() ! 11) { return false; } // 简单校验手机号段 String[] validPrefix {13, 14, 15, 16, 17, 18, 19}; boolean valid false; for (String prefix : validPrefix) { if (phone.startsWith(prefix)) { valid true; break; } } return valid phone.matches(\\d); }3.3 超长内容分批次处理短信平台通常有单次请求限制如最多100个号码需要分批次处理public void batchSend(ListString phones, String content) { int batchSize 100; for (int i 0; i phones.size(); i batchSize) { ListString subList phones.subList(i, Math.min(i batchSize, phones.size())); String batchNumbers buildPhoneNumberString(subList); sendSMS(batchNumbers, content); // 避免触发限流 try { Thread.sleep(200); } catch (InterruptedException e) { Thread.currentThread().interrupt(); } } }4. 常见问题与解决方案4.1 内存溢出问题当处理超大号码列表如10万时可能遇到内存问题。解决方案采用分批处理机制使用文件存储中间结果增加JVM堆内存-Xmx1024m4.2 特殊符号处理某些平台要求号码间用英文逗号分隔但开发中可能误用中文逗号。建议// 统一替换所有逗号变体 phoneStr phoneStr.replaceAll(, ,) .replaceAll(;, ,) .replaceAll(\\s, );4.3 平台特异性问题不同短信服务商对号码格式有不同要求服务商格式要求处理建议阿里云逗号分隔最多1000个严格分批腾讯云JSON数组格式改用JSON序列化云片每行一个号码替换逗号为换行符4.4 性能监控指标建议在生产环境监控以下指标平均拼接耗时单批次最大处理量内存使用峰值短信平台响应成功率可通过Spring Boot Actuator或自定义Metrics实现Bean public MeterRegistryCustomizerMeterRegistry metrics() { return registry - { registry.gauge(sms.numbers.batch.size, Tags.empty(), batchSize); }; }5. 高级应用场景5.1 多通道负载均衡当需要极高发送量时可结合多个短信通道public void multiChannelSend(ListString phones, String content) { ListListString partitions Lists.partition(phones, 500); ExecutorService executor Executors.newFixedThreadPool(3); for (int i 0; i partitions.size(); i) { ListString batch partitions.get(i); int channelIdx i % 3; executor.submit(() - { String numbers buildPhoneNumberString(batch); getChannel(channelIdx).send(numbers, content); }); } executor.shutdown(); }5.2 智能分流策略根据号码归属地选择最优通道public void smartRouteSend(ListString phones, String content) { MapString, ListString grouped phones.stream() .collect(Collectors.groupingBy(this::detectCarrier)); grouped.forEach((carrier, list) - { SmsChannel channel selectChannel(carrier); String numbers buildPhoneNumberString(list); channel.send(numbers, content); }); }5.3 与Spring Boot集成推荐的生产级实现方式Service public class SmsService { Value(${sms.batch-size:100}) private int batchSize; Async public void sendBatch(ListString phones, String content) { // 实现细节... } public String buildNumberString(ListString phones) { // 使用StringJoiner更简洁 return phones.stream() .collect(Collectors.joining(,)); } }在真实项目中我们通常会结合数据库存储发送记录CREATE TABLE sms_records ( id BIGINT PRIMARY KEY, phone_numbers TEXT NOT NULL, content TEXT NOT NULL, send_time DATETIME NOT NULL, status TINYINT DEFAULT 0 ) ENGINEInnoDB;6. 安全合规要点6.1 隐私保护措施处理手机号码时必须注意日志脱敏处理数据库加密存储传输使用HTTPS遵循GDPR等法规推荐使用Hutool工具进行脱敏String safeLog DesensitizedUtil.mobilePhone(phone); log.info(发送短信至{}, safeLog); // 输出138****12346.2 防滥用机制为避免被利用为短信轰炸工具应实现单号码发送频率限制总量控制验证码校验使用Redis实现简单限流public boolean allowSend(String phone) { String key sms:limit: phone; long count redisTemplate.opsForValue().increment(key); if (count 1) { redisTemplate.expire(key, 1, TimeUnit.MINUTES); } return count 3; // 每分钟不超过3条 }6.3 内容安全审核短信内容需过滤敏感词public boolean checkContent(String content) { SetString bannedWords loadSensitiveWords(); return bannedWords.stream() .noneMatch(content::contains); }7. 替代方案对比7.1 StringJoinerJava8更简洁的字符串拼接方案public String joinNumbers(ListString phones) { StringJoiner sj new StringJoiner(,); phones.forEach(sj::add); return sj.toString(); }与StringBuilder对比特性StringBuilderStringJoiner代码简洁度中等高灵活性高低性能最优次优可读性一般优秀7.2 第三方工具库Guava的JoinerString result Joiner.on(,).join(phones);Apache Commons Lang的StringUtilsString result StringUtils.join(phones, ,);7.3 直接使用平台SDK主流短信平台SDK通常内置批量发送支持// 阿里云示例 SendSmsRequest request new SendSmsRequest(); request.setPhoneNumbers(13800001111,13900002222); request.setSignName(签名); request.setTemplateCode(SMS_123456); request.setTemplateParam({\code\:\1234\}); SendSmsResponse response client.getAcsResponse(request);8. 实战经验总结在实际项目中我们遇到过几个典型问题号码重复问题发现同一批号码中有重复导致浪费短信费用解决方案拼接前先用Set去重SetString uniquePhones new LinkedHashSet(phones);国际号码处理需要支持86等前缀改进方案String formatted phone.startsWith() ? phone : 86 phone;凌晨发送限制某些地区禁止非工作时间发送营销短信解决方案public boolean isAllowableTime() { LocalTime now LocalTime.now(); return now.isAfter(LocalTime.of(9, 0)) now.isBefore(LocalTime.of(20, 0)); }退订机制合规要求包含退订方式内容模板示例【XX公司】尊敬的用户您获得50元优惠券退订回T对于超大规模发送百万级建议采用消息队列异步处理KafkaListener(topics sms-tasks) public void handleBatch(SmsBatch batch) { // 分批处理逻辑 }
