NAME

Server - Perl websockets server supporting RFC 6455 standard.

SYNOPSIS

Simple broadcast server for utf8 messages.

#!/usr/bin/env perl
use IO::Socket::INET;
use threads("yield", 
"stack_size" => 64 * 4096, 
"exit" => "threads_only", 
"stringify");
use Thread::Queue;
use Server;
use BroadcastConsumer;

my $q = Thread::Queue->new();
# q
my $clients = Thread::Queue->new();
# clients
my $broadcastThread;
# broadcastThread;
$socket = new IO::Socket::INET (
  LocalHost => '127.0.0.1',
  LocalPort => '8080',
  Proto => 'tcp',
  Listen => 10,
  Reuse => 1
) or die "Oops: $!\n";
print STDERR "Server is up and running\n";
while(1) {
  $clientSocket = $socket->accept();
  push @clients, $clientSocket;
  if(defined $broadcastThread) {
    $broadcastThread->kill("SIGTERM");
  }
  $thread = threads->create(sub {
    $server = new Server();
    $server->doHandshake($clientSocket);
    while(1) {
      $server->listen($clientSocket, $q);
    }
  });
  $thread->detach();
  $broadcastThread = threads->create(sub {
    $SIG{"TERM"} = sub {threads->exit();};
    $broadcastConsumer = new BroadcastConsumer();
    while(1) {
      $broadcastConsumer->broadcast(\@clients, $q);
    }
  });
  $broadcastThread->detach();
}

DESCRIPTION

The module implements websockets 6455 standard. It supports concurrent connections using threads and communication based on message queue.

AUTHOR

scripts <nikolapav1985@gmail.com>