rpc/filter-reference/server.pl

#!/usr/bin/perl

#use warnings;
#use strict;

use POE;
use POE::Filter::Reference;
use POE::Component::Server::TCP;
#use POE::Component::Client::TCP;
use Data::Dumper;

### Create a server that receives and sends Perl data structures.  It
### will be referred to by the name "sum-server" when necessary.  It
### listens on localhost port 12345.  It uses POE::Filter::Reference
### to parse input and format output.

POE::Component::Server::TCP->new
  ( Alias => "sum_server",
    Address      => "localhost",
    Port         => 12345,
    ClientFilter => "POE::Filter::Reference",

    # Handle client requests here.

    ClientInput => sub {
        my ( $heap, $list ) = @_[ HEAP, ARG0 ];
        my $sum = 0;
        my ( @odd, @even, @bad, $status );

        print Dumper ($list);

        # Process the request into buckets for odd, even, and
        # non-integers.  Sum the integers in the request.

        if ( ref($list) eq 'ARRAY' ) {
            foreach (@$list) {
                if (/^\d+$/) {
                    if ( $_ % 2 ) { push @odd, $_; }
                    else { push @even, $_; }
                    $sum += $_;
                }
                else {
                    push @bad, $_;
                }
            }
            $status = "OK";
        }
        else {
            $status = "Error: Bad request type: " . ref($list);
        }

        # Build the response hash, then send it to the client.

        my %response =
          ( sum => $sum,
            odd  => \@odd,
            even => \@even,
            bad  => \@bad,
            stat => $status,
          );

        $heap->{client}->put( \%response );
    },

    # Since this is a one-shot test program, shut down the server
    # after the first client has disconnected.  This posts "shutdown"
    # to the server itself.  Using yield() here would just shut down
    # the client connection.

    ClientDisconnected => sub {
        my $kernel = $_[KERNEL];
        $kernel->post( sum_server => "shutdown" );
    },
  );


### Run both the client and server.  Yes, in the same program.

$poe_kernel->run();
1	#!/usr/bin/perl
2
3	#use warnings;
4	#use strict;
5
6	use POE;
7	use POE::Filter::Reference;
8	use POE::Component::Server::TCP;
9	#use POE::Component::Client::TCP;
10	use Data::Dumper;
11
12	### Create a server that receives and sends Perl data structures. It
13	### will be referred to by the name "sum-server" when necessary. It
14	### listens on localhost port 12345. It uses POE::Filter::Reference
15	### to parse input and format output.
16
17	POE::Component::Server::TCP->new
18	( Alias => "sum_server",
19	Address => "localhost",
20	Port => 12345,
21	ClientFilter => "POE::Filter::Reference",
22
23	# Handle client requests here.
24
25	ClientInput => sub {
26	my ( $heap, $list ) = @_[ HEAP, ARG0 ];
27	my $sum = 0;
28	my ( @odd, @even, @bad, $status );
29
30	print Dumper ($list);
31
32	# Process the request into buckets for odd, even, and
33	# non-integers. Sum the integers in the request.
34
35	if ( ref($list) eq 'ARRAY' ) {
36	foreach (@$list) {
37	if (/^\d+$/) {
38	if ( $_ % 2 ) { push @odd, $_; }
39	else { push @even, $_; }
40	$sum += $_;
41	}
42	else {
43	push @bad, $_;
44	}
45	}
46	$status = "OK";
47	}
48	else {
49	$status = "Error: Bad request type: " . ref($list);
50	}
51
52	# Build the response hash, then send it to the client.
53
54	my %response =
55	( sum => $sum,
56	odd => \@odd,
57	even => \@even,
58	bad => \@bad,
59	stat => $status,
60	);
61
62	$heap->{client}->put( \%response );
63	},
64
65	# Since this is a one-shot test program, shut down the server
66	# after the first client has disconnected. This posts "shutdown"
67	# to the server itself. Using yield() here would just shut down
68	# the client connection.
69
70	ClientDisconnected => sub {
71	my $kernel = $_[KERNEL];
72	$kernel->post( sum_server => "shutdown" );
73	},
74	);
75
76
77	### Run both the client and server. Yes, in the same program.
78
79	$poe_kernel->run();
MailToCvsAdmin">MailToCvsAdmin	ViewVC Help
Powered by ViewVC 1.1.26