How to use AnyEvent::Handle to read data from a websocket?

pudda has asked for the wisdom of the Perl Monks concerning the following question:

Hi!

I'm new with perl, so please have patience if I misunderstood anything, or got something wrong.

What I'm trying to do is connect to a websocket, read the data the ws is sending and do some stuff with it. My code is connecting to the ws but when I try to read and print in the console the data readed it shows nothing. Can you guys help me?

here's my code:

#!/usr/bin/env perl

use strict;
use warnings;

use lib 'lib';

use Data::Dumper;

use AnyEvent;
use AnyEvent::Socket;
use AnyEvent::Handle;

$|++;

my $cv = AnyEvent->condvar;

my $ws_handle;

$ws_handle = AnyEvent::Handle->new(
    connect   => [ 'localhost', '8082' ],
    keepalive => 1,
    on_eof => sub {
        print ("! Server disconnected");
    },
    on_read => sub {
        my ($handle) = @_;

        my $buf = delete $handle->{rbuf};
        print "teste";

    },
    on_connect => sub {
        my ($handle, $host, $port, $retry) = @_;
        print "Server connected\n";              # this works
    },
    on_connect_error => sub {
        my ($handle, $message) = @_;

        print $message;
    },
);

$cv->recv;
[download]

Comment on How to use AnyEvent::Handle to read data from a websocket? Download Code

Replies are listed 'Best First'.
Re: How to use AnyEvent::Handle to read data from a websocket? by Corion (Patriarch) on Sep 29, 2020 at 13:24 UTC
If your task is about communication with a Websocket, I would use AnyEvent::WebSocket::Client. If you want to learn how it is done with AnyEvent, I would look at how AnyEvent::WebSocket::Client does it.	[reply]
Re^2: How to use AnyEvent::Handle to read data from a websocket? by pudda (Acolyte) on Sep 29, 2020 at 14:11 UTC
Wow thanks a lot! I rewrote my code using AnyEvent::WebSocket::Client and it is working just the way I wanted! Here's my code after changing it in case someone get curious: #!/usr/bin/env perl use strict; use warnings; use lib 'lib'; use Data::Dumper; use AnyEvent::WebSocket::Client 0.12; $\|++; my $client = AnyEvent::WebSocket::Client->new; $client->connect("ws://localhost:8082/")->cb(sub { our $connection = eval { shift->recv }; if($@) { # handle error... warn $@; return; } $connection->send('a message'); $connection->on(each_message => sub { my($connection, $message) = @_; if($message->is_text \|\| $message->is_binary) { my $body = $message->body; print $body. "\n"; } }); $connection->on(finish => sub { my($connection) = @_; print "Server Disconnected!\n" }); }); AnyEvent->condvar->recv; [download]	[reply] [d/l]


Perl: the Markov chain saw
	PerlMonks