PHP может открывать сокеты на локальной или удаленной машине. В данной статье будет рассмотрен пример использования сокетов для: соединения с Usenet-новостным сервером, ведения диалога с ним и скачивания некоторых статей.
Открываем сокет
Для открываения сокета используется функция fsockopen(). Вызов функции имеет следующий вид:
int fsockopen (string hostname, int port [, int errno [, string errstr [, double timeout]]])
Для UDP соединения, надо определить протокол: udp://hostname.
Больше информации о функции fsockopen() можно узнать здесь.
NNTP-протокол (Network News Transfer Protocol)
Для доступа к новостному usenet-серверу мы будем использовать NNTP-протокол. Этот протокол детально описан в RFC977 (Request For Comment number 977). Полное описание присутствует в интернете: http://www.w3.org/Protocols/rfc977/rfc977.html Этот документ детально описывает процедуру соединения и диалога с сервером.
Соединение (Connecting)
Для соединения с NNTP-сервером нам необходимо знать его имя (или IP-адрес) и порт. Так же необходимо указывать таймер, чтобы в случае невозможности подсоединения к серверу не “заморозили” application.
$cfgServer = "your.news.host"; $cfgPort = 119; $cfgTimeOut = 10;
// open a socket if(!$cfgTimeOut) // without timeout $usenet_handle = fsockopen($cfgServer, $cfgPort); else // with timeout $usenet_handle = fsockopen($cfgServer, $cfgPort, &$errno, &$errstr, $cfgTimeOut);
if(!$usenet_handle) { echo "Connexion failedn"; exit(); } else { echo "Connectedn"; $tmp = fgets($usenet_handle, 1024); }
?>
Ведение диалога с сервером
Итак, теперь мы присоединились к серверу и можем вести диалог с ним, используя ранее открытый сокет. Для примера, попробуем достать десять последних сообщений с какой-либо группы. В RFC977 описано, что первый шаг – выбрать группу с помощью GROUP комманды:
GROUP ggg
Обязательный парамтор - ggg - имя группы, которую мы хотим выбрать (например, "net.news"). Список существующих групп может быть получен с помощью комманды LIST. Удачный выбор группы будет подтвержден ответом сервера, где будет сообщаться колличество новых, старых статей и общее колличество.
chrome:~$ telnet my.news.host 119 Trying aa.bb.cc.dd... Connected to my.news.host. Escape character is '^]'. 200 my.news.host InterNetNews NNRP server INN 2.2.2 13-Dec-1999 ready (posting ok). GROUP alt.test 211 232 222996 223235 alt.test quit 205
После получения команды "GROUP alt.test", новостной сервер ответил "211 232 222996 223235 alt.test". 211 – определенный RFC спецификацией код (говоря обычным языком – 212 – означает, что команда была завершена с положительным результатом – смотрите документацию RFC для более полной характеристики). Следующая цифра – 232 – количество имеющихся в текущий момент новых статей. 222996 – старых. 223235 – всего статей. 232+222996 не равно 223235. Почему? Возможно, недостающие семь статей были каким-либо образом удалены модератором или самим автором.
В зависимости от сервера (public или private) вас могут попросить идентифицироваться. Так-же возможно, что идентификация понадобиться только при написании своих сообщений, а чтение может производиться без этого.
//$cfgUser = "xxxxxx"; //$cfgPasswd = "yyyyyy"; $cfgNewsGroup = "alt.php";
// identification required on private server if($cfgUser) { fputs($usenet_handle, "AUTHINFO USER ".$cfgUser."n"); $tmp = fgets($usenet_handle, 1024);
fputs($usenet_handle, "AUTHINFO PASS ".$cfgPasswd."n"); $tmp = fgets($usenet_handle, 1024);
// check error
if($tmp != "281 Okrn") { echo "502 Authentication errorn"; exit(); } }
// select newsgroup
fputs($usenet_handle, "GROUP ".$cfgNewsGroup."n"); $tmp = fgets($usenet_handle, 1024);
if($tmp == "480 Authentication required for commandrn") { echo "$tmpn"; exit(); }
$info = split(" ", $tmp); $first = $info[2]; $last = $info[3];
print "First : $firstn"; print "Last : $lastn"; ?>
Скачивание некоторых статей
Теперь мы имеем номер последней статьи, так что сейчас нам не составит труда скачать десять последних статей. RFC977 спецификация допускает использование команды ARTICLE, как с номером статьи, так и Message ID (Уникальный Номер Сообщения). Будьте внимательны здесь – номер статьи отличен от Message ID. Если статья опубликована на нескольких серверах, то она несомненно будет иметь разный номер оба раза, но одинаковый Message ID. Грубо говоря, номер статьи – присваивается каждый раз по-новому на сервере, и может меняться со временем; Message ID – у каждой статьи уникальный.
$cfgLimit = 10;
// upload last articles
$boucle=$last-$cfgLimit;
while ($boucle <= $last) {
set_time_limit(0);
fputs($usenet_handle, "ARTICLE $bouclen");
$article=""; $tmp = fgets($usenet_handle, 4096); if(substr($tmp,0,3) != "220") { echo "+----------------------+n"; echo "Error on article $bouclen"; echo "+----------------------+n"; } else { while($tmp!=".rn") { $tmp = fgets($usenet_handle, 4096); $article = $article.$tmp; }
echo "+----------------------+n"; echo "Article $bouclen"; echo "+----------------------+n"; echo "$articlen"; }
$boucle++; }
?>
Также благодаря команде HEAD возможно получить только хэадер (header) сообщения или-же только текст, используя команду BODY.
Отсоединяемся от сервера
Чтобы закрыть сессию с NNTP-сервером, просто закройте сокет используя fclose() (аналогично закрытию файла).
Больше информации о функции fclose() можно узнать здесь.
// close connexion
fclose($usenet_handle);
?>
Заключение
Мы только что видели как открыть, использовать и затем закрыть сокет – для соединения с NNTP-сервером и получения некоторых статей из новостных групп. Для опубликования сообщения необходимо использовать POST комманду.
Примеры приложений работующих с новостными группами можно найти здесь: http://www.phpindex.com/ng/ ;
|