París markat Berlín markar: Kunjamas Kotlin markanx interruptores ukanakax lurasispa

1. Uñt’ayañataki Jichhürunakanx apnaqatawa, ukhamat jan sinti mayiwinakax mä jan ukax yaqha servicio jan jaysañataki. Amuytʼañataki, kunapachatï mä serviciojj jistʼantatäki ukhajja, kunatsa mä interruptorajj kunjamtï sutipajj siski ukhamarjamaw circuito pʼakjañapa. Mä arunxa, mä situación ukanx 1 millón mayiwinakaw mä pachan lurasiski, mä caballot t’ijtäwin askinak jikxatañataki, uka mayiwinakax yaqha servicio ukar kutt’ayañ munapxta, ukax ukax apnaqañapawa. Circuit-breakers Aka yaqha servicio ukaxa mä réplica ukhamawa, jan ukaxa purapata apnaqatarakiwa yaqha lurawinakaru lurañataki original servicio ukan jan walt’awipata. Tukuyañ amtax sapa kutiw jan wakiskir jawsatanakar t’unjañawa ukat yaqha chiqan flujo ukax irpañawa. maranx , Circuit Breaker ukan diseño ukan patrón ukarux software desarrollo ukan diseño ukan nayrar sartayawayiwa. Ukax Release It!: Diseño y Despliegue de Software Listo para la Producción (Programadores Pragmáticos) 1ra Edición ukan qillqatapan lurasiwayi. 2017 Michael Nygard Uka patrón de diseño chiqpach circuitos electrónicos ukat eléctricos ukanakat amuyt’ayatawa. Ukampirus mä jach’a amuyunakatxa, chiqpachansa interruptor de circuito uka amuyunakax maran jupaw uñstayatayna . Kunjamtï uka tiempon luraskäna ukhamarakiw mä corriente phuqhantat uñjasiñapa. Wali, wali sapuru arunakampixa, akax arquitectura de software ukaruw aka tuqinx apnaqasktanxa. Jilïr amtax sistema ukax wali ch’amampiw ch’amanchasi. Kunjams resiliente ukhamarak kunjams ukax chiqpachapuniw ingenieronakan nayraqatapanx aka patrón phuqhañ yanapt’añataki. Uka amuyux akawa , yaqhip condicionanakanx mä mayiwix jan kuna jan walt'awimpiw yaqha juk'amp utjki uka flujo ukar pachpa qhipäxanx mayjt'ayañ munaraksna . circuit breaker 1879 Thomas Edison fault-tolerant endpoint ukat ukar mä mayiw phuqhañ munapxta sañäni. Awisax B ukax pantjasiwa ukatx ukax sapa kutiw utji. ukax aleatoriamente pantjasispa ukhaxa, ukaruw puriñ munapxta, ukhamat servicios ukanakax taqpach utjañapataki. Ukampirus ukar kutt’ayañ mayiwinak lurañatakix, ukax jan mayamp ukham pantjasiñapatakiw uñjañ munapxta. Ukatx sistema ukarux configurar luraraksnawa, B ukar aleatorio mayiwinak lurañataki ukat ukar taqpach kutt’añatakikix mä kutix tasa de fallo ukax mä nivel ukar sarawayxi ukhakiw. A B C B C B B B Inas C mayiwix pantjasiwi tuqit lurañ munstan ukampis latencia tuqit lurañ munaraksnawa. ukax wali llamp’u chuymanïchi ukhaxa, inas taqi mayiwinak ukar wasitat apayañ munaraksna. Walja yaqha configuración ukanakaw utji, kunjamatix uksar puriñ yant’añax mä qhanañchat jakhüwi yant’awinak tukuyatat, mayiwi kasta, concurrentes hilos, ukat walja yaqha amtawinakax Akax uñt’atarakiwa , ukatx jilpachax mä juk’a pachatakiw sarnaqawi. B C C short-circuiting Kunas chiqpachanx mä interruptor ukax uk juk’amp amuyañatakix, mä interruptor de circuito ukax mä entidad ukhamaw jiwasan aplicación ukanx irnaqaski, uk amuyañasawa. Mä circuito-interruptor ukan kimsa jach’a estados ukanakaw utji. Ukax jist’antatäspawa, jist’aratäspawa, jan ukax chikat jist’aratäspawa. Mä estado jist’antat ukax jiwasan aplicación flujos normales ukan sarnaqañ sañ muni. Jiwasax jan kuna usuniw A servicio ukar mayiwinak luraraksna, taqi mayiwinakax servicio B ukar sarañ yatisax Estado abierto ukax sañ muniw taqi mayiwinakax servicio B ukarux jan phuqhasiñapataki. Mä pantjasiw uñacht’ayañatakix kamachinak uñt’ayawayktan ukax utjawayiwa ukatx janiw servicio B ukaruw puriñjamakiti, aka tuqinx mä excepción ukax sapa kutiw kutt’ayataraki. Estado ukax kunapachatix jiwasan interruptor ukarux servicio B ukan yant’äwinak lurañapatak yatiyatäki ukhax wasitat irnaqaskiti janicha uk yatiñataki. half-open Sapa mayt’awix suma phuqhaski ukax normal ukhamaw uñjasi, ukampis C ukarux mayiwinak luraskakiniwa, B ukax kunjamtix suyatäki ukhamarjam sarnaqaspa ukhax jiwasan utt’ayat kamachinak chiqanchañ kamachirjama, jiwasan interruptor de circuito ukax jist’antat estado ukar kutt’ani, ukatx servicio A ukax lurañ qalltani solicitudes exclusivamente a servicio B. Jilapacha apnaqawinakanxa, mä interruptor de circuito ukaxa decorador diseño patrón ukarjamawa. Ukampirus amparampi phuqhasispawa, ukatx kimsa programatico thakhinak uñakipt’añäni, interruptores de circuito ukar phuqhañataki, ukatx tukuyañatakix AOP ukan phuqhasiñapatakiw uñakipt’añäni. Uka chimpux ukan uñt'ayatawa. GitHub 2. Auto Checks ukanaka Aka yatichäwin qhipa tʼaqapanxa, auto tʼijuñ anattʼañ tuqitwa uñakiptʼañäni. Ukampirus janïr uka chiqar puriñkamax mä qawqha askinak mä aplicación lurañatakix mä ukamp irnaqañapatak irpañ munapxsma . circuit breaker 2.1.1.1. Kystrix (parís-at-berlín-kystrix-runable-app) ukax mä jach’a uñacht’äwiwa. , mä jisk'a ukhama , mä muspharkañ biblioteca ukaw jupan uñstayata ukat lurata . Biblioteca ukax walja lurañanak churaraki, Spring ukat Spring WebFlux ukanakamp mayachasiñataki. Mä uñakipañax wali askiwa ukat mä juk’a anatt’añax wali askiwa: Kystrixs DSL Johan Haleby se.haleby.kystrix kystrix-core se.haleby.kystrix kystrix-spring Nayax mä uñacht’äw lurawayta, ukatx ukax módulo ukan jikxatasi. Nayraqatxa, aka chimpunak uñakipt’añäni: from-paris-to-berlin-kystrix-runnable-app GitHub @GetMapping("/{id}") private fun getCars(@PathVariable id: Int): Mono { return if (id == 1) Mono.just(Car("Jaguar")) else { hystrixObservableCommand { groupKey("Test2") commandKey("Test-Command2") monoCommand { webClient.get().uri("/cars/carros/1").retrieve().bodyToMono () .delayElement(Duration.ofSeconds(1)) } commandProperties { withRequestLogEnabled(true) withExecutionTimeoutInMilliseconds(5000) withExecutionTimeoutEnabled(true) withFallbackEnabled(true) withCircuitBreakerEnabled(false) withCircuitBreakerForceClosed(true) } fallback { Observable.just(Car("Tank1")) } }.toMono() } } Aka chimpuxa uñacht’awina 2 kamachi uñacht’ayi. Kamachi 1. Kunatix akanx luraski ukax ukampiw munat kamachir qhanañchasktanxa. Aka chiqanx, kuna thakhis jawsañax wakisi uk qhanañcht’apxtanwa. ukanxa, kamachinakaxa qhananchatawa kunatixa mayjt’ayaña estado jist’arañataki. Jiwasax qhanpach jawsañasarux qhiphart’ayapxtanwa, ukhamat 1 segundo chiqaparu puriñapataki. monoCommand commandProperties circuit-breaker Uka pachparaki, milisegundos ukja pacha tukuyaña uñt’ayaraktanxa. Ukax sañ muniwa, janipuniw mä tiempo de espera ukar puriñäniti. Aka uñacht’awina, mä ukampiw jawsañanak lursna. Niyakixay akax mä yant’awikïchixa, , mä auton ukhamaw sasaw amuyapxtanxa, mä Jaguar ukax janiw ukax wakiskiti . Ukax sañ munarakiw janipuniw Tank1 ukax jikxataskaniti kunjamtix fallback método ukan qhanañchaski ukhama. Janitï jichhakamax amuyasksta ukhaxa, fallback método ukar sum uñakiptʼañamawa. Aka lurawix mä ukampiw apnaqasi. ukax ukan diseño ukarjam phuqhachatäkchisa, ukax janiw chiqpachans Observable ukhamäkiti. 5000 Id Id=1 Id circuit-breaker Observable WebFlux Observable Flux Ukampirus, hystrix ukax panpachaniw yanapt’i. Mä aplicación ukar apnaqañamawa, ukatx navegador ukar jist’arañamawa , ukax chiqañchañataki. Wali askiw amuyañaxa, jumatix wali nayratpach jawsañ qalltasma Spring Boot qalltawinxa, inas qhipharux mä Tank1 yatiyaw katuqaraksta. Ukax kunatix qalltañ qhipharux 5 segundos ukjat jilaw wali jasakiw kunjams aka lurawix apnaqasi ukarjamaw lurasispa. Payïr uñacht’äwinx, jiwasan uñacht’äwisarux Tanque 2 ukar cortocircuito ukamp uñacht’ayañani: http://localhost:8080/cars/2 @GetMapping("/timeout/{id}") private fun getCarsTimeout(@PathVariable id: Int): Mono { return if (id == 1) Mono.just(Car("Jaguar")) else { hystrixObservableCommand { groupKey("Test3") commandKey("Test-Command3") monoCommand { webClient.get().uri("/cars/carros/1").retrieve().bodyToMono () .delayElement(Duration.ofSeconds(1)) } commandProperties { withRequestLogEnabled(true) withExecutionIsolationThreadInterruptOnTimeout(true) withExecutionTimeoutInMilliseconds(500) withExecutionTimeoutEnabled(true) withFallbackEnabled(true) withCircuitBreakerEnabled(false) withCircuitBreakerForceClosed(true) } fallback { Observable.just(Car("Tank2")) } }.toMono() } } Aka uñacht’awina, jiwasana ukaxa mä estado abierto final retorno Tanque 2 ukarux mä jaysawimpiw sarani. Ukax kunatix jiwasax mä 1s qhipharäwiw akanx luraraktanxa, ukampis jiwasan condición de ruptura de circuito ukax 500ms markan qhipatw ch’amanchasi sasaw qhanañchapxta. Jumatix yatiskta kunjams irnaqaski, ukax jikxatasmawa ukax janiw kunas mayjäkiti nayrar sartañataki. Kuntix hystrix ukax jan aka pachanx nayatak churawaykitu, mä jan ch’am tukus, jan ch’am tukus kuntix nayax anatäw lurañatakix wakiski uk churañataki. jupax mä cliente ukarjam irnaqkaspas ukhamawa. Ukax sañ muniw jiwasan código ukar yatiyañasawa janïr servicios ukanakar mayiwinak lurañkamax jiwasan jach’a servicio qhipäxanxa. circuit-breaker hystrix kystrix Kystrix 2.2.2.2.1. Resiliencia ukaxa4J ukax waljaniruw uñt’ayasi, mä interruptor ukan wali phuqhat phuqhawipa. Nayrïr yant’äwinakajax interruptores ukan yaqhip wakiskir tuqinakat yatxatañatakiw sarawayta. Mä arunxa, mä interruptor uñjañ munta, ukax tiempo de espera ukat sapa kuti sum mayitanakarjamaw irnaqaspa. ukaxa kunaymana kasta módulos de wakicht’añatakixa jay satawa. Ukanakax kunayman jamuqanakaruw jaljasi: , , , , ukat . Taqi ukanakax patrón de diseño ukan sutinakaparakiwa. uka módulo ukax aka patrón ukan taqpach phuqhawip uñacht’ayi. Resilience4J Resilience4J short-circuiting 6 CircuitBreaker Bulkhead Ratelimiter Retry Timelimiter CircuitBreaker Jiwasax walja parámetros ukaniwa configurar, ukampis esencial, módulo ukax configurar kuntix uñt’ktan ukax mä fallo ukhama, qawqha mayiwinaks permitimos estado chika jist’arat ukhamarak mä ventana deslizante, ukax configurar tiempo jan ukax jakthapiwi, kawkhantixa mayiwinaka jakthapiwixa jist’antata estado ukana utji. Ukax pantjasiwinak sapa kuti jakhthapiñatakix wali askiwa. Chiqpachanx aka módulo ukax tasa de solicitud ukampiw yanapt’istani sañjamawa, ukampis ukax janiw chiqäkiti. CircuitBreaker CircuitBreaker Kunjamsa qhanañchäta ukarjamaw lurasini. Pantjasiwinakar saykatañatakik amuytʼañax jukʼamp askïkaspas ukhamawa. Mä pacha tukuyatat jutapxchi jan ukax mä excepción ukan jutapxchi, akax kawkhantix uñjatäki ukat kunjams mayiwinakax jan kuna jan walt’awimp yaqha chiqar mayjt’ayatäspa Módulo ukax mä pachan mayiwinakar uñjañatakiwa. Janiw mä tarifa limitador ukhamäkiti. Bulkhead Ukhamakipansti, ukax patrón de diseño de ukaruw phuqhi, ukax mä sapa tukuyan jan sinti lurañanak utjañapatakiw apnaqasi. Ukhamächi ukhaxa, mayiwinakas mä thakhinjam lurañ yanapt’istu, ukhamat taqi utjki uka tukuyañ chiqanakan jaljatäñapataki. sutix kunayman sellado compartimientos ukanakat juti, mä jach’a barcox jan chhaqhañapataki, mä accidente utjaspa ukhaxa, ukat kunjamatix barconakax utjki ukhamarakiw qawqha hilos ukanakax piscina de hilos ukan utjani ukat arrendamiento ukan pachap qhanañchañasa . Bulkhead Bulkhead Bulkhead uka módulo ukax tasa de solicitud ukar uñjañatakiwa. Aka ukat módulo ukan mayjt’awipax wali wakiskiriwa kunatix jiwasax tasas ukar tolerante ukhamäñ munapxta mä puntokama. Ukax sañ muniw janiw ukatakix pantjasiwinak utjayañax wakiskiti. Jiwasax ukhamakiw sañ munapxta, diseño ukanx janiw mä tasa mä valor ukar juk’amp tolerañjamäkiti. Ukhamaraki, mä mayiwiruw mayjt’ayaraksna jan ukax mayiwi phuqhañatak permiso churañkamax suyt’ayaraksnawa. uka módulo ukax inas juk’amp jasakiw amuyañax kunatix janiw yaqha módulos ukanakamp chikachasiñax utjkiti. RateLimiter Bulkhead Retry Jiwasax chiqpachanx qhanancht’tanwa qawqha kutis yant’awinakax utji mä tukuyar puriñkama, jiwasan umbral definido ukar puriñkama. Módulo ukax mä simplificación ukhamaw uñjasispa uka módulo ukax panpachaniw configurar tiempos de espera ukar uñt’ayasipxi. Ukampirus janiw yaqha parámetros ukanakat dependerkiti kunjamakitix ventanas deslizantes ukanakax ukhamarakiw jan mä calculación umbral de fallo in-build ukankiti. Timelimiter CircuitBreaker Timelimiter Ukhama, jiwasatix mä servicio ukar jawskasax tiempos de esperas ukar q’umachañ munstanxa, ukat yaqha pantjasiwinak jan factor ukarjam uñjksna ukhax ukampix juk’amp askïspawa. Timelimiter 2.2.1.1.1.1. Resilience4J ukax Kotlin ukat No Spring uka marco ukampiw (parís-at-berlín-resilience4j-runnable-app) Aka módulo ukanx kotlin biblioteca ukak apnaqañ amtawayta: resilience4j io.github.resilience4j resilience4j-kotlin io.github.resilience4j resilience4j-retry io.github.resilience4j resilience4j-circuitbreaker io.github.resilience4j resilience4j-ratelimiter io.github.resilience4j resilience4j-timelimiter Aka phuqhawix repo ukan GitHub ukan uñt’ayatawa. Nayraqatax ukan uñacht’äwip uñakipt’añäni: TimeLimiter var timeLimiterConfig: TimeLimiterConfig = TimeLimiterConfig.custom() .timeoutDuration(Duration.ofMillis(100)) .build() var timeLimiter: TimeLimiter = TimeLimiter.of("backendName", timeLimiterConfig) private suspend fun getPublicCar(): Car { return timeLimiter.decorateSuspendFunction { getPrivateCar() }.let { suspendFunction -> try { suspendFunction() } catch (exception: Exception) { Car("Opel Corsa") } } } private suspend fun getPrivateCar(): Car { delay(10000) return Car("Lancya") } Uka tuqinxa, jiwasan ukax lurawimpiw k’achacht’atäski lurawimpi. Kuntix akax lurani ukax mä tiempo de espera ukaw utjañapa, función ukar jawsktan ukax sinti jaya pachaw mä Opel Corsa ukax Lancya ukat sipanx jikxatasi. Uk yant’añatakix, ukak apnaqañasawa ukat uk jist’araraksnawa. function getPrivateCar TimeLimiter decorateSuspendFunction http://localhost:8080/cars/timelimiter/normal/1 Uka phuqhawi uñakipt’asax uñjtanwa, janipuniw mä ukax jikxataskaspati. Ukat ukax kunatix amuyuparjamaw suyt’apxta janïr kutt’ayañkama. Jiwasan ukax mä juk’a pachakiw utji ukhamat akax janipuniw irnaqkaniti. Mä ukax mä juk’a amuyañjamawa. Maysa tuqitxa, , ukax yaqha sarnaqäwiwa. Akax mä uñacht’äwiwa kunjams ukax lurasispa: Lancya 10s TimeLimiter TimeLimiter CircuitBreaker val circuitBreakerConfig = CircuitBreakerConfig.custom() .failureRateThreshold(20f) .slowCallRateThreshold(50f) .slowCallDurationThreshold(Duration.ofMillis(1000)) .waitDurationInOpenState(Duration.ofMillis(1000)) .maxWaitDurationInHalfOpenState(Duration.ofMillis(1000)) .permittedNumberOfCallsInHalfOpenState(500) .minimumNumberOfCalls(2) .slidingWindowSize(2) .slidingWindowType(COUNT_BASED) .build() val circuitBreaker = CircuitBreakerRegistry.of(circuitBreakerConfig).circuitBreaker("TEST") private suspend fun getPublicCar(id: Long): Car { return circuitBreaker.decorateSuspendFunction { getPrivateCar(id) }.let { suspendFunction -> try { suspendFunction() } catch (exception: Exception) { Car("Opel Corsa") } } } private fun getPrivateCar(id: Long): Car { if (id == 2L) { throw RuntimeException() } return Car("Lancya") } Uka tuqinxa, jiwasaxa sañ munapxtanwa jiwasana interruptor ukaxa circuito jist’antañapawa mä kuti tasa de falla ukaxa ukjata jisk’akiwa propiedad ukampi. K’achat k’achat jawsatanakax mä umbral ukanirakiwa, ukampis aka tuqinx 50% ukjat juk’ampikiw utjani. Mä k’achat jawsañax 1s ukjat juk’amp pachaw utjañapa sasaw sapxtanxa, ukhamat mä jawsatäñapataki. Ukhamaraki, chika jist’arat estado ukan pachapax 1s ukhamäñapawa sasaw qhanañcharaktanxa. Ukax sañ muniw, chiqpachanx estado abierto, estado medio abierto, jan ukax estado cerrado ukanïñäniwa. 20% Ukhamaraki sapxaraktwa, mä máximo 500 chika jist’arat estado mayiwinakarux jaysapxtanwa. Pantjasiwi jakthapiwinakatakixa, interruptor ukaxa kawkiri markansa ukham lurani uk yatiñapawa. Ukajj kunapachas circuito jistʼantañasa uk yatiñatakejj wali wakiskiriwa. Jiwasax siwa 2 mayiwix juk’akiw aka jakhüwitakix wakisini, ukax propiedad ukampi. ¿Amtastati chikat jist’arat ukax kunapachatix circuito jist’antañatak ch’amachasiskakiñäni, mayiwinakax mä seguro umbral de fallo ukar purispa ukhaxa? minimumNumberOfCalls Aka configuración ukanxa, sañ muniwa mayiwi lurañasa wakisi, ventana deslizante ukanxa, frecuencia de error ukanaka jakhthapiñataki ukhamaraki estado cerrado ukar kutt’añatakisa jani ukaxa jani utjañapataki. Akax taqi variables ukanakan chiqaparu uñakipañawa. Taqi kunat sipansa, kuntix ukax sañ munki ukax jiwasan aplicación ukax walja jawsatanakaw servicio alternativo ukar luraspa, utjaspa ukhax janiw sinti jasakix estados abierto ukanakat jist’antat ukar mayjt’kaniti kunatix tasa de éxito ukax lurañatakix 80% chikat pachanx utjañapawa -jist’arat estados ukat jist’arat estado ukatakix pacha tukuyañax utjañapawa. 2 Ukham pachanak uñt’ayañatakix walja thakhiw utji. Jiwasan uñacht’awisanx ukax 1s ukhamawa sasaw sapxtanxa. Ukax sañ muniw jiwasan ukax estado jist’arat uñjani, ukax jiwasan chequeo ukax janiw condición de estado jist’antat ukar phuqhkiti jan ukax aka tiempo de espera ukax janïraw utjkiti. Aka ukan qhanañchata sarnaqawix inas ch’amakïchispa arktañataki ukhamarak yatiyañataki, q’uma kunatix específicos tiempos de inactividad, tasas ukat yaqha lurawinakat mayiwinakax mäkiw jan chiqapar uñtasit lurañax wakiskiti, ukampis walja mayiwinak aka tukuyar lurañäni ukhax uk uñjañäni uka sarnaqawix akham uñacht’ayatawa, jiwasan experienciasampi chika. maxDurationInHalfOpenState CircuitBreaker CircuitBreaker Ukhama, yant’añäni ukat walja mayiwinak tukuyañ chiqanakar phuqhañäni: ukat . 1 ukampi tukuyañax mä suma auto apsuñ tukuyañawa, ukatx 2 ukampi tukuyañax mä especificado auto katuqañan jan walt’awipawa. Código uñakipt’asax uñjtanwa, kunatix 2 ukat sipanx mä ukax mä jaysäwiw sañ muni. A , ukax sañ muniw jank’akiw mä excepción de tiempo de ejecución ukar jaquntañasa, ukax sañ muniw mä ukar jaysañatak tukuyañasa. http://localhost:8080/cars/circuit/1 http://localhost:8080/cars/circuit/2 Lancya 2 Opel Corsa Jiwasatix tukuyäwir mayiwinakak lurañänixa, mä jaysäwimp uñjaskakiñäniwa. Sistema ukax jan walt’ayañ qalltxi ukhaxa, ukax 2,\; uñjätawa markar kutt’añax janiw mä juk’a pachatxa constante ukhamäkaniti. ukax estado Abierto ukankatapat yatiyani, ukatx janiw juk’amp mayiwinakax jaysatäkiti. 1 Lancya Lancya System 2021-10-20 09:56:50.492 ERROR 34064 --- [ctor-http-nio-2] .fcbrrcCarControllerCircuitBreaker : io.github.resilience4j.circuitbreaker.CallNotPermittedException: CircuitBreaker 'TEST' is OPEN and does not permit further calls Ukatx jiwasan interruptor de circuito ukax chika jist’arat estado ukar sarani mä suma mayiwi tukuyatatxa, ukat ukax sañ muniw mä qawqha mayiwinak 1 ukar kutt’ayañax wakisispa janïr normalizatäkipana. Mä pä kutiw markat markar mayjt’ayañäni, janïr ukar wasitat puriñkama. Aka jakhüwix 2. Akax pantjasiw jakhüwitakix jisk’akiwa. Jiwasatix mä pantjasiwiruki lurasktan ukat jan pantjasir tukuyañ chiqar jawsaskakiñäni ukhaxa, kunatix luraski ukanak juk’amp qhan uñacht’ayaraksnawa: Lancya Opel Corsa Lancya 2021-10-20 11:53:29.058 ERROR 34090 --- [ctor-http-nio-4] .fcbrrcCarControllerCircuitBreaker : java.lang.RuntimeException 2021-10-20 11:53:41.102 ERROR 34090 --- [ctor-http-nio-4] .fcbrrcCarControllerCircuitBreaker : io.github.resilience4j.circuitbreaker.CallNotPermittedException: CircuitBreaker 'TEST' is OPEN and does not permit further calls Aka jist’arat estado yatiyawix chiqäkchisa, 2 mayiwinak jan pantjasir tukuyañ chiqar lurawaykta uka qhipatw uñstawayi. Ukatpï estadox chikat jist’aratawa sasaw sapxi. 2.2.2.2.2.2.2.2.2.2.2.2.2.2.2.2.1. Resilience4J ukax Spring Boot ukampiw ukat No AOP ukampiw (parís-at-berlín-resilience4j-primavera-app) Nayrir t’aqapanx kunjams mä jach’a programatjam phuqhañax uk uñjapxta, jan kuna tecnología Primavera apnaqasa. Jiwasax Spring uka apnaqapxta ukampis mä tipo de servicio ukak churañataki. Ukhamarus, janiw kuns mayjt’ayawaykti servicios ukanakat pachpa. Aka aplicación ukanx aka bibliotecas ukanakat yatxatañäni: WebFlux MVC io.github.resilience4j resilience4j-spring-boot2 io.github.resilience4j resilience4j-all io.github.resilience4j resilience4j-reactor Kunjams codigox lurasi uk uñakipt’asax mä jach’a mayjt’äwiw uñjasi: @RestController @RequestMapping("/cars") class CarController( private val carService: CarService, timeLimiterRegistry: TimeLimiterRegistry, circuitBreakerRegistry: CircuitBreakerRegistry, bulkheadRegistry: BulkheadRegistry ) { private var timeLimiter: TimeLimiter = timeLimiterRegistry.timeLimiter(CARS) private var circuitBreaker = circuitBreakerRegistry.circuitBreaker(CARS) private var bulkhead = bulkheadRegistry.bulkhead(CARS) @GetMapping("/{id}") private fun getCars(@PathVariable id: Int): Mono { return carService.getCar() .transform(TimeLimiterOperator.of(timeLimiter)) .transform(CircuitBreakerOperator.of(circuitBreaker)) .transform(BulkheadOperator.of(bulkhead)) .onErrorResume(TimeoutException::class.java, ::fallback) } @GetMapping("/test/{id}") private fun getCarsTest(@PathVariable id: Int): Mono { return carService.getCar() .transform(TimeLimiterOperator.of(timeLimiter)) .transform(CircuitBreakerOperator.of(circuitBreaker)) .transform(BulkheadOperator.of(bulkhead)) .onErrorResume(TimeoutException::class.java, ::fallback) } @GetMapping("/carros/{id}") private fun getCarros(@PathVariable id: Long): Mono { return Mono.just(Car("Laborghini")) } private fun fallback(ex: Throwable): Mono { return Mono.just(Car("Rolls Royce")) } } Aka uñacht’awina ukhamaraki aka uñacht’awina, jilpachaxa propiedades de tiempo de espera ukanakat uñakipt’añäni. ukan jan walt’awinakapax jupanakpachaw juk’amp jan wakiskirïkiti kunatix akax mä uñt’ayawiwa. Kunatix akan amuyañax wali wakiskirïki ukax kunjams jasakiw ukax phuqhassna decoradores ukanakamp churat Spring by . Wali ukhamäkchisa, qallta yatiyirisarux jasakiw k’achacht’araksna, khititix ukan jikxatktan ukax, kuna kasta ukanakatix munktan ukanakampi. CircuitBreaker Resilience4J programmatical carService.getCar() short-circuit Aka uñacht’awina, mä , mä ukat mä qillqt’apxta. Tukuyañatakix, mä TimeoutException ukax utjki ukhax fallback función ukax ch’amanchatäñapatakiw qhanañcht’apxtanxa. Kuntix wali uñjañax wakiski ukax kunjams akax taqpach wakicht’ata. Jiwasax Resilience4J ukax Spring ukanx wakicht’tanwa kunjamatix yaqha módulo configurable ukhama. Jiwasax apnaqapxta : TimeLiter BulkHead CircuitBreaker application.yml resilience4j.circuitbreaker: configs: default: registerHealthIndicator: true slidingWindowSize: 10 minimumNumberOfCalls: 5 permittedNumberOfCallsInHalfOpenState: 3 automaticTransitionFromOpenToHalfOpenEnabled: true waitDurationInOpenState: 5s failureRateThreshold: 50 eventConsumerBufferSize: 10 recordExceptions: - org.springframework.web.client.HttpServerErrorException - java.util.concurrent.TimeoutException - java.io.IOException ignoreExceptions: # - io.github.robwin.exception.BusinessException shared: slidingWindowSize: 100 permittedNumberOfCallsInHalfOpenState: 30 waitDurationInOpenState: 1s failureRateThreshold: 50 eventConsumerBufferSize: 10 ignoreExceptions: # - io.github.robwin.exception.BusinessException instances: cars: baseConfig: default roads: registerHealthIndicator: true slidingWindowSize: 10 minimumNumberOfCalls: 10 permittedNumberOfCallsInHalfOpenState: 3 waitDurationInOpenState: 5s failureRateThreshold: 50 eventConsumerBufferSize: 10 # recordFailurePredicate: io.github.robwin.exception.RecordFailurePredicate resilience4j.retry: configs: default: maxAttempts: 3 waitDuration: 100 retryExceptions: - org.springframework.web.client.HttpServerErrorException - java.util.concurrent.TimeoutException - java.io.IOException ignoreExceptions: # - io.github.robwin.exception.BusinessException instances: cars: baseConfig: default roads: baseConfig: default resilience4j.bulkhead: configs: default: maxConcurrentCalls: 100 instances: cars: maxConcurrentCalls: 10 roads: maxWaitDuration: 10ms maxConcurrentCalls: 20 resilience4j.thread-pool-bulkhead: configs: default: maxThreadPoolSize: 4 coreThreadPoolSize: 2 queueCapacity: 2 instances: cars: baseConfig: default roads: maxThreadPoolSize: 1 coreThreadPoolSize: 1 queueCapacity: 1 resilience4j.ratelimiter: configs: default: registerHealthIndicator: false limitForPeriod: 10 limitRefreshPeriod: 1s timeoutDuration: 0 eventConsumerBufferSize: 100 instances: cars: baseConfig: default roads: limitForPeriod: 6 limitRefreshPeriod: 500ms timeoutDuration: 3s resilience4j.timelimiter: configs: default: cancelRunningFuture: false timeoutDuration: 2s instances: cars: baseConfig: default roads: baseConfig: default Aka qillqataxa mä uñacht’awi qillqatawa jupanakana repo ukanakata apsuta ukatxa ukarjamawa nayan uñacht’awijaru mayjt’ayata. Kunjamtix nayraqat uñjawayktanxa, instancias de los diferentes tipos de , mä sutimpiw uñt’ayasi. Sutixa wali wakiskiriwa kunaymana registros ukatxa kunaymana limitadores ukanakampi. Jiwasan uñacht’äwisatakix, ukat kunjamtï nayraqat arsuwayktanxa, pacha limitador ukarux munapxtanwa. Jiwasax uñjaraksnawa, ukax 2s ukhakiw utji. Kunjams servicio ukax phuqhasiwayi uk uñakipt’añäni ukhax mä tiempo de espera ukar obligañaw uñjasi: limiters/short-circuit @Component open class CarService { open fun getCar(): Mono { return Mono.just(Car("Fiat")).delayElement(Duration.ofSeconds(10)); } } Aplicación qalltañäni, ukatx navegador ukanx, aka chiqar sarañäni: . ukat sipansa, sat auto apsuñäni. Ukhamatwa pacha tukuyañ qhanañchapxta. Ukhamaraki, mä jasakiw lurasispa. http://localhost:8080/cars/test/2 Fiat Rolls Royce CircuitBreaker 3. Caso ukaxa Jichhakamax kimsa wakiskir thakhinak uñjtanwa ukat ukar uñtasit limitadores ukanakar phuqhañataki. Ukhamarus, mä uñakipäwiw utjani, nayan munat thakhix interruptores ukanakar phuqhañataki, mä aplicación luratax tuqi, ukax mä jach’a anatawiwa kawkhantix cuadrados ukar ch’iqt’añakiw París markat Berlín markar puriñatakiki. Anatañax kunjams phuqhañax uk amuyañatakiw lurasiwayi. Kawkhans ukax phuqhasispa ukxat janiw sinti arsuwaykiti. Mä caso ukhamakiwa, nayax jumanakamp yatiñanak uñt’ayañatakiw lurawayta. CircuitBreakers Uka yatiña-kunawsatix nayax jaytawaykta jumanakar qhipat amtañamataki. Chiqpachanx mä qawqha autonak lurañ munapxta ukat Berlín markar mä thakhi utt’ayañ munapxta. Kunayman chiqanakanx aka thakhinx markanakaruw puriñäni kawkhantix aleatoriamente, jan walt’awinak uñstayañäni. Jiwasan qawqha pachas suyt’añax wakisispa uk amtapxani, janïr nayrar sartañax jaysatäkipanxa. Mayni autonakajj janiw kuna jan waltʼäwinïpkiti, ukat cheqa thak ajlliñakiw wakisi. circuit breakers Jiwasax mä horario uñakipañaw jaysatätanxa kawkhantix qillqantatäki kunapachatix mä jan walt’awix mä markan mä minuto markan utjani. Minuto markax 0 indexado ukanx wali askiwa. Ukax sañ muniw 2 ukax sañ muniw 2, 12, 22, 32, 42, 52 minutos chimpunakax reloj ukanx walikïskaniwa aka jan walt’äw uñstayañataki. Jan walt’awinakax 2 kastawa: ukat . Mä pantjasiw pantjasiwix 20 segundos ukjaw qhipharxani. every ERROR TIMEOUT Mä tiempo de espera ukax 50 segundos ukjaw qhipharxani. Sapa markan mayjt’awipatakix taqiniw 10 segundos suyt’apxañapa. Ukampirus janïr suyt’kasax autox niyaw aka markar mantañ chiqankxi kunawsatix ukax fallback métodos ukan luratäki ukhaxa. Ukhamächi ukhaxa, jutïr markax aleatoriamente ajllitäxiwa. 4. Phuqaña Nayraqat uñjtanwa, kunjams registro ukar wakicht’añax apnaqasa. Ukham lurasax mä qawqha uñacht’äwinakat uñakipt’añäni, kunjams jiwasan lurawinakas k’achacht’añasa: resilience4j application.yml @TimeLimiter(name = CarService.CARS, fallbackMethod = "reportTimeout") @CircuitBreaker(name = CarService.CARS, fallbackMethod = "reportError") @Bulkhead(name = CarService.CARS) open fun moveToCity(id: Long): Mono { val myCar = roadRace.getMyCar() if (!myCar.isWaiting()) { val destination = myCar.location.forward.find { it.id == id } val blockage = destination?.blockageTimeTable?.find { it.minute.toString().last() == LocalDateTime.now().minute.toString().last() } blockage?.let { roadBlockTime -> when (roadBlockTime.blockageType) { BlockageType.TIMEOUT -> return Mono.just(roadRace).delayElement(Duration.ofSeconds(10)) BlockageType.ERROR -> return Mono.create { it.error(BlockageException()) } BlockageType.UNKNOWN -> return listOf(Mono.create { it.error(BlockageException()) }, Mono.just(roadRace).delayElement(Duration.ofSeconds(10))).random() else -> print("Nothing to do here!") } } destination?.let { myCar.delay(10) myCar.location = it myCar.formerLocations.add(myCar.location) } } return Mono.just(roadRace) } private fun reportError(exception: Exception): Mono { logger.info("---- **** error reported") roadRace.getMyCar().delay(20L) roadRace.getMyCar().randomFw() roadRace.errorReports.add("Error reported! at ${LocalDateTime.now()}") return Mono.create { it.error(BlockageException()) } } private fun reportTimeout(exception: TimeoutException): Mono { logger.info("---- **** timeout reported!") roadRace.getMyCar().delay(50L) roadRace.getMyCar().randomFw() roadRace.errorReports.add("Timeout reported! at ${LocalDateTime.now()}") return Mono.just(roadRace) } Kunjamtï uñjktanxa, servicio original jawsatanakax anotaciones apnaqasaw chiqak k’achacht’ata! Ukax lurasispawa kunatix módulo ukax paquete ukan utjatapatakiwa: AOP org.springframework.boot spring-boot-starter-aop , jan ukax ukax yaqha paradigma de programación ukawa, ukax ukarjam luratawa. Ukax ukar mä complemento ukhamaw uñjasi, ukatx chiqpachapuniw qawqha anotaciones ukanakas irnaqapxi. Ukhamatwa yaqha lurawinakax nayrïr lurawimp muyuntat, nayraqat jan ukax qhipat chiqapar khuchhuqañanakan ch’amanchañapataki. Kunjamtix uñacht’äwin uñjktanxa, jiwasax pacha tukuyañ jan ukax pantjasiwinak lurasktanxa. , ukax fallback uka thakhi manqhanx luratarakiwa. Ukajj janiw mä jan waltʼäwir uñtasitäkiti. Jan ukax jaysawix janiw ukhamäkiti. AOP Aspect Oriented Programming OOP OOP BlockageException Ukampirus, lurawix ukat ukatw, aka pantjasiwix janiw apnaqawin uñjatäkaniti. Jichhakamax akax anatt’awiwa. Nayax ukax kunjams anotaciones apnaqañax jakäwisax juk’amp jasak luraspa uk uñacht’ayañ amtampiw phuqhawayta, kunawsatix mä aplicación resiliente ukar phuqhasktan ukhaxa. Janiw CircuitBreakers ukakix phuqhatäkiti, jan ukasti yaqha tecnologías ukanakaw utjaraki, , , , , , ukat walja yaqhanaka. Taqi ukax luratawa kunjams CircuitBreakers ukax mä aplicación ukan anataspa uk uñjañataki. Aka aplicación ukamp anatt’añ munsta ukhax proyecton saphipar sarañamawa ukat t’ijt’añamawa: WebSockets, WebSockets Spring WebFlux Docker NGINX typescript make docker-clean-build-start Ukatxa aka kamachi phuqhaña: curl -X POST http://localhost:8080/api/fptb/blockage -H "Content-Type: application/json" --data '{"id":1,"name":"Paris","forward":[{"id":2,"name":"Soissons","forward":[{"id":5,"name":"Aken","forward":[{"id":8,"name":"Berlin","forward":[],"blockageTimeTable":[]}],"blockageTimeTable":[]},{"id":6,"name":"Heerlen","forward":[{"id":8,"name":"Berlin","forward":[],"blockageTimeTable":[]}],"blockageTimeTable":[]},{"id":7,"name":"Düren","forward":[{"id":8,"name":"Berlin","forward":[],"blockageTimeTable":[]}],"blockageTimeTable":[]}],"blockageTimeTable":[]},{"id":3,"name":"Compiègne","forward":[{"id":5,"name":"Aken","forward":[{"id":8,"name":"Berlin","forward":[],"blockageTimeTable":[]}],"blockageTimeTable":[]},{"id":6,"name":"Heerlen","forward":[{"id":8,"name":"Berlin","forward":[],"blockageTimeTable":[]}],"blockageTimeTable":[]},{"id":7,"name":"Düren","forward":[{"id":8,"name":"Berlin","forward":[],"blockageTimeTable":[]}],"blockageTimeTable":[]}],"blockageTimeTable":[]},{"id":4,"name":"Reims","forward":[{"id":5,"name":"Aken","forward":[{"id":8,"name":"Berlin","forward":[],"blockageTimeTable":[]}],"blockageTimeTable":[]},{"id":6,"name":"Heerlen","forward":[{"id":8,"name":"Berlin","forward":[],"blockageTimeTable":[]}],"blockageTimeTable":[]},{"id":7,"name":"Düren","forward":[{"id":8,"name":"Berlin","forward":[],"blockageTimeTable":[]}],"blockageTimeTable":[]}],"blockageTimeTable":[]}],"blockageTimeTable":[]}' Aka mayiwix payload ukax módulo ukampiw lurasi. Aka módulo ukar uñakipt’asax uñjañamawa, amuyañax wali ch’amawa ukat juma pachpaw anatañatakix mapa lurasma! Tukuyañatakix ukar sarañamawa ukatx aplicación ukax apnaqañapawa! Jichhaxa, anataña anatañatakixa chiqa cuadrado ukanakaru ch’iqt’añakiw wakisi. Ukampis janiw wila masinakarux ch’iqt’añamäkiti, atipt’añ munsta ukhaxa. Ukampirus circuito-interruptor ukan lurawipan uñjañ munsta ukhax, ukatx aplicación ukan registronakap apnaqañamawa: from-paris-to-berlin-city-generator http://localhost:9000 docker logs from_paris_to_berlin_web -f Ukat qhanpachax wila cuadradonakaruw ch’iqt’añama, ukhamat mä pantjasiw utjañapataki. 5. Kunjams Kystrix ukat Resilience4J ukax mayj mayja ukax wali askiwa kawkhantix aplicación ukax jisk’akiwa, ukatx DSL apnaqañax chiqpachans jisk’akiwa. Ukax mä jan walt’awikiwa, kunatix janiw mä jasak thakhi uñacht’aykiti k’achacht’añ thakhinak mä interruptor ukamp jan walt’ayasiñataki. ukax mä jach’a amtawiw empresan irnaqañatakix interruptores ukanakamp uñt’ayasi. Chiqans anotación ukarjam programación ukaw utji, taqi beneficios van AOP ukampiw apnaqasi, ukatx módulos ukanakax jaljatawa. Mä arunxa, estratégicamente apnaqasirakispawa puntos críticos ukanakatakix aplicación ukanxa. Ukhamaraki, mä phuqhat marco ukham apnaqasirakispawa, mä aplicación ukan walja askinak uñakipañataki. Kystrix Resilience4J 6. Tukuyañataki Kawkïr markas ajlliñäni, amtäwix sapa kutiw mä aplicación resiliente ukaniña. Aka qillqatanx mä qawqha uñacht’awinak uñacht’ayawayta, kunjams naya pachpax interruptores ukanakat yatxatañ yatiqawayta ukat jikxatatanakajax wali jach’a nivelanwa. Ukax sañ muniw aka qillqatax chiqpachans jaqinakatakiw qillqt’ata, jupanakax yatiñ munapxi kunas interruptores ukat kuns Limiters ukanakax lurapxaspa. Posibilidades ukax chiqpachanx janiw tukuskiti kunawsatix amuyt'ktan jiwasan aplicaciones ukanakax mecanismos de resiliencia ukanakamp ukham askinchañataki . Aka patrón ukax chiqpachans mä aplicación ukan suma askichañapatakiw jayti, ukhamat kunatix utjkistu ukanak juk’amp sum apnaqañataki. Jilpachax cloud ukanx wali wakiskiriwa, jiwasan qullqinak sum apnaqañax, ukatx qawqha yänaks chiqpachanx jaljañax wakisi. circuit breakers ukar wakicht’añax janiw mä jisk’a lurawikiti kunjamatix Limiters ukanakatakix ukhama, ukat chiqpachans taqi configuración ukan lurawinakap amuyañaw wakisi, ukhamat niveles óptimos de rendimiento ukat resiliencia ukar puriñatakiki. Ukatwa aka qallta qillqatanx interruptores ukanakat jan juk’amp yatxatañ munkti. CircuitBreakers walja kunaymana lurawinakaru apnaqatarakiwa. Jilpacha yatiyawinak ukhamarak streaming kasta aplicacionanakax ukax munasini. Aplicaciones ukatakix jach’a volúmenes de datos ukanak apnaqapxi ukax wali jach’a utjañapawa, jiwasax mä forma de interruptor de circuito ukarux phuqharaksnawa ukat phuqhañasarakiwa. Jach’a aljirinakax internet tuqinx sapa uruw jach’a yatiyawinak apnaqañax wakisi ukatx nayra pachanx wali apnaqatawa. Jichhax uka thakhinjam sarasktan ukhamaw uñstaski ukax akat sipans juk’ampiruw uñt’ayi. Circuit-breakers Hystrix Resilience4J 6. Uñakipt’atanaka https://youtu.be/kR2sm1zelI4 ukax mä juk’a pachanakanwa https://youtu.be/AiP2_icXpAk ukax mä juk’a pachanakanwa Kotlin ukax Detekt ukampiw juk’amp askinak luraña Resiliencia 4J Primavera-Bota-Demo ukat juk’ampinaka Netflix / Hystrix ukax mä jach’a uñacht’äwiwa Kystrix – Mä Kotlin DSL Hystrix ukataki johanhaleby / ukat juk’ampinaka resiliencia4j / ch’amanchaña4j CircuitBreaker - Resilience4j-interruptor ukampi qalltañataki Pay suma! ¡Aka qillqat lurañax nayatakix wali askïspawa sasaw suyt’askta! Mä revisión, comentarios, jan ukax kuna retroalimentación ukanakatix sociales ukanakat churañ munkta ukanak aka links ukan jaytañamawa. Aka qillqat juk’amp sum lurañatakix yanapt’añ munapxsta ukhax walpun yuspärta. Nayax taqi uka aplicación ukan código fuente ukar ¡Liytʼapjjatamat yuspärapjjsmawa! GitHub ukan uñt’ayawayta.