外挂编程

开发平台：
Windows_Unix

Server.pm.svn-base：源码内容
							#########################################################################
#  OpenKore - Ragnarok Online Assistent
#
#  This software is open source, licensed under the GNU General Public
#  License, version 2.
#  Basically, this means that you're allowed to modify and distribute
#  this software. However, if you distribute modified versions, you MUST
#  also distribute the source code.
#  See http://www.gnu.org/licenses/gpl.html for the full license.
#
#  $Revision$
#  $Id$
#
#########################################################################
##
# MODULE DESCRIPTION: Basic implementation of a TCP/IP server
#
# When writing TCP servers, a significant amount of time is spent in
# handling connection issues (such as establishing connections, client
# multiplexing, etc). This class makes it easier to write a TCP server
# by handling all connection issues for you, so you can concentrate
# on handling the protocol.
#
# You are supposed to create a class which is derived from Base::Server.
# Override the abstract methods onClientNew(), onClientExit() and
# onClientData() (see the API specification).
#
# <h3>Example</h3>
# Here is an example of how to use Base::Server (MyServer.pm):
# <pre class="example">
# package MyServer;
#
# use strict;
# use Base::Server;
# use base qw(Base::Server);
#
# sub onClientNew {
#     my ($self, $client, $index) = @_;
#     print "Client $index connected.n";
# }
#
# sub onClientExit {
#     my ($self, $client, $index) = @_;
#     print "Client $index disconnected.n";
# }
#
# sub onClientData {
#     my ($self, $client, $data, $index) = @_;
#     print "Client $index sent the following data: $datan";
# }
#
# 1;
# </pre>
# And in the main script you write:
# <pre class="example">
# use strict;
# use MyServer;
#
# my $port = 1234;
# my $server = new MyServer($port);
# while (1) {
#     # Main loop
#     $server->iterate;
# }
# </pre>
#
# <h3>The client object</h3>
# See @MODULE(Base::Server::Client) for more information about how to use $client.
package Base::Server;
use strict;
use warnings;
no warnings 'redefine';
use IO::Socket::INET;
use Base::Server::Client;
use Utils::ObjectList;
use Utils::Exceptions;
################################
### CATEGORY: Constructor
################################
##
# Base::Server Base::Server->new([int port, String bind])
# port: the port to bind the server socket to. If unspecified, the first available port (as returned by the operating system) will be used.
# bind: the IP address to bind the server socket to. If unspecified, the socket will be bound to "localhost". Specify "0.0.0.0" to not bind to any address.
#
# Start a server at the specified port and IP address.
#
# Throws SocketException if the server socket cannot be created.
sub new {
	my $class = shift;
	my $port = (shift || 0);
	my $bind = (shift || 'localhost');
	my %self;
	$self{BS_server} = IO::Socket::INET->new(
		Listen		=> 5,
		LocalAddr	=> $bind,
		LocalPort	=> $port,
		Proto		=> 'tcp',
		ReuseAddr	=> 1);
	if (!$self{BS_server}) {
		SocketException->throw($@);
	}
	$self{BS_host} = $self{BS_server}->sockhost;
	$self{BS_port} = $self{BS_server}->sockport;
	$self{BS_clients} = new ObjectList();
	return bless %self, $class;
}
sub createFromSocket {
	my ($class, $socket) = @_;
	my %self = (
		BS_server  => $socket,
		BS_clients => new ObjectList()
	);
	return bless %self, $class;
}
sub DESTROY {
	my ($self) = @_;
	$self->{BS_server}->close if ($self->{BS_server});
}
################################
### CATEGORY: Methods
################################
sub clients {
	return $_[0]->{BS_clients}->getItems();
}
##
# String $BaseServer->getHost()
# Returns: an IP address in textual form.
#
# Get the IP address on which the server is started.
sub getHost {
	return $_[0]->{BS_host};
}
##
# int $BaseServer->getPort()
# Returns: a port number.
#
# Get the port on which the server is started.
sub getPort {
	return $_[0]->{BS_port};
}
##
# void $BaseServer->iterate()
#
# Handle connection issues. You should call this function in your
# program's main loop.
sub iterate {
	my ($self, $timeout) = @_;
	my $serverFD = fileno($self->{BS_server});
	# Generate the bit field for select();
	my $rbits = '';
	vec($rbits, $serverFD, 1) = 1;
	my $clients = $self->{BS_clients}->getItems();
	foreach my $client (@{$clients}) {
		if (!$client->getSocket()->connected) {
			$self->_exitClient($client, $client->getIndex());
		} else {
			my $fd = $client->getFD();
			vec($rbits, $fd, 1) = 1;
		}
	}
	if (@_ == 1) {
		$timeout = 0;
	} elsif ($timeout == -1) {
		$timeout = undef;
	}
	if (select($rbits, undef, undef, $timeout) > 0) {
		# Checks whether new clients want to connect.
		if (vec($rbits, $serverFD, 1)) {
			$self->_newClient();
		}
		# Check for connection changes in clients.
		foreach my $client (@{$clients}) {
			my $fd = $client->getFD();
			if (vec($rbits, $fd, 1)) {
				# Incoming data from client.
				my $data;
				$client->getSocket()->recv($data, 32 * 1024, 0);
				if (!defined($data) || length($data) == 0) {
					# Client disconnected.
					$self->_exitClient($client, $client->getIndex());
				} else {
					$self->onClientData($client, $data, $client->getIndex());
				}
			}
		}
	}
}
##
# boolean $BaseServer->sendData(Base::Server::Client client, Bytes data)
#
# This function is obsolete. Use $BaseServerClient->send() instead.
sub sendData {
	my ($self, $client) = @_;
	return $client->send($_[2]);
}
####################################
### CATEGORY: Abstract methods
####################################
##
# abstract void $BaseServer->onClientNew(Base::Server::Client client, int index)
# client: a client object (see overview).
# index: the client's index (same as $client->getIndex).
# Requires: defined($client)
#
# This method is called when a new client has connected to the server.
sub onClientNew {
}
##
# abstract void $BaseServer->onClientExit(Base::Server::Client client, int index)
# client: a client object (see overview).
# index: the client's index (same as $client->getIndex).
# Requires: defined($client)
#
# This method is called when a client has disconnected from the server.
sub onClientExit {
}
##
# abstract void $BaseServer->onClientData(Base::Server::Client client, Bytes data, int index)
# client: a client object (see overview).
# data: the data this client received.
# index: the client's index (same as $client->getIndex).
# Requires: defined($client) && defined($data)
#
# This method is called when a client has received data.
sub onClientData {
}
##############
# Private
##############
# Accept connection from new client
sub _newClient {
	my ($self) = @_;
	my $sock = $self->{BS_server}->accept();
	$sock->autoflush(0);
	my $fd = fileno($sock);
	my $host;
	$sock->peerhost if ($sock->can('peerhost'));
	my $client = new Base::Server::Client($sock, $host, $fd);
	my $index = $self->{BS_clients}->add($client);
	$client->setIndex($index);
	$self->onClientNew($client, $index);
}
# A client disconnected
sub _exitClient {
	my ($self, $client, $index) = @_;
	$self->onClientExit($client, $index);
	$self->{BS_clients}->remove($client);
}
1;

						