VPF::Помогите оптимизировать код - Форум программистов

gers

Дата 24.3.2008, 12:23 (ссылка)

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

Загрузка ...

Новичок

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

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

Доброго времени суток Уважаемые!
Вот написал код демона который висит и периодически лезет в бд mysql за информацией, но после нескольких часов, бывает дней появляется ошибка mysql server going away(точно непомню). Код рабочий, но с этой проблемой немогу справиться, почитав форумы узнал о InactiveDestroy, прописав ее проблема не исчезла, может быть вы натолкнете на ошибку?
часть проблеммного кода:

Код


while ($sock->recv($newmsg, $MAXLEN)) {
    my($port, $ipaddr) = sockaddr_in($sock->peername);
        my $call= IO::Socket::INET->new(PeerAddr => inet_ntoa($ipaddr), PeerPort => $PORTNO, Proto=> 'udp' ) or die "socket: $@";
        my $hishost = inet_ntoa($ipaddr);
        my $addr_bill = inet_aton_bill($hishost);
            if ($newmsg eq "deposit") {
                my ($sth, $balans);
                $db->{ InactiveDestroy } = 1;
                $sth = $db->prepare("SELECT * FROM users WHERE addr='$addr_bill'");
                $sth->execute();
                $balans = $sth->fetchrow_hashref();
                my $new = $db->prepare("select * from news ORDER BY time DESC LIMIT 1");
                $new->execute();
                my $news = $new->fetchrow_hashref();
                my $ppp = $db->prepare("SELECT * FROM sessions WHERE id_user=$balans->{'id'}");
                $ppp->execute();
                my $sess = $ppp->fetchrow_hashref();
                my ($ss, $mm, $hh, $dd, $mo, $y) = (localtime($news->{'time'}))[0,1,2,3,4,5];
                my $year = $y+1901;
                my $format_win = "$dd.$mo.$year $hh:$mm:$ss";
                my $data = $db->prepare("select sum(incoming), sum(outgoing) from data where id_user='$balans->{'id'}' and (log_time between '$sess->{'connected'}' and '".time()."')");
                $data->execute();
                my $traff = $data->fetchrow_hashref();
                my $tarif = $db->prepare("select * FROM tariffs WHERE id=$balans->{'id_tariff'}");
                $tarif->execute();
                my $period = $tarif->fetchrow_hashref();
                my $abonplata = $balans->{'last_period'} + $period->{'period'};
                $call->send($balans->{'deposit'}."|".$currency."|".$traff->{'sum(incoming)'}."|".$traff->{'sum(outgoing)'}."|".$balans->{'p_in'}."|".$balans->{'p_out'}."|".$abonplata."|".$format_win."|".$news->{'text'}."");
                }
        }
        $db->disconnect;
        die "recv: $!";

ginnie

Дата 24.3.2008, 12:43 (ссылка)

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

Загрузка ...

Эксперт

Профиль
Группа: Комодератор
Сообщений: 1287
Регистрация: 6.1.2008
Где: Москва

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

Уважаемый gers, возможно, поможет

Код


$dbh->{mysql_auto_reconnect} = 1;

если включен AutoCommit.

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

Написать код, понятный компьютеру, может каждый, но только хорошие программисты пишут код, понятный людям. (Мартин Фаулер. Рефакторинг)

KSURi

Дата 24.3.2008, 15:02 (ссылка)

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

Загрузка ...

Опытный

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

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

Еще можно сделать отдельный тред, который, каждые N минут будет делать тестовый запрос ('SELECT 1' например). Что-нибудь вроде вот этого:

Код


threads->create(\&knock_knock, $db)->detach;
sub knock_knock {
    sleep 60 * 5;
    shift->prepare('SELECT 1')->execute
}

Это сообщение отредактировал(а) KSURi - 24.3.2008, 15:03

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

Died at Life.pl line 21

Bulat

Дата 29.3.2008, 14:52 (ссылка)

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

Загрузка ...

татарский Нео

Профиль
Группа: Завсегдатай
Сообщений: 1701
Регистрация: 22.3.2006
Где: Альметьевск

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

При ошибке mysql going away , как правило нужно рыть в сторону самой базы. На моей практике такая ошибка могла возникать, если в коде нет нормального дисконнекта от базы, не более того smile

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

менеджер по кодеврайтингу smile

gers

Дата 30.3.2008, 22:23 (ссылка)

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

Загрузка ...

Новичок

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

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

Код


$dbh->{mysql_auto_reconnect} = 1;

да, этот код помог моей проблеме,

подскажи еще по коду насколько безопасно сравнивать пришедшее значение переменной тут:

Код


if ($newmsg eq "deposit")

я так понимаю если $newmsg подсунуть сформированную специальным образом , то можно ли навредить бд?

PanamOS

Дата 30.3.2008, 22:29 (ссылка)

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

Загрузка ...

Шустрый

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

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

Цитата(gers @ 30.3.2008, 22:23

)

$newmsg подсунуть сформированную специальным образом

думаю при таком жестком сравнении врятли.

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