Очередь запросов в websocket?

Question

[Aleksey100]

Делаю приложение и использую вебсокет. В приложении есть авторизация и пока не авторизуешься, на все остальные запросы сервер соответственно отвечает ошибкой.

В чем проблема: После потери связи с сервером все запросы встают в очередь и после восстановления связи выполняются (это механизм вебсокета). Но если связи не было достаточно долго (более 30 сек) то вебсокет создает новое подключение (оно уже не авторизованно получается) и пытается в него отправить запросы из очереди. У меня реализовано что сразу после установления соединения выполнялась авторизация, но бывает что некоторые запросы из очереди улетают раньше авторизации. И на них сервер отвечает ошибкой.

Вопрос: Как то можно управлять этой очередью или запретить вебсокету создавать новые подключения, а все время пытаться восстановить старое? Или может есть ещё какие-то варианты?

Comments

[Сергей Соколов]

если бы можно было авторизацию засунуть в HTTP-заголовок устанавливаемого соединения.. Пока не нашёл такой возможности.

[Aleksey100]

Сергей Соколов, там во время авторизации кроме токена передается еще другая информация (ОС, название устройства и т.д.)

[Сергей Соколов]

какова последовательность событий WS при «переконнекте»?

• open – connection established,
  
• message – data received,
  
• error – websocket error,
  
• close – connection closed.
  

можно проверять длину буфера:

// every 100ms examine the socket and send more data
// only if all the existing data was sent out
setInterval(() => {
  if (socket.bufferedAmount == 0) {
    socket.send(moreData());
  }
}, 100);

Можно сделать свою обёртку над буфером отправки. Чтобы в буфере самого WS было максимум одно сообщение, а остальные ждали в _вашей_ очереди, над которой вы полный хозяин.

[Aves]

Авторизация по websocket происходит? Можно в handshake добавить отправку информации для авторизации, в headers или query.

[Кирилл Кузнецов]

Сергей Соколов, именно, нужна реализация очереди (queue wrapper) и проверка на выполнение (queue executor)

[Сергей Соколов]

Кирилл Кузнецов, готовую не подскажу, но.. массив!
Пихать в настоящий WS по одному сообщению, и, (знаю, отстой), раз в X ms поллить размер настоящего буфера на предмет отправилось или ещё нет?

[Сергей Соколов]

Aves, как в headers WebSocket'а что-то добавить?

spoiler

[Aves]

Сергей Соколов, через cookie, если websocket не на другом порту

[Aleksey100]

Сергей Соколов, спасибо! Примерно так и сделал, только не по одному добавляю. Создал свою собственную очередь в которую сохраняю запросы, после успешного ответа удаляю из очереди. А если после реконнекта какие то запросы остались без ответа или пришел ответ что "Пользователь не авторизован", то авторизую его и отправляю их заново. Напишите ваш коммент ответом, отмечу верным

Answer 1

[Сергей Соколов]

Можно проверять длину буфера:

// every 100ms examine the socket and send more data
// only if all the existing data was sent out
setInterval(() => {
  if (socket.bufferedAmount == 0) {
    socket.send(moreData());
  }
}, 100);

Вариант — сделать свою обёртку над буфером отправки. Чтобы в буфере самого WS было максимум одно сообщение, а остальные ждали в _вашей_ очереди, над которой вы полный хозяин.

Comments

[Aleksey100]

Спасибо! Примерно так и сделал, только не по одному добавляю. Создал свою собственную очередь в которую сохраняю запросы, после успешного ответа удаляю из очереди. А если после реконнекта какие то запросы остались без ответа или пришел ответ что "Пользователь не авторизован", то авторизую его и отправляю их заново