spring线程中无法创建bean

之前一年半都是看别人的博客,很多都是有用的,但是也不乏cv之人，所以找起答案来着实费劲，于是实在忍不住要动手写博客了。这是我入职新公司的第十四天，写了四个服务，部署在了六个服务器，因为每个公司用到的技术是不一样的，所以刚开始的时候肯定会遇到很多问题。我解决问题的方式也大多百度的，但是基本都是实用靠谱的，而且是亲自经历检验的。废话不多说，先来第一个问题：公司的邮箱表本来是一张，但是随着业务的增加一张表已经支持不了了，所以要数据拆分，也就是一张表拆成三张表，并且把之前的数据导入到三张表中。刚开始也没想那么多，就直接写了个储存过程在数据库上执行，但是吧一下午才执行了一万条。于是果断放弃，然后就想着开多线程用代码执行，下面上代码：
+++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
@Component
public class OldToNewThread implements Runnable {
static Logger logger = Logger.getLogger(OldToNewThread.class);
@Autowired
private EmailService emailService;
@Autowired
private RedisTemplate redisTemplate;
public void run() {
BoundListOperations oldList = redisTemplate.boundListOps(“oldId”);
String oldId = “”;
while (oldId != null) {
oldId = (String) oldList.rightPop();
if (!StringUtils.isEmpty(oldId)) {
emailService.insertNew(emailService.findChangeFlightNew(oldId));
}
}
System.out.println("======================= 执行完成 =======================");
}
}
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
感觉没问题吧，但是实际上运行会报空指针，因为注入不了bean。

于是开始找方案，百度了一圈只有个匿名内部类最靠谱，上代码：
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
@Component
public class ClientTest {
static Logger logger = Logger.getLogger(ClientTest.class);
@Autowired
private EmailService emailService;
@Autowired
private ThreadPoolTaskExecutor tptw;
@Autowired
private RedisTemplate redisTemplate;
public void testThread() {
// 查询全部id 存进redis
emailService.findOldId();
tptw.execute(new OldToNewThread());
tptw.execute(new OldToNewThread());
tptw.execute(new OldToNewThread());
tptw.execute(new OldToNewThread());
tptw.execute(new OldToNewThread());
}
private class OldToNewThread implements Runnable {
private Logger logger = Logger.getLogger(OldToNewThread.class);
public void run() {
BoundListOperations oldList = redisTemplate.boundListOps(“oldId”);
String oldId = “”;
while (oldId != null) {
oldId = (String) oldList.rightPop();
if (!StringUtils.isEmpty(oldId)) {
// emailService.insertNew(emailService.findChangeFlightNew(oldId));
System.out.println("================================="+oldId);
}
}
System.out.println(" ==================== 执行完成 ======================");
}
}
}
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
完美解决，最后附上线程池的配置
++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
@Configuration
//@EnableAsync
public class ThreadConfig {
@Bean
public ThreadPoolTaskExecutor taskExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
// 设置核心线程数
executor.setCorePoolSize(10);
// 设置最大线程数
executor.setMaxPoolSize(15);
// 设置队列容量
executor.setQueueCapacity(25);
// 设置线程活跃时间（秒）
executor.setKeepAliveSeconds(60);
// 设置拒绝策略
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
// 等待所有任务结束后再关闭线程池
executor.setWaitForTasksToCompleteOnShutdown(true);
return executor;
}
}

++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++

执行效率也高了不少，其中用到的redis在中间也遇到过问题，下篇博文讲