POE::Component::Client::TCPMulti 0.0521

POE::Component::Client::TCPMulti is a high performance client TCP library. SYNOPSIS # Short Usage POE::Component::Client::TCPMulti->create ( InputEvent => sub { printf "%s:%d: %s", $_[CHEAP]->ADDR, $_[CHEAP]->PORT, $_[ARG0]; }, SuccessEvent => sub { printf "%s:%d: Connection Recieved", $_[CHEAP]->ADDR, $_[CHEAP]->PORT; $_[KERNEL]->yield( send => "" ); }, inline_states => { _start => sub { $_[KERNEL]->yield( connect => "127.0.0.1", $_ ) for 1..1024; }, }, InputTimeout => 15, ); # Longer Usage POE::Component::Client::TCPMulti->create ( InputEvent => sub { $_[KERNEL]->yield(send => $_[CHEAP]->ID, "Some Stuff"); }, Initialize => sub { $_[CHEAP]->input_filter ( "POE::Filter::Block", BlockSize => 4); }, ErrorEvent => &ErrorHandle, Disconnected => &ErrorHandle, TimeoutEvent => &TimeoutHandle, FailureEvent => &FailureHandle, SuccessEvent => sub { $_[CHEAP]->filter("POE::Filter::Line"); # Set timeout for this connection to 350 seconds. $_[CHEAP]->timeout(350); # This state is part of the component interface $_[KERNEL]->yield(send => $_[CHEAP]->ID, "Some Data"); }, Domain => AF_INET, # Optional Alias => "MySession", # Optional InputTimeout => 360, # Seconds, Optional ConnectTimeout => 30, # Seconds, Optional Timeout => 30, # Seconds, Optional Filter => "POE::Filter::Something", # Optional inline_states => { _start => sub { $_[KERNEL]->yield(connect => q(127.0.0.1), 25); # _start isnt needed if you use an alias. }, }, args => $Session_Args, # Optional object_states => $Object_States, # Optional package_states => $Package_States, # Optional ); # This should be done from within a state in the TCPMulti # Session. Its purpose is to allow prepropigation of the # connection heap as well as connection specific timeout # Settings. POE::Component::Client::TCPMulti->connect ( RemoteAddress => "127.0.0.1", RemotePort => 25, BindAddress => "127.0.0.1", # Optional BindPort => 0, # Optional ConnectTimeout => 50, # Connect only. InputTimeout => 300, # Input only. Heap => %Propigation ); POE::Component::Client::TCPMulti is a very lightweight, highly optimized component designed for large numbers of simultanious outgoing connections. The major advantage to this module over POE::Component::Client::TCP is that it runs in a single session, reguardless of the number of outgoing simultanious connections. I have found this in fact to use considerable less overhead than POE::Component::Client::TCP in high traffic. The disadvantage lies mearly in the API complexity over POE::Component::Client::TCP. It is in fact due to this added API complexity that I decided to create a seperate module, rather than altering POE::Component::Client::TCP [ or coaxing Rocco to let me ]. POE::Component::Client::TCP is a great module and this is not designed to completely replace it. It is however designed as a solution for extremely high traffic situations when the overhead of an individual session for each outgoing connection is not appropriate for the added simplicity in the API. Especially considering that this API is not really *that* much more complex..

Requirements:	No special requirements
Platforms:	Linux
Keyword:	Api,  Cheap,  Connection,  High Performance,  Kernel,  Libraries,  Optional,  Poe,  Poecomponentclienttcpmulti,  Programming,  States,  Sub,  Tcpmulti,  Yield
Users rating:	0/10