這篇文章主要講解了“Java Spring Cloud客戶服務創(chuàng)建方法是什么”,文中的講解內(nèi)容簡單清晰,易于學習與理解,下面請大家跟著小編的思路慢慢深入,一起來研究和學習“Java Spring Cloud客戶服務創(chuàng)建方法是什么”吧!
新建一個基本的 Spring Boot 工程,命名為 cloud-customer
。
配置文件如下,僅是改了服務名和端口號:
spring: application: name: cloud-customer server: port: 8200 eureka: client: service-url: defaultZone: http://localhost:8000/eureka/
創(chuàng)建一個 Customer 的實體類
@Data @AllArgsConstructor @NoArgsConstructor @Document(collection = "customers") public class Customer { @Id private String id; private String name; private String mobile; }
數(shù)據(jù)訪問層直接繼承 ReactiveCrudRepository
我們便有了基本的 CRUD 能力
public interface CustomerMongoReactiveRepository extends ReactiveCrudRepository<Customer, String> { }
因為我們只是示例,不做復雜的業(yè)務邏輯,所以省略了 Service 層,在 Controller 里邊直接將 CRUD 的操作代理給了 Repository。
@RestController @RequestMapping("/customer") public class CustomerController { @Autowired private CustomerMongoReactiveRepository repository; @Autowired private WebClient.Builder webClientBuilder; @GetMapping("") public Flux<Customer> list() { return repository.findAll(); } @GetMapping("/{id}") public Mono<Customer> get(@PathVariable String id) { return repository.findById(id); } @PostMapping("") public Mono<Customer> create(@RequestBody Customer customer) { return repository.save(customer); } @PutMapping("/{id}") public Mono<Customer> update(@PathVariable("id") String id, @RequestBody Customer customer) { customer.setId(id); return repository.save(customer); } @DeleteMapping("/{id}") public Mono<Void> delete(@PathVariable String id) { return repository.deleteById(id); } }
到這里,我們的服務注冊中心和兩個微服務就都好了。但是,這兩個微服務之間還是完全獨立的,沒有相互間的服務調(diào)用。現(xiàn)在我們來實現(xiàn)之前說的需求:客戶服務與帳戶服務可以相互通信,以獲取客戶的所有帳戶,并通過客戶服務 API 方法返回。
首先創(chuàng)建一個 Java Config,這里我們不再使用 RestTemplate
來調(diào)用服務,而是 WebClient
。這個配置看起來和注冊 RestTemplate
時差不多,但是要注意這里注冊的 Bean 是 WebClient.Builder
。
@Configuration public class WebClientConfig { @Bean @LoadBalanced public WebClient.Builder loadBalancedWebClientBuilder() { return WebClient.builder(); } }
除了這種寫法,還有一種寫法是
public class MyClass { @Autowired private LoadBalancerExchangeFilterFunction lbFunction; public Mono<String> doOtherStuff() { return WebClient.builder().baseUrl("http://cloud-account/account") .filter(lbFunction) .build() .get() .uri("") .retrieve() .bodyToMono(String.class); } }
下邊的是錯誤的寫法,會拋出異常
@Bean @LoadBalanced public WebClient loadBalancedWebClient() { return WebClient.builder().baseUrl("http://cloud-account/account").build(); }
然后在 CustomerController
實現(xiàn)這個端點:
@GetMapping("/{id}/account") public Flux<Account> getAllAccounts(@PathVariable String id) { return webClientBuilder.baseUrl("http://cloud-account/account/").build() .get().uri("/customer/" + id) .retrieve() .bodyToFlux(Account.class); }
這里需要在 cloud-customer
里創(chuàng)建一個 DTO Account
,因為和 cloud-account
里的完全一樣,就省略了。
感謝各位的閱讀,以上就是“Java Spring Cloud客戶服務創(chuàng)建方法是什么”的內(nèi)容了,經(jīng)過本文的學習后,相信大家對Java Spring Cloud客戶服務創(chuàng)建方法是什么這一問題有了更深刻的體會,具體使用情況還需要大家實踐驗證。這里是創(chuàng)新互聯(lián),小編將為大家推送更多相關知識點的文章,歡迎關注!
新聞標題:JavaSpringCloud客戶服務創(chuàng)建方法是什么-創(chuàng)新互聯(lián)
文章起源:http://www.rwnh.cn/article26/ccspcg.html
成都網(wǎng)站建設公司_創(chuàng)新互聯(lián),為您提供軟件開發(fā)、響應式網(wǎng)站、小程序開發(fā)、靜態(tài)網(wǎng)站、動態(tài)網(wǎng)站、網(wǎng)站營銷
聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權請盡快告知,我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場,如需處理請聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時需注明來源: 創(chuàng)新互聯(lián)
猜你還喜歡下面的內(nèi)容