问题标签 [mom]

我得到了 etcd/consul/$whatever 试图解决的问题。服务消费者需要与服务提供者交谈，一个流动性极大的分布式系统需要一种机制来将两者结合起来。

然而，“服务消费者的请求去哪儿了”的问题？是旧的，IMO 已经用 MOM 解决了 - 面向消息的中间件。

在 MOM 中，这个想法是服务消费者不关心服务提供者住在哪里。他们只是发送一条消息并让消息总线负责将消息路由到适当的消费者。可以有多个提供者都在做同样的事情（基于队列的循环）或版本化的提供者（/v1/request 转到一个，/v2/request 转到另一个）。

这是一种简单而强大的集成模式，将服务接口与其实现完全分离。

然而我看到了这种对发现服务提供者的奇怪痴迷，这似乎在消费者和提供者之间建立了紧密的耦合（除了一些其他的反模式之外）。

那么，我在这里缺少什么？TIA。

我已经阅读了一些关于 JMS 的教程和文章，但是这些都没有给出可以使用这个 API 的应用程序的示例。我想知道是否有人可以举一个Java消息服务在现实世界中使用的例子。谢谢

我想检查设计方法的可行性，以使用 JMS 或 ActiveMQ 或 RabbitMQ 等面向消息的中间件 (MOM) 技术来处理单个 Web 应用程序中的异步处理，即 MOM 服务器的发布者和订阅者将包含在相同的网络应用程序。这种设计背后的基本原理是将一些繁重的处理功能卸载为后台异步操作。在这种情况下，发布者是服务器端实时 Web 服务方法，需要立即（< 1 秒）响应调用 Web 服务客户端，并且发布者在 MOM 主题上发出消息。订阅者包含在与发布者相同的 Web 应用程序中，并且订阅者使用消息异步处理复杂的稍微耗时（5-7 秒）的功能。通过这种设计，我们可以避免在应用服务器容器中生成新线程来处理繁重的复杂处理功能。

在这种情况下，如果消息发布者和消息订阅者包含在同一个 Web 服务器地址空间中，那么使用 MOM 服务器是否过大？根据我的阅读，MOM 技术主要用于应用程序间通信，并想检查是否可以使用 MOM 进行应用程序内通信。

让你知道你的想法。

谢谢，

我在 Windows 7 上使用 apache ActiveMQ 6.0。我run.bat在文件夹中运行并在http://localhost:8161/bin上测试了 Web 控制台，它工作正常。

但是当我尝试通过http://localhost:8161/admin进入管理员模式时，出现错误：

解决办法是什么？

我找不到 log4net 是否是 MOM 的信息。如果不是那为什么？我试图从他们的网站上弄清楚。

我试图在过去 12 个月中获得相同的结果，它们的值与去年相同的月份以及百分比差异。

每个选择都可以，但是当结合起来时，我得到了

[Err] 1242 - 子查询返回多于 1 行

感谢您的时间和支持！

是Message Oriented Middleware（例如JMSin JEE）aSpace Base Architecture吗？MOM如果答案是错误的，那么系统和基本系统之间有什么不同Space？

我正在研究 Kafka 9 作为一个爱好项目，并完成了一些“Hello World”类型的示例。

我不得不考虑基于请求响应消息的真实世界 Kafka 应用程序，更具体地说，如何将 Kafka 请求消息链接到其响应消息。

我正在考虑使用生成的 UUID 作为请求消息键并将此请求 UUID 用作关联的响应消息键。与 WebSphere MQ 具有消息相关 ID 的机制类型非常相似。

我的结束 2 结束过程将是。

1）。Kafka 客户端生成随机 UUID 并发送单个 Kafka 请求消息。2）。服务器将使用此请求消息提取并存储请求 UUID 值 3)。使用消息有效负载完成业务流程。4）。使用请求消息中存储的 UUID 值作为响应消息 Key 的响应消息进行响应。5）。Kafka 客户端轮询响应主题，直到超时或检索到具有原始请求 UUID 值的消息。

我担心的是 Kafka 消费者轮询会从响应主题中删除其他客户端消息，并增加偏移量，使其他客户端失败。

我是否正在尝试将 Kafka 应用到它从未设计过的用例中？

是否可以在 Kafka 中实现请求/响应消息传递？

I'm new to distributed systems and try to get an fitting architecture and frameworks for my scenario.

I have an scenario, where many heterogeneous computers shall be connected as a distributed system. Some computers can mine data and store these locally, other want to access the data for visualization. The data must be transfered regularly and can be quite big (some MegaBytes), to create plots out of it. I also want to be able to start services (e.g. data visualization) on specific computers.

• Can I transfer the data with an MoM, like ActiveMQ, efficiently? For Example that my data visualization services subscribe the topic with the needed data and the data miner publishes it. Would be be fast enough for having live data updating 10 times per second?
• Would an RPC Framework be more efficient?
• Can i combine a overlaying MoM with an RPC Framework or a socket Connection for the data-transfer? Or does this make sense at all?

我需要设置 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 推荐一些框架组件

感谢您对此的投入。