问题标签 [bayeux]

在服务器端，CometD 提供了一个 MaxQueueListener 钩子来丢弃消息，但是如果 Bayeux 客户端想要停止从服务器接收消息而不断开连接，它可以实现吗？

当我们在 chrome 上运行我们的 web 应用程序时，我们遇到了一些奇怪的问题。应用程序上的所有操作都按预期执行，但在某些日子，当我们执行应用程序的非常基本和常见的功能时，chrome 开始显示此弹出窗口，说明：-“以下页面已变得无响应。您可以等待它变为响应或杀死它。有等待和杀死两个选项。

所以我们想知道，为什么有时应用程序会出现这种意外行为。所以需要你的帮助来找出可能的原因。

小应用程序背景： 1. 分析应用程序有多个选项卡，每个选项卡上有多个图表和网格。2. 对大数据进行操作的 DOM 密集型应用程序。3. 使用 EXTJs -4.2 开发完整的 UI 和 JAVA 作为后端，4. CometD 作为消息服务器。4. Jetty 服务器上部署的应用程序。

因此，我们已经找出了一些可能导致问题但很难确定确切原因的区域。可能需要关注的领域： 1. 在 Chorme 上渲染图表、网格和其他 UI 组件。2. 访问的应用程序的互联网或网络速度慢。3. 对服务器的大量请求和来自服务器的大量响应数据。

所以有什么想法可能导致这种情况。还有任何工具或插件等可用于确定确切的问题区域。

我想将push-topic、salesforce 流 api数据获取到前端 python 客户端。我看过几篇文章，但没有一篇涉及 python 前端。大多数在 Node.js 上。如果有人能指出如何在 python 中订阅来自 salesforce 的流式 API 数据，那将非常有帮助。我想对收到的数据运行一些机器学习算法并将结果写回销售人员。

此SO 帖子中的链接不起作用。

我的目标是拥有一个监听服务器消息的bayeux客户端。但是，我仍在努力与bayeux客户端的服务器建立连接。服务器需要登录凭据。但我发现很多没有任何登录细节的例子。使用一些示例，我发现bayeux 客户端对象需要 LongPollingTransport 对象。其中包含一个 httpclient。但是，我想先握手，以便我知道连接正常，然后我应该开始在频道 /test/temp 上收听服务器。服务器的 url 是 (url = " https://manse.abcd .fi"; ) 和下面给出的客户端定义。但是由于 Bayuex http url 需要登录。我如何通过登录（用户和密码）来建立连接。我觉得应该在 LongPollingTransport 类的某个地方给出它。到目前为止我连接失败。

此代码仍然给出错误。我仍然不确定 LongPollingTransport.create(null) 是否正常工作。我使用了您建议的相同名称空间。这样好吗。

目的是构建一个订阅和收听频道的java客户端。然后将来自 cumulocity 服务器的到达事件处理到 hadoop。首先，使用 java 客户端很难连接（订阅）cumulocity 服务器。但是，现在我们已经有了订阅者（因为我们能够获得一些价值，如代码注释中所述）。接下来我们想要订阅者收听我们在 cumulocity 服务器中定义的频道。但是我们无法在 cumulocity java 文档中获得任何有助于实现此步骤的方法或任何有用的东西。这是代码。我已经匿名化了凭据和服务器 url。

因为我们能够获得一些整数值来验证与服务器的连接。但是现在下一点是如何监听事件的通道并获取这些事件。任何帮助将不胜感激。

我正在尝试通过 Websocket 将 WebRTC C 客户端连接到 CometD 下的 Java 服务器。

问题是，不可能使用像“Libwebsockets”这样的常规 websocket 库来握手 Java Bayeux 服务器。

是否有任何 C 库可以让我们与 Bayeux 服务器握手或让我们制作自定义握手形式？

如果没有，我将不得不编写自己的连接器。考虑到这种情况，您是否有任何想法从哪里开始或使用什么来让我在 C 中制作自定义握手表单？

任何帮助将非常感激。

我在 Android 上使用 CometD Java 客户端。

