note
haukex
<p>Here's a complete example with [mod://Mojo::IOLoop] and [mod://Mojo::IOLoop::Stream::Role::LineBuffer]:</p>
<h3><c>mojo_serv.pl</c>:</h3>
<c>
#!/usr/bin/env perl
use warnings;
use strict;
use Mojo::Util qw/dumper/;
use Mojo::IOLoop;
use Mojo::IOLoop::Stream::Role::LineBuffer;
Mojo::IOLoop->server(
{ address => '127.0.0.1', port => 3000, reuse => 1 } => sub {
my ($loop, $stream) = @_;
my $peer = $stream->handle->peerhost.":".$stream->handle->peerport;
print "$peer: Connect\n";
$stream->timeout(30);
$stream = $stream->with_roles('+LineBuffer')->watch_lines;
$stream->on(read_line => sub {
my ($strm, $line, $sep) = @_;
print "$peer: Got line ".dumper($line);
});
$stream->on(timeout => sub { print "$peer: Timeout\n" });
$stream->on(close => sub { print "$peer: Closed\n" });
$stream->on(error => sub { warn "$peer: Error: $_[1]" });
$stream->write("Hello, client from $peer.\n");
});
print "Starting server...\n";
Mojo::IOLoop->start unless Mojo::IOLoop->is_running;
</c>
<h3><c>mojo_cli.pl</c>:</h3>
<c>
#!/usr/bin/env perl
use warnings;
use strict;
use Mojo::Util qw/dumper/;
use Mojo::IOLoop;
use Mojo::IOLoop::Stream::Role::LineBuffer;
Mojo::IOLoop->client(
{ address => '127.0.0.1', port => 3000 } => sub {
my ($loop, $err, $stream) = @_;
if (defined $err) { warn "Error: $err"; return }
print "Connect\n";
$stream->timeout(10);
$stream = $stream->with_roles('+LineBuffer')->watch_lines;
$stream->on(read_line => sub {
my ($strm, $line, $sep) = @_;
print "Got line ".dumper($line);
});
$stream->on(timeout => sub { print "Timeout\n" });
$stream->on(close => sub { print "Closed\n" });
$stream->on(error => sub { warn "Error: $_[1]" });
$stream->write("Hello, server, I am a client.\n");
});
print "Starting client...\n";
Mojo::IOLoop->start unless Mojo::IOLoop->is_running;
</c>
11113052
11113052