草庐IT

go - 聆听高级 Oracle 队列 (AQ)

coder 2023-06-28 原文

我正在检查 Go 迁移现有 C++ 应用程序的能力。 主要任务之一是主动监听(无轮询)高级 Oracle 队列。 在 Java 和 C++ 中，很早就有支持它的现有库。

我在 Go 中找不到任何类似的东西(库和示例)。 你能帮我吗？

最佳答案

我有一个实现，其中我使用“gopkg.in/goracle.v2”包连接到 Oracle，以及通用 Go 库“database/sql”。 我这样做的方式是，我有从我的 Go 代码调用的 PL/SQL 过程中的 AQ 读取的代码。尽管这不是最好的方法——实际上我将对其进行更改，使其不依赖于存储的 oracle 过程——但它确实有效。代码如下所示:

Oracle PL/SQL 过程:

PROCEDURE GetAQMessage ( out_content    OUT VARCHAR2, in_acknowledge IN  VARCHAR2 DEFAULT 'N' )
IS 
   dyn_sql   VARCHAR2(32000);
   l_content VARCHAR2(4000);
BEGIN

   dyn_sql := '
      DECLARE 
         l_payload MESSAGE_TYPE := MESSAGE_TYPE (NULL);
         l_msg_id             RAW(16);
         l_dequeue_options    DBMS_AQ.DEQUEUE_OPTIONS_T;
         l_message_properties DBMS_AQ.MESSAGE_PROPERTIES_T; 
      BEGIN
         DBMS_AQ.DEQUEUE(
            queue_name => '''|| v_queue_name ||''',
            dequeue_options => l_dequeue_options,
            message_properties => l_message_properties,
            payload => l_payload,
            msgid => l_msg_id
        );
        :b_output := l_payload.message;
      END;';

   EXECUTE IMMEDIATE dyn_sql USING OUT l_content;
   -- Return the content to the OUT parameter
   out_content := l_content;

   -- Permanently removes the message from the Queue
   IF in_acknowledge = 'Y' THEN
      COMMIT;
   END IF;

END GetAQMessage;

Go代码:

func GetAQMessage(transaction *sql.Tx) (string, error) {
    var outResult string
    var resErr error
    var debug int

    configuration = conf.Read()

    //Run the command
    _, resErr = transaction.Exec(`BEGIN CONSENT.GETAQMESSAGE(:1,:2) ; END;`, sql.Out{Dest: &outResult}, "N")

    return outResult, resErr
}

关于go - 聆听高级 Oracle 队列 (AQ)，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/50943153/

聆听Oraclesectioncontentstronggoadvanced-queuing

