https://github.com/phoenixframework/phoenix/blob/master/lib/phoenix/transports/websocket.ex транспорт для Socket'а, как и https://github.com/phoenixframework/phoenix/blob/master/lib/phoenix/transports/long_poll.ex

а вебсокет - это поверх сокетов протокол. для http. чтоб js на странице установил постоянный коннект к сервером

без http, это другой протокол

ok.. а что использовать для работы с сокетом оси?

ok.. а что использовать для работы с сокетом оси?

да что угодно, или имеется ввиду эликсир?

elixir

afunix например

гуглится ещё какая-то альтернатива, я забыл какая

@che_onza для какой задачи?

куча пакетов сыпятся на сокет .. обработка этих пакетов и запись в бд данных

gen_tcp

сокет - unix сокет?

да unix soket

куча пакетов сыпятся на сокет .. обработка этих пакетов и запись в бд данных

http://elixir-lang.org/getting-started/mix-otp/task-and-gen-tcp.html

https://github.com/tonyrog/afunix ну и обработчик пакетов пиши поверх него, интерфейс как у gen_tcp вроде

о, а gen_tcp вроде бы тоже умеет в unix socket'ы

спасибо)

почему тогда долбаный экто не может подключиться на постгрес? :)

Долбаный экто может

Новая версия не умеет в эскулайт, а в постгрес может

кстати оно вроде как experimental появилось только в 19, какой сейчас статус - непонятно, пометки что оно experimental нет

кстати оно вроде как experimental появилось только в 19, какой сейчас статус - непонятно, пометки что оно experimental нет

да, нагуглил только что ченжлог)

https://www.erlang.org/news/tag/%20OTP-19.0

Коллеги как приложение на phoenixframework запустить как службу в UBUNTU, так чтобы после перезапуска или падения приложение запускалось?

ок буду пробовать благодарю! $ cat /etc/systemd/system/myapp.service [Unit] Description=my app [Service] User=erl WorkingDirectory=/home/erl ExecStart=/home/erl/bin/myapp foreground

ето, а в еликсире пулы по-прежнему через пулбой принято делать, или что-то лучше придумали?

пулбой, альтернатив нет

если только poolgirl :D

а как в пулбой засунуть уникальные идентификаторы для каждого воркера?

допустим я хочу их 500 штук, и чтобы у каждого было 1, 2, 3, 4, ..., 500

и потом при работе какой дёрнется, такой и использует работу с таким ID

или я где-то туплю и не вижу очевидного?

ПУСТЬ КАЖДЫЙ ВОРКЕР ПРИ ИНИЦИЛИЗАЦИИ ДЁРГАЕТ НЕКИЙ ГЕНСЕРВЕР И ПОЛУЧАЕТ ОТ НЕГО ИДЕНТИФИКАТОР

СУПЕРВАЙЗОР ДЛЯ ПРОЦЕССА РАЗДАЮЩЕГО НАТУРАЛЬНЫЕ ЧИСЛА

можно же зарегать воркер в Registry при старте и всо

а что это даст?

я Registry ещё не использовал ни разу

вообще не очень понял, что ты хочешь получить... сливать задачи по ID на определенный воркер в пуле?

не

я хочу, чтобы у каждого воркера был какой-то свой уникальный числовой ID

я хочу, чтобы у каждого воркера был какой-то свой уникальный числовой ID

Зачем это надо?

Registry - замена для gproc'а прост... рандомный? что при рестарте процесса? он должен сохранить этот ID?

и когда он делает работу — делает её с этим ID

Зачем это надо?

в моём случае — порт, который надо слушать из пула портов

т.е. есть 5000..5500 порты

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

одна сессия работает с одним воркером

они запускаются и гасятся

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

перестал — погас

Вообще то такое можно сделать с помощью registry, но смысла я не вижу

Если ты делаешь stateless сервер, то тебе без разницы какой из воркеров обрабатывает запрос

А если делаешь stateful - то state определятся должен уж точно не портом

Что возвращает нас к тому что ты можешь узнать state в любом воркере, и тебе без разницы каким именно обрабатывать

А для этого ставится poolboy, а стейт выносится из воркера

Если ты делаешь stateless сервер, то тебе без разницы какой из воркеров обрабатывает запрос

мне без разницы какой обрабатывает запрос, но мне надо, чтобы каждый обрабатывал свой порт

чтобы порты были в заданном диапазоне и каждый использовался только одним воркером

или запустить 500 simple_one_for_one?

т.е. мне нужен пул целых чисел

можно хранить список портов в Agent'е, при старте воркера брать из него порт, после завершения возвращать его обратно в список

что за агент?

абстракция для хранения стейта, почти GenServer, только проще

Используй ets

Используй ets

ага, монгодб ещё приделать

целые числа хранить

:D

ERROR: S client not available

MapSet и Agent - норм варик

А в чем проблема ets?

да, Agent похоже то, что нужно

спасибо!

Ets не создаёт отдельных процессов, хорошо масштабируется, очень быстрая, хранится в оперативке. И ещё не теряет данные если supervision tree упадёт. Запись чтение одной командой. Для пула где надо set pop/push идеально.

да. чем ets не нравится - тож не понимаю. а Agent где-то видел, что их вообще не рекомендуют к применению. изобретение эликсирщиков.

хм

Агент туповат потому что его отдельным модулем не импортировать, и получается что для его изменения надо писать лямбду, а это выглядит не очень - как callback hell в js. Я во всяком случае всегда использую gen server вместо агента

не смогу найти ссыль на обсуждение, но это точно было

даже валима туда приплетали, что идея с агентами плохая

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

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

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

так мне же надо и помечать тогда в ETS, какой порт занят

Делаешь set и смотришь есть там порт или нет. Если есть - удаляешь, если нету - значит занято

два процесса смотрят один порт — есть, удаляют, начинают использовать

я делал, у меня супервизор отлавылиывал смерть воркеров (нормальную или ненормальную) и убирал

один падает

упадет - и норм.

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

по какой? порт нельзя слушать?

либо работу с выдачей номеров - етс кладете в генсервер. тогда он один порт двоим не выдаст

так-то да, но если генсервер, то зачем в нём етс, и чем это отличается от Agent?

это как раз тот случай, когда параллельное чтение не нужно

можно и не етс. я бы мап использовал

агенты не пользую. так что не подскажу

зачем с ets оверинжинирить непонятно, объемы небольшие и стейта процесса для этого заглаза хватит

https://github.com/elixir-lang/elixir/blob/master/lib/elixir/lib/agent.ex реализация агента, там видно что это и зачем это

@mtreskin щас ещё модно на GenStage всё перепиливать, с ним можно и без poolboy обойтись поидее

про него писали даже недавно. https://habrahabr.ru/post/317724/

@mtreskin щас ещё модно на GenStage всё перепиливать, с ним можно и без poolboy обойтись поидее

а это что?

https://github.com/elixir-lang/gen_stage