perl – 如何在散列中保存套接字并从另一个线程循环它们？

my $clients = &share({});

旧式语法是由Perl原型的文档问题引起的.如果您有at least Perl 5.8.9,请使用更好的

my $clients = shared_clone({});

代替.

您还希望使用锁来保护$client,例如

my $clients_lock : shared;
{
  lock $clients_lock;
  $clients->{time()} = fileno $connection;
}

最后,因为IO :: Socket :: INET实例是Perl typeglobs,你不能共享它们,所以改为将它们的套接字描述符(从fileno)添加到$clients,然后在必要时用fdopen套接字

open my $fh,">&=",$sockdesc or warn ...

下面的程序将入站数据重复到其他连接的套接字：

#!/usr/bin/perl

use strict;
use IO::Socket;
use threads;
use threads::shared;
use Thread::Queue;

# init
my $clients = &share({});
my $clients_lock : shared;

my $queue = Thread::Queue->new;

# thread that monitors
threads->create("monitor");

# create the listen socket
my $port = 12345;
my $listenSocket = IO::Socket::INET->new(
  LocalPort  => $port,Listen     => 10,Proto      => 'tcp',Reuse      => 1
);

# make sure we are bound to the port
die "Can't create a listening socket: $@" unless $listenSocket;

print "Server ready. Waiting for connections on $port ... n";

# wait for connections at the accept call
while (my $connection = $listenSocket->accept) {
  # set client socket to non blocking
  my $nonblocking = 1;
  ioctl($connection,$nonblocking);

  # autoflush
  $connection->autoflush(1);

  # debug
  print "Accepted new connectionn";

  # add to list
  {
    lock $clients_lock;
    $clients->{time()} = fileno $connection;
  }

  # start new thread and listen on the socket
  threads->create("readData",$connection);
}

sub readData {
  # socket parameter
  my ($client) = @_;

  # read client
  while (<$client>) {
    chomp;
    $queue->enqueue($_);
  }

  close $client;
}

sub monitor {
  # endless loop
  while (1) {
    # loop while there is something in the queue
    while ($queue->pending) {
      # get data from a queue
      my $data = $queue->dequeue;

      # loop all sockets
      {
        lock $clients_lock;
        while ( my ($key,$value) = each(%$clients) ) {
          # send to socket
          if (open my $fh,$value) {
            print $fh "$datan";
          }
          else {
            warn "$0: fdopen $value: $!";
          }
        }
      }
    }

    # wait 0,25 seconds
    select(undef,0.25);
  }
}

close $listenSocket;