Яндекс

150 milyon istifadəçini dəstəkləyən, 75 milyon DAU, 225 milyon MAU, 1.2M oxuma / 300k yazma zirvəsi QPS, 5 milyon eyni vaxtda istifadəçi, ildə 60 PB yeni məlumat, illik 30% artım, SLA 99.95%, p99 <200 ms oxumaq üçün, <300 ms yazmaq üçün, miqyaslana bilən mesajlaşma sistemi layihələndirmək. KONTEKST WhatsApp-ə bənzər, 1:1 və qrup söhbətlərini dəstəkləyən, mesajların çatdırılmasını təmin edən, istifadəçilərin onlayn statuslarını göstərən və multimedia fayllarını (foto, video, audio) ötürən paylanmış mesajlaşma sistemi layihələndirmək lazımdır. Sistem yüksək mövcudluğu və aşağı gecikməni təmin etməli, yüksək paralelliyi dəstəkləməli və qlobal miqyasda genişlənə bilməlidir. FUNKSİONAL TƏLƏBLƏR - Şəxsi (1:1) və qrup söhbətlərini dəstəkləmək, iştirakçıların əlavə və ya çıxarılması imkanı ilə - Mətn mesajları və multimedia fayllarını göndərmək və qəbul etmək Xidmətlər və ya müştərilər səviyyəsində end-to-end şifrələmə mexanizminin aydın tətbiqi görünmür, ümumi qeyd xaricində. - chat_id və ya user_id əsasında verilənlər bazalarının sharding və replikasiyasının aydın təsviri yoxdur, miqyaslana bilmək və nasazlığa davamlılıq üçün. - Offline mesajların və çatdırılma qəbzlərinin sinxronizasiyası üçün aydın komponent və ya mexanizm yoxdur. - Yükün paylanması və bazalar arasında, xüsusən pik vaxtlarda, necə həyata keçirildiyi aydın deyil. **Əhəmiyyətli diqqət yetirilməli nöqtələr:**

type Response interface{} type Backend interface { Invoke(ctx context.Context, req Request) (Response, error) } var _ Backend = &BackendImpl{} // addr содержит ip:port конкретной экземпляра func NewBackend(addr string) *BackendImpl type backentry struct { backend Backend inflight int64 } type Balancer struct { backends []*backentry mu *sync.Mutex } var _ Backend = &Balancer{} // addrs содержат адреса всех балансируемых экземпляров 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(&best.inflight){ best = entry } } return best }

DiffUtil sinifindəki areContentsTheSame və areItemsTheSame metodları arasındakı fərq nədir və onlar nə üçün lazımdır?

RxJava-da subscribeOn və observeOn metodlarının istifadəsi arasındakı fərq nədir və onlar icra axınına necə təsir edir?

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

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

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

Algoritmlərin mürəkkəbliyi n və ya k-dən asılıdırsa, bu nə ilə bağlıdır və ona nə təsir edir?

ROC-AUC nədir? ROC əyrisi necə qurulur, oxlar nəyi göstərir?

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

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

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

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

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

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

Şəbəkədə paketlərin həyat müddətini müəyyən edən protokol hansıdır?

Şəbəkə yolunda yönləndirilmiş bütün hop paketlərini necə görə bilərsiniz?

Avtomobillərin təsnifat tapşırığında xüsusiyyətlərin seçilməsi üçün ML istifadə olunubmu?

Bir zamanlar, Yandex Reklamları saxtakarlıq üzrə stajyer komandaya qoşuldu. Saxtakarlıq qrupu aktiv idi və botlar vasitəsilə saytlarında trafiki simulyasiya edirdi və beləliklə, botlar tərəfindən reklam göstərişi üçün pul alırdı, stajyerin vəzifəsi bütün bu saxtakarlıq saytlarını tapmaq idi. Maraqlıdır ki, bu saytlar üzərindəki bütün trafik IP dəyişdirilməsi ilə yaradılmışdı və sanki bot A şəhərindən ziyarət edirmiş kimi görünürdü, amma əslində cihaz tamamilə başqa yerdə idi. Çox vaxt keçdi və stajyer bu saxtakarlıq qrupunu əhatə etməyə çalışdı, hətta bəzi saytları qismən tutmağa müvəffəq oldu. Amma bütün şəbəkəni tutmaq mümkün olmadı. Bir müddət sonra, o xəbər gördü: A şəhərində, 02.08.2025 tarixində, mobil internet tamamilə yox idi. Ancaq, kabel (ev) interneti işləməyə davam edirdi. Buna görə, stajyer bütün saxtakarlıq saytlarını necə tapa bilər? Sizdə, 30.07.2025-dən 10.08.2025-ə qədər olan dövr üçün saytların logları cədvəl formatında mövcuddur: timestamp | site_id | city_id Hər qeyd, bir cihaz tərəfindən bir saytın ziyarətini göstərir. Bilirsiniz ki, bot trafiki, hər gün real trafiyə nisbətən çox az dəyişir. Sizin vəzifəniz, regionunu şəhər A olaraq dəyişən və əsasən botlardan ibarət trafiki olan bütün saytları tapmaqdır. Qeyd Məlumatların saxlandığı cədvəl logs adlanır. Cədvəldə nümunə qeyd: timestamp | site_id | city_id [phone]:13:53 | 6e84d9b71ca44aea | A

HashMap-ə element əlavə etmə əməliyyatının vaxt mürəkkəbliyi necə müəyyən edilir?

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

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

Tibbi startapda sertifikasiya və tibbi məlumatların işlənməsi (152-FZ Qanunu) ilə bağlı problemləri necə həll etdiniz?

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