Perl и сокеты. Часть 2

Итак, weather.yandex.ru — это хост, к которому мы будем подключаться, а все, что следует после него, будет текстом запроса. В моем случае это /city.xml?city=26063.

Теперь о необходимости временного интервала: нам нужно, чтобы скрипт периодически обновлял погодные данные через заданный промежуток времени, который и определяется временным интервалом.

Далее следует разобраться, какие модули будут использоваться.

• Уже хорошо знакомый нам Socket.
• IO::Handle. Этот модуль содержит полезный метод autoflush. Perl имеет неприятное свойство накапливать данные в буфере, но нам нужно будет их немедленно сбрасывать, для чего и применяется указанный метод.
• Getopt::Std позволит сделать классический консольный интерфейс в виде: $ ./script -v parametr -c parametr -a parametr etc. За подробностями обращайтесь к perldoc Getopt::Std.
• И модуль Lingua::RU::PhTranslit. Пользователям Windows этот модуль не потребуется. Объясняю причину: данный модуль умеет менять кодировки. Например, у меня на FreeBSD стандартной кодировкой является koi8-r, а на weather.yandex.ru текст представлен в виндовой кодировке cp1251, поэтому, чтобы не выводились на экран кракозябы, мне нужно поменять кодировку выдаваемых строк.

Приступим:

#!/usr/bin/perl# подключаем нужные модулиuse strict;use Socket;use Getopt::Std;use IO::Handle;use Lingua::RU::PhTranslit;# хостuse constant HOST => "weather.yandex.ru";# интервал времени в минутах по умолчаниюuse constant DEF_INT => 30;# наш программный интерфейс прост:# -q текст запроса -t (необязательно) временной интервал# эти параметры будут находиться в хэше %params. # за подробностями в perldoc Getopt::Stdmy %params = undef;getopt(qt, \%params);# далее все знакомоmy $query = $params{q}     die "you to must set the -q argument!";my $interval = $params{t}  DEF_INT;my $host = gethostbyname(HOST)     die "HOST!";my $protocol = getprotobyname(tcp);# www-http — это http службаmy $port = getservbyname(www-http, tcp);my $socket_addr = sockaddr_in($port, $host);# делаем бесконечный циклwhile(1) {   socket(SOCK, AF_INET, SOCK_STREAM, $protocol)       or die "Cant create socket =(";   connect(SOCK, $socket_addr)       or die "Cant connect to socket =(";      # посылаем в сокет простенький GET-запрос      print SOCK "GET $query HTTP/1.1\n";   print SOCK "Host: ".HOST."\n\n";   # включаем автосбрасывание, иначе ничего не получится   SOCK->autoflush(1);   # в хэше %data будут храниться полученные данные   my %data = undef;   # регекспы писались после просмотра кода требуемой    # страницы на weather.yandex.ru   while(<SOCK>) {      if(/: <a href="\/tune\.xml\?rnd=\d+" class="black">(.+)<\/a>/)         { $data{sity} = win2koi($1) }      elsif(/<div class="big"><nobr>(.+?)</)         { $data{degr} = $1 }      elsif(/<td nowrap>([^<]+)<\/td>/)         { $data{dop} .= win2koi($1)." " }   }   close SOCK;   print $data{sity}.": ".$data{degr}."\n".      $data{dop}."\n";   # засыпаем на нужный интервал   sleep($interval*60);}

После выполнения скрипта в командной строке он должен вывести прогноз погоды на сегодняшний день для вашего города. В моем случае это выглядело следующим образом:

Далее. Я, помнится, обещал рассказать о модуле IO::Socket, упрощающем работу с сокетами в perl. Зачем понадобился еще один модуль для реализации одной и той же цели? Да, многим программистам, которым доводилось работать с сокетами на C++, и стандартный модуль Socket может показаться раем, но посмотрите на описанный выше пример. Он, мягко говоря, реализован не слишком изящно, ибо нам пришлось подключать целый модуль IO::Handle только из-за одного метода autoflush. Не слишком практично, не так ли?

Да и вообще, многим неприятна эта долгая последовательность действий в виде определения хоста (getservbyname("host_name")), определения порта (getservbyname("service", "protocol")), определения числового номера протокола (getprotobyname("protocol")), составления адреса сокета (sockaddr_in($port, $host)), создания нового сокета, используя многочисленные константы, я устал перечислять… Люди часто путаются в последовательности действий, в функциях get*byname, постоянно обращаясь к perldoc Socket, что, в общем-то, не есть плохо, но довольно неудобно.

