前几天改造完成的邮件拨测项目又改需求了，leader 希望能改造成多线程下运行，以email为维度收集日志。
但是改造过程并不顺利，首先改造成多线程很简单，先上代码：
//创建全局线程池
private ExecutorService threadPool = Executors.newCachedThreadPool();
//job
public void sendEmail() {
//省略若干配置...
//读取配置的测试邮箱信息，包括protocol，email，pwd，host等等
SONArray emailArr = getEmailsArray();
//CountDownLatch
CountDownLatch countDownLatch = new CountDownLatch(emailArr.size());
//遍历邮箱
for (int j = 0; j < emailArr.size(); j++) {
final JSONObject obj = emailArr.getJSONObject(j);
//加入线程池
threadPool.execute(() -> {
Map<String, String> indexedTags = new HashMap<>();
Map<String, String> storedTags = new HashMap<>();
indexedTags.put("module", "记录日志模块名");
try {
String proto = obj.getString("protocol");
String email = obj.getString("email");
String pass = obj.getString("pass");
String host = obj.getString("host");
String uuid = UUID.randomUUID().toString();
SendEmailTool sendEmailTool = new SendEmailTool();
sendEmailTool.setFrom(sender);
sendEmailTool.setTo(email);
sendEmailTool.setTemplateId(Integer.parseInt(templateId));
sendEmailTool.setSubject("uuid:" + uuid);
//发邮件
SendEmailResponse response = sendEmailTool.sendEmail();
//发送状态
boolean sent = (response != null && response.getResultCode() == 1);
//记录发送状态
storedTags.put("sent", sent ? "1" : "0");
//记录email
indexedTags.put("email", getEmailSupplierWithUnderLine(email));
//等待接收
Thread.sleep(Integer.valueOf(waitTime));
//开始接收
List<EmailEntity> list = ReceiveEmailTool.getEmailList(proto, email, pass, host, deleteFlag, socksProxyHost, socksProxyPort, timeout);
//接收状态
boolean received = false;
for (EmailEntity entity : list) {
if (entity.getSubject() != null && entity.getSubject().startsWith("uuid:") && entity.getSubject().contains(uuid)) {
received = true;
}
}
//记录接收状态
storedTags.put("received", received ? "1" : "0");
//记录ack 状态
indexedTags.put("ack", (sent && received) ? "1" : "0");
} catch (Throwable e) {
//记录异常信息
indexedTags.put("ack", "0");
indexedTags.put("exception", StreamUtility.toString(e));
} finally {
countDownLatch.countDown();
//写日志
}
});
}
//等待线程全部结束
countDownLatch.await();
//job 完成
}
这一版改完直接发布运行，发现第一批次的7个线程，只有5个完成并输出了日志，然后job不知道什么原因卡住了。分析无果，只得本地调试。发现finally 写日志的地方抛出来异常。这是公司的基础组件引起的线程安全问题。于是修复bug，再次发布运行。
重点来了
运行一段时间，查看日志，发现失败率异常的高。远远高于改造之前，查看日志异常信息，发现不同的邮箱catch 到的异常居然相同，hotmail的异常竟然输出了qq的帮助地址，肯定是线程串了。于是再次查看代码，线程池改造这里应该是没有问题，问题可能出在抛异常的类。
检查 ReceiveEmailTool 的 getEmailList 方法，发现
// 获取连接
Session session = Session.getDefaultInstance(props);
进入 getDefaultInstance 方法发现
public static synchronized Session getDefaultInstance(Properties props, Authenticator authenticator) {
if(defaultSession == null) {
defaultSession = new Session(props, authenticator);
} else if(defaultSession.authenticator != authenticator && (defaultSession.authenticator == null || authenticator == null || defaultSession.authenticator.getClass().getClassLoader() != authenticator.getClass().getClassLoader())) {
throw new SecurityException("Access to default session denied");
}
return defaultSession;
}
该类下面还有另2个方法
public static Session getInstance(Properties props, Authenticator authenticator) {
return new Session(props, authenticator);
}
public static Session getInstance(Properties props) {
return new Session(props, (Authenticator)null);
}
原来，由于我改造成了多线程，当线程A应实例化了session对象以后，线程B将直接返回A实例化的seesion，导致线程串并。
将代码替换为
Session session = Session.getInstance(props);
再次发布运行，发现依然没有解决。这又是为什么？再次检查代码，发现还有一个共享的变量
Properties props = System.getProperties();
这是当初使用全局代理时遗留下来的。若非如此，直接new 就好了
Properties props = new Properties();
再次发布，问题解决。
