如何使用flink中的本地套接字，其中端口号后面有“/*”，其中*是源的其余部分？

Question

我是apache-flink的新手，我需要处理一些来自akka本地分车的数据，这些数据正在流到'ws://localhost:9000/ws‘

在flink中，我只能找到一个名为“socketTextStream”的函数，它使用主机名、端口和分隔符

例：

DataStream<String> text = env.socketTextStream(hostname, port, "\n");

如何将套接字指定为'ws://localhost:9000/ws‘？

Answer 1

问题是，socketTextStream内部使用常规套接字，即与指定地址连接的java.net.Socket。但假设从您描述的地址来看，您正在处理的是WebSockets。不能使用常规套接字从WebSockets读取数据。目前，Flink没有从WebSockets AFAIK创建数据存储的API。唯一要获得的是编写您自己的SourceFunction，它将在内部使用javax.websocket-api创建连接并从服务器读取数据。