Модуль же IO::Socket является объектно-ориентированным и наследует все методы модуля IO::Handle, в том числе и уже знакомый нам autoflush, который он, кстати, выполняет автоматически, но об этом позже. Итак, после рассмотрения причин, которые подтолкнули умных и ленивых (как говорит Ларри Уол — создатель языка perl — каждым программистом движет прежде всего лень =)) людей на создание данного модуля, дабы упростить жизнь многим таким же ленивым и умным(?) программистам, как они, можно рассмотреть этот несомненно замечательный модуль подробнее.

Прежде всего, следует отметить, что модуль IO::Socket экспортирует все константы и функции метода Socket. Методы модуля IO::Socket (здесь перечислены не все методы, за подробностями обращайтесь к perldoc IO::Socket):

Также существуют модули IO::Socket::INET и IO::Socket::UNIX — наследники IO::Socket. Первый определяет правила поведения для сокетов AF_INET, второй — для сокетов AF_UNIX (по стандартизации POSIX константа AF_UNIX переименована в AF_LOCAL). В данной статье будет рассматриваться лишь модуль IO::Socket::INET, если хотите узнать больше о IO::Socket::UNIX, читайте perldoc IO::Socket::UNIX.

Конструктором модуля IO::Socket::INET является метод с классическим именем new(), который принимает в качестве аргументов имя хоста и имя порта в таком виде:

Например:

Заметьте, модуль самостоятельно находит ip-адрес хоста, номер службы, номер порта, строит правильную структуру sockaddr_in(), создает сокет и автоматически предпринимает попытку подключиться к удаленному сокету (выполняет метод connect()). И все это чудо занимает одну строчку. Приятно освобождать себя от лишней рутинной работы и экономить время =), не правда ли? В случае ошибки метод new() возвращает значение undef, тогда переменная $! будет содержать системное сообщение об ошибке, а переменная $@ — более содержательное сообщение об ошибке, выработанное самим модулем. Синтаксис его очень гибок. Все ниже перечисленные варианты являются верными:

Модуль IO::Socket::INET поддерживает следующие параметры:

Параметры PeerHost, LocalAddr, LocalPort применяются в программах, работающих в качестве серверов, т.е. позволяют принимать соединения.

Метод new() может также применяться для создания сокетов с универсальными опциями. Для этого существует так называемый расширенный режим метода new(). Например:

или

или

my $sock = IO::Socket::INET->new(Listen    => 5,             LocalAddr => localhost,             LocalPort => 9000,             Proto     => tcp);

или

или, наконец

my $sock = IO::Socket::INET->new(PeerPort  => 9999,             PeerAddr  => inet_ntoa(INADDR_BROADCAST),             Proto     => udp,             LocalAddr => localhost,             Broadcast => 1 )         or die "Cant bind : $@\n";

Методы объекта IO::Socket::INET:

Надоело писать сухую и скучную теорию =(. Вернемся к практике, а именно — к нашему daytime клиенту. Тоже не слишком увлекательно, но все же приятнее чтения теории. Перепишем daytime клиент, используя модуль IO::Socket.

#!/usr/bin/perluse strict;use IO::Socket;# устанавливаем константу, хранящую адрес# хоста по умолчаниюuse constant HOST => s2.daytime.net.ru;my $host = shift  HOST;# создаем новый объект IO::Socket::INET с помощью# метода new(), принимающего указанный хост # и имя службыmy $sock = IO::Socket::INET->new("$host:daytime") or   die "Cant connect to socket =(";# getline — метод модуля IO::Handle, который был# унаследован модулем IO::Socket. в принципе, getline# является объектно-ориентированным # эквивалентом <DESKRIPTOR>my $time = $sock->getline;# мы не выводим символ новой строки потому, что# сервер возвращает сообщение с символом# новой строки в конце. ВНИМАНИЕ! это подойдет только для# *nix систем, т.к. символ новой строки в конце сообщения — # LF (в Windows используется CRLF, в MacOS — LFCR), # принятый в *nix. # если вы работаете в Windows или MacOS,# придется изменить строки my $time = $sock->getline; на# chomp(my $time = $sock->getline);# и# print $time; на# print "$time\n";print $time;

Все. В следующей и последней статье, посвященной сокетам, почти не будет теории, только практика. Ждите, Ill be back © …