erlang open_port用法

shijiang1130

1. -module(my_ping).
   
2. -compile(export_all).
   
3. 
   
4. t_ping()->
   
5.         P = open_port({spawn,"c:/windows/system32/PING.exe -t www.chinaunix.net"},[binary]),
   
6.         loop(P).
   
7. 
   
8. loop(P)->
   
9.         receive
   
10.                 {P,{data,Data}} ->
    
11.                         case re:run(Data,<<"time=.*">>,[{capture,all,list}]) of
    
12.                                {match,Res} -> io:format("~p~n",[Res]);
    
13.                                                  _-> ok
    
14.                          end,
    
15.                 loop(P)
    
16.         end.

复制代码

shijiang1130

erl -noshell -s my_ping t_ping

shijiang1130

1. ["time=13ms "]
   
2. ["time=12ms "]
   
3. ["time=11ms "]
   
4. ["time=24ms "]
   
5. ["time=28ms "]
   
6. ["time=13ms "]
   
7. ["time=11ms "]
   
8. ["time=12ms "]
   
9. ["time=12ms "]
   
10. ["time=16ms "]
    
11. ["time=13ms "]
    
12. ["time=13ms "]
    
13. ["time=12ms "]

复制代码

q1208c

能 直接输出平均值就好了

laputa73

这个无限循环,停止erl还是杀掉ping
会有不同码?

shijiang1130

q1208c 发表于 2014-07-01 11:45
能 直接输出平均值就好了

是啊，我还想有一个功能是超过10ms通过gen_event来报警 昨天写case of嵌套写出语法错语来了。。。

shijiang1130

laputa73 发表于 2014-07-01 11:55
这个无限循环,停止erl还是杀掉ping
会有不同码?

等待去发jue

q1208c

回复 6# shijiang1130

Good Job, 继续呀. 写完了我正好用用
   

shijiang1130

我亲爱的朋友们，刚写完，就迫不及待的贴上来了，

1. -module(my_ping).
   
2. -behaviour(gen_event).
   
3. -compile(export_all).
   
4. 
   
5. t_ping()->
   
6.                 put(count,1),
   
7.                 put(total,1),
   
8.                 gen_event:start({local,monitor}),
   
9.             gen_event:add_handler(monitor,my_ping,"warning.txt"),
   
10.         P = open_port({spawn,"c:/windows/system32/PING.exe -t www.chinaunix.net"},[binary]),
    
11.         loop(P).
    
12. 
    
13. loop(P)->
    
14.         receive
    
15.                 {P,{data,Data}} ->
    
16.                         case re:run(Data,<<"(\\d+)ms\s">>,[{capture,[1],list}]) of
    
17.                                {match,[Res]} -> io:format("~n~p",[Res]),
    
18.                                                            Num=erlang:list_to_integer(Res),
    
19.                                                            average(Num),
    
20.                                                            alert(Num);
    
21.                                _  -> ok
    
22.                          end,
    
23.                 loop(P)
    
24.         end.
    
25. 
    
26. alert(Num)->
    
27.         case Num > 10 of
    
28.         true -> io:format("!!!! warning"),gen_event:notify(monitor,[Num]);
    
29.         false -> ok
    
30.         end.
    
31. 
    
32. average(Num)->
    
33.         C=get(count),
    
34.         T=get(total),
    
35.         P=T/C,
    
36.         io:format(" * average is: ~p~n",[P]),
    
37.         put(count,C+1),
    
38.         put(total,T+Num).
    
39. %%% gen_event part       
    
40. init(File)->
    
41.         {ok,Fd} = file:open(File,write),
    
42.         {ok,Fd}.
    
43. handle_event(Event,Fd)->
    
44.         io:format(Fd,"[Warning] ~p~n",[Event]),
    
45.         {ok,Fd}.
    
46. terminate(_Args,Fd)->
    
47.         file:close(Fd).               

复制代码

shijiang1130

带平均值的哦，还有就是被kill后，后台一堆的ping.exe没有被清理。