Яндекс

150 million foydalanuvchiga mo support qiladigan, 75 million DAU, 225 million MAU, 1.2M o'qish / 300k yozish piki QPS, 5 million bir vaqtning o'zida foydalanayotgan foydalanuvchilar, yillik 60 PB yangi ma'lumotlar, yillik 30% o'sish, SLA 99.95%, p99 <200 ms o'qish uchun, <300 ms yozish uchun, kengaytiriladigan va global miqyosda ishlashga mo'ljallangan skalable xabar yuborish tizimi loyihalashtirish. KONTEKST WhatsApp ga o'xshash, 1:1 va guruh chatlarni qo'llab-quvvatlaydigan, xabarlarni yetkazib berishni ta'minlaydigan, foydalanuvchilarning onlayn holatini ko'rsatadigan va multimedia fayllarini (foto, video, audio) uzatishni ta'minlaydigan tarqatilgan xabar tizimini loyihalashtirish zarur. Tizim yuqori mavjudlik va past kechikishni ta'minlashi, yuqori parallelizmni qo'llab-quvvatlashi va global miqyosda kengayishi kerak. FUNKTSIONAL TALABLAR - Shaxsiy (1:1) va guruh chatlarni qo'llab-quvvatlash, ishtirokchilarni qo'shish/olib tashlash imkoniyati bilan - Matnli xabarlar va multimedia fayllarini yuborish va qabul qilish Xizmatlar yoki mijozlar darajasida end-to-end shifrlash mexanizmining aniq amalga oshirilishi ko'rinmayapti, umumiy yozuvdan tashqari. - chat_id yoki user_id bo'yicha ma'lumotlar bazalarini sharding va replikatsiyasining aniq ta'rifi yo'q, kengaytirilish va nosozlikka chidamlilik uchun. - Offline xabarlar va yetkazib berish qabul qiluvchilarini sinxronlashtirish uchun aniq komponent yoki mexanizm yo'q. - Yuk ortish paytida ma'lumotlar bazalari va xizmatlar o'rtasida yukni taqsimlash qanday amalga oshirilishini aniqlash qiyin. **Muhim nuqtalar:**

type Response interface{} type Backend interface { Invoke(ctx context.Context, req Request) (Response, error) } var _ Backend = &BackendImpl{} // addr contains ip:port of a specific instance func NewBackend(addr string) *BackendImpl type backentry struct { backend Backend inflight int64 } type Balancer struct { backends []*backentry mu *sync.Mutex } var _ Backend = &Balancer{} // addrs contain the addresses of all balancable instances 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 sinfidagi areContentsTheSame va areItemsTheSame metodlari orasidagi farq nima va ular nima uchun kerak?

RxJava'da subscribeOn va observeOn metodlaridan foydalanishning farqi nima va ular bajarilish oqimiga qanday ta'sir qiladi?

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

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

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

Algoritmlarning murakkabligi n yoki k ga bog'liq bo'lsa, bu nima bilan bog'liq va u nima bilan bog'liq?

ROC-AUC nima? ROC egri chizig'i qanday quriladi, o'qlar nima ifodalaydi?

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

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

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

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

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

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

Tarmoqda paketlarning yashash muddatini belgilash uchun qaysi protokol javobgardir?

Tarmoq yo'lida marshrutlangan barcha hop-paketlarini qanday ko'rish mumkin?

Avtomobillarni tasniflash vazifasida xususiyatlarni tanlash uchun ML ishlatildimi?

Bir vaqtlar, Yandex Reklamalaridagi firibgarlik bo'yicha stajyor jamoaga qo'shildi. Firibgarlik guruhi faoliyat yuritayotgan va botlar orqali trafikni simulyatsiya qilgan va shuning uchun botlar tomonidan reklama ko'rsatish uchun pul olgan paytda, stajyorning vazifasi, bunday firibgarlik saytlarini topish edi. Qiziqarli tomoni, bu saytlar ustida barcha trafik IP o'zgartirish bilan yaratilgan bo'lib, bot A shahridan kirayotgan kabi ko'rinishda bo'lsa-da, aslida qurilma butunlay boshqa joyda edi. Ko'p vaqt o'tdi, va stajyor bu firibgarlik guruhini qamrab olishga harakat qildi, hatto ba'zi saytlarni qisman ushlashga muvaffaq bo'ldi. Ammo butun tarmoqni ushlash mumkin bo'lmadi. Bir muddat o'tgach, u yangilikni ko'rdi: A shahrida, 02.08.2025, mobil internet to'liq yo'q edi. Biroq, simli (uy) internet ishlashda davom etdi. Buni hisobga olgan holda, stajyor qanday qilib barcha firibgar saytlarni topishi mumkin? Sizda, 30.07.2025 dan 10.08.2025 gacha bo'lgan davr uchun saytlar loglari jadval formatida mavjud: timestamp | site_id | city_id Har bir yozuv, bir qurilma tomonidan saytga tashrifni anglatadi. Bilamizki, botlar trafiklari, har kuni haqiqiy trafikga nisbatan juda kam o'zgaradi. Sizning vazifangiz, regionini A shahriga o'zgartirgan va asosan botlardan iborat bo'lgan trafikni ko'rsatadigan barcha saytlarni topishdir. Eslatma Ma'lumotlar jadvali logs deb nomlangan. Jadvaldagi misol yozuv: timestamp | site_id | city_id [phone]:13:53 | 6e84d9b71ca44aea | A

HashMap ga element qo'shish operatsiyasining vaqt murakkabligi qanday aniqlanadi?

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

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

Sog'liq texnologiyalari startapida sertifikatsiya va tibbiy ma'lumotlarni qayta ishlash muammolarini qanday hal qildingiz?

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