编译组：'org.cometd.java'，名称：'cometd-java-client'，版本：'2.9.1'

我需要订阅 CometD 服务器上的频道。但是有一个问题 - 服务器需要自定义订阅消息（这是来自服务器文档的预期订阅消息有效负载）：

所以我的问题是如何将自定义字段添加到订阅消息（user、、、domain等pid）sid？目前我正在订阅这样的频道：

但它按预期失败了。

顺便说一下，我使用org.eclipse.jetty.client.HttpClient的是 HttpClient。

我正在尝试自定义 Bayeux 服务器响应的响应，以便在将其发送回 UI 之前添加一些标头参数。我可以使用 LongPollingTransport 中的自定义方法在请求中添加标头值。需要很多帮助。

根据http://cumulocity.com/guides/reference/real-time-notifications/发起握手以接收实时通知的客户端可以在其请求正文中包含建议。这个建议可以有一个超时（“发送连接消息和服务器响应之间的最大时间，以毫秒为单位。”）和一个间隔（“如果没有收到来自客户端的下一个连接消息，服务器将关闭会话的时间段。”） . 我不了解这些参数以及它们如何应用于我的长轮询连接。

1. 为什么服务器会对客户端用于其连接调用的超时感兴趣？它应该在通知可用时立即发送通知（即“实时”）。正如预期的那样，确实如此。即使我指定了一个非常短的超时，但实际上为我的连接使用了更长的超时，我仍然会收到发生在这两个时间点之间的通知而没有任何问题。当我指定长时间超时时，无论如何我都会立即收到通知。延迟通知是有意义的，但我没有看到文档中提到这些。那么这个值是什么意思呢？
2. 间隔的含义是什么？如果我指定一个较短的间隔，但在两次连续的连接调用之间等待更长的时间，那么服务器不会“关闭会话”，如果这意味着我的 clientID 变得无效并且我需要进行新的握手。也许这只是保证的最短时间，服务器必须保持会话？即客户端希望被允许在连接之间等待的最长时间[并且等待更长的时间可能会或可能不会起作用，由服务器自行决定]？这也不是实际清除队列的时间，因为如果我在未连接时触发通知，并在间隔时间过去后重新连接，那么该通知仍然可以正常传递。

如果我们将其与 SmartREST 通知进行比较，我们会发现它应该以相反的方式工作，恕我直言，这更有意义：服务器将建议发送给客户端，告诉它应该如何配置自己。这种情况下的含义可能仍然有些模棱两可，但至少处理可能更直接（=按照服务器的建议做）：

1. 超时：不要使用较长的超时，因为服务器不希望保持连接打开的时间超过 X。不要使用较短的超时，因为服务器可能需要 X 时间来生成响应的所有通知。
2. 间隔：不要比 Y 更快地重新连接，因为服务器内部通知分发甚至没有运行得那么快。在重新连接之前不要等待超过 Y，因为内部队列不会缓冲超过 Y 的通知。（在 CometD 参考中，这两个被命名为interval和maxInterval，因此很明显它们是独立的。）

为什么两个场景的“建议方向”是相反的？我应该如何（如果有的话）将建议用于定期实时通知握手？

非常感谢您对此的任何澄清。

我试图通过 websocket 客户端连接到 commetd 服务器。我完全使用了github 上的官方 cometd 演示中的代码，没有修改，并尝试连接到http://localhost:8080/cometd/test

.. 但是，一旦我的客户尝试执行 websocket 升级 http 请求，我就会收到“HTTP/1.1 400 Unknown Bayeux Transport”的响应有什么想法吗？

我用 SSL 尝试过，没有它，后者显然是为了减少潜在的错误来源。在这两种情况下，我都会遇到相同的错误。

这是我的 pom，以防我忘记了一些重要的 websocket 相关依赖项

mvn dependency:tree 产生以下

码头日志显示以下内容

在哪里可以看到调用了一些 Jetty_WebSocketUpgradeFilter，这让我认为 websocket 依赖项存在但仍然出现问题。