问题标签 [smack-stack]

即将深入了解具有 IoT 数据摄取架构的 Kafka Streams，并查看大量SMACK 堆栈示例。但是，现在可以使用Kafka Streams，是否真的需要 Spark 和 Akka（也许只是没有 Spark）？

我一直在为此苦苦挣扎。我想用支持 X-FACEBOOK-PLATFORM 的 Java Asmack 库做类似于 XMPP 中提到的事情

我将准备我的自定义 SASL 机制，同样，在 XMPP 服务器端，我们将注册该机制，以便我们可以使用我们设计的协议对用户进行身份验证，而不是 smack 客户端和 XMPP 服务器的默认身份验证。

我想知道如何使用我的 smack 客户端注册该自定义 SASL 机制吗？

我在网上找不到任何东西，我只能看到以前使用旧方法的代码片段，例如：

像 SUpportSASLMechanism 这样的方法甚至不再存在于 smack 库中。任何人都可以请提出一些建议。

首先对不起我的英语不好..

我浏览了 Xabber Android 的示例代码。服务器正在使用带有 XMPP 协议的 Ignite 服务器。在 Xabber android 的存储库中，里面有文件上传代码。但它不起作用。HttpFileUploadManger 向其文件传输服务返回 false。

在服务器端，Jingle 和 SI 协议都实现了。但是 HttpFileUpload 管理器正在为上传服务器抛出 null。

请帮我解决这个问题..我会非常感谢你..

我们已经为具有查询能力的数据摄取系统构建了一个不错的 SMACK 堆栈（目前没有 Akka，但这是另一个问题）。

现在，如果我们想将这个平台公开给不同的用户——比如不同的垂直行业或应用程序——想要限制被摄取的数据之间的访问，是否有任何最佳实践。

我可以看到一些对 Cassandra 甚至 Kafka 的 ACL 支持，但我正在考虑完全分离并为每个应用程序提供不同的堆栈（使用 mesos/DC-OS）。有一点控制开销，但如果数据在应用程序之间完全隔离，那么这很好。

第二个想法是当数据没有完全隔离并且您希望根据凭据限制访问时该怎么做。这需要一些思考——有什么经验吗？

谢谢。

我使用SMACK堆栈开发了一个应用程序，目前正在研究一个在集群内自动分配资源的研究项目（我们使用 DC/OS）。

为了扩大或缩小Kafka或Cassandra，Marathon框架可以轻松启动或多或少的实例。现在我想为 Apache Spark 做这个“运行时缩放”。Spark 配置手册中spark.cores.max描述的配置非常适合设置可以请求多少 CPU 内核的初始限制。

当以“粗粒度”共享模式在独立部署集群或 Mesos 集群上运行时，从整个集群（而不是从每台机器）请求应用程序的最大 CPU 内核数。如果未设置，默认值将是 Spark 的独立集群管理器上的 spark.deploy.defaultCores，或 Mesos 上的无限（所有可用核心）。

Spark 已经自动启动新的执行程序，但只要spark.cores.max不超过（暂时不考虑 RAM）。

我现在的问题是，如何在运行时扩展（即允许 Spark 从集群请求更多 CPU），而无需使用更新的配置重新部署应用程序？

带有送达收据的 smack stanzaFilter 消息无法像以下格式一样处理Stanza？

我们收到“在回复超时内未收到回复。超时为 5000 毫秒（约 5 秒）。当我们尝试同时连接 300 个客户端时，在所有 smack 客户端中等待成功的 SASL 身份验证时出现异常。

服务器机器环境： 操作系统：Microsoft Windows 7 Professional 系统类型：64 位操作系统 处理器：Intel(R) Core™2 Duo CPU E7500 @ 2.93GHz，2 核 RAM：4GB

Openfire 环境：版本：Openfire-4.0.4。Java 内存：我们将最小和最大内存大小自定义为 600MB。

openfire-service.vmoptions -Xms600m -Xmx600m

Smack 版本：4.4.2

我们正在使用一个基于 Java 的 Windows 桌面客户端，该客户端使用 smack 4.4.2 版本与 Openfire 服务器进行通信。我们将 Openfire 作为 Windows 服务运行。当我们尝试连接 50 个 50 到 300 个客户端时，我们没有遇到任何问题。连接所有 300 个客户端并建立通信后，我们尝试重新启动 Openfire 服务器。客户端将持续 ping 服务器，直到它启动。服务器启动后，我们所有的客户端都将尝试与服务器连接。当时所有客户端都抛出异常“在回复超时内没有收到响应。”。无论它尝试重新连接多少次，都会收到相同的异常。

例外：

我们参考了论坛并尝试使用 XMPPTCPConnection 类的“setReplyTimeout(20000)”方法将所有客户端（300）的回复超时时间增加到 20 秒。但是在上面提到的 Openfire 服务器重启案例中问题仍然没有解决。在我们遇到这个问题后，在不停止 Openfire 服务器的情况下，我们修改了一些客户端回复超时，最长可达 80 秒。仍然是客户通过同样的例外。此外，当客户端尝试连接时 Openfire 重新启动后，Openfire Java 内存达到最大值。

解决此问题的唯一方法是重新启动每个客户端。请帮助我们找到更多相关信息并解决问题。

提前致谢！

我需要将 smack 调试器中的所有日志详细信息写入一个单独的文件。这对我从客户站点进行调试非常有帮助。

** Smack 版本：4.4.2 **

我在类路径中添加了“smack-debug-4.4.2.jar”和“smack-debug-slf4j-4.4.2.jar”，并在代码级别启用了调试配置。

代码示例：

在运行我的项目时，我可以看到包含所有请求和响应详细信息的 Smack 调试窗口。我研究了将这些日志写在一个单独的文件中。但我没有找到任何解决方案。

是否可以将这些日志写入文件。如果您能提出一些解决方案，将会很有帮助。提前致谢！！