java.lang.NoClassDefFoundError 当发送到 oracle aq 时

Question

我在Spring应用程序中遇到以下异常：

Exception in thread "Thread-0" Exception in thread "Thread-1" java.lang.NoClassDefFoundError: javax/transaction/Transaction
    at oracle.jms.AQjmsSession.<init>(AQjmsSession.java:364)
    at oracle.jms.AQjmsConnection.createSession(AQjmsConnection.java:1130)
    at org.springframework.jms.support.JmsAccessor.createSession(JmsAccessor.java:192)
    at org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:475)
    at org.springframework.jms.core.JmsTemplate.send(JmsTemplate.java:570)
    at org.springframework.jms.core.JmsTemplate.convertAndSend(JmsTemplate.java:658)
    at com.company.service.JmsMessageSender.sendMessage(JmsMessageSender.java:19)
    at com.company.service.TradeService.processTrade(TradeService.java:72)
    at com.company.task.TradeProcessingTask.run(TradeProcessingTask.java:28)
    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
    at java.lang.Thread.run(Thread.java:745)
Caused by: java.lang.ClassNotFoundException: javax.transaction.Transaction
    at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
    ... 12 more

我已经配置了一个Oracle AQ如下，我想在其中推送一些交易消息：

import static oracle.jms.AQjmsFactory.getQueueConnectionFactory;
@Configuration
@ConfigurationProperties("oracle")
public class OracleAQConfiguration {
    @NotNull
    private String url;
    @NotNull
    private String aqname;
    @NotNull
    private String aquser;
    @NotNull
    private String aqpassword;
    @NotNull
    private String driver;

    @Bean
    public ConnectionFactory connectionFactory() throws Exception {
        Properties info = new Properties();
        info.put("driver-name", driver);
        info.put("user", aquser);
        info.put("password", aqpassword);
        return getQueueConnectionFactory(url, info);
    }

        //setter and getters
}

JmsMessageSender实现如下：

@Component
@EnableJms
public class JmsMessageSender implements MessageSender {
    @Autowired
    private JmsTemplate jmsTemplate;
    @Override
    public void sendMessage(String queueName, String message) {
        jmsTemplate.convertAndSend(queueName, message);
        log.info("Message sent: {}", message);
    }
}

接收交易对象并使用执行器服务提交任务的服务：

@Service
public class TradeService {
    private final ExecutorService executorService = Executors.newSingleThreadExecutor();
    @Autowired
    private TradeRequestBuffer buffer;
    @Autowired
    private JmsMessageSender jmsMessageSender;

    @Value("${oracle.aqname}")
    private String aqname;

    public void submitTradeForProcessing(Trade trade) {
        final TradeProcessingTask tradeProcessingTask = new TradeProcessingTask(this, trade);
        executorService.execute(() -> buffer.executeTask(tradeProcessingTask));
    }
    public void processTrade(Trade trade) {
        Optional<String> xmlTradeMessage = XmlParserUtil.marshall(trade);
        if (xmlTradeMessage.isPresent()) {
            jmsMessageSender.sendMessage(aqname, xmlTradeMessage.get());
            updateTradeStatus(tradeProcessingContext);
        }

    }
}

Answer 1

看起来您的一个库缺少必需的依赖项transaction-api

如果您使用的是 Maven，请尝试

<!-- https://mvnrepository.com/artifact/javax.transaction/javax.transaction-api -->
<dependency>
    <groupId>javax.transaction</groupId>
    <artifactId>javax.transaction-api</artifactId>
    <version>1.2</version>
</dependency>

https://mvnrepository.com/artifact/javax.transaction/javax.transaction-api/1.2