问题标签 [data-distribution-service]

For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.

0 投票
1 回答
695 浏览

java - 带有 raspbian 的树莓派上的 openDDS

是否可以在带有 raspbian 的树莓派上构建 openDDS 和所需的 ACE+TAO?

我想为 java 构建它,所以我尝试了 $DDS_ROOT/java/INSTALL 中描述的方式,包括这里的提示

但如果我做

它以这个错误结束

有什么想法可以解决这个问题吗?

0 投票
1 回答
385 浏览

publish-subscribe - DDS 9th topic 导致崩溃

我正在DDS(更具体地说RTI DDS)用于java应用程序。我在代码中topic为我的DDS实现一个一个地创建每个,因此我可以在DDS spy编写代码后用 a 测试每个。当我写第 8 篇时,topic一切正常。然而,当我随后写 9th 时topic,似乎什么也没发生,因为程序似乎停在了某个地方。然后我进行了调试,并在大量进入代码之后,将其打印到理事会。

我不确定为什么在我创建 9th 时会突然发生这种情况topic,但如果我只有 8 个,它会很好用。我也试图增加我resourcelimits的值并得到一个Immutable QOS Policy错误。有谁知道为什么会发生这个错误,为什么我的 9topic会导致失败以及如何解决这个问题?我正在运行我的应用程序32 bit RHEL 6.6

0 投票
1 回答
1191 浏览

java - RTI DDS Qos profile history not working as expected

I am currently using RTI DDS for a pub sub system I am implementing, and for some topics want to keep a history depth of only 1 to keep to be resent if ever needed and for other topics, want to keep all the history to be resent if ever needed. Below is the Qos policy file I am using.

The following, is the code written in java to load the Keep_All_History_profile from the Qos policy file for the reader.

As well as the code to load the Qos file into the writer

However the problem I am having is when I try to load the Keep All History profile, a depth of one is only keep and not anymore. However if I change the keep last history part of the profile to a depth to say a depth of 10 it will keep and read the last 10 messages where the keep all history is supposed to be loaded. Why would this be happening where it appears as though the wrong profile is being loaded?

EDIT

Code used to make the datawriter which is used right after the loading of the Qos profile.

as well as the datareader

The data reader then sends a message with the following method,

0 投票
4 回答
1315 浏览

java - 主线程抛出异常时停止后台线程

我正在用 Java 编写一个程序,该程序使用一种消息传递机制,该机制在创建作者等时DDS启动它自己的背景。threads但是,如果main thread发生错误,我会exception使用以下代码抛出一个错误。

throw new FooUncheckedException(writerTypes.get(i) + " is not a writer type");

然后主线程像它应该的那样终止。但是,我正在使用的库创建的后台线程继续运行,因此程序在技术上永远不会停止运行。DDS我将如何优雅地关闭使程序保持活力的后台线程?

0 投票
0 回答
1317 浏览

c++ - 如何从 DDS 数据类型转换为原语?

我正在使用 DDS 在我正在开发的软件中的模块之间缓冲数据。我是整个 DDS 的新手,但我需要做的一件事是访问 a 中的数据sequence<octect,1024>并将其作为array<double>.

我知道我可以使用sequence.get_contiguous_buffer()( docs ) 函数访问数据,但这会返回一个类型为DDS_Octet( docs ) 的数组。我怎样才能使这个可以传递给我的函数(即把它变成一个原始数组)?

注意:该函数可以采用任何原语,而不仅仅是双精度;这就是我正在使用的。

0 投票
1 回答
105 浏览

mobile - 在 Linux 上找不到开放的 Splice 移动设备?

早上好。我尝试在 linux 上安装 open splice mobile(DDS for mobile),我想找到构建版本(zip 版本),但我没有在网站上找到它,我只得到 vortex 版本,它是二进制文件。如果有人知道我如何获得最新版本的开放拼接手机。 我试过这个教程:www.prismtech.com/download-documents/1322 但它没有给我任何中间件的链接。当我在 prismtech http://www.prismtech.com/vortex/software-downloads的网站上打开软件下载页面时,我没有找到 opensplice 移动版。请提供任何帮助。

0 投票
1 回答
949 浏览

c++ - 对 org::opensplice::core::DWDeleter::DWDeleter 的未定义引用

我是 OpenSplice 的新手,想从这里编译简单的教程:

