java - RabbitMQ 与应用程序解耦

Question

我需要设置 RabbitMQ 来尝试使用异步消息传递重新设计我们的架构。

现有申请流程:

• JEE Web 应用程序(通过浏览器)创建一个新线程。
• 该线程创建一个新的操作系统进程来调用 Perl 脚本来进行一些处理。
• Perl 脚本将其输出写入文件，然后控制权返回到线程。
• 然后该线程读取输出文件并将结果加载到数据库中。
• 控制权传递给 servlet，servlet 将结果显示到 UI。

所有这些都是同步且耗时的，我们需要将其转换为异步消息通信。

现在，我计划将其分解为以下不同的组件，但不确定这是否适用于 RabbitMQ:

应用程序分割:

• JEE Web 应用程序，它是 RabbitMQ 的生产者
• 将 Perl 脚本分离到其自己的支持 RabbitMQ 通信的应用程序中。这个 Perl 客户端将使用该消息，对其进行处理，并将新消息放入 RabbitMQ 中以供下一步
• 将数据库加载器的输出文件分离到其自己的支持 RabbitMQ 通信的 Java 应用程序中。这将消耗与上一步中 Perl 客户端消息相对应的队列中的消息。

这样，输出将在数据库中可用，并且异步流程将完成。

1. 这种方式分离应用程序是否可以与 RabbitMQ 兼容？
2. 有更好的方法吗？
3. 请推荐一些 RabbitMQ 和 Perl 的框架组件

感谢您的意见。

Answer 1

是的，你可以这样做。如果这不是一项艰苦的工作，我会将数据库负载包括在 Perl 步骤中。这可能避免处理中间文件，但我不知道这对您的项目是否是可行的任务。

为了使用 RabbitMQ，我向您推荐 AnyEvent::RabbitMQ CPAN 模块。正如文档所述，您可以使用 AnyEvent::RabbitMQ 来:

• 声明和删除交换
• 声明、删除、绑定(bind)和取消绑定(bind)队列
• 设置 QoS 并确认模式
• 发布、使用、获取、确认、恢复和拒绝消息
• 选择、提交和回滚事务