javascript — лучшая технология для обработки такой сложной системы, приложение Wep + тяжелая обработка

Из интереса: зачем кому-то еще нужно получать оповещения?

К каким данным у вас есть доступ?

Вы всегда знаете позиции такси? Это GPS? Драйверы добавляют / обновляют данные?

Вы всегда знаете позиции пользователей? Это GPS? Пользователи добавляют / обновляют данные?

Откуда вы знаете, что такое «зона» и что определяет, находится ли пользователь / такси в зоне действия?

ПОЦЕЛУЙ — Сохраняй это простым Шадин

Я предлагаю следующие объекты в вашей системе:

Taxi
+ id : int
+ positions : Position[]

User
+ id : int
+ username / password / email etc
+ observing : Taxi[]
+ rules : Rule[]

Rule
I do not know what you need or expect from this

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

Теперь по правилам. Кажется, вам нужен домен-специфичный язык (DSL).

Тогда возникает вопрос, правила предопределены? Или пользователь должен иметь возможность создавать их динамически?

Если они предопределены, вы можете просто реализовать класс для этого правила и выполнить его в своем контроллере (или любом другом, который вы используете для обработки http-запросов), когда пришло время проверить это правило. Что-то вроде myRule.checkFor(user), Может даже быть какой-то рабочий процесс.

Я буду обновлять мой ответ, когда вы отвечаете на мои вопросы в качестве комментариев 🙂

РЕДАКТИРОВАТЬ:

Хорошо, я думаю, я начинаю чувствовать твою проблему. Это было бы моим решением:

REST API:

POST yoursite.com/v1/taxi/1.json {x:0.23, y:23} //update position for taxi 1 with json payload
POST yoursite.com/v1/user/1/register {taxi:1, eventType:NO_MOVEMENT, args:"3600"} //no mov for 1 hr
POST yoursite.com/v1/user/1/unregister {taxi:1, eventType:NO_MOVEMENT }

Мне кажется, этого должно быть достаточно для объединения нужных вам данных. Он отвечает на следующие вопросы:

Where are the taxis? Which user is looking for events on x taxi?

Вам понадобится стол (такси) для хранения идентификатора такси и его позиции. [taxiid: int, long: float, lat: float]

Вам понадобится таблица (слушатели) для хранения того, какое такси слушает, какими пользователями и для какого события. [userid: int, taxiid: int, event: enum, arguments: string]

Вам понадобится таблица (события), в которой хранится каждое событие. [eventid: int, eventType: enum, taxiid: int]

Следующим шагом в моем предложенном решении было бы иметь работника, непрерывно агрегирующего события на основе полученных данных. Скажем, вы определяете процесс NoMovement. Этот процесс выполняется с частотой, достаточной для определения минимально допустимого интервала в вашей системе. Для этого примера, давайте предположим, что мы могли бы бежать с 15-минутным интервалом (то есть, вы не заинтересованы в такси, которое стоит на месте 14 минут).

Теперь каждый из ваших процессов сможет хранить события в новой таблице в вашей базе данных. Давайте исследуем процесс NoMovement (который будет запускаться каждые 15 минут вашим работником):

For each $taxiid present in listeners@taxiid
Retrieve taxipos closest to now, and taxipos closest to 15 minutes ago (interval must be => to 15 minutes)
Check distance between now, and 15 minutes ago
If distance is <1 THRESHOLD (I don't know what this should be)
Add to event table with (eventType:NO_MOVEMENT, taxiid: $taxiid) you'll get that from the loop

Наконец, это просто вопрос

GET youriste.com/v1/events/taxiid (your client will need to store which taxiids we want to ask for events, and call get at an appropriate interval - your client should then locally set event by id as read and filter those out before alerting)

Это имеет какой-то смысл для вас?