问题标签 [solace]

全部

在使用 Solace 进行一些桥接式工作时，我注意到日志输出量大幅增加，例如：

Sdk _solClient_context_registerForFdEvents，fd 2436，事件 2，回调 000000001001EC10，会话 '(c1,s1)_jsqual2' 的用户数据 0000000008B78960

SDK _solClient_context_unregisterForFdEvents, fd 2436, 会话 '(c1,s1)_jsqual2' 的事件 2

Sdk _solClient_context_registerForFdEvents，fd 2436，事件 2，回调 000000001001EC10，会话 '(c1,s1)_jsqual2' 的用户数据 0000000008B78960

SDK _solClient_context_unregisterForFdEvents, fd 2436, 会话 '(c1,s1)_jsqual2' 的事件 2

Sdk _solClient_context_registerForFdEvents，fd 2436，事件 2，回调 000000001001EC10，会话 '(c1,s1)_jsqual2' 的用户数据 0000000008B78960

SDK _solClient_context_unregisterForFdEvents, fd 2436, 会话 '(c1,s1)_jsqual2' 的事件 2

所以有很多注册和注销的东西:)

我使用单独的上下文和会话来订阅和发布，并将传出消息直接从订阅者会话的 Solace 消息回调处理程序中发送到 >1 个会话。

知道这些可能是什么以及它们表示什么吗？日志记录量很高，并且处于 INFO 级别，因此不太容易过滤掉。

任何建议将被认真考虑。

我听说过 Solace 并且正在阅读它，但我对此知之甚少。我有一个HashMap：

我想把它发布给 Solace。我怎么做？我需要遵循哪些步骤？请帮忙！

我希望将慰藉与春季批处理/反之亦然集成，其中春季项目编写者应该是一个慰藉主题/队列。有没有办法做到这一点？我有一些关于春天的安慰的小贴士，但这些都是独立的信息。我正在寻找批量插入来安慰。

我将 JCSMP API 封装在一个类中，并为其他类提供发送和消费消息的方法。

我有以下方法：

当我有多个线程调用此方法时，偶尔会注意到以下异常：

com.solacesystems.jcsmp.ClosedFacilityException：试图对关闭的 XML 消息生产者执行操作

我想知道每次调用 send() 后是否关闭了生产者。我应该如何使这个方法线程安全？谢谢你。

如何将字符串作为协议缓冲区消息发送？我想做以下事情：

是否有人使用 Solace 设置了“消息分组”（重新 ActiveMQ）场景。

例如，考虑大量消息（例如订单），每个订单都有一个唯一的订单 ID。对订单的修改/更改具有相同的订单 ID。我想对不同的订单 ID 使用循环调度，但需要确保“按顺序”处理相同订单 ID 的消息。

消息组专门解决了这个问题，但我看不到如何在 Solace 中实现相同的功能。

-- 附加上下文

我正在考虑使用主题结构，例如： TOPIC/orders/ ，它为我提供了组。然后通过 TOPIC/orders/* 订阅...

从文档看来，似乎所有组件都可用：通过主题名称进行分组，保证消息，应用程序确认，通过非排他队列进行循环调度......但我没有看到一个具体的例子来展示如何带来这些共同解决“消息组”问题。

谢谢。

我有许多设备使用 MQTT 通过 Solace 向后端服务器发送数据。由于我需要处理大量传入消息，我正在考虑启动一些侦听器实例来处理传入消息。但是，它没有帮助，因为 MQTT 发布/订阅实际上是一对多的消息传递，即相同的消息将被传递给所有订阅的侦听器。我知道 Solace 支持 DTO，但它是否支持使用 MQTT 的 DTO？如果是这样，我该怎么做？如果没有，有什么建议我可以启动多个侦听器来处理大量传入消息吗？我现在想到的是创建订阅这些主题的非独占交付队列。不确定是否有其他更好的方法。

谢谢你。

我有以下制作人：

在调用producer.send()向主题发布消息时，我如何知道是否有任何错误，因为responseReceived()没有为直接消息调用而调用？由于消息是异步发布handleError()的，什么时候JCSMPStreamingPublishEventHandler调用？我应该等多久才能得出发布消息没有错误的结论？

谢谢你。

我们想做一个功能，一旦设备连接并订阅慰藉，我们将发布一个主题给它。我们想知道设备连接到慰藉并订阅慰藉的事件是什么？我们可以参考哪一章。谢谢

我知道 MQTT 客户端可以通过首先订阅“$SYS/client/reply-to”来获取他们的点对点（P2P）主题。这将返回客户端将订阅的 P2P 主题。但是，他们需要在消息体中传递这个 P2P 主题，让消息的订阅者以请求/回复模式回复。有没有办法减少在消息体中传递 P2P 主题的开销？我们可以使用 SEMP 获取 P2P 主题?

谢谢你。