Oracle AQ Java实现enque / deque

过去几天,我一直在互联网上搜索Oracle Adavanced Queue的任何正在运行的示例实现,以用于消息的入/出队列,但并没有取得成功。

我正在尝试遵循有关oracle文档的说明,但这对我来说还不是很清楚。

  • 它没有有关公开使用的依赖项(Maven / Gradle)的任何信息。 [我知道我需要使用 aqapi.jar ]。任何与我使用的jdbc驱动程序兼容的特定版本。

  • 我还为此使用c3p0连接池,并为c3p0寻求对 AQSession 的任何支持,以从代码角度避免连接和会话处理。

注意:队列表和队列已从数据库层设置。我只是想写一个生产者/消费者来进行消息委派。我们正在使用oracle 12c和Java 11。

任何种类的信息都将不胜感激。

wodedark 回答:Oracle AQ Java实现enque / deque

您需要的是Oracle JDBC瘦驱动程序(ojdbc)来执行AQ操作,例如入队或出队。有关API的更多详细信息,请参见Oracle JDBC Javadoc。也请在stackoverflow上检查其他问题,以获取一些代码示例: How to enqueue on Oracle AQ table on commit with Java and consume with a JMS client

请注意,您有两个选择:a)直接使用AQ API或b)如果要使用JMS API则使用AQ-JMS。

aqapi.jar仅用于管理目的,例如“创建队列”,“启动队列”等。否则,则不需要它。

本文链接:https://www.f2er.com/2565936.html

大家都在问