Как я могу получить библиотеку Ganymed SSH для хвоста файла (в Clojure)?

Question

Следующий код никогда не удается подключить файл.Он просто зависает в ожидании ввода читателя.Кто-нибудь пробовал что-нибудь подобное?

(def output     (ref [] ))

(import 'ch.ethz.ssh2.Connection)
(import 'ch.ethz.ssh2.Session)
(import 'ch.ethz.ssh2.StreamGobbler)
(import 'java.lang.StringBuilder)
(import 'java.io.InputStream)
(import 'java.io.BufferedReader)
(import 'java.io.InputStreamReader)

(let [connection  (new Connection  "hostname")]
  (. connection connect)
  (let [ok         (. connection authenticateWithPassword "username"  "password" )
        session    (. connection openSession )]

    (. session execCommand "tail -f filename.txt")

    (let [sb      (StringBuilder.)
          stdout  (StreamGobbler. (. session getStdout))
          br      (BufferedReader. (InputStreamReader. stdout))
         ]

      (future (loop [line2 (. br readLine)] 
        (if (= line2 nil)  
          nil 
          (do 
            (dosync (ref-set output (conj @output line2)))
            (recur (. br readLine))))
          )
      )
    )
  )
)

Answer 1

Я согласен с Артуром. Мне не ясно, как это будет работать на практике, поскольку удаленная команда никогда не вернется / не завершится. Попробуйте в качестве примера следующее:

> (defn never-returns []
  (while true
    (do (Thread/sleep 2000)
    (println "i'm never going to finish")))
    "done")
> (def x (future (never-returns)))
> (@x)
i'm never going to finish
i'm never going to finish
...

Я думаю, что, возможно, лучшим подходом было бы избавиться от многопоточности вашего клиента, предоставляя средства для асинхронного доступа к хвосту файла. Например, вы можете рассмотреть возможность использования netcat для отправки вывода tail -f в сокет, а затем периодически читать из этого сокета в вашем клиенте, чтобы получить вывод файла. Примерно так на удаленной стороне:

tail -f filename.txt | nc -l 12000

Тогда в вашем коде clojure:

(import '(java.net ServerSocket Socket))     
(def client (java.net.Socket. "hostname" 12000)) 
(def r (java.io.BufferedReader. (java.io.InputStreamReader. (.getInputStream client)))) 
(println (.readLine r))  ; or capture the output

Нечто подобное. Надеюсь, это поможет.

Answer 2

Я не уверен, что будущее - это лучшая конструкция для запуска вашего рабочего потока, потому что оно блокируется при разыменовании до работа завершена