NAME

HTTP::MultiGet - Run many http requests at once!

SYNOPSIS

use Modern::Perl;
use HTTP::MultiGet;
use HTTP::Request;

my $getter=new HTTP::MultiGet;

my @requests=(map { HTTP::Request->new(GET=>"http://localhost$_") } (1 .. 1000));
my @responses=$getter->run_requests(@requests);

my $id=0;
foreach my $response (@responses) {
  my $request=$requests[$id++];
  print "Results for: ".$request->uri."\n";
  if($response->is_success) {
    print $response->decoded_content;
  } else {
    print $response->status_line,"\n";
  }
}

Handling Multiple Large Downloads

use Modern::Perl;
use HTTP::MultiGet;
use HTTP::Request;

my $req=HTTP::Request->new(GET=>'http://some.realy.big/file/to/download.gz');
my $req_b=HTTP::Request->new(GET=>'http://some.realy.big/file/to/download2.gz');

# create a callback 
my $code=sub {
  my ($getter,$request,$headers,$chunk)=@_;
    # 0: Current HTTP::MultiGet instance
    # 1: HTTP::Request object
    # 2: HTTP::Headers object
    # 3: Chunk of data being downloaded
  if($headers->header('Status')==200) {
    # do something
  } else {
    # do something with $body
  }
};
my $getter=new HTTP::MultiGet;
my ($result,$result_b)=$getter->run_requests([$req,on_body=>$code],[$req_b,on_body=>$code]);

The arguments: on_body=>$code are called called on each chunk downloaded. $result is created when the download is completed, but $result->decoded_content is going to be empty

DESCRIPTION

Created a wrapper for: AnyEvent::HTTP, but provides a more LWP like feel.

Moo Stuff

This is a Moo class the object constructor takes the following arguments, along with the following roles

Role List:

Log::LogMethods
Data:::Result::Moo

Arguemnts and object accessors:

logger:          DOES(Log::Log4perl::Logger)
request_opts:    See AnyEvent::HTTP params for details
timeout:         Global timeout for everything ( default 300 )
max_que_count:   How many requests to run at once ( default 20 )
max_retry:       How many times to retry if we get a connection/negotiation error 

For internal use only:

in_control_loop: true when in the control loop
stack:           Data::Queue object 
que_count:       Total Number of elements active in the que
retry:           Anonymous hash used to map ids to retry counts

UNIT TESTING

For Unit testing

on_create_request_cb: Anonymous code ref to be called 
  when a new request object has been created
      sub { my ($id,$request)=@_ }

Arguments for the call back

id:  number for the object
req: a new instance of $self->SENDER_CLASS

Interal blocking control variables

loop_control: AnyEvent->condvar object

Class constants

• my $class=$self->RESPONSE_CLASS

  Returns the http response class, typically AnyEvent::HTTP::Response.

• my $class=$self->HEADER_CLASS

  Returns the header class, typically HTTP::Headers.

OO Methods

• my $id=$self->next_que_id

  Returns the next id.

• my @ids=$self->add(@requests)

  Adds @requests to the stack, @ids relates as id=>request

• my @ids=$self->add([$request,key=>value]);

  Wrapping [$request] allows passing additional key value to AnyEvent::HTTP::Request, with one exception, on_body=>$code is wrapped an additional callback.

• my $id=$self->add_by_id($id=>$request);

  Adds the request with an explicit id.

• $self->run_next

  Internal functoin, used to run the next request from the stack.

• my $result=$self->has_request($id)

  Returns a Charter::Result Object.

  When true it contains a string showing where that id is in the list.

  Values are:

  complete: Has finished running
  running:  The request has been sent, waiting on the response
  in_que:   The request has not been run yet

• if($self->has_running_or_pending) { ... }

  Returns a Charter::Result object

  true:  it contains how many objects are not yet complete.
  false: no incomplete jobs exist

• if($self->has_any) { ... }

  Returns a Charter::Result object

  true: conains how many total jobs of any state there are
  false: there are no jobs in any state

• my $result=$self->block_for_ids(@ids)

  Returns a Charter::Result object

  when true: some results were found

  while(my ($id,$result)=each %{$result->get_data}) {
    if($result) {
      my $response=$result->get_data;
      print "Got response: $id, code was: ",$response->code,"\n";
    } else {
      print "Failed to get: $id error was: $result\n";
    }
  }

• my $class=$self->SENDER_CLASS

  $class is the class used to send requests.

• my $req=$self->create_request($req,$id)

  Internal method. Returns a new instance of $self->SENDER_CLASS for Teh given $request and $id.

• my $code=$self->que_function($req,$id);

  Internal method. Creates a code refrence for use in the que process.

• $self->block_loop

  Internal Function. Does a single timed pass against the current set of data, stops when the requests complete.

• my @responses=$self->run_requests(@requests);

  Ques runs and blocks for all https requests, and returns the result objects

  Arguments:

  @requests: list of HTTP::Request Objects

  Responses

  @responses: list of HTTP::Result in order of the requests.

• $self->clean_results

  Used to remove any results that are unclaimed ( Use to prevent memory leaks! ).

• my @responses=$self->block_for_results_by_id(@ids)

  Blocks on the @ids lsit for list of HTTP::Response objects

• my @results=$self->get_results(@ids);

  Does not block, just returns a list of HTTP::Response objects based on @ids

Using with AnyEvent

See AnyEvent::HTTP::MultiGet

AUTHOR

Mike Shipper mailto:AKALINUX@CPAN.ORG

cpanm HTTP::MultiGet

perl -MCPAN -e shell
install HTTP::MultiGet