В emacs норм )

юзал кто https://github.com/ninenines/ranch для tcp сокетов?

Ковбой использует это под капотом вроде

это да

да

А его используют более или менее все

у меня непонимание tcp протокола или мозг не на месте. Реализовал на эликсире вот этот пример https://github.com/ninenines/ranch/tree/master/examples/tcp_reverse

Вот так фигачу в него данные

спустя ровно 28312 успешных соединений начинает вываливаться в php ошибка PHP Warning: socket_recv(): unable to read from socket [107]: Transport endpoint is not connected

я так понимаю, что создаю слишком большое количество соединений и ranch тупо отсеивает их

Старт ранча def start_link(port) do {:ok, _} = :ranch.start_listener( :teaser_view, 1024, :ranch_tcp, [port: port], TeaserView.Handler, [] ) end

Это хендлер, логика тупая до безобразия

какая ОС?

попробуй {max_connections, infinity}

хыы,, видать никто не понял нифига)) Linux Mint

сокеты иногда не сразу закрываются

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

я думал что он сокеты не закрывает и тогда просто уперся в ос

между твоим socket_close и реальным закрытием

еще проходит некоторое время

я для подобного случая пересобирал в убунте чтобы ejabberd мог работать

попробуй {max_connections, infinity}

Вот так делал еще def start_link(port) do {:ok, _} = :ranch.start_listener( :teaser_view, 1000, :ranch_tcp, [port: port, max_connections: 2048, backlog: 10000], TeaserView.Handler, [] ) end

черт.. я даже эрланговый код научился читать нормально))))

примерно то о чем я говорил с джабером http://www.sundeepmachado.com/2016/03/how-to-tune-ejabber-server-to-handle.html

The linux machine needs to be tuned for handling a large number of connections.

можешь посмотреть количество TIME_WAIT коннекетов

TIME-WAIT state can exists on either server or client program. It represents waiting for enough time to pass to be sure the remote TCP received the acknowledgment of its connection termination request. The /proc/sys/net/ipv4/tcp_fin_timeout setting determines the time that must elapse before TCP/IP can release a closed connection and reuse its resources. This is known as TIME_WAIT state. TIME_WAIT is a normal part of the TCP connection. However, if you must close a socket in TIME_WAIT state, try:

net.ipv4.tcp_max_syn_backlog = 10240000 net.ipv4.tcp_max_tw_buckets = 400000 net.ipv4.tcp_max_orphans = 60000

cat /proc/sys/net/ipv4/tcp_fin_timeout 60

ну вот, у тебя еще 60 секунд будет висеть твой сокет

да.. круто)))

примерно то о чем я говорил с джабером http://www.sundeepmachado.com/2016/03/how-to-tune-ejabber-server-to-handle.html

спс, в закладках теперь

получается, что теперь только систему тюнить. Я вот эти статьи смотрю https://dbeck.github.io/Wrapping-up-my-Elixir-TCP-experiments/ он вроде не тюнил ничего.

Может просто не написал

Да, я перепроверил. Ошибка пропадает ровно спустя 60 сек

т.е. сокеты остаются открытыми и не создаются новые

не понятно как тогда работает тот-же cowboy

а ты разве с transport.setopts не сбрасываешь {reuseaddr, true} ?

не понял, можешь подробнее?

я сейчас смотрю в сторону php для reuseaddress

ну ты там в исходнике опции сокету меняешь

и по умолчанию reuseaddr включен, а у тебя его нет

как я понимаю это основная опция для того чтобы обрабатывать большое количество соеднинений

так если он по умолчанию включен - то зачем его задавать?

ну если setopts не добавляет опции, а переназначает, то ты его сбрасываешь

сейчас пытаюсь в исходниках посмотреть как это работает

пока не разобрался

я уже и от этого отказался, упростил до усновного варианта

и тюнил tcp соединения в ОС

какая элементарная задача)))) ума не приложу как решить

нужно тупо передавать кучу данных из php в эликсир большим потоком

большие нагрузки редко решаются элементарно

но важно удостовериться в успешной передаче

rabbitMQ ведь так работает

гоню, у него протокол другой ведь

ещё раз повторюсь - я ни разу не смог ПХПнёй нагрузить ерланг проекты на одном сервере

вот с кучи серверов - легко

у меня на эрланге - Riak CS и RabbitMQ

In Erlang/OTP 19.0, UNIX Sockets are now available

ERROR: S client not available

у вас в ПХП кроме соединений же ещё какая-то логика будет?

чем черт не шутит))

=)

конечно будет

попробую через unix сокет, вроде даже быстрее должно работать

другое дело, что только локально

на внешний сервер не повесить тогда

пробросить unix сокет наружу через socat

я думаю что производительность тестировать стоит на нагрузке приближенной к настоящей, а то получается "предварительная оптимизация" с усложнением архитектуры

конечно, оптимизировать надо только когда упёрся в это

из головы придумывать (((улучшения))) на ровном месте неэффективно

вот давайте результат разложим

28к соединений он создает за 2 сек, потом висит 60 сек и продолжает создавать новые 28к соединений

я не знаю, почему он больше не может

А на php стороне ты сокеты нормально закрываешь?

А попробуй socket_shutdown перед close

такая-же песня)

Хм... Ну тогда бери в руки tcpdump и смотри в какой момент тормоза

И нестатом посмотри что там творится

еще полезные команды линукса

ss -s

и в самом ерланге inet:i(). аналог нетстата

Ровно 28232 соединений))

вот хоть тресни))

причем тачка то не виснет

видать это ограничение эрланга, сейчас туда смотрю

ss -s что показывает?

http://www.linuxscrew.com/2011/02/15/quick-tip-port-range/

у тебя заняты все порты