स्प्रिंग रिएक्टिव एप्लिकेशन उदाहरण (01/14/2020 से जारी)

नया साल मुबारक हो, वसंत समुदाय!

जैसा कि स्प्रिंग इकोसिस्टम में विकास और सुधार का अगला अद्भुत वर्ष शुरू होता है, मैं आपके साथ एक एप्लिकेशन के एक अद्यतन उदाहरण को साझा करना चाहता हूं जो कि प्रतिक्रियाशील प्रोग्रामिंग मॉडल के समर्थन के बारे में स्प्रिंग प्रोजेक्ट पोर्टफोलियो में की गई प्रगति के हिस्से को प्रदर्शित करता है।

बुकस्टॉर सर्विस ब्रोकर एप्लिकेशन को कई अलग-अलग स्प्रिंग प्रोजेक्ट्स के एकीकरण को प्रदर्शित करने के लिए अपडेट किया गया है, जिसमें स्प्रिंग क्लाउड ओपन सर्विस ब्रोकर, स्प्रिंग डेटा, स्प्रिंग सिक्योरिटी, स्प्रिंग हेटोस और निश्चित रूप से स्प्रिंग वेबफ्लक्स और स्प्रिंग बूट शामिल हैं। इन सभी परियोजनाओं में GA के संस्करण हैं, जिनमें प्रतिक्रियात्मक समर्थन और अपने स्वयं के अनुप्रयोगों और सेवाओं में उत्पादन के लिए तैयार हैं।

@Middle_java द्वारा अनुवादित

सादगी के लिए, आवेदन स्वयं एक दलाल और एक सेवा उदाहरण के रूप में कार्य करता है। हालांकि ब्रोकर खुद ओपन सर्विस ब्रोकर एपीआई का पालन करते हैं, लेकिन वे जो सेवाएं प्रदान करते हैं वे अधिक सारगर्भित रूप से परिभाषित होती हैं। सेवाएँ लगभग कुछ भी कर सकती हैं या हो सकती हैं। हमारे आवेदन के मामले में, सेवा के प्रत्येक उदाहरण के लिए क्रेडेंशियल्स का एक नया सेट बनाया गया है। ये क्रेडेंशियल सेवा के अनुरोध के लिए उपयोग किए जाते हैं। नई सेवा आवृत्ति का URL ब्रोकर के रूट के समान है। इस प्रकार, क्रेडेंशियल का उपयोग विभिन्न सेवा उदाहरणों के अनुरोधों को अलग करने के लिए किया जाता है। लक्ष्य पूरी तरह से सुसज्जित उदाहरण विकसित करना था जो स्प्रिंग प्रोजेक्ट पोर्टफोलियो के कई हिस्सों को प्रदर्शित करता है।

स्प्रिंग क्लाउड ओपन सर्विस ब्रोकर 3.1

स्प्रिंग क्लाउड ओपन सर्विस ब्रोकर स्प्रिंग बूट एप्लिकेशन के निर्माण के लिए एक प्लेटफ़ॉर्म है जो ओपन सर्विस ब्रोकर एपीआई को लागू करता है, और डेवलपर्स को क्लाउड फाउंड्री, कुबेरनेट्स और ओपनशिफ्ट जैसे क्लाउड प्लेटफार्मों पर चलने वाले एप्लिकेशन को सेवाएं प्रदान करने की अनुमति देता है। संस्करण 3.0 से शुरू होकर, स्प्रिंग क्लाउड ओपन सर्विस ब्रोकर नियंत्रक और सेवा इंटरफेस में प्रतिक्रियाशील प्रकारों का उपयोग करके स्प्रिंग वेबफ्लक्स और स्प्रिंग एमवीसी वेब फ्रेमवर्क का समर्थन करता है।

स्प्रिंग क्लाउड ओपन सर्विस ब्रोकर के साथ शुरुआत करने के लिए, अपने आवेदन में स्प्रिंग बूट स्टार्टर शामिल करें:

implementation('org.springframework.cloud:spring-cloud-starter-open-service-broker:3.1.0.RELEASE') 

फिर हम ServiceInstateService और ServiceInstateBindingService लागू ServiceInstateBindingService । निम्न कोड आवश्यक API दिखाता है। पूर्ण विवरण के लिए नमूना आवेदन देखें।

 @Service public class BookStoreServiceInstanceService implements ServiceInstanceService { @Override public Mono < CreateServiceInstanceResponse > createServiceInstance( CreateServiceInstanceRequest request) { ... } @Override public Mono < GetServiceInstanceResponse > getServiceInstance( GetServiceInstanceRequest request) { ... } @Override public Mono < DeleteServiceInstanceResponse > deleteServiceInstance( DeleteServiceInstanceRequest request) { ... } } 

स्प्रिंग डेटा मूर

