1. 项目背景与需求分析在短信营销和通知类业务场景中批量发送短信是一个高频需求。假设我们需要向10,000个用户发送促销短信如果采用单条发送的方式不仅效率低下还会对短信网关造成不必要的压力。更合理的做法是将所有手机号码拼接为一个字符串通过单次API调用完成批量发送。传统字符串拼接使用运算符但在Java中这会带来严重的性能问题。因为String是不可变对象每次拼接都会生成新的String对象。当处理大量手机号码时例如10,000个会产生大量中间对象导致内存占用飙升频繁触发GC执行效率急剧下降测试数据显示使用拼接10,000个手机号码耗时约450ms而使用StringBuilder仅需3ms - 性能差距达150倍。这就是为什么在Java中处理批量字符串拼接时StringBuilder成为首选方案。2. StringBuilder核心技术解析2.1 StringBuilder底层实现原理StringBuilder通过维护一个可变字符数组(char[])实现高效拼接。关键设计点包括初始容量(默认16字符)和扩容机制当当前容量不足时按(旧容量*2)2的规则扩容非线程安全设计相比StringBuffer省去了同步锁开销方法链式调用append()等方法返回this支持连续操作// 典型扩容代码实现 void expandCapacity(int minimumCapacity) { int newCapacity value.length * 2 2; if (newCapacity minimumCapacity) newCapacity minimumCapacity; value Arrays.copyOf(value, newCapacity); }2.2 关键API说明对于手机号码拼接场景主要使用以下方法append(String str)核心拼接方法toString()最终生成拼接结果length()检查当前字符数避免超过短信网关限制经验提示在已知最终长度的情况下建议通过构造函数预设容量如new StringBuilder(11*10000)避免多次扩容带来的性能损耗。3. 完整实现方案3.1 基础实现代码public class SmsBatchSender { public static String concatPhoneNumbers(ListString phoneNumbers) { if (phoneNumbers null || phoneNumbers.isEmpty()) { throw new IllegalArgumentException(手机号码列表不能为空); } StringBuilder sb new StringBuilder(phoneNumbers.size() * 12); // 预估容量 for (int i 0; i phoneNumbers.size(); i) { String phone phoneNumbers.get(i); if (!isValidPhoneNumber(phone)) { continue; // 或抛出异常 } sb.append(phone); if (i phoneNumbers.size() - 1) { sb.append(,); } } return sb.toString(); } private static boolean isValidPhoneNumber(String phone) { // 实现手机号校验逻辑 return phone ! null phone.matches(^1[3-9]\\d{9}$); } }3.2 性能优化要点容量预分配根据手机号码数量预先计算所需容量每个号码11位逗号// 优化后的容量计算 int estimatedLength phoneNumbers.stream() .filter(phone - phone ! null phone.length() 11) .count() * 12 - 1; StringBuilder sb new StringBuilder(estimatedLength 0 ? estimatedLength : 16);批量处理当号码量极大时如10万建议分批处理避免超大字符串// 分批次处理示例 int batchSize 10000; for (int i 0; i phoneNumbers.size(); i batchSize) { ListString batch phoneNumbers.subList(i, Math.min(i batchSize, phoneNumbers.size())); String batchStr concatPhoneNumbers(batch); sendSmsBatch(batchStr); }内存映射文件对于超大规模数据如百万级考虑使用内存映射文件处理try (RandomAccessFile file new RandomAccessFile(phones.txt, rw); FileChannel channel file.getChannel()) { MappedByteBuffer buffer channel.map(READ_WRITE, 0, estimatedTotalBytes); // 直接操作buffer... }4. 短信网关集成实践4.1 常见短信API格式主流短信服务商如阿里云、腾讯云的批量发送接口通常支持两种格式逗号分隔的字符串// 阿里云示例 SmsSendRequest request new SmsSendRequest(); request.setPhoneNumbers(13800138000,13800138001,13800138002); request.setSignName(阿里云); request.setTemplateCode(SMS_123456789); request.setTemplateParam({\code\:\1234\});JSON数组格式// 腾讯云示例 ArrayListString phoneList new ArrayList(); phoneList.add(8613800138000); phoneList.add(8613800138001); SmsMultiSenderRequest request new SmsMultiSenderRequest(); request.setPhoneNumbers(phoneList);4.2 异常处理机制必须实现的健壮性检查单批次号码数量限制通常500-1000个短信内容长度限制通常450-500字符敏感词过滤频率控制如QPS限制public void sendBatchSms(String phoneNumbers, String content) throws SmsException { if (phoneNumbers null || phoneNumbers.isEmpty()) { throw new SmsException(手机号码不能为空); } String[] phones phoneNumbers.split(,); if (phones.length MAX_BATCH_SIZE) { throw new SmsException(单批次最多支持 MAX_BATCH_SIZE 个号码); } if (content.getBytes(StandardCharsets.UTF_8).length MAX_CONTENT_LENGTH) { throw new SmsException(短信内容超过 MAX_CONTENT_LENGTH 字节限制); } // 实际发送逻辑... }5. 生产环境注意事项5.1 性能基准测试在不同数据量下的性能对比测试环境JDK17MacBook Pro M1手机号码数量StringBuilder耗时(ms)String拼接耗时(ms)内存占用(MB)1,000125210,000345020100,00030超时(10s)2005.2 常见问题排查乱码问题确保全程使用UTF-8编码特别检查文件读取和网络传输环节号码重复问题// 使用Set去重 SetString uniquePhones new LinkedHashSet(phoneNumbers); ListString deduplicated new ArrayList(uniquePhones);国际号码处理添加国际区号如86注意不同国家的号码长度差异网关返回处理// 典型响应处理 if (response.getCode().equals(OK)) { for (SmsSendDetail detail : response.getDetails()) { if (!DELIVERED.equals(detail.getStatus())) { log.warn(短信发送失败: {}, detail.getErrMsg()); } } }5.3 监控指标建议在生产环境中建议监控批量发送成功率平均处理时长内存使用峰值网关返回错误码分布可以通过JMX或自定义Metrics实现public class SmsMetrics { private final AtomicLong successCount new AtomicLong(); private final AtomicLong failureCount new AtomicLong(); private final Histogram latencyHistogram new Histogram(); public void recordSend(boolean success, long latencyMs) { if (success) { successCount.incrementAndGet(); } else { failureCount.incrementAndGet(); } latencyHistogram.update(latencyMs); } }6. 替代方案对比6.1 Java 8的StringJoiner对于简单场景可以考虑使用StringJoinerStringJoiner joiner new StringJoiner(,); phoneNumbers.forEach(joiner::add); String result joiner.toString();优势语法更简洁内置分隔符处理劣势底层仍使用StringBuilder功能较简单缺少灵活控制6.2 Guava的JoinerGoogle Guava库提供的增强方案String result Joiner.on(,) .skipNulls() .join(phoneNumbers);特色功能自动处理null值支持Map拼接线程安全实现6.3 并行流处理对于超大规模数据集百万级String result phoneNumbers.parallelStream() .filter(Objects::nonNull) .collect(Collectors.joining(,));注意事项需要足够大的数据量才能体现优势可能增加CPU负载要确保线程安全7. 安全合规要点隐私保护日志脱敏处理传输加密// 日志脱敏示例 logger.info(发送短信至{}, maskPhone(phone)); private String maskPhone(String phone) { if (phone null || phone.length() 7) return ***; return phone.substring(0, 3) **** phone.substring(7); }防滥用机制单手机号发送频率限制总量控制黑名单过滤内容审核敏感词过滤系统模板审核流程签名报备法律合规确保用户授权提供退订方式遵守《通信短信息服务管理规定》