server.pl

   1 #!/usr/bin/perl
   2 use warnings;
   3 use strict;
   4 use IO::Socket;
   5 use threads;
   6 use threads::shared;
   7 $|++;
   8 print "$$ Server started\n";;  # do a "top -p -H $$" to monitor server
   9
  10 our @clients : shared;
  11 @clients = ();
  12
  13 my $server = new IO::Socket::INET(
  14   Timeout   => 7200,
  15   Proto     => "tcp",
  16   LocalPort => 10000,
  17   Reuse     => 1,
  18   Listen    => 3
  19 );
  20 my $num_of_client = -1;
  21
  22 while (1) {
  23   my $client;
  24
  25   do {
  26     $client = $server->accept;
  27   } until ( defined($client) );
  28
  29   my $peerhost = $client->peerhost();
  30   print "accepted a client $client, $peerhost, id = ", ++$num_of_client, "\n";
  31   my $fileno = fileno $client;
  32   push (@clients, $fileno);
  33   #spawn  a thread here for each client
  34   my $thr = threads->new( \&processit, $client, $fileno, $peerhost )->detach();
  35 }
  36 # end of main thread
  37
  38 sub processit {
  39   my ($lclient,$lfileno,$lpeer) = @_; #local client
  40
  41   if($lclient->connected){
  42     while(<$lclient>){
  43       #print $lclient "$lpeer->$_\n";
  44       print "clients-> @clients\n";
  45
  46       foreach my $fn (@clients) {
  47         open my $fh, ">&=$fn" or warn $! and die;
  48         print $fh  "$_";
  49         print "Sending $_\n";
  50       }
  51     }
  52   }
  53   #close filehandle before detached thread dies out
  54   close( $lclient);
  55   #remove multi-echo-clients from echo list
  56   @clients = grep {$_ !~ $lfileno} @clients;
  57 }
  58 __END__