有人知道用 erlang 實(shí)現(xiàn)類似 tail 的么?

q1208c

RT.

這應(yīng)該是監(jiān)控系統(tǒng)的一個(gè)部分. 有人知道現(xiàn)在有沒有人實(shí)現(xiàn)了這樣的功能呢?

shijiang1130

q1208c 發(fā)表于 2014-08-26 15:49
RT.

這應(yīng)該是監(jiān)控系統(tǒng)的一個(gè)部分. 有人知道現(xiàn)在有沒有人實(shí)現(xiàn)了這樣的功能呢?

https://github.com/richcarl/file_monitor  是類似這樣的么？

q1208c

回復(fù) 2# shijiang1130

沒細(xì)看代碼, 單看 readme 的話, 好象不是太一樣.

我要實(shí)現(xiàn)的, 是 tail 的 差不多全部功能. 也就是可以指定輸出一個(gè)文件的部分或全部?jī)?nèi)容, 并且可以跟蹤文件的追加.

當(dāng)然, 這只是第一步, 后面要做的工作是跟蹤log的滾動(dòng). 也就是說, 不管log滾動(dòng)了多少個(gè)文件, 都要從最早的一個(gè)文件開始,
一條條把log讀出來(lái)并發(fā)送出去, 同時(shí),要記錄已經(jīng)發(fā)送過的log, 不要重復(fù)發(fā)送相同的內(nèi)容.

可以認(rèn)為是異步的消息處理. 基于日志的.
   

shijiang1130

1. -module(t).
   
2. -compile(export_all).
   
3. -include_lib("kernel/include/file.hrl").
   
4. 
   
5. start() ->
   
6.                 ets:new(?MODULE,[public,named_table]),
   
7.                 ets:insert(?MODULE,{t,"ini"}),
   
8.                 ets:insert(?MODULE,{size,0}),
   
9.         spawn(fun()->timer() end).
   
10. 
    
11. cancel(Pid) -> Pid ! cancel.
    
12. 
    
13. timer() ->
    
14.         receive
    
15.                 cancel ->
    
16.                         void
    
17.                 after 5000 ->
    
18.                         do_check(),
    
19.                         timer()
    
20.                 end.
    
21. 
    
22. do_check()->
    
23.         case file:read_file_info("t.txt") of
    
24.                 {ok,Exist}->
    
25.                         F = Exist#file_info.mtime,
    
26.                         [{t,G}]= ets:lookup(t,t),
    
27.                                 case F =:= G of
    
28.                                         true ->
    
29.                                                 ok;
    
30.                                         false ->
    
31.                                                 [{size,O}]= ets:lookup(t,size),
    
32.                                                 N=Exist#file_info.size,
    
33.                                                 L = N - O,
    
34.                                                 ets:insert(?MODULE,{t,F}),
    
35.                                                 ets:insert(?MODULE,{size,N}),
    
36.                                                 {ok,S}=file:open("t.txt",[]),
    
37.                                                 {ok,C}=file:pread(S,O,L),
    
38.                                                 io:format("NewContent:~p~n",[C])
    
39.                                 end;
    
40.                 _->
    
41.                 error
    
42.         end.

復(fù)制代碼

q1208c

回復(fù) 4# shijiang1130

好象略復(fù)雜。 沒太看懂。