स्प्रिंग डेटा प्रोजेक्ट परिवार में, प्रतिक्रियात्मक समर्थन मूल रूप से स्प्रिंग डेटा Kay में पेश किया गया था। स्प्रिंग डेटा R2DBC ने हाल ही में GA रिलीज़ की घोषणा की है, लेकिन स्प्रिंग बूट में अभी तक स्प्रिंग डेटा R2DBC के साथ GA रिलीज़ एकीकृत नहीं है। यह उदाहरण बैकअप डेटा स्टोर के रूप में MongoDB का उपयोग करता है।

प्रतिक्रियाशील MongoDB के साथ आरंभ करने के लिए, अपने आवेदन में स्प्रिंग बूट स्टार्टर शामिल करें:

 implementation('org.springframework.boot:spring-boot-starter-data-mongodb-reactive') 

प्रदर्शित करने के लिए, अंतर्निहित MongoDB सर्वर जोड़ें:

 implementation('de.flapdoodle.embed:de.flapdoodle.embed.mongo') 

फिर जेट रिपोजिटरी की स्थापना करें:

 @Configuration @EnableReactiveMongoRepositories(basePackageClasses = { ServiceBrokerRepositoryPackageMarker.class, WebRepositoryPackageMarker.class }) public class ApplicationRepositoryConfiguration { } 

अंत में, ReactiveCrudRepository को परिभाषित करें। निम्नलिखित इंटरफ़ेस एक नमूना अनुप्रयोग से एक उदाहरण है:

 public interface ServiceInstanceRepository extends ReactiveCrudRepository < ServiceInstance, String > { } 

वसंत सुरक्षा 5.2

प्रतिक्रियात्मक समर्थन मूल रूप से स्प्रिंग सुरक्षा 5 में शामिल किया गया था , और स्प्रिंग बूट के साथ एकीकरण और स्प्रिंग फ्रेमवर्क विकसित करना जारी है।

स्प्रिंग सुरक्षा का उपयोग करने के लिए, स्प्रिंग बूट स्टार्टर जोड़ें:

 implementation('org.springframework.boot:spring-boot-starter-security') 

अगला, @EnableWebCardingSecurity का उपयोग करके सुरक्षा कॉन्फ़िगरेशन को परिभाषित करें। यह कोड बताता है कि कैसे एक आवेदन ब्रोकर एंडपॉइंट्स /v2 और /bookstars सुरक्षा करता है, जो सेवा उदाहरणों के अनुरोधों का जवाब देते हैं:

 @Configuration @EnableWebFluxSecurity public class SecurityConfiguration { @Bean public SecurityWebFilterChain securityWebFilterChain( ServerHttpSecurity http) { return http .csrf().disable() .httpBasic() .and().authorizeExchange() .pathMatchers("/bookstores/**").authenticated() .pathMatchers("/v2/**").hasAuthority( SecurityAuthorities.ADMIN) .matchers(EndpointRequest.to("info", "health")).permitAll() .matchers(EndpointRequest.toAnyEndpoint()).hasAuthority( SecurityAuthorities.ADMIN) .and().build(); } @Bean public PasswordEncoder passwordEncoder() { return new BCryptPasswordEncoder(); } } 

अगला, हम ReactiveUserDetailsService लागू करते हैं:

 @Service public class RepositoryUserDetailsService implements ReactiveUserDetailsService { private final UserRepository userRepository; public RepositoryUserDetailsService(UserRepository userRepository) { this.userRepository = userRepository; } } 

अंत में, WebFlux नियंत्रकों में अनुमति मूल्यांकनकर्ताओं का समर्थन नहीं किया जाता है, लेकिन हम स्पेल एक्सप्रेशन में बीन को कॉल करके और ऑथेंटिकेशन ऑब्जेक्ट को पास करके समान कार्यक्षमता प्राप्त कर सकते हैं:

 @GetMapping("/{bookStoreId}") @PreAuthorize("hasAnyRole('ROLE_FULL_ACCESS','ROLE_READ_ONLY') and @bookStoreIdEvaluator.canAccessBookstore(authentication, #bookStoreId)") public Mono<ResponseEntity<BookStoreResource>> getBooks( @PathVariable String bookStoreId) { return bookStoreService.getBookStore(bookStoreId) .flatMap(this::createResponse); } 

यह उदाहरण निर्धारित करने के लिए अनुमतियों का विश्लेषण करता है कि क्या बुकस्टोर पहचानकर्ता मौजूद है:

 public boolean canAccessBookstore(Authentication authentication, String bookStoreId) { return authentication.getAuthorities().stream() .filter(authority - > authority.getAuthority() .startsWith(BOOK_STORE_ID_PREFIX)) .map(authority - > { String serviceInstanceId = authority.getAuthority() .substring(BOOK_STORE_ID_PREFIX.length()); return serviceInstanceId.equals(bookStoreId); }) .findFirst() .orElse(true); } 

