问题描述
我的任务是处理进入ApacheMQ Artemis的大型xml文件(
我需要的伪算法是
AnswerXml processIncomingXml(){
currentXmlMessage = getXmlMessageFromApacheMQArtemis();
answerXmlMessage = processCurrentXmlMessageUsingApacheStormFunctionality(currentXml);
saveXmlToApacheMQArtemis(answerXml);
return answerXml;
}
我希望processCurrentXmlMessageUsingApacheStormFunctionality(currentXml)
方法能做到
像这样的东西
AnswerXml processCurrentXmlUsingApacheStormFunctionality(currentXml) {
1. split currentXml message into chunks
2. answerXml + = process chunks in parallel (retrieving necessary data from database
MySQL,calculations,etc. for each chunk independently)
return a stream of answerXml (BufferedWriter or something like that) from all chunks per currentXml;
}
我期望的xml文件结构
<Employees>
<Employee>
<Address>
<street>test street</street>
<houseNr>23</houseNr>
<Country>
<city>test city</city>
</Country>
</Address>
<salary>200</salary>
<maritalstatus>test</maritalstatus>
...
</Employee>
...
</Employees>
我的问题是:“ Apache Storm是适合我的问题的工具,还是我在错误的树上吠叫?”
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)