有关go - 聆听高级 Oracle 队列 (AQ)的更多相关文章

  1. ruby - 分布式事务和队列，ruby，erlang，scala - 2

    我有一个涉及多台机器、消息队列和事务的问题。因此，例如用户点击网页，点击将消息发送到另一台机器，该机器将付款添加到用户的帐户。每秒可能有数千次点击。事务的所有方面都应该是容错的。我以前从未遇到过这样的事情，但一些阅读表明这是一个众所周知的问题。所以我的问题。我假设安全的方法是使用两阶段提交，但协议(protocol)是阻塞的，所以我不会获得所需的性能，我是否正确？我通常写Ruby，但似乎Redis之类的数据库和Rescue、RabbitMQ等消息队列系统对我的帮助不大——即使我实现某种两阶段提交，如果Redis崩溃，数据也会丢失，因为它本质上只是内存。所有这些让我开始关注erlang和

  2. ruby-on-rails - Ruby 长时间运行的进程对队列事件使用react - 2

    我有一个将某些事件写入队列的Rails3应用。现在我想在服务器上创建一个服务，每x秒轮询一次队列，并按计划执行其他任务。除了创建ruby​​脚本并通过cron作业运行它之外，还有其他稳定的替代方案吗？ 最佳答案 尽管启动基于Rails的持久任务是一种选择，但您可能希望查看更有序的系统，例如delayed_job或Starling管理您的工作量。我建议不要在cron中运行某些东西，因为启动整个Rails堆栈的开销可能很大。每隔几秒运行一次它是不切实际的，因为Rails上的启动时间通常为5-15秒，具体取决于您的硬件。不过，每天这样做几

  3. ruby-on-rails - Textmate 'Go to symbol' 相当于 Vim - 2

    在Railcasts上，我注意到一个非常有趣的功能“转到符号”窗口。它像Command-T一样工作，但显示当前文件中可用的类和方法。如何在vim中获取它？ 最佳答案 尝试:helptags有各种程序和脚本可以生成标记文件。此外，标记文件格式非常简单，因此很容易将sed(1)或类似的脚本组合在一起，无论您使用何种语言，它们都可以生成标记文件。轻松获取标记文件(除了下载生成器之外)的关键在于格式化样式而不是实际解析语法。 关于ruby-on-rails-Textmate'Gotosymbol

  4. 如何判断oracle是否启动及启动oracle数据库 - 2

    plsql连接Oracle超时，完犊子了肯定是服务器断电了。得马上检查Oracle服务器状态1、检查数据库是否启动su-oracle切换到Oracle用户，输入sqlplus/assysdba显示连接状态。如果末尾显示的状态是Connectedtoanidleinstance.证明未启动2、启动数据库startup启动数据库，末尾出现Databaseopened说明数据库启动成功3、查看数据库监听是否正常先quit;断开Oracle连接，使用lsnrctlstatus查看监听状态，如果出现TNS-开头的Nolistener、Connectionrefused等错误，说明监听未启动4、启动数据库

  5. ruby - 高级语言是否使用数据结构？ - 2

    我目前还在上学，正在上一门关于用C++实现数据结构的类(class)。在业余时间，我喜欢使用“高级”语言(主要是Ruby和一些c#)进行编程。既然这些高级语言为你管理内存，你会用数据结构做什么？我可以理解对队列和堆栈的需求，但是您需要在Ruby中使用二叉树吗？还是2-3-4树？为什么？谢谢。 最佳答案 Sosincethesehigherlevellanguagesmanagethememoryforyou,whatwouldyouusedatastructuresfor?使用数据结构的主要原因与垃圾收集无关。但它是以某种方式有效的

  6. ruby - 在不提供其所有属性的情况下获取队列 - 2

    我正在尝试为现有队列编写消费者。RabbbitMQ在一个单独的实例中运行，名为“org-queue”的队列已经创建并绑定(bind)到一个交换器。org-queue是一个持久队列，它还有一些额外的属性。现在我需要从这个队列接收消息。我使用下面的代码来获取队列的实例conn=Bunny.newconn.startch=conn.create_channelq=ch.queue("org-queue")它抛出一个错误，指出不同的耐用属性。默认情况下，Bunny似乎使用durable=false。所以我添加了durabletrue作为参数。现在它说明了其他参数之间的区别。我是否需要指定所有参

  7. ruby - 如何在特定队列中推送作业并使用 sidekiq 限制工作人员数量？ - 2

    我知道我们可以做到:sidekiq_optionsqueue:"Foo"但在这种情况下，Worker只分配给一个队列:“Foo”。我需要在特定队列中分配作业(而不是worker)。使用Resque很容易:Resque.enqueue_to(queue_name,my_job)另外，为了并发问题，我需要限制每个队列的Worker数量为1。我该怎么做？ 最佳答案 您可能会使用https://github.com/brainopia/sidekiq-limit_fetch然后:Sidekiq::Client.push({'class'=>

  8. Python：每日一题之小张的衣服（优先队列、哈夫曼编码） - 2

    题目描述小张买了 n 件白色的衣服，他觉得所有衣服都是一种颜色太单调，希望对这些衣服进行染色，每次染色时，他会将某种颜色的所有衣服寄去染色厂，第 i 件衣服的邮费为 ai​ 元，染色厂会按照小张的要求将其中一部分衣服染成同一种任意的颜色，之后将衣服寄给小张，请问小张要将 n 件衣服染成不同颜色的最小代价是多少？输入描述第一行为一个整数 n ，表示衣服的数量。第二行包括 n 个整数a1​,a2​...an​ 表示第 i 件衣服的邮费为 ai​ 元。（1≤n≤10^5,1≤ai​≤10^9 ）输出描述输出一个整数表示小张所要花费的最小代价。输入输出样例输入551321输出25 思考🤔：题意：意思是

  9. ruby - 使用 Ruby 连接到 Oracle 数据库 - 2

    我无法连接到OracleDB，阅读了很多资料但对结果没有帮助。我有远程OracleDB，我正在使用DBVisualizer设置连接连接到它，如下所示:DBType:OracleDriver(jdbc):OraclethinDatabaseURL:jdbc:oracle:thin:@10.10.100.10:1521/VVV.LOCALDOMAINUserIdf:SomeUserPass:SomePass连接正常。我在Ruby中所做的是:require'oci8'require'dbi'...conn=OCI8.new('SomeUser','SomePass','//10.10.100

  10. ruby - Resque:每个队列一个 worker - 2

    我目前有一个Rails3.0项目，使用Ruby1.9.2和Resque。我的应用程序有多个工作类和多个队列，它们是动态创建的(在运行时)。此外，有多个worker已启动，可以自由地在任何队列上工作，因为在启动时没有任何现有队列，并且无法预测它们:$COUNT=3QUEUE=*rakeresque:workers根据project的id创建队列:@queue="project_#{project.id}".to_sym对于给定的队列，他们的作业必须按顺序处理，一次处理一个。我的问题是，通过拥有多个工作人员，可以并行处理多个作业。有没有办法设置每个队列的最大worker数(为1)？有没有办

随机推荐