वसंत हेटोस 1.0

स्प्रिंग हेटोस 1.0 जीए हाल ही में जारी किया गया था और इसमें लिंकिंग और मॉडलिंग विचारों के लिए प्रतिक्रियात्मक समर्थन शामिल है।

स्वचालित स्प्रिंग बूट कॉन्फ़िगरेशन को सक्रिय करने के लिए स्प्रिंग हेटोस स्टार्टर जोड़ें। चूंकि हम स्प्रिंग वेबफ्लक्स रिएक्टिव एप्लिकेशन बना रहे हैं, हमें स्प्रिंग वेब स्टार्टर को बाहर करने की आवश्यकता है:

 implementation('org.springframework.boot:spring-boot-starter-hateoas') { exclude group: 'org.springframework.boot', module: 'spring-boot-starter-web' } 

अगला, आप हाइपरमीडिया संसाधनों के निर्माण के लिए WebFluxLinkBuilder का उपयोग कर सकते हैं:

 public Mono < BookResource > toModel(Book book, String bookStoreId) { return Mono.just(new BookResource(book)) .flatMap(bookResource - > linkTo(methodOn( BookController.class).getBook(bookStoreId, book.getId())) .withSelfRel() .toMono() .flatMap(link - > Mono.just(bookResource.add(link))) .thenReturn(bookResource)); } 

तब आप नियंत्रक प्रतिक्रिया के शरीर में इस संसाधन का उपयोग कर सकते हैं:

 return new BookStoreResourceAssembler().toModel(bookStore) .flatMap(bookStoreResource - > Mono.just(new ResponseEntity < > (bookStoreResource, HttpStatus.OK))); 

वसंत की रूपरेखा 5.2

स्प्रिंग फ्रेमवर्क 5 ने मूल रूप से नए स्प्रिंग वेबफ्लक्स वेब फ्रेमवर्क में प्रतिक्रियात्मक सहायता की पेशकश की। इसके अलावा, नए WebClient और WebTestClient में स्प्रिंग वेबफ्लक्स अनुप्रयोगों के उपयोग और परीक्षण के लिए समर्थन शामिल है।

उनका उपयोग करने के लिए, बस स्प्रिंग बूट शुरुआत जोड़ें:

 implementation('org.springframework.boot:spring-boot-starter-webflux') testImplementation('org.springframework.boot:spring-boot-starter-test') { exclude group: 'org.junit.vintage', module: 'junit-vintage-engine' } 

उदाहरण के लिए, नियंत्रक कार्यक्षमता का परीक्षण करने के लिए WebTestClient का उपयोग करें:

 this.client.get().uri("/bookstores/{bookStoreId}", bookStoreId) .accept(MediaType.APPLICATION_JSON) .exchange() .expectStatus().isEqualTo(HttpStatus.OK); 

स्प्रिंग बूट 2.2

स्प्रिंग बूट इन सभी परियोजनाओं को एकीकृत करता है, स्प्रिंग वेबफ्लक्स, स्प्रिंग डेटा, स्प्रिंग सिक्योरिटी, स्प्रिंग हेटोस में रिएक्टिव सपोर्ट के ऑटो-कॉन्फ़िगरेशन के साथ-साथ परीक्षण उपकरणों की पेशकश करता है। कई मामलों में, कार्यक्षमता को सक्रिय करने के लिए कार्यान्वयन को केवल विशिष्ट स्प्रिंग बूट शुरुआत या संबंधित निर्भरता के अतिरिक्त की आवश्यकता होती है।

निष्कर्ष

इस पोस्ट में कुछ स्प्रिंग प्रोजेक्ट्स में रिएक्टिव सपोर्ट का एक संक्षिप्त परिचय शामिल है। अधिक से अधिक स्प्रिंग प्रोजेक्ट्स प्रतिक्रियाशील एपीआई का अनुकूलन और समर्थन करते हैं, डेवलपर्स के पास अपने अनुप्रयोगों में आवश्यक या प्रतिक्रियाशील प्रोग्रामिंग का उपयोग करने के लिए अधिक विकल्प होंगे। इसके अलावा, यह नमूना एप्लिकेशन केवल कुछ स्प्रिंग प्रोजेक्ट्स को प्रदर्शित करता है जो वर्तमान में रिएक्टिव सपोर्ट प्रदान करते हैं। भविष्य में और देखें! यदि आपके पास किसी विशिष्ट स्प्रिंग प्रोजेक्ट के बारे में प्रश्न या चिंताएँ हैं, तो कृपया संबंधित GitHub पृष्ठ पर प्रोजेक्ट अनुरक्षकों से संपर्क करें।

@Middle_java द्वारा अनुवादित