Kafka çöldükdə hadisələrin göndərilməsi nə olur?
Golang
// Sorğuların rəqabətə davamlı olması və cavab kodunun göstərilməsi üçün kodu düzəldin // və səhv baş verərsə, logu göstərin və işləməyə davam edin package main import "net/http" var addrs = []string{"[link] "[link] "[link] "[link] "[link] "[link] "[link] func main() { var wg sync.WaitGroup data := make(map[string]bool) for _, url := range addrs { wg.Add(1) if !data[url] { data[url] = true go func(url string) { defer wg.Done() resp, err := http.Get(url) if err != nil { log.Println(err) return } log.Println(resp.StatusCode) }(url) } } wg.Wait() }
JSON etiketləri ilə model (məsələn, RegisterUserRequest) domen modelidir? DTO və domain entity-ni düzgün necə ayırmaq olar?
Altıbucaq Arxitekturası ilə tanışsınız? Onun quruluşu haqqında danışın.
Altıbucaqlı Memarlıq üç elementdən ibarətdir: adaptör, port və mərkəzi tətbiq. Gələn sorğu handler vasitəsilə domain modelinə necə işlənir?
Bildiriş xidməti tərəfində tərs tərəfi — Inbox nümunəsini necə həyata keçirmək olar? Hadisələrin işlənməsində idempotentliyi necə təmin etmək olar?
// Kodu düzgün işlashi uchun so'rovlar raqobatlashgan va javob kodini chiqaradigan qilib tuzish // va xatolik yuzaga kelsa, uni logga yozib, ishlov berishni davom ettirish package main import "net/http" var addrs = []string{"[link]"} func main() { for _, url := range addrs { resp, err := http.Get(url) if err != nil { log.Error(err) continue } // Agar kerak bo'lsa, resp ni ishlash } }
DDD və CQRS ilə işləmisinizmi? Bu barədə danışın.
Yığım həmişə bir əməliyyat səviyyəsində işləyir. DDD-də yığımlar haqqında başqa nə bilmək vacibdir?
Mikroxizmat arxitekturasında hər bir xidmətin öz məlumat bazası var. Kafka hələ mesajı almamışsa, Outbox nümunəsi bu kontekstdə necə işləyir?
Transactional Outbox nümunəsi haqqında danışın — necə işləyir və niyə istifadə olunur?