所以我有一个从JMS队列中读取消息的 EAR 。根据要求，消息是 XML 数据。我从队列中读取数据，使用 JAXB 对其进行解组并将 xml 数据保存到数据库中。但这整个过程占用了我90-95%的 CPU 使用率。我跟进了此链接中建议的更改，以减少我的 CPU 使用率。但即使在实现这些之后，它仍然使用 90% 的 mu CPU，直到队列中的所有消息都被处理。
请注意，我创建了一个单独的 hibernatePersistance.jar，这是我实现 JAXB 解组的地方。hibernate.cfg.xml 文件也在 jar 中。这是我认为可能是高使用率的问题吗？
每次调用 save() 函数时是否有一个单独的 jar 用于持久性建立和关闭数据库连接，这可能导致 CPU 使用率高或其他原因？
这是代码
**MDB Listener Class**
/**
* @see MessageListener#onMessage(Message)
*/
public void onMessage(Message message) {
try {
if (message instanceof BytesMessage) {
BytesMessage bytesMessage = (BytesMessage) message;
StringBuffer buffer = new StringBuffer();
for (int i = 0; i < (int) bytesMessage.getBodyLength(); i++) {
buffer.append((char) bytesMessage.readByte());
}
String cbeXml = buffer.toString().trim();
persistAuditMessage(cbeXml);
} else if (message instanceof TextMessage) {
TextMessage textMessage = (TextMessage) message;
persistAuditMessage(textMessage.getText());
}
} catch (JMSException e) {
e.printStackTrace();
} catch (Exception jmse) {
jmse.printStackTrace();
}
}
private void persistAuditMessage(String auditMessage) {
// for without Session Bean Call
count++;
if (auditMessage != null && auditMessage.trim().length() != 0) {
MarshalImpl impl = new MarshalImpl();
impl.saveCbeXml(auditMessage);
}
}
Persistence JAR 中的类
public class MarshalImpl extends AbstractHibernateLayar<BaseEvent, Long> implements Marshal {
private static Logger logger = LoggerFactory.getLogger(MarshalImpl.class);
private static JAXBContext context = null;
public static synchronized JAXBContext createJAXBContext() throws JAXBException {
if (context == null) {
System.out.println("Creating jaxb context");
context = JAXBContext.newInstance(BaseEvents.class.getPackage().getName());
}
return context;
}
public MarshalImpl() {
super();
}
@Override
public void saveCbeXml(String auditMessage) {
try {
Unmarshaller unmarshaller = createJAXBContext().createUnmarshaller();
@SuppressWarnings("unchecked")
JAXBElement<BaseEvents> root = (JAXBElement<BaseEvents>) unmarshaller.unmarshal(new StreamSource(new StringReader(auditMessage)));
List<BaseEvent> baseEvent = root.getValue().getCommonBaseEvent();
// Persist BaseEvent one by one
for (BaseEvent event : baseEvent) {
event.setSequenceNumber(new Long(1));// Indicate Working Flag
event.setCreationTimeItem(new Date());
save(event);
}
} catch (Exception e) {
logger.error("MarshalImpl::saveCbeXml::CBE Records not inserted!!::" + e.getMessage(), e);
} finally {
System.gc();
}
}