Fastcgi प्रबंधक के साथ संचार

विवरण

FCGI :: ProcManager के लिए एक छोटा सा विस्तार, जिससे आप fcgi प्रोसेस मैनेजर को एक्सेस कर सकते हैं। एक सॉकेट का उपयोग प्रबंधक के साथ तीसरे पक्ष के कार्यक्रम को संप्रेषित करने के लिए किया जाता है।

नुकसान

FCGI :: ProcManager मॉड्यूल का उपयोग आने वाले अनुरोध हैंडलर को स्पॉन करने के लिए किया जाता है। वर्तमान प्रक्रिया एक प्रबंधक है। शुरू से, यह हैंडलर (n_processes pieces) को जन्म देता है, फिर यह लड़ाई में मृतकों की निगरानी करके उनकी संख्या बनाए रखता है। इन उद्देश्यों के लिए, यह प्रतीक्षा का उपयोग करता है। यह वह जगह है जहाँ समस्या निहित है। थ्रेड्स शुरू होने के बाद, प्रबंधक, प्रतीक्षा कॉल करके, अवरुद्ध है। आप इसे केवल संकेतों के माध्यम से ही पहुंच सकते हैं। सिग्नल हैंडलर में कोड को बुद्धिमानी से और सही तरीके से निष्पादित करना आवश्यक है, गोवनोकॉड को चलाने के लिए अच्छा नहीं है। इसलिए एक और संचार चैनल स्थापित करना आवश्यक है।

कार्यान्वयन

उदाहरण के लिए, चलिए मैनेजर को सॉकेट सुनने की कोशिश करते हैं। ऐसा करने के लिए, हमें प्रबंधक को ब्लॉक करने के लिए मजबूर करने की आवश्यकता है। Pm_wait फ़ंक्शन FCGI में प्रतीक्षा करने के लिए जिम्मेदार है :: ProcManager:

sub pm_wait { my ($this) = self_or_default(@_); # wait for the next server to die. next if (my $pid = wait()) < 0; # notify when one of our servers have died. delete $this->{PIDS}->{$pid} and $this->pm_notify("server (pid $pid) exited with status $?"); return $pid; } 

हमें वेटपिड के साथ प्रतीक्षा कॉल को बदलने और अपना कोड वहां पेस्ट करने की आवश्यकता है। हमारे प्रबंधक को दूसरे पोर्ट को खोलना और सुनना होगा, और स्टैंडबाय मोड में समय-समय पर वंशजों को देखना और पोर्ट को सुनना होगा। हम pm_wait फ़ंक्शन का अपना संस्करण लिखेंगे और FCGI :: ProcManager मॉड्यूल में एक ही नाम के फ़ंक्शन को बंदर पैच के साथ बदल देंगे। संदेशों के जवाब में, हम परियोजना के पुस्तकालयों को अपडेट करने के बाद, सभी वंशज को अधिभारित करेंगे।

 use FCGI; use FCGI::ProcManager; use IO::Select; use IO::Socket; use POSIX ":sys_wait_h"; #use Module::Refresh; use feature ':5.14'; use strict; # For fastcgi app my $socket = FCGI::OpenSocket( ":9019", 5 ); my $request = FCGI::Request( \*STDIN, \*STDOUT, \*STDERR, \%ENV, $socket, FCGI::FAIL_ACCEPT_ON_INTR ); # To communicate with the manager my $server = IO::Socket::INET->new(LocalPort => '9034', Type => SOCK_STREAM, Reuse => 1, Listen => 1) or die "Couldn't start messange server $@\n"; my $select = IO::Select->new($server); # Patch my $pm_wait = sub { my ($pm) = @_; my $pid; while (1) { last if ($pid = waitpid(-1, WNOHANG)); foreach my $client ($select->can_read(1)) { if ($client == $server) { $client = $server->accept(); $select->add($client); } else { my $msg = <$client>; chomp $msg; if ($msg eq 'reload') { #my $refresher = Module::Refresh->new(); #my @module_list = qw( MyLib1.pm My/Lib2.pm ); #foreach my $module_name (@module_list){ # $refresher->refresh_module($module_name); #} $pm->sig_manager('HUP'); } print $client "done!\n"; $select->remove($client); close $client; } } } # notify when one of our servers have died. delete $pm->{PIDS}->{$pid} and $pm->pm_notify("server (pid $pid) exited with status $?"); return $pid; }; no strict 'refs'; *{'FCGI::ProcManager::pm_wait'} = $pm_wait; use strict 'refs'; my $pm = FCGI::ProcManager->new( ); $pm->pm_manage( n_processes => 3, pm_title => 'perl-fcgi-pm', die_timeout => 10 ); while ( $request->Accept() >= 0 ) { $pm->pm_pre_dispatch(); print "Content-Type: text/plain\n\n"; print "server works"; $pm->pm_post_dispatch(); } FCGI::CloseSocket($socket); close $server; 

निम्नलिखित परीक्षण के लिए कोड है:

 use IO::Socket; use feature ':5.14'; use strict; my $socket = new IO::Socket::INET(Proto => "tcp", Type => SOCK_STREAM, PeerPort => 9034, PeerAddr => "127.0.0.1" ) or die "Can't connect: $!"; #my $msg = $ARGV[0]; my $msg = 'reload'; if ($msg) { print $socket "$msg\n"; my $answer = <$socket>; say "Answer: ".$answer; } 

कुल मिलाकर

इस प्रकार, हम फास्टेगी प्रक्रिया प्रबंधक को संदेश (प्रोटोकॉल का आविष्कार स्वयं द्वारा किया जा सकता है) भेजने में सक्षम हैं। इसका उपयोग एप्लिकेशन के वर्तमान कॉन्फ़िगरेशन को क्वेरी करने के लिए किया जा सकता है। रिलोड प्रोजेक्ट लाइब्रेरी (उदाहरण में टिप्पणी की गई)। आप हैंडलर की संख्या बढ़ा / घटा सकते हैं

 $pm->{n_processes} = 10; $pm->sig_manager('HUP'); 

ठीक है, ऐसी छोटी चीजें जैसे प्रोफाइल को चालू / बंद करना। बेशक, इन कार्यों को अन्य तरीकों से हल किया जा सकता है।

इसे करने का एक से अधिक तरीका है