有人知道用 erlang 实现类似 tail 的么?

q1208c

RT.

这应该是监控系统的一个部分. 有人知道现在有没有人实现了这样的功能呢?

shijiang1130

q1208c 发表于 2014-08-26 15:49
RT.

这应该是监控系统的一个部分. 有人知道现在有没有人实现了这样的功能呢?

https://github.com/richcarl/file_monitor  是类似这样的么？

q1208c

回复 2# shijiang1130

没细看代码, 单看 readme 的话, 好象不是太一样.

我要实现的, 是 tail 的 差不多全部功能. 也就是可以指定输出一个文件的部分或全部内容, 并且可以跟踪文件的追加.

当然, 这只是第一步, 后面要做的工作是跟踪log的滚动. 也就是说, 不管log滚动了多少个文件, 都要从最早的一个文件开始,
一条条把log读出来并发送出去, 同时,要记录已经发送过的log, 不要重复发送相同的内容.

可以认为是异步的消息处理. 基于日志的.
   

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.

复制代码

q1208c

回复 4# shijiang1130

好象略复杂。 没太看懂。