阿里二面：1000万条短信1小时发完，线程池怎么配？

// 最终线程池参数
核心线程数：200
最大线程数：500
队列容量：5000
空闲保活：60s
拒绝策略：CallerRunsPolicy（保证不丢短信）

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.concurrent.*;

@Configuration
publicclass SmsThreadPoolConfig {

    @Bean("smsSendExecutor")
    public ExecutorService smsSendExecutor() {
        // 4核8G 服务器 → 200~500 线程最稳
        int corePoolSize = 200;
        int maximumPoolSize = 500;
        long keepAliveTime = 60L;
        int queueCapacity = 5000;

        returnnew ThreadPoolExecutor(
                corePoolSize,
                maximumPoolSize,
                keepAliveTime,
                TimeUnit.SECONDS,
                new LinkedBlockingQueue<>(queueCapacity),
                new ThreadFactory() {
                    privateint count = 0;
                    @Override
                    public Thread newThread(Runnable r) {
                        Thread t = new Thread(r);
                        t.setName("sms-send-thread-" + count++);
                        t.setDaemon(false);
                        return t;
                    }
                },
                // 重要：调用者运行，避免拒绝丢短信
                new ThreadPoolExecutor.CallerRunsPolicy()
        );
    }
}

import lombok.Data;
import java.util.List;

@Data
publicclass SmsSendTask implements Runnable {
    // 每批次发 50 条（可调整）
    private List<String> phoneList;
    private String content;

    public SmsSendTask(List<String> phoneList, String content) {
        this.phoneList = phoneList;
        this.content = content;
    }

    @Override
    public void run() {
        try {
            for (String phone : phoneList) {
                // 真实发送短信接口（你自己的业务）
                sendSms(phone, content);
            }
        } catch (Exception e) {
            // 失败重试/记录日志
            e.printStackTrace();
        }
    }

    // 短信发送接口
    private void sendSms(String phone, String content) {
        // 调用阿里云/腾讯云/华为云短信SDK
        System.out.println("发送成功：" + phone + " 内容：" + content);
    }
}

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.stereotype.Service;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;

@Service
publicclass SmsBatchService {

    @Autowired
    @Qualifier("smsSendExecutor")
    private ExecutorService executorService;

    /**
     * 批量发送 1000 万短信
     * 每 50 条一个任务
     */
    public void batchSendSms() {
        // 1. 从DB读取 1000 万手机号（分页查询！不要一次加载）
        List<String> allPhoneList = get1000MPhonesFromDB();

        // 2. 每 50 条拆分一个任务
        int batchSize = 50;
        List<String> taskPhones = new ArrayList<>(batchSize);

        for (String phone : allPhoneList) {
            taskPhones.add(phone);
            if (taskPhones.size() == batchSize) {
                // 提交线程池
                executorService.submit(new SmsSendTask(taskPhones, "您的验证码是：888888"));
                taskPhones = new ArrayList<>(batchSize);
            }
        }

        // 最后不足50的部分
        if (!taskPhones.isEmpty()) {
            executorService.submit(new SmsSendTask(taskPhones, "您的验证码是：888888"));
        }
    }

    // 模拟从数据库读取手机号（真实项目必须分页：limit 1000 循环查）
    private List<String> get1000MPhonesFromDB() {
        returnnew ArrayList<>();
    }
}

核心线程：200
最大线程：500
队列：5000
每批次：50条