Проблема
Было приложение, использующее Ruby on Rails, и стандартный набор гемов (вроде devise). На одной из страниц необходимо было выводить информацию о текущих активных пользователях.
Решение
Первой же мыслью было при каждом запросе записывать в текущего юзера время этого самого запроса и, таким образом, зная таймаут сессии, можно было вычислить, кто активен, а кто нет. Но таймаут стоял порядка 15 минут, поэтому если вкладку просто закрыли — то он все еще будет «активным» на протяжении этого времени. Уменьшать таймаут сессии было нельзя. Да и вариант каждый раз обновлять запись в базе выглядел немного костыльно, учитывая, что одновременных активных юзеров было порядка 2к. Из самых быстрых и простых вариантов — реализация используя вебсокеты + redis.
Faye vs WebsocketRails
tldr; В итоге был выбран faye.
Изначальный выбор был предоставлен двумя вариантами. Гугление ответ на вопрос что лучше не дало, поэтому все плюсы и минусы — это то, что удалось накопать из доков и статей.
Плюсов у websocket-rails я не нашел, зато минусы были очевидные: последнее обновление было довольно давно, на каждое подключение открывался отдельный поток, что потенциально могло заддосить наш и так не очень мощный сервер. Faye в свою очередь работает через event machine и полностью асинхронный, плюс постоянно обновляется.
Установка
Gemfile:
gem "hiredis", "~> 0.4.0"
gem 'redis'
gem 'faye'
gem 'faye-rails'
Настройка
В initializers/redis.rb была добавлена инициализация подключения к redis:
Redis.current = Redis.new(host: 'localhost', port: 6379, driver: :hiredis)
application.rb
config.middleware.delete Rack::Lock
config.middleware.use FayeRails::Middleware, mount: '/faye', timeout: 25 do
map '/active_users' => ActiveUsersController
add_extension(Inc.new)
end
В этом куске происходит подключение faye по урлу '/faye', и указание таймаута, что очень было важно в решении данной задачи. А так же маппинг канала на определенный обработчик, в моем случае это был ActiveUsersController. Так же добавил расширение для файе. Его код выглядит примерно так:
class Inc
def incoming(message, _request, callback)
if message["channel"] == "/active_users"
OnlineUsers.new(message["data"]["id"], message["clientId"]).online!
end
callback.call(message)
end
end
Это дало мне возможность узнавать кто отправил запрос на '/faye'. Внутри OnlineUsers было просто добавление id и client_ud (который выдается faye, при коннекте)юзера в редис внутрь хеша, что то вроде:
redis.hset(HASH_KEY, client_id, user_id)
чтобы можно было достать всех активных просто по ключу хеша.
Так же в контроллере сделал монитор события «unsubscribe», которое по идее должно было срабатывать, когда закрывается вкладка, но на практике срабатывало через раз. Так же срабатывало когда пользователь кликал на логаут и после клика удалял из редиса нашего клиента и по истечении таймаута, когда от клиента не слышно ничего.
channel '/channel_name' do
monitor :unsubscribe do
remove_online_user(client_id)
end
end
На фронте был простой скрипт:
client = new Faye.Client('/faye');
client.subscribe("/active_users", function(message){})
client.publish('/active_users', {id: user_id});
client.disable('autodisconnect');
Для faye был поднят отдельный thin сервер, который слушал только порт на котором вещал faye. Таким образом, получилось сделать возможность мониторинга онлайн пользователей с дельтой в 30 секунд.
В итоге, что бы получить список id всех онлайн юзеров достаточно
redis.hgetall(HASH_KEY).values.uniq
