问题标签 [data-distribution-service]

Stackless python 允许您序列化一个任务（酸洗）以供以后在同一台机器上执行：http: //www.stackless.com/wiki/Pickling

我的问题是无堆栈 python 是否提供任何类型的 IPC、中间件、服务代理或 DDS 技术来在进程和/或机器之间移动这些腌制任务？我们真的需要在这里使用套接字吗？

他们有一个很好的频道概念：http: //www.stackless.com/wiki/Pickling

如果通道可以跨机器工作，并且您可以简单地在网络上向服务代理注册通道，那将是非常棒的。本质上，允许您将任务移动到位于不同机器上的不同无堆栈 python 服务。

我正在研究一个要求，即一个进程（比如生产者）需要向可变数量的进程（比如消费者）发送单向消息。

发布-订阅模型似乎对此很好，因为消费者将订阅来自生产者的消息。我尝试使用ZeroMQ来实现这一点。

但是，我有一些问题：

1. 消费者必须不断地轮询消息。当有新消息时，我会通知消费者。

2. 生产者队列有可能被填满。我希望生产者根据某些条件从队列中删除消息（比如删除超过 5 秒的消息，或者删除已阅读 5 次的消息）。

3. 由于消费者正在轮询并且消息没有从队列中删除，因此消费者会看到重复的消息，直到有新消息进来。我希望每条新消息只通知消费者一次。

我知道我可能使用了错误的模型（发布订阅可能不合适）。我曾考虑过使用 request-reply，但这不起作用，因为生产者不想跟踪消费者的数量。

任何人都可以提出一个好的选择吗？

我喜欢如下配置 OpenSpliceDDS。

我必须配置集中式 OpenSpliceDDS。它将发送和接收来自全局的所有数据。在集中式 dds 服务器中，只会打开 443 端口。

如何使用端口 443（安全层）配置 OpenSpliceDDS？

客户端机器具有本地 OpenSpliceDDS。本地 OpenSpliceDDS 应负责将本地数据发送到具有安全层 (443) 的集中式 OpenSpliceDDS。

如何与客户端配置？

谢谢

如果我要通过 dds 实现修复协议，而不是使用 quickfix 引擎及其发送/接收修复消息的方式，你会建议我如何处理它？

我是dds的新手。我知道我可能必须配置主题，但是要修复的主题是什么？

使用带有java的Linux环境，我有一个配置文件，应该在从控制台执行eclipse应用程序之前配置，

这是源的 OpenspliceDDS 配置文件，位于以下目录中

source /../HDE/x86.linx2.6./release.com --->在命令行执行

但是我需要在 ANT 脚本中执行源命令，任何人都可以帮助我解决这个问题。

例子 ：

我已经为命令创建了属性标签

我已经成功地创建了具有原始类型的发布者和订阅者。现在我在尝试将文件（如 xml、txt、视频、音频等）发布到 DDS 时遇到问题。我不知道如何指定 IDL 文件中的类型以及如何将整个文件发布到 DDS（以及如何在订阅者端接收文件）。

还有一个问题：“在 DDS 中发布是否有任何内存限制？”

我在订阅数据时遇到问题（使用 java 平台）。当订阅者订阅主题时，订阅的数据必须从 DDS 中删除。但就我而言，每当我订阅数据时，都会多次订阅相同的数据。数据不会从 DDS 中删除。我尝试了 QoS，但我不知道如何使用它。

请建议我如何从 DDS 中删除读取的数据。

我创建了使用 java 实现的普通发布者和订阅者，它按大小读取内容，总大小为 5MB，每 1MB 发布一次给订阅者。数据正在成功发布。现在正面临附加问题内容到现有文件。最后我只能在文件中找到最后 1MB 的数据。所以请让我知道如何解决这个问题？我还附上了发布者和订阅者的源代码。

提前致谢

在 DDS 中我的要求是，我有很多订阅者，但发布者是单身。我的订阅者从 DDS 读取数据并检查该消息是针对该特定订阅者的。如果检查成功，那么它只需要数据并从 DDS 中删除。消息必须保存在 DDS 中，直到经过身份验证的订阅者获取它的数据。如何使用 DDS（在 java 环境中）实现这一点？

我在 Linux 平台上工作，使用 Eclipse 作为 IDE 用 Ja​​va 实现 Opensplice DDS。主要类的发布者和订阅者正在执行。目前使用工具 EMMA 在代码覆盖部分工作。我已经使用 ant 脚本创建了构建文件并为 EMMA 创建了目标，目前面临如下问题，这是控制台内容：

我是否应该更改任何配置？最后是否可以在 DDS 实现中进行代码覆盖？如果其他人知道这个问题，请指导我继续。

提前致谢