请教AnyEvent::SNMP的用法

laputa1973

AnyEvent::HTTP和AnyEvent:ing都试通了。
但是AnyEvent::SNMP运行没有反应。
感觉这个作者太不喜欢写（完整可用的）例子了。
以下是给出的例子
运行没反应
查了anyevent 的文档，cv似乎没有wait方法啊
有人试通的吗？

1. use AnyEvent::SNMP;
   
2. use Net::SNMP;
   
3. 
   
4. # just use Net::SNMP and AnyEvent as you like:
   
5. 
   
6. # use a condvar to transfer results, this is
   
7. # just an example, you can use a naked callback as well.
   
8. my $cv = AnyEvent->condvar;
   
9. 
   
10. # ... start non-blocking snmp request(s)...
    
11. Net::SNMP->session (-hostname => "127.0.0.1",
    
12.                      -community => "public",
    
13.                      -nonblocking => 1)
    
14.           ->get_request (-callback => sub { $cv->send (@_) });
    
15. 
    
16. # ... do something else until the result is required
    
17. my @result = $cv->wait;
    

复制代码

nsnake_cu

你callback除了停止外也没说要做什么
print几个数就可以看到了

laputa1973

回复 2# nsnake_cu
那个是作者的例子。
我的是这样的

1. #/usr/bin/env perl
   
2. #测试NET::SNMP的异步性能
   
3. #先测试按设备并发的情形
   
4. 
   
5. use AnyEvent;
   
6. use AnyEvent::SNMP;
   
7. use Net::SNMP;
   
8. 
   
9. 
   
10. 
    
11. my $cocurrent = 1;    # 并发数
    
12. #my @todoList = map { "192.168.6." . $_ } (1 .. 254); #
    
13. my @todoList = ("192.168.6.87"); #
    
14. 
    
15. 
    
16. my $cv = AnyEvent->condvar;
    
17. 
    
18. 
    
19. doit() foreach 1..$cocurrent;
    
20. sub doit{
    
21.     my $ip = shift @todoList;
    
22.     return if not defined $ip;
    
23. 
    
24.     $cv->begin;
    
25.     my $oid=".1.3.6.1.2.1.1.7.0";
    
26.     my @oids=($oid);
    
27.     my $sess=Net::SNMP->session (-hostname => $ip,
    
28.                      -community => "public",
    
29.                      -timeout => 2,
    
30.                      -nonblocking => 1,
    
31.                      -translate   => [-timeticks => 0x0]
    
32.                      )
    
33.           ->get_request (-varbindlist      => \@oids, -callback => sub { $cv->send (@_) });
    
34.     #my $Ret=$sess->get_request (
    
35.     #      -callback => sub {  done( $ip, @_ ) },
    
36.     #      -varbindlist      => \@oids,
    
37.     #      );
    
38. 
    
39. 
    
40.     my @result = $cv->wait;
    
41.     print @result;
    
42. }
    
43. 
    
44. 
    
45. $cv->recv();
    
46. 
    
47. 
    

复制代码

执行以后就挂住了


   

laputa73

新装环境.测试通过.

1. #/usr/bin/env perl
   
2. #测试anyevent::snmp 并发
   
3. 
   
4. use AnyEvent;
   
5. use AnyEvent::SNMP;
   
6. use Net::SNMP;
   
7. 
   
8. 
   
9. 
   
10. my $cocurrent = 100;    # 并发数
    
11. #my @todoList = map { "192.168.6." . $_ } (1 .. 254); #
    
12. my @todoList = ("192.168.6.87","192.168.6.25","192.168.6.45"); #
    
13. 
    
14. my $oid=".1.3.6.1.2.1.1.1.0";  #sysDescr
    
15. 
    
16. 
    
17. my $cv = AnyEvent->condvar;
    
18. 
    
19. 
    
20. doit() foreach 1..$cocurrent;
    
21. 
    
22. sub doit{
    
23.     my $ip = shift @todoList;
    
24.     return if not defined $ip;
    
25. 
    
26.     $cv->begin;
    
27.    # my $oid=".1.3.6.1.2.1.1.7.0";
    
28.    # my @oids=($oid);
    
29.    print "$ip.\n";
    
30.     my $sess=Net::SNMP->session (-hostname => $ip,
    
31.                      -community => "public",
    
32.                      -timeout => 1,
    
33.                      -nonblocking => 1,
    
34.                      -translate   => [-timeticks => 0x0]
    
35.                      )
    
36.           ->get_request (
    
37.            -varbindlist => [ $oid ],
    
38.            #-varbindlist      => \@oids,
    
39.            -callback => sub { done(@_,$ip) }
    
40.           );
    
41. 
    
42. }
    
43. 
    
44. sub done {  
    
45.     my ($session,$ip) = @_;
    
46.     my $result = $session->var_bind_list();
    
47. 
    
48.       if (!defined $result) {
    
49.          printf "ERROR: Get request failed for host '%s': %s.\n",
    
50.                 $session->hostname(), $session->error();
    
51.                
    
52.       }
    
53.       else{
    
54.           printf "The sysDescr for host '%s' is %s.\n",
    
55.           $session->hostname(), $result->{$oid};
    
56.       }   
    
57.       $cv->end();      
    
58.       &doit();              
    
59. }
    
60. 
    
61. 
    
62. $cv->recv();

复制代码