java - 我在批处理作业期间面临空指针
问题描述
我有一个批处理作业,它处理从源到目标的数据。偶尔我会在作业触发后立即看到 NPE,它运行良好,直到完成。看起来第 96 行正在引发错误,但我不确定为什么作业何时触发?这是我认为是错误来源的行。
Node node = nodeList.item( 0 ).getAttributes().getNamedItem(DCDirectProcessorConstants.Tag_Response_Status);
Java 代码
InputSource source = new InputSource();
source.setCharacterStream(new StringReader(response));
Document document = builder.parse(source);
XPath xpath = XPathFactory.newInstance().newXPath();
NodeList nodeList = document.getElementsByTagName(DCDirectProcessorConstants.Tag_Response_getValue);
Node node = nodeList.item( 0 ).getAttributes().getNamedItem(DCDirectProcessorConstants.Tag_Response_Status);
RatingSessionTO responseTO = XMLProcessingUtil.processResponseData(
ratingSessionTO, response, migrationConfig, data.toString());
/*DataMigrationDao dao = null;
if( migrationConfig.isOneTimeMigration() ){
dao = (DataMigrationDao) appContext.getBean("oneTimeMigrationDao");
}else{
dao = (DataMigrationDao) appContext.getBean("dailyMigrationDao");
}
*/
//This flow is explicitly for Catchup
if("1".equals(catchUp)){
if(kafkaFailure){
postMessageToKafka(responseTO,catchUp,dao);
}
else if(raterFailure){
//Handle rater failure
int ID = dao.getExternalID(responseTO);
if(ID != 0){
responseTO.setExternalID(ID);
}
migrateMessageToRaterInfo(responseTO,dao,catchUp);
}
else{ //Handle XML_Sessions failure
try{
if(dao.verifySessionID(responseTO) == 0){
// Defect 76093
if (node == null || DCDirectProcessorConstants.Status_Failure.equalsIgnoreCase(node.getTextContent())) {
logger.error("Retry failure.Source id already present in catchup "+ ratingSessionTO.getSrcId());
} else {
dao.migrateData(responseTO);
postMessageToKafka(responseTO, catchUp, dao);
migrateMessageToRaterInfo(responseTO, dao, catchUp);
}
} else{
logger.error("Source id already present in archive "+ratingSessionTO.getSrcId()+" Updating status to 'C'");
dao.updateCatchupCompletion(ratingSessionTO.getSrcId());
}
}
catch(Exception e){
logger.error("Catchup failed for "+ratingSessionTO.getSrcId()+" Status remains 'P'");
}
}
}
堆栈跟踪
java.lang.NullPointerException
在 com.mercuryinsurance.r3.util.MigrationExecutorThread.run(MigrationExecutorThread.java:96) [migration.jar:?] 在 java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) [?:1.8.0_66]在 java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) [?:1.8.0_66] 在 java.lang.Thread.run(Thread.java:745) [?:1.8.0_66]
解决方案
来自Java Doc NodeList.item()
:
“返回集合中的第 index 个项目。如果 index 大于或等于列表中的节点数,则返回 null。”
https://docs.oracle.com/javase/8/docs/api/org/w3c/dom/NodeList.html
为了防止NullPointerException
,您应该在访问元素之前检查 nodeLists 长度:
NodeList nodeList = document.getElementsByTagName(DCDirectProcessorConstants.Tag_Response_getValue);
if(nodeList.getLength() > 0) {
Node node = nodeList.item( 0 ).getAttributes().getNamedItem(DCDirectProcessorConstants.Tag_Response_Status);
...
} else {
// handle the case no node found
}
尽管您的代码没有显示为什么作业仍然运行良好,NullpointerException
但我猜try / catch
您发布的代码片段周围有一些处理和记录异常。
推荐阅读
- python - 使用元数据而不是图像训练模型
- c++ - 您可以将 NULL 指针变量分配给指针变量吗?
- netty - 通道管道 addLast 有时不起作用
- vue.js - Vuex:未知突变类型:dropdownState
- python - 无法使用 div 类从 3 个下拉列表中进行选择 - python selenium
- security - connect-src CSP 的安全注意事项
- c# - 使 dotnet publish 使用来自 bin 文件夹而不是来自 nuget 缓存的依赖项
- python - ValueError:发现样本数量不一致的输入变量:[1, 137]
- excel - 我如何指定我的列表框以便 VBA 理解我所指的内容?
- bash - 如何从多个 CSV 打印一次组名和组名下方的成员