AIOHTTP, emit события на стороне сервера?

Question

[prikoz]

Всем привет.
1. Как сделать emit события на стороне сервера ?
https://github.com/aio-libs/sockjs/ - использую
Все взял с примера, суть в том что ничего отправлять с клиетна не хочу а только принимать.
К примеру сделал запись в БД и хочу отправить на клиент но как не могу понять.
2. Деплой приложения
https://docs.aiohttp.org/en/stable/deployment.html... - следовал етим настройкам
И тут у нас

http {
  upstream aiohttp {
    # fail_timeout=0 means we always retry an upstream even if it failed
    # to return a good HTTP response

    # Unix domain servers
    server unix:/tmp/example_1.sock fail_timeout=0;
    server unix:/tmp/example_2.sock fail_timeout=0;
    server unix:/tmp/example_3.sock fail_timeout=0;
    server unix:/tmp/example_4.sock fail_timeout=0;

    # Unix domain sockets are used in this example due to their high performance,
    # but TCP/IP sockets could be used instead:
    # server 127.0.0.1:8081 fail_timeout=0;
    # server 127.0.0.1:8082 fail_timeout=0;
    # server 127.0.0.1:8083 fail_timeout=0;
    # server 127.0.0.1:8084 fail_timeout=0;
  }
}

Я хочу понять, есть у меня 4 сокета а можно на 1 все сделать и какой будет результат по быстродействию ?

Comments

[Сергей Горностаев]

1. Непонятно, что именно вам непонятно. Как вызвать метод send_str?
2. Зачем вам Nginx?

[prikoz]

Сергей Горностаев,
1.Сергей напишите пожалуйста мне тупому как вызвать буду признателен.
2. Зачем вам Nginx? - ну как задеплоить ?

[Сергей Горностаев]

prikoz,
1. Предположим, что в переменной ws у вас сохранён подключенный websocket, тогда ws.send_str('hello')
2. В минимальном возможном варианте просто запускаете на сервере скрипт и всё - python server.py

[prikoz]

Сергей Горностаев,
Сергей я понял про что Вы.
https://github.com/aio-libs/sockjs/ - тут либа

вот к примеру

клиент

conn = new SockJS('http://' + window.location.host + '/sockjs/', transports, {debug: true});

transports - это протокол, в моем случае "xhr-polling"

Сервер

async def chat_msg_handler(msg, session):
    if msg.type == sockjs.MSG_OPEN:
        session.manager.broadcast("Someone joined.")
    elif msg.type == sockjs.MSG_MESSAGE:
        session.manager.broadcast(msg.data)
    elif msg.type == sockjs.MSG_CLOSED:
        session.manager.broadcast("Someone left.")

И тут вопрос, у меня есть мое представление и мне как-то надо отправить стоку на chat_msg_handler, но тут session не просто сессия

[Сергей Горностаев]

prikoz, если вам надо с сервера отправлять события клиенту, то polling - неподходящий транспорт. Websocket'ы или SSE подойдут лучше.

[prikoz]

Сергей Горностаев,
Сергей ну можно же реализовать по polling и с помощью https://github.com/aio-libs/sockjs/ этого ?

[Сергей Горностаев]

prikoz, можно, но через костыль:

1. Уведомления для клиента сохранять в памяти, очереди или отдельной таблице базы;
   
2. Требовать от клиентов аутентификации, чтобы знать какие уведомления на какой запрос отправлять;
   
3. При получении нового запроса от клиента выгребать сохранённые в пункте 1 уведомления и отправлять в ответе.
   

[prikoz]

Сергей Горностаев, Сергей спасибо, понял.
Вопрос второй по деплое приложения, какая разница будет если приложение будет крутится на одном сокете а не как в примере на 4-х ?

[Сергей Горностаев]

prikoz, я вообще не понимаю зачем вам Nginx. Единственное, что приходит в голову - использование всех ядер процессора. Но это сработает только со stateless-сервисом.

[prikoz]

Сергей Горностаев, Сергей а тогда что использовать лучше всего ?

[Сергей Горностаев]

prikoz, в смысле? Если вы не знаете нужен ли вам Nginx, просто не используйте Nginx.

[prikoz]

Сергей Горностаев, Сергей а какую лучше связку для деплоя использовать ?

[Сергей Горностаев]

prikoz, от конкретной ситуации зависит. Как я уже писал, можно вообще никаких связок не использовать, просто запускать скрипт.

[prikoz]

Сергей Горностаев, Сергей спасибо, пересмотрю свой подход, буду читать пока документацию.