问题标签 [point-to-point]

我们的项目是集成两个应用程序，使用每个应用程序的rest api，使用JMS（提供异步性质）和spring批处理从JMS队列中读取批量数据并对其进行处理，然后将其发布到接收应用程序。

我是 JMS 和 Spring Batch 的新手。我有几个基本问​​题要问：

• 哪个 JMS 模型领先——（PTP或Pub/Sub）
• 可以从 JMS 队列中批量读取消息（使用 JMSItemReader）。如果是，任何人都可以提供代码。
• 我们希望在消息成功发布（即读-处理-写）到接收应用程序后确认消息为“已读”，而不是在 JMSItemReader 读取消息时确认消息为“已读”。我们怎样才能做到这一点？

高级设计图如下

我希望使用 MPI 环拓扑，将每个处理器的最大值传递给环，比较局部最大值，然后输出所有处理器的全局最大值。我正在使用 10 维蒙特卡洛积分函数。我的第一个想法是用每个处理器的局部最大值创建一个数组，然后传递该值，比较并输出最大值。但是我不能优雅地编写一个数组，该数组只取每个处理器的最大值并将其存储为对应于处理器的等级，这样我还可以跟踪哪个处理器获得了全局最大值。

我还没有完成我的代码，现在我很想看看是否可以创建一个具有来自处理器的局部最大值的数组。我编码的方式非常耗时，如果有很多处理器，那么我每次都必须声明它们，但我无法生成我正在寻找的数组。我在这里分享代码：

编译：

我很感激建议：

1. 如果有更优雅的方法来制作局部最大值数组？
2. 如何在传递环中的值时比较局部最大值并确定全局最大值？

也可以随意修改代码，为我提供一个更好的示例。我会很感激任何建议。谢谢。

我需要使用 ns-3 创建两个无线网络和一个以太网网络，但我的所有想法似乎都不起作用，因为我不能有 collison。我试图创建一些连接的东西，例如：

（wifi）----点对点---（以太网）---点对点---（wifi）

不能发图，给个链接

它不起作用，似乎是因为我需要一种称为点对多点通信的东西，而我不知道如何在 ns-3 上做到这一点（我什至在 ns-3 上都没有找到它）而且我几乎没有查找有关此问题的参考。尝试只创建三个节点并在尝试时分配两个无线节点和一个以太网。

还尝试创建两对节点，每个节点之间都有点对点通信，但我意识到我正在改变问题。

如何使用 NS3 构建具有故障转移备份链路的点对点网络？例如，在每对连接点之间，有 2 条链路，默认情况下处于活动状态的主链路和阻塞的具有不同参数（数据速率、延迟等）的辅助链路。在主链路发生故障时，使用辅助链路。

我已经通过 UDP 协议使用 ffmpeg 设置了一个点对点流，并且流可以正常工作，但是出现屏幕撕裂等问题。我已经尝试提高缓冲区大小，但没有帮助。这是一个工作网络，所以 UDP 协议不起作用。这是完整的命令：

我试图用 TCP 进行这项工作但没有成功这是我现在得到的：

这将返回一个错误：

实时缓冲区 [UScreenCapture] [视频输入] 太满或接近太满 <323% of size: 3041280 [rtbufsize parameter]>！掉帧！

最后一条消息重复了 xxxx 次（它上升到大约 1400 次，我只是将其关闭）。

我试图实现-rtbufsize参数并将 buffsize 提高到 800000000，但没有帮助。

我将不胜感激有关如何解决此问题的任何建议。

我正在设计一个系统，其中两台计算机将在同一个本地有线网络上（因此 <1ms 延迟和 100Mbps 带宽），我需要将一台计算机上的高质量 1080p 30fps 实时生成的视频传输到下一台计算机。我正在研究基于 TCP 的 RTSP，因为视频需要可靠且没有伪影，但跳帧是可以接受的。我已经阅读了一些资料，RTSP 会增加几秒钟的延迟，这是不可接受的。我考虑的另一个选择是每秒发送 30 张 JPEG 图像。

最后，我计划将系统的每一端集成到一个应用程序中，接收器最有可能使用 SDL 和 FFMPEG，但如果有更好的系统，我会接受它。

RTSP 是否能够通过接近实时传输且无伪影来处理此问题？由于这只是一个点对点系统，会有更好的协议吗？

我是 jmeter 的新手。我正在尝试设置 JMS 点对点负载测试脚本。请求消息是固定长度格式。我需要一种从 csv 读取字段并以固定长度格式排列它们的方法。我尝试使用 javascript 切片函数，方法是使用 csv 数据配置变量并切片到所需的长度，将它们全部连接在一行中。但它不起作用。可能是我的方法是错误的。有关如何使其以固定长度格式工作的任何指示都会有所帮助。这是我尝试过的：

其中 Var1,Var2..Var4 来自 csv。

Jmeter版本：3.3

MQ：IBM Websphere MQ

只需一条输入消息，我就可以执行测试。我需要从 csv 和/或日期/时间函数中动态填充值，并以固定长度格式排列它们。

我需要一些帮助让 ffplay 接收和解码以 h264 编码的实时流。

我正在尝试在从 Kinect 接收视频帧的计算机 A 和运行 ffplay 的计算机 B 之间创建点对点流以显示直播。

这些是我在两台计算机上运行的命令。

计算机 A (RPI 3)

ffmpeg -f rawvideo -vcodec rawvideo -pix_fmt rgb24 -s 640x480 -i - -threads 4 -preset ultrafast -codec:v libx2 64 -an -f rtp rtp://192.168.0.100:2000

这是 ffmpeg 的输出：

fps= 14 q=12.0 size=856kB time=00:00:05.56 bitrate=1261.4kbits/s speed=0.54x

输出流在 10-20 帧之间运行。这不好，但我可以用它。

电脑B

ffplay -protocol_whitelist "file,udp,rtp" -probesize 32 -sync ext -i streaming.sdp

流媒体.sdp

我得到了流，但大约是 0.0001fps，这非常糟糕。我的猜测是我在 ffplay 命令上遗漏了一些东西，因为 ffmpeg 显示了更稳定和快速的流，但我似乎找不到我遗漏的东西。

提前致谢

未建立连接，错误为 javax.naming.NoInitialContextException：无法实例化类：com.solacesystems.jndi.SolJNDIInitialContextFactory [根异常为 java.lang.ClassNotFoundException：com.solacesystems.jndi.SolJNDIInitialContextFactory]

我正在尝试在 Python 上编写一个 MPI 程序来计算邻居值的平均值。

我的算法如下

使用您拥有的邻居初始化值。然后计算邻居值的平均值并从新值中减去。

我写了以下程序

但是程序不工作它卡住了，当我尝试使用以下命令在控制台上运行它时，会出现以下窗口，