Re: any blocked websocket client for perl?

[Raunak Kathuria]

Have a look at
https://metacpan.org/pod/Net::Async::WebSocket

For client:
https://metacpan.org/pod/Net::Async::WebSocket::Client

On Thu, 4 Feb 2021 at 10:32 AM, Wesley Peng  wrote:

> I am trying to find a websocket client for perl.
> But most modules on cpan is asynchronous, such as
> AnyEvent::WebSocket::Client.
> Do you know if there is a synchronous websocket client library available?
>
> Thanks in advance.
>
>
> BTW, I tried to use the anyevent module above to access my WS service, it
> doesn't work.
> When program run, it just hangs without any output.
> Can you see why this happens?
> The code as below:
>
> use strict;
>
> use JSON;
>
> use Data::Dumper;
>
> use AnyEvent::WebSocket::Client 0.12;
>
>
>
> my $client = AnyEvent::WebSocket::Client->new;
>
> my $url =
> 'ws://localhost:8080/ws/v2/producer/persistent/public/default/my-topic';
>
>
>
>
> $client->connect($url)->cb(sub {
>
>
>
>   # make $connection an our variable rather than
>
>   # my so that it will stick around.  Once the
>
>   # connection falls out of scope any callbacks
>
>   # tied to it will be destroyed.
>
>   our $connection = eval { shift->recv };
>
>   if($@) {
>
> # handle error...
>
> warn $@;
>
> return;
>
>   }
>
>
>
>   # send a message through the websocket...
>
>   my $payload = encode_json({'payload' => 'hello world'});
>
>   $connection->send($payload);
>
>
>
>   # recieve message from the websocket...
>
>   $connection->on(each_message => sub {
>
> # $connection is the same connection object
>
> # $message isa AnyEvent::WebSocket::Message
>
> my($connection, $message) = @_;
>
> print Dumper decode_json($message);
>
>   });
>
>
>
>   # handle a closed connection...
>
> #  $connection->on(finish => sub {
>
> ## $connection is the same connection object
>
> #my($connection) = @_;
>
> #...
>
> #  });
>
>
>
>   # close the connection (either inside or
>
>   # outside another callback)
>
> #  $connection->close;
>
>
>
> });
>
>
>
> ## uncomment to enter the event loop before exiting.
>
> ## Note that calling recv on a condition variable before
>
> ## it has been triggered does not work on all event loops
>
> AnyEvent->condvar->recv;
>
>

any blocked websocket client for perl?

[Wesley Peng]

I am trying to find a websocket client for perl.
But most modules on cpan is asynchronous, such as AnyEvent::WebSocket::Client.
Do you know if there is a synchronous websocket client library available?

Thanks in advance.


BTW, I tried to use the anyevent module above to access my WS service, it 
doesn't work.
When program run, it just hangs without any output.
Can you see why this happens?
The code as below:

use strict;

use JSON;

use Data::Dumper;

use AnyEvent::WebSocket::Client 0.12;

 

my $client = AnyEvent::WebSocket::Client->new;

my $url = 
'ws://localhost:8080/ws/v2/producer/persistent/public/default/my-topic';



 

$client->connect($url)->cb(sub {

 

  # make $connection an our variable rather than

  # my so that it will stick around.  Once the

  # connection falls out of scope any callbacks

  # tied to it will be destroyed.

  our $connection = eval { shift->recv };

  if($@) {

# handle error...

warn $@;

return;

  }

   

  # send a message through the websocket...

  my $payload = encode_json({'payload' => 'hello world'});

  $connection->send($payload);

   

  # recieve message from the websocket...

  $connection->on(each_message => sub {

# $connection is the same connection object

# $message isa AnyEvent::WebSocket::Message

my($connection, $message) = @_;

print Dumper decode_json($message);

  });

   

  # handle a closed connection...

#  $connection->on(finish => sub {

## $connection is the same connection object

#my($connection) = @_;

#...

#  });

 

  # close the connection (either inside or

  # outside another callback)

#  $connection->close;

 

});

 

## uncomment to enter the event loop before exiting.

## Note that calling recv on a condition variable before

## it has been triggered does not work on all event loops

AnyEvent->condvar->recv;