Akka 输入流处理

Question

我正在使用 java 在 akka/play 框架上构建一个系统。我需要建立一个与外部系统建立 SSH 连接并在用户交互范围内维护会话的演员。

我找到了支持 java SSH 连接的 Java JCraft/JSch 库

1. 有没有办法将 JSch 输入流包装为事件驱动的输入流，因此当数据到达时会触发 onmessage(data) 事件。
2. 我的其他选择是让工作线程从位于 actor 范围内的流中读取/等待数据，这是一个好的模式吗，我担心工作线程会显着降低可伸缩性
3. 我找到了 akka 套接字支持，但不是专门的 SSH，是否已经有这样的库？

Answer 1

Jsch 通道支持写入给定的 OutputStream

channel.setOutputStream(stream)

作为解决方案，我所做的是编写一个自定义 OutputStream，在 write(buffer) 上通过 actorRef.tell(buffer, ActorRef.noSender());

因此无需外螺纹。