NAME
TCPServer::Interface - A generic multithreaded TCP Server interface.
VERSION
This documentation describes version 0.01
DESCRIPTION
A server listens for and accepts incoming TCP connections on a port or a Unix domain socket. And a pool of threads are created to handle the connections in parallel. The server code handling the connections is to be implemented in the inheriting class.
A more sophisticated implementation may require serialization in processing requests, e.g. logging. There must be a dedicated worker thread that serially processes requests from the server threads.
Hence _server() is the interface method to be implemented, and _worker() is an optional interface method. If _worker() is inplemented, each _server() thread needs to communicate with it via a pair of queues for two-way communication. e.g.
sub _server
{
my ( $this, $socket, @queue ) = @_;
...
}
sub _worker
{
my ( $this, @queue ) = @_;
...
}
run()
Launches server.
EXAMPLE
## an echo server module
package Echo;
use base TCPServer::Interface;
use strict;
use constant MAX_BUF => 2 ** 5;
sub _server
{
my ( $this, $socket ) = @_;
my $buffer;
syswrite( $socket, $buffer ) if sysread( $socket, $buffer, MAX_BUF );
}
1;
__END__
## echo server
use strict;
use Echo;
my $server = Echo->new
(
port => 12345,
thread => 30,
listen => 10,
maxconn => 300,
);
$server->run();
SEE ALSO
Socket, threads, Thread::Queue, and IO::Select,
AUTHOR
Kan Liu
COPYRIGHT and LICENSE
Copyright (c) 2010. Kan Liu
This program is free software; you may redistribute it and/or modify it under the same terms as Perl itself.