- 論壇徽章:
- 2
|
我想做日志實時監(jiān)控。
思路是,創(chuàng)建一個命名管道,
用tail -f監(jiān)控應(yīng)用程序日志,并重定向給命名管道,
在管道另一側(cè),用tail -f監(jiān)視并發(fā)送給kafka(一種消息隊列)。
第一步,啟動管道讀側(cè):- stdbuf -oL tail -f ${FIFO} | ${KAFKA_HOME}/bin/kafka-console-producer.sh
復(fù)制代碼 第二步,啟動管道寫側(cè):- stdbuf -oL tail -F -n0 ${APPLOG} > ${FIFO}
復(fù)制代碼 (使用stdbuf把tail設(shè)置成行緩沖模式,避免io緩沖導(dǎo)致延時輸出。)
但是遇到的問題是,有時會發(fā)生應(yīng)用日志在不斷寫入,但并沒有發(fā)出kafka。
我使用strace -p連接到管道讀側(cè)的tail查看運行情況,
在另一個窗口執(zhí)行 echo xxx > ${FIFO},
可以觀察到tail read 讀出了 xxx,但沒有執(zhí)行write。
有怕是io緩沖問題,所以我 echo 了10KB的內(nèi)容,發(fā)現(xiàn)tail調(diào)用了read,和brk,但仍然沒有write。
這種問題并不總發(fā)生,似乎是運行了一段時間以后會發(fā)生,重新啟動一次就好了。
求高手幫忙解決。 |
|