- 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/
关闭。这个问题需要更多focused .它目前不接受答案。 想改善这个问题吗?更新问题,使其仅关注一个问题 editing this post . 4年前关闭。 Improve this questi
.NET 框架:4.5.1 我在 Blend for visual studio 2015 中遇到一个奇怪的错误,我找不到它的来源。 如果我在 VS 中打开我的 WPF 解决方案,它会加载并运行良好。
我经常遇到这样的问题,与 Hierarchical RESTful URL design 非常相似 假设该服务仅提供用户上传文档。 POST, GET /accounts PUT, DELETE /a
在 Rails 应用程序中,我使用 devise 来管理我的用户,而我用来销毁 session 的链接不再有效。它正在工作,现在我添加了事件管理员,但没有。 我的链接是 :delete, :clas
我已经坚持了超过 24 小时,试图按照此处发布的其他解决方案进行操作,但我无法使其正常工作。我是 Rails 新手,需要帮助! 我想让我的/users/edit 页面正常工作,以便我可以简单地更改用户
Devise 在以下情况下不会使用户超时: 用户登录,关闭选项卡,然后在超时 + X 分钟内重新访问该 URL。用户仍处于登录状态。 如果选项卡已打开并且稍后刷新/单击,则超时可以正常工作。这意味着
我想使用这样的 slider 我希望该 slider 根据提供给它的值进行相应调整。到目前为止,我只能应用具有渐变效果的背景,但无法获得这种效果。请通过提供样式代码来帮助我。
您应该为每种方法创建一个请求/响应对象,还是应该为每个服务创建一个? 如果我在所有方法中使用它,我的服务请求对象中将只有 5 个不同的东西,因为我对几乎所有方法使用相同的输入。 响应对象将只有一个字典
我正在尝试在 REST 中对实体的附件进行建模。假设一个缺陷实体可以附加多个附件。每个附件都有描述和一些其他属性(上次修改时间、文件大小...)。附件本身是任何格式的文件(jpeg、doc ...)
我有以下表格: Blogs { BlogName } BlogPosts { BlogName, PostTitle } 博客文章同时建模一个实体和一个关系,根据 6nf(根据第三个宣言)这是无效的。
如果 A 类与 B、C 和 D 类中的每一个都有唯一的交互,那么交互的代码应该在 A 中还是在 B、C 和 D 中? 我正在编写一个小游戏,其中许多对象可以与其他对象进行独特的交互。例如,EMP点击
关于如何记住我与 Omniauth 一起工作似乎有些困惑。 根据这个wiki ,您需要在 OmniauthCallbacksController 中包含以下内容: remember_me(user)
设计问题: 使用 非线程安全 组件(集合,API,...)在/带有 多线程成分 ... 例子 : 组件 1 :多线程套接字服务器谁向消息处理程序发送消息... 组件 2 :非线程安全 消息处理程序 谁
我们目前正在设计一个 RESTful 应用程序。我们决定使用 XML 作为我们的基本表示。 我有以下关于在 XML 中设计/建模应用程序数据的问题。 在 XML 中进行数据建模的方法有哪些?从头开始然
我正在设计一个新的 XSD 来从业务合作伙伴那里获取积分信息。对于每笔交易,合作伙伴必须提供至少一种积分类型的积分值。我有以下几点:
设计支持多个版本的 API 的最佳方法是什么。我如何确保即使我的数据架构发生更改(微小更改),我的 api 的使用者也不会受到影响?任何引用架构、指南都非常有用。 最佳答案 Mark Nottingh
关闭。这个问题是opinion-based 。目前不接受答案。 想要改进这个问题吗?更新问题,以便 editing this post 可以用事实和引文来回答它。 . 已关闭 4 年前。 Improv
我想用 php 创建一个网站,其工作方式与 https://www.bitcoins.lc/ 相同。确实,就每个页面上具有相同布局但内容会随着您更改链接/页面而改变而言,我如何在 php 中使用lay
我有一个关于编写 Swing UI 的问题。如果我想制作一个带有某些选项的软件,例如在第一个框架上,我有三个按钮(新建、选项、退出)。 现在,如果用户单击新按钮,我想将框架中的整个内容更改为其他内容。
我正在尝试找出并学习将应用程序拥有的一堆Docker容器移至Kubernetes的模式和最佳实践。诸如Pod设计,服务,部署之类的东西。例如,我可以创建一个其中包含单个Web和应用程序容器的Pod,但
我是一名优秀的程序员,十分优秀!