如何在Hazelcast Jet中打开一个tcp套接字并处理通过它获得的连续信息
我尝试使用Hazelcast Jet分析传感器数据，为此我需要打开一个Tcp套接字并处理通过它获得的信息。
共有1个答案
您可以使用套接字流带从Jet中的套接字读取。查看文档:http://docs.hazelcast.org/docs/jet/0.4/manual/vertices_in_the_library/sources.html#page_socket+streamer
-
问题内容： 我正在考虑AJAX应用程序必须轮询轮询更新有多大限制，而最理想的是javascript能够建立与服务器的真正双向连接。我想知道是否存在将javascript与可以建立tcp连接的浏览器插件集成的方法，以便可以将数据传入和传出浏览器插件。 问题答案： 这是具有类似方法的实现： 套接字 它使用Java Applet，并将其API桥接到JavaScript，有趣的是… 这里是另一个： 套接字
-
问题内容： 大家好。我有一个使用ServerSocket和Socket类用Java编写的服务器。 我希望能够检测并处理断开连接，然后在必要时重新连接新客户端。 检测客户端断开连接，关闭套接字然后接受新客户端的正确步骤是什么？ 问题答案： 大概是在从套接字读取数据，也许是在输入流上使用包装器，例如BufferedReader。在这种情况下，当相应的读取操作返回-1（对于原始read（）调用）或为nu
-
我是一个初学者程序员，所以这很可能是显而易见的，我忽略了答案。但说到这个问题。 我有一个由两部分组成的程序（它比这个例子稍微复杂一点，但情况是一样的）。该程序在客户端和服务器之间触发了多条消息。我在服务器端有一个PrintWriter来向客户机发送消息，在客户机上有一个BufferedReader来读取发送的消息。当这个例子运行时，我得到了两行作为输出。第一个消息是两个消息，第二个消息是NULL。
-
结果: 在步骤6中，如果服务器在几分钟内关闭死连接--CY，则新通道CY2将变为单向--从客户端Y发送的数据不能到达服务器，包括ACK数据包，而反之亦然。 如果服务器在很长的时间（例如2小时）内关闭了已死的连接--CY，则不会出现任何问题。 这个问题只在运行NAT时才会发生，至少我们在同一个LAN中运行应用程序时不会重现这个问题（不需要穿越NAT）。 更多信息: 1)第一台计算机上的连接A：192
-
问题内容： 我已经用套接字卡住了4h，我使用的方式是只有一个应用程序作为客户端和服务器，一旦客户端连接， 它将与新客户端一起打开theard，并等待消息。 一旦消息发送到服务器，客户端将收到响应，该部分正在正常工作。 客户专区的一部分： 服务器支持2条消息，第一条是“列表”，发送一条命令是“获取值”。 如果客户端将请求命令“列表”，它将运行以下命令：有一个“服务器/客户端”，它正在发送请求并接收一
-
问题内容： 我正在尝试在Python中建立安全的套接字连接，而使用SSL有点麻烦。我已经找到一些有关如何与SSL建立连接的代码示例，但它们都涉及密钥文件。我尝试连接的服务器不需要接收任何密钥或证书。我的问题是，我该如何实质上包装带有SSL的python套接字连接。我知道我应该使用的密码是，协议是。这就是我一直在尝试的： 运行此代码时，没有任何错误，但响应为空。当尝试在命令行中调试此代码时，通过在终