VPF::Постоянное соединение с XMPP(Jabber)-сервером

iNfantry

Дата 30.11.2013, 14:01 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 41
Регистрация: 17.9.2006

Репутация: нет
Всего: нет

Всем привет, вобщем такая ситуация. Есть Jabber-бот на PHP, который должен постоянно висеть в онлайне и обрабатывать входящие сообщения. Всё впринципе сделал и всё прекрасно работает, но по прошествии некоторого времени происходит разрыв соединения, в джаббер клиенте пользователя мой бот становится "теперь отключен" и я не знаю как эту ситуацию отследить. Тоесть вопрос у меня такой - как по-правильному держать постоянное соединение с XMPP-сервером и как отследить что произошел разрыв связи, чтобы потом сделать реконнект? Привожу мой код в очень упрощенном виде:

Код


function getxml($stream)
{
    sleep(1); // перед получением информации дадим паузу, чтобы сервер успел отдать информацию
    $xml = '';

    // запрашивать данные 1600 раз, но не более 15 пустых строк
    $empty_line = 0;
    for ($i=0; $i<1600; $i++) {
        $line = fread($stream, 2048);
        if (strlen($line) == 0) {
            $empty_line++;
            if ($empty_line > 15) {
                break;
            }
        }
        else {
            $xml .= $line;
        }
    }
    if (!$xml) {
        return false;
    }
    return $xml;
}


// устанавливаем соединение с сервером
$stream = fsockopen($host, $port, $errorno, $errorstr, 10);

// эти настройки необходимы, чтобы при получении данных из потока не было зависания.
// иначе при обнаружении пустой строки php зависнет в длительном ожидании
stream_set_blocking($stream, 0);
stream_set_timeout($stream, 3600*24);

... //отправка и получение всех необходимых данных для авторизации и выхода в онлайн

while (true)
{
    sleep(3); // ставим паузу в 3 секунды, чтобы не создавать большую нагрузку на php
    $xmlin = getxml($stream); // и раз в 3 секунды идет сбор данных из потока. тут будут приходить сообщения, информация о смене статусов ваших контактов и т.д.
    if (strlen($xmlin))
    {
        ... //обрабатываем входящие пакеты
        //здесь надо както узнать, не произошел ли разрыв связи
    }
}

Sanchezzz

Дата 1.12.2013, 15:28 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 1670
Регистрация: 19.11.2006
Где: Voronezh

Репутация: 41
Всего: 60

pfsockopen использовать как постоянное соединение?

socket_read

Цитата

возвращает данные в виде строки в случае успеха, или FALSE в случае ошибки (включая случай, когда удалённый хост закрыл соединение

Вам просто нужно перед чтением или после не удачного прочтения спросить сокет о последней ошибки

Код


if( ! $data = socket_read($socket)) 
{
    $errorcode = socket_last_error($socket);
    // коды ошибок  http://www.php.net/manual/ru/function.socket-last-error.php
}

--------------------

Понравился ответ "+" по репе, не забываем закрывать тему, заказы в LS.

iNfantry

Дата 1.12.2013, 16:15 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 41
Регистрация: 17.9.2006

Репутация: нет
Всего: нет

Спасибо, не знал про pfsockopen() но я тут уже повозился с гугловским классом и нашел такое:

Код


stream_socket_client('tcp://'.$this->host.':'.$this->port, $errorno, $errorstr, $timeout, STREAM_CLIENT_CONNECT | STREAM_CLIENT_PERSISTENT)

Это по идее тоже самое, так?

Насчет отлова ошибок, наткнулся еще на функцию stream_select() - что лучше выбрать? Ее или socket_last_error($socket)? Или без разницы?

iNfantry

Дата 1.12.2013, 16:35 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 41
Регистрация: 17.9.2006

Репутация: нет
Всего: нет

Кстати, методом дебага нашел решение проблемы относительно джаббера - есть в нем механизм пинга, мне приходило:

Код


<iq from='capulet.lit' to='[email protected]/balcony' id='s2c1' type='get'>
  <ping xmlns='urn:xmpp:ping'/>
</iq>

а я его не обрабатывал, ибо не знал о нем smile

Надо отправлять в ответ:

Код


<iq from='[email protected]/balcony' to='capulet.lit' id='s2c1' type='result'/>

Sanchezzz

Дата 1.12.2013, 20:03 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 1670
Регистрация: 19.11.2006
Где: Voronezh

Репутация: 41
Всего: 60

stream_select === false выдаст что не может читать поток а socket_last_error даст конкретную сетевую ошибку.

Ну не кто не мешает использовать оба варианта =)

--------------------

Понравился ответ "+" по репе, не забываем закрывать тему, заказы в LS.

1 Пользователей читают эту тему (1 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| PHP: Общие вопросы \| Следующая тема »