- Java 双重比较
- java - 比较器与 Apache BeanComparator
- Objective-C 完成 block 导致额外的方法调用?
- database - RESTful URI 是否应该公开数据库主键?
我正在设计一个将在 OSGi 容器(目前是 Equinox)中运行的应用程序。它将通过 RabbitMQ 接收消息并在内部处理它们。该应用程序将作为服务器持续运行。我目前的计划是使用 QueueingConsumer
并在它们自己的线程中运行,让 RabbitMQ 监听器包配置其队列并在其上放置监听器。监听器将调用一个或多个处理服务来处理消息。处理器需要进行 JDBC 调用以访问数据库。我希望能够控制调用处理器的顺序。如果能够在以后灵活地添加更多服务而无需重新编码 RabbitMQ 监听器,那就太好了。
我面临的问题是消息可能是突发的,也可能是缓慢的。我希望能够使用 PreparedStatement
来加速数据库访问,但我也不希望在没有任何事情发生的情况下长期保持连接打开。我考虑过直接子类化 DefaultConsumer
并让它在 RabbitMQ Connection
中的线程上运行,但后来我失去了知道什么时候没有发生的能力。我最初的想法是让消息处理器作为 OSGi 服务完全独立,并且在每次调用时都从池中获取一个数据库连接,但这失去了准备好的语句的优势。我正在使用 Tomcat JDBC 池,它似乎没有准备好的语句缓存。此外,我不确定为每次调用创建准备好的语句会花费多少,但这似乎很浪费。
到目前为止,我想到的最好的想法是让我的监听器在双循环中处理。外循环等待消息,然后调用内循环建立数据库连接和准备好的语句并运行,直到在指定的超时时间内没有更多消息传入,然后关闭其连接并返回到外循环。我得到这个来处理一点点,但是如果我有多个处理器可能有不同的准备语句,我很难想象如何管理它。
也许我必须放弃多个服务的想法,并将处理过程硬编码到我的监听器中。
有什么建议吗?谢谢!
最佳答案
为什么不将服务用作监听器并向它们传递它们应该使用的 JDBC 连接?然后,一段代码将队列分派(dispatch)给您的服务。这个中央调度程序可以简单地维护准备好的 JDBC 连接池。如果不想在 API 中看到 JDBC 连接,请使用 Coordinator 服务来保持连接。然后,“感知”服务可以获得优化的 JDBC 连接。
或者,将数据源注册为您的监听器服务的服务并实现您自己的池策略。由于您知道 OSGi 服务调用中的调用者,因此您可以进行各种优化,例如从包的 jar 中读取准备好的语句并相应地缓存它们。
我不会放弃这里的服务,你得到的解耦效果很好,我从经验中知道。由于在此模型中,服务监听器不依赖于 RabbitMQ,因此您可以轻松地测试它们和/或切换到另一种队列技术。
话又说回来,在这些情况下,最好的办法是采用您能想到的最简单的解决方案。如果您遇到性能问题,请测量并修复瓶颈。过早的解决方案浪费了大量的精力......我可以告诉你很多我浪费时间的愚蠢的过早优化。
关于java - 在使用 PreparedStatement 的同时使用 RabbitMQ 设计 Java OSGi 应用程序,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/12681833/
我是 C 语言新手,我编写了这个 C 程序,让用户输入一年中的某一天,作为返回,程序将输出月份以及该月的哪一天。该程序运行良好,但我现在想简化该程序。我知道我需要一个循环,但我不知道如何去做。这是程序
我一直在努力找出我的代码有什么问题。这个想法是创建一个小的画图程序,并有红色、绿色、蓝色和清除按钮。我有我能想到的一切让它工作,但无法弄清楚代码有什么问题。程序打开,然后立即关闭。 import ja
我想安装screen,但是接下来我应该做什么? $ brew search screen imgur-screenshot screen
我有一个在服务器端工作的 UDP 套接字应用程序。为了测试服务器端,我编写了一个简单的 python 客户端程序,它发送消息“hello world how are you”。服务器随后应接收消息,将
我有一个 shell 脚本,它运行一个 Python 程序来预处理一些数据,然后运行一个 R 程序来执行一些长时间运行的任务。我正在学习使用 Docker 并且我一直在运行 FROM r-base:l
在 Linux 中。我有一个 c 程序,它读取一个 2048 字节的文本文件作为输入。我想从 Python 脚本启动 c 程序。我希望 Python 脚本将文本字符串作为参数传递给 c 程序,而不是将
对于一个类,我被要求编写一个 VHDL 程序,该程序接受两个整数输入 A 和 B,并用 A+B 替换 A,用 A-B 替换 B。我编写了以下程序和测试平台。它完成了实现和行为语法检查,但它不会模拟。尽
module Algorithm where import System.Random import Data.Maybe import Data.List type Atom = String ty
我想找到两个以上数字的最小公倍数 求给定N个数的最小公倍数的C++程序 最佳答案 int lcm(int a, int b) { return (a/gcd(a,b))*b; } 对于gcd,请查看
这个程序有错误。谁能解决这个问题? Error is :TempRecord already defines a member called 'this' with the same paramete
当我运行下面的程序时,我在 str1 和 str2 中得到了垃圾值。所以 #include #include #include using namespace std; int main() {
这是我的作业: 一对刚出生的兔子(一公一母)被放在田里。兔子在一个月大时可以交配,因此在第二个月的月底,每对兔子都会生出两对新兔子,然后死去。 注:在第0个月,有0对兔子。第 1 个月,有 1 对兔子
我编写了一个程序,通过对字母使用 switch 命令将十进制字符串转换为十六进制,但是如果我使用 char,该程序无法正常工作!没有 switch 我无法处理 9 以上的数字。我希望你能理解我,因为我
我是 C++ 新手(虽然我有一些 C 语言经验)和 MySQL,我正在尝试制作一个从 MySQL 读取数据库的程序,我一直在关注这个 tutorial但当我尝试“构建”解决方案时出现错误。 (我正在使
仍然是一个初学者,只是尝试使用 swift 中的一些基本函数。 有人能告诉我这段代码有什么问题吗? import UIKit var guessInt: Int var randomNum = arc
我正在用 C++11 编写一个函数,它采用 constant1 + constant2 形式的表达式并将它们折叠起来。 constant1 和 constant2 存储在 std::string 中,
我用 C++ 编写了这段代码,使用运算符重载对 2 个矩阵进行加法和乘法运算。当我执行代码时,它会在第 57 行和第 59 行产生错误,非法结构操作(两行都出现相同的错误)。请解释我的错误。提前致谢:
我是 C++ 的初学者,我想编写一个简单的程序来交换字符串中的两个字符。 例如;我们输入这个字符串:“EXAMPLE”,我们给它交换这两个字符:“E”和“A”,输出应该类似于“AXEMPLA”。 我在
我需要以下代码的帮助: 声明 3 个 double 类型变量,每个代表三角形的三个边中的一个。 提示用户为第一面输入一个值,然后 将用户的输入设置为您创建的代表三角形第一条边的变量。 将最后 2 个步
我是新来的,如果问题不好请见谅 任务:将给定矩阵旋转180度 输入: 1 4 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 输出: 16 15 14 13 12 11
我是一名优秀的程序员,十分优秀!