I was wondering whether its possible to write a program which acts like a proxy server in Perl, so what I figured out was anything is possible with Perl. Below is the code, try it, its wonderful.
I used threads to manage multiple requests, so the program can handle multiple requests concurrently.
More can be done with IO::Socket in Perl.
I used threads to manage multiple requests, so the program can handle multiple requests concurrently.
More can be done with IO::Socket in Perl.
Code: Perl
#!/usr/bin/perl
#use strict;
use URI;
use IO::Socket;
use threads('yield', 'stack_size' => 64*4096);
# don't want to die on 'Broken pipe' or Ctrl-C
$SIG{PIPE} = 'IGNORE';
my $showOpenedSockets=1;
my $server = IO::Socket::INET->new (
LocalPort => 8080,
Type => SOCK_STREAM,
Reuse => 1,
Listen => 18);
binmode $server;
while (my $browsera = $server->accept()) {
print "\n\n----Accepted Connection--------\n";
binmode $browsera;
my $t = threads->new(\&fetch, $browsera);
$t->detach;
}
sub fetch{
my $browser = $_[0];
my $method ="";
my $content_length = 0;
my $content = 0;
my $accu_content_length = 0;
my $host;
my $hostAddr;
my $httpVer;
while (my $browser_line = <$browser>) {
unless ($method) {
($method, $hostAddr, $httpVer) = $browser_line =~ /^(\w+) +(\S+) +(\S+)/;
print "$hostAddr";
my $uri = URI->new($hostAddr) or print "Could not build URI for $hostAddr";
$host = IO::Socket::INET->new (
PeerAddr=> $uri->host,
PeerPort=> $uri->port );
die "couldn't open $hostAddr" unless $host;
if ($showOpenedSockets) {
print "Opened ".$uri->host." , port ".$uri->port."\n";
}
binmode $host;
print $host "$method ".$uri->path_query." $httpVer\n";
print "$method ".$uri->path_query." $httpVer\n";
next;
}
$content_length = $1 if $browser_line=~/Content-length: +(\d+)/i;
$accu_content_length+=length $browser_line;
#print $browser_line;
print $host $browser_line;
last if $browser_line =~ /^\s*$/ and $method ne 'POST';
if ($browser_line =~ /^\s*$/ and $method eq "POST") {
$content = 1;
last unless $content_length;
next;
}
if ($content) {
$accu_content_length+=length $browser_line;
last if $accu_content_length >= $content_length;
}
}
print "\n\nThread id --> ".threads->self->tid()."\n";
print "No of. threads at present --> ".threads->list()."\n";
print "Stack size --> ".threads->get_stack_size()."\n";
$content_length = 0;
$content = 0;
$accu_content_length = 0;
while (my $host_line = <$host>) {
#print $host_line;
print $browser $host_line;
$content_length = $1 if $host_line=~/Content-length: +(\d+)/i;
if ($host_line =~ m/^\s*$/ and not $content) {
$content = 1;
#last unless $content_length;
next;
}
if ($content) {
if ($content_length) {
$accu_content_length+=length $host_line;
#print "\nContent Length: $content_length, accu: $accu_content_length\n";
last if $accu_content_length >= $content_length;
}
}
}
$browser-> close;
$host -> close;
print "---- End thread ----\n";
}
