Golang

Mi történik az eseményküldéssel, ha a Kafka leáll?

// Javítsa ki a kódot úgy, hogy a kérések versenyképesek legyenek, és megjelenjen a válasz kódja // és hibás esetén, jelenítse meg a naplót, és folytassa a feldolgozást 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-címkékkel ellátott modell (pl. RegisterUserRequest) domain modell? Hogyan válasszuk szét helyesen a DTO-t és a domain entitást?

Ismeri a hexagonális architektúrát? Meséljen a szerkezetéről.

A hatszögletű architektúra három elemből áll: adapter, port és központi alkalmazás. Hogyan kezelődik a bejövő kérés a handler-en keresztül a domain modellé?

Hogyan valósítható meg a fordított oldal — az Inbox minta az értesítési szolgáltatás oldalán? Hogyan biztosítható az események idempotens feldolgozása?

// Javítsa ki a kódot úgy, hogy a kérések párhuzamosak legyenek, és megjelenjen a válasz kódja // és hibás esetén írja be a logba, és folytassa a feldolgozást 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 } // Feldolgozás resp, ha szükséges } }

Dolgozott már DDD-vel és CQRS-sel? Meséljen róla.

Az aggregátum mindig egy tranzakció szintjén működik. Mi még fontos tudni az aggregátumokról a DDD-ben?

Mikroszervizes architektúrában minden szolgáltatásnak saját adatbázisa van. Hogyan működik az Outbox minta ebben a kontextusban, ha a Kafka még nem kapta meg az üzenetet?

Meséljen a Transactional Outbox mintázatról — hogyan működik és mire használják?