问题标签 [mom]

我使用 gearman 作为 C++ 应用程序和 PHP 应用程序之间的接口。我的工作依赖于订单。使用内存队列，它们执行的顺序与添加它们的顺序相同（由 1 个工作人员确定）。我想坚持我的队列。gearman 会按照崩溃或重启后添加的顺序在持久队列中执行作业吗？

我想在任意形状（已知函数）闭合曲线边界内用积分方程（MoM）求解拉普拉斯方程。我们根据边界点在内部解空间中找到给定坐标的点的值。有谁知道任何算法或想法来为里面的所有点实现这个？

我是RabbitMQ的新手。我需要一个 MOM 系统来实现这些目的：

1. 在我的逻辑成功执行之前，会使用已发布的消息。
2. 在我的逻辑成功执行之前，代理不必从队列中删除已发布的消息。

对于这些目标，我在第一次尝试时编写了以下代码：

通过这种方法，我达到了第二个目的，换句话说，代理不会删除我的消息，但是有一次队列中的所有消息都被消费并全部回滚，代理不会再次向我的消费者发送消息.

在第二次尝试时，我编写了以下代码：

通过这个解决方案，我实现了这两个目标，但我不知道我的代码是否正确？该方法是否会在高 TPS 的生产环境中引起问题？不知道basicNack方法的requeue flag是重还是轻？

我有一个用例，我必须使用一种排队机制来确保消息由消费者（“工人”）按顺序处理，一个接一个。

我过去使用过 RabbitMQ，它保证了接收消息的顺序。但是，如果该顺序不正确怎么办？

假设我提交消息 [4, 5, 3, 2, 1]，RabbitMQ 消费者将按该顺序处理消息。如果我希望它们按 [1, 2, 3, 4, 5] 的顺序处理，因为消息相互依赖，该怎么办？

另外，我不想让消费者在消息 2 被确认之前消费消息 3（没有间隙）。

是否有任何支持此用例的排队解决方案？目前，我们将消息转储到数据库中，并让工作人员按顺序定期提取数据。

我在尝试学习面向消息的中间件 (MOM)，并在此过程中参考在线资料。

我了解 MOM 用于使两个异构系统通过消息传递进行通信。

我还了解了各种产品，例如：

• IBM MQ / IBM WebSphere MQ / IBM MQSeries
• 兔MQ
• Apache ActiveMQ

这些产品是概念的实现Message oriented middle-ware吗？如果是这样，是否有任何标准规范MOM？

在应用程序中，我们必须通过 Internet 将来自多个客户端的传感数据流发送到中央服务器。一个明显的解决方案是使用诸如 Kafka 之类的 MOM（面向消息的中间件），但我最近了解到我们可以使用诸如 oracle Materialized View 之类的数据库同步工具来做到这一点。

后一种方法适用于某些应用程序（将数据从中央服务器发送到多个客户端，与我们的应用程序相反），但它在我们的应用程序中的优缺点是什么？在速度、安全性等方面，哪一个更适合从多个（约 100 个）客户端向服务器发送感官数据流？

谢谢。

附言

有关更多详细信息，请考虑一个应用程序，其中许多（大约 100 个）客户端必须通过 Internet 将流数据（每分钟 1MB 数据）发送到中央服务器。服务器中需要这些数据来进行在线监控、分析和一些计算，例如机器学习和数据挖掘任务。

我的问题是关于 db-to-db 连接和流解决方案之间的区别，例如用于将数据从客户端传输到服务器的 kafka。

通过仅使用一个 JMS 队列，应用程序是否可以在其上消费和生产？

或者它需要使用两个 JMS Queue ？一个用于消费，另一个用于生产。

提前谢谢你。

我将 MQTT 与 QOS 1 一起使用。

我有一个消费者和一个生产者。它们相互通信（HiveMQ作为客户端）。他们使用VerneMQ作为代理。我使用持久性会话。

如果消费者离线，后来又上线，他应该成为他离线的所有消息。但这只有在消费者在另一台计算机上并且我不停止微服务但我关闭 WiFi 然后再打开时才有效。但是，如果我关闭了一个微服务，然后重新启动它，它就不适用于离线消息。

如果我再次启动微服务，我认为这就是它再次订阅该主题的原因。是这个原因吗？或不？

更新：我刚刚在消费者第二次开始时没有订阅就对其进​​行了测试。那也行不通。所以订阅并不是消费者收不到消息的原因。

带有 czmq 的 ZeroMQ 显示出一些令人担忧的性能。计时结果相差近 20 倍。具体来说，在以下示例中，测试时间范围从大约 7 毫秒到 150 毫秒！？

基于提供的czmq“草原”[1] 测试示例，我向abcdefghijklmnopqrstuvwxyz消费者发送了一个类似 1000x 的字符串。

有谁知道这可能是为什么？

最小、完整和可验证的示例

基于grasslands示例。生产者和消费者分成不同的文件/进程。

主题

观察者

五次运行

参考

1. https://github.com/zeromq/czmq/tree/master/examples/security

我是 JavaEE 的新手，正在尝试处理 JMS 的东西。这是实现MessageListener和 Override onMessage的MessageBean ，因此我尝试从队列接收消息 我的代码片段：

但不幸的是有一个编译错误，方法getBody 无法解析并在 IntelliJ 中标记为红色。帮我弄清楚。提前致谢