如何使用Java在Akka流中加入流

编程问答 2022-06-12

问题描述

我是Akka Streams的新手。如何使用akka创建以下调用序列：

读取文件->处理文件的行->通过tcp调用远程服务器->接收并处理响应

我不明白如何以这种方式连接从文件读取的行：

final Source<String,NotUsed> lines =
       akka.stream.alpakka.file.javadsl.FileTailSource.createLines(fs.getPath(FILE_NAME),maxLinesize,pollingInterval,"\n",Charset.forName("utf8"));

和

final Flow<ByteString,ByteString,CompletionStage<Tcp.OutgoingConnection>> connection =
                Tcp.get(system).outgoingConnection("127.0.0.1",8888);

CompletionStage<Tcp.OutgoingConnection> connectionCS =  connection.join(repl).run(system);

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

akkaakkaflowflowjavajava