新手学习POE遇到问题

mysqllog

代码遇下：

1. BEGIN {
   
2.   @INC = (@INC,'C:\Perl\site\lib','C:\Perl\lib');
   
3. }
   
4. 
   
5. use warnings;
   
6. use strict;
   
7. use POE;
   
8. use POE::Wheel::SocketFactory;
   
9. use POE::Wheel::ReadWrite;
   
10. 
    
11. POE::Session->create(
    
12.         inline_states => {
    
13.           _start => \&start,
    
14.           connected => \&connected,
    
15.           flushed => \&flushed,
    
16.     }
    
17. );
    
18. 
    
19. POE::Kernel->run;
    
20. 
    
21. sub start {
    
22.   print "_start\n"; #用于调试
    
23.   $wheel = POE::Wheel::SocketFactory->new(
    
24.     RemoteAddress => '192.168.1.234',
    
25.         RemotePort => 2012,
    
26.         SuccessEvent => "connected",
    
27.         FailureEvent => "flushed",
    
28.   );
    
29. }
    
30. 
    
31. sub connected {
    
32.   print "connected\n";
    
33.   my ($kernel,$heap,$socket) = @_[KERNEL,HEAP,ARG0];
    
34.   my $wheel = POE::Wheel::ReadWrite->new(
    
35.     Handle => $socket,
    
36.         FlushedEvent => 'flushed',
    
37.   );
    
38.   $heap->{wheel} = $wheel;
    
39.   $wheel->put("up_sql"); #远程服务器得到字符串
    
40. }
    
41. 
    
42. sub flushed {
    
43.   print "flushed\n";
    
44.   delete $_[HEAP]->{wheel};
    
45. }

复制代码

start 事件没有创建 $wheel? 不知道为什么

我用telnet 192.168.1.234 2012可以telnet上。

rubyish

my
.....

mysqllog

回复 2# rubyish


    麻意思 ？

flw

Wheel 创建完之后，必须持有它才行。

改成 $_[HEAP]->{wheel} = .............. 就可以了。

rimrockcn

sub start {
  print "_start\n"; #用于调试
  $wheel = POE::Wheel::SocketFactory->new(
    RemoteAddress => '192.168.1.234',
        RemotePort => 2012,
        SuccessEvent => "connected",
        FailureEvent => "flushed",
  );
   $_[HEAP]->{wheel}=$wheel; # add this line
}

兰花仙子

好久没看POE了。