https://github.com/PrismTech/dds-tutorial-cpp-ex

我下载了 OpenSplice 社区版并获取了 release.com 文件。

然后我克隆了 dds-tutorial-cpp-ex git 存储库并尝试构建 ch1:

不幸的是,有一个未定义的引用 `org::opensplice::core::DWDeleter::DWDeleter(std::shared_ptr const&)

该库被添加到定义此参考libdcpsisocpp.so的链接目标(参见https://github.com/PrismTech/dds-tutorial-cpp-ex/blob/master/cmake/FindOpenSplice.cmake#L56 )。

HDE/x86_64.linux/custom_lib我已经通过更改到文件夹并执行make -f Makefile.Build_DCPS_ISO_Cpp_Lib它完成了没有错误的重建库。

为什么我会收到此错误?我该如何解决?

我的系统是 Ubuntu 14.04 amd64。

OpenSplice 版本为:OpenSplice HDE Release V6.4.140407OSS For x86_64.linux,日期2014-04-15

编辑: OpenSplice OpenSplice HDE Release V6.5.0p1 For x86_64.linux 中存在同样的问题,日期 2015-03-19

那里的错误是:


注意:交叉发布(没有任何答案):http://forums.opensplice.org/index.php?/topic/2517-undefined-reference-to-orgopensplicecoredwdeleterdwdeleter /

0 投票
1 回答
406 浏览

ace - 只接收来自特定 DDS 主题实例的消息?

我正在使用 OpenDDS v3.6,并尝试向特定的 DDS 对等方发送消息,这是众多对等方之一。在 IDL 中,消息结构如下所示:

我的理解是,因为数据键是唯一的,所以这是一个正在写入的主题的新实例,并且使用相同的数据键写入的任何进一步的 msgs 都会发送到该主题的这个特定实例。我的发送代码如下:

所以现在我需要弄清楚如何让接收对等方只从这个主题实例中读取,而不是接收发送给其他对等方的所有其他消息。我从以下内容开始,但不确定如何正确选择特定主题实例。

非常感谢任何帮助。

0 投票
2 回答
195 浏览

wcf - 将分布式数据收集到中央数据库

我被指派更新现有的收集来自销售点的数据并将其插入中央数据库的系统。现在工作的是基于 FTP/SFTP 传输,其中信息每天发送一次,通常在晚上。不幸的是,由于不稳定的连接链接(低质量的 2G/3G 调制解调器),一些文件似乎已损坏。以这种方式连接的只有几家商店,一切都很顺利,但随着商店数量的增加,错误变得更加频繁。更糟糕的是,

我的经理建议的想法是在白天连续发送数据。数据包会更小,因此它们的传输和插入速度会更快,中央服务器将包含实际(几乎实时)数据,夜间可用于长时间运行的数据库活动,如创建备份、重建索引等。

浏览了很多网站后,我发现:

这就是我感到困惑的地方。有这么多选择,你对这些技术有什么优缺点吗?我们将 .NET 与 Windows Forms 和 SQL Server 一起使用,但如果有必要,我们可以更改为更合适的东西。我也有点害怕服务器效率。经过一些计算,服务器每秒将接收大约 15 个数据包(峰值)。很多吗?我知道有很多网站没有严格的服务器基础设施,在线处理数百名访问者仍然运行流畅,但网站主要将数据上传到客户端,这里我们将从客户端下载。

我还发现了一些类似的 SO 问题:Middleware to build data-gathering and monitoring for a Distributed System 其中提到了 DDS。您如何看待引入一些中间件服务器来处理到销售点的低质量链接,这样主服务器就不会被 1KB/s 的传输阻塞?

我会很感激你的帮助。先感谢您!

0 投票
1 回答
230 浏览

java - 测试 DDS 阅读器接收 java 单元测试的消息

我有一个单元测试,我可以在其中测试DDS当前发送消息。但是,我想实现测试消息阅读器的能力。

问题是,由于程序设置用于创建 DDS 读取器和写入器。如果我尝试让读者成为我需要的读者,他们已经拥有与topic作者相同的内容,因此会引发异常。

有没有人因此想出一种方法来模拟向读者发送 DDS 消息,就好像它们来自 DDS 作家一样?在一台计算机内,并且不使用网络上的单独计算机来执行此操作。