Kafka құласа, оқиғаларды жеткізу не болады?
Golang
// Сұраулар бәсекеге қабілетті болатындай және жауап коды шығатындай етіп кодты түзетіңіз // және қате болған жағдайда - оның логын шығарып, өңдеуді жалғастырыңыз package main import "net/http" var addrs = []string{"[link] "[link] "[link] "[link] "[link] "[link] "[link] func main() { 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.err return } log.info }(url) } } wg.Wait() }
JSON тегтері бар модель (мысалы, RegisterUserRequest) домендік модель бе? DTO мен domain entity-ді қалай дұрыс бөлу керек?
Hexagonal Architecture-мен таныссыз ба? Оның құрылымын сипаттаңыз.
Гексагональды архитектура үш элементтен тұрады: адаптер, порт және негізгі қолданба. Қабылданған сұраныс қалай өңделеді, ол қалай домен моделіне өтеді?
Қайтарым жағын — хабарландыру қызметі жағында Inbox үлгісін қалай жүзеге асыруға болады? Оқиғаларды өңдеудің идемпотенттілігін қалай қамтамасыз етуге болады?
// Сұрауларды бәсекеге қабілетті ету және жауап кодын көрсету үшін кодты түзетіңіз // және қате болған жағдайда - оны журналға жазып, өңдеуді жалғастырыңыз package main import "net/http" var addrs = []string{"[link]", "[link]"} func main() { for _, url := range addrs { resp, err := http.Get(url) if err != nil { log.err return } } }
DDD және CQRS-мен жұмыс істедіңіз бе? О туралы айтыңыз.
Агрегат әрқашан бір транзакция деңгейінде жұмыс істейді. DDD-да агрегаттар туралы тағы не білу маңызды?
Микросервис архитектурасында әр қызметтің өз дерекқоры бар. Kafka хабарламаны әлі алмаған жағдайда, Outbox паттерні осы контексте қалай жұмыс істейді?
Транзакциялық Outbox паттерні туралы айтып беріңіз — ол қалай жұмыс істейді және не үшін пайдаланылады?