Яндекс

Dizajn skalabilnog sistema za razmenu poruka koji podržava 150 miliona korisnika, 75 miliona DAU, 225 miliona MAU, 1.2M peak QPS za čitanje / 300k za pisanje, 5 miliona istovremenih korisnika, 60 PB novih podataka godišnje, rast od 30% godišnje, SLA 99.95%, p99 <200 ms za čitanje, <300 ms za pisanje. KONTEKST Potrebno je dizajnirati distribuirani sistem za razmenu poruka, sličan WhatsApp-u, koji podržava 1:1 i grupne razgovore, obezbeđuje dostavu poruka, prikazuje online statuse korisnika i omogućava prenos multimedijalnih fajlova (fotografije, video, audio). Sistem mora obezbediti visoku dostupnost i nisku latenciju, podržavati visok paralelizam i skalirati na globalnom nivou. FUNKCIONALNI ZAHTEVI - Podrška za lične (1:1) i grupne razgovore sa mogućnošću dodavanja/uklanjanja učesnika - Slanje i primanje tekstualnih poruka i multimedijalnih fajlova Nije jasno implementiran mehanizam end-to-end enkripcije na nivou servisa ili klijenata, osim opšte napomene. - Nedostaje eksplicitni opis sharding-a i replikacije baza podataka po chat_id ili user_id radi skalabilnosti i otpornosti na greške. - Nema jasnog komponenta ili mehanizma za offline sinhronizaciju poruka i potvrda isporuke. - Nije jasno kako se vrši balansiranje opterećenja između baza podataka i servisa, posebno u vršnim periodima. **Kritične tačke za razmatranje:**

type Response interface{} type Backend interface { Invoke(ctx context.Context, req Request) (Response, error) } var _ Backend = &BackendImpl{} // addr obsahuje ip:port konkrétneho inštancie func NewBackend(addr string) *BackendImpl type backentry struct { backend Backend inflight int64 } type Balancer struct { backends []*backentry mu *sync.Mutex } var _ Backend = &Balancer{} // addrs obsahujú adresy všetkých vyvažovaných inštancií func NewBalancer(addrs []string) *Balancer { data := make([]*backentry,len(addrs)) for i,addr := range addrs{ data[i] = &backentry{ backend: NewBackend(addr), inflight: 0, } } return &Balancer{backends:data} } func(b *Balancer)Invoke(ctx context.Context, req Request) (Response, error){ b.mu.Lock() entry := b.best() atomic.AddInt64(&entry.inflight,1) b.mu.Unlock() defer atomic.AddInt64(&entry.inflight,-1) return entry.backend.Invoke(ctx,req) } func(b *Balancer) best() *backentry{ var best *backentry for _,entry := b.backends{ if best == nil || atomic.LoadInt64(&entry.inflight) < atomic.LoadInt64(&bests.inflight){ best = entry } } return best }

Od čega zavisi složenost algoritama koja zavisi od n ili k i od čega zavisi?

Šta je ROC-AUC? Kako se gradi ROC kriva, šta predstavljaju ose?

Da li je ML korišćen za odabir karakteristika u zadatku klasifikacije automobila?

Једном је у тим стигао практикант за борбу против преваре у Јандек огласима. Док је група за превару била активна, симулирала је саобраћај на својим сајтовима преко ботова, и тако добијала новац за приказе огласа од ботова, задатак практиканта био је да пронађе све такве преварне сајтове са лажним саобраћајем. Занимљиво је да је сав саобраћај на тим сајтовима генерисан IP заменом, што је изгледало као да бот посећује са града А, али у стварности, уређај је био на потпуно другом месту. Прошао је много времена, и практикант је покушао да обухвати целу ову групу преваре, чак је успео делимично да ухвати неке сајтове. Али целу мрежу није успео да ухвати. После неког времена, приметио је вест: у граду А, 02.08.2025, потпуно је недостајао мобилни интернет. Међутим, кабловски (кућни) интернет наставио је да ради. Узимајући то у обзир, како практикант може да пронађе све лажне сајтове? Имаш логове сајтова у формату табеле за период од 30.07.2025 до 10.08.2025: timestamp | site_id | city_id Сваки запис одговара посети сајту од стране једног уређаја. Зна се да се саобраћај ботова мења знатно мање него стварни саобраћај по дану. Твој задатак је да пронађеш све сајтове чији је саобраћај у великој мери сачињен од ботова који су фалсификовали свој регион у град А. Напомена Табела која садржи податке зове се logs. Пример записа у таблици: timestamp | site_id | city_id [phone]:13:53 | 6e84d9b71ca44aea | A

Koji protokol je odgovoran za određivanje vremena trajanja paketa u mreži?

Kako prikazati sve rutirane hop pakete u mrežnom putu?

Kako ste rešavali probleme sertifikacije i obrade medicinskih podataka (Zakon 152-FZ) u medicinskom startapu?

Kako se određuje vremenska složenost operacije umetanja elementa u HashMap?

Подсчёт подстрок без повторяющихся символов

Определение возможности преобразования строки за одно редактирование

Koja je razlika između metoda areContentsTheSame i areItemsTheSame u klasi DiffUtil i čemu služe?

Koja je razlika između korišćenja metoda subscribeOn i observeOn u RxJava i kako oni utiču na tok izvršenja?

Создание собственного аналога findViewById для View

Нахождение ближайшего общего предка в иерархии экранов

Разбор поведения flatMap в цепочке RxJava

Что выведет console.log в примере №81

Функция определения палиндромности строки

Надёжный GET‑запрос с автоматическим повтором

Проверка массива на монотонность

Определение пути перелёта между двумя пунктами

Что будет выведено в консоль в данном JavaScript‑фрагменте?

Инвертирование порядка битов в 64‑разрядном беззнаковом числе