這篇文章主要講解了“Java Spring Cloud客戶服務創建方法是什么”，文中的講解內容簡單清晰，易于學習與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學習“Java Spring Cloud客戶服務創建方法是什么”吧！

成都創新互聯專注于企業全網整合營銷推廣、網站重做改版、紅河哈尼網站定制設計、自適應品牌網站建設、H5網站設計、商城網站開發、集團公司官網建設、成都外貿網站建設公司、高端網站制作、響應式網頁設計等建站業務，價格優惠性價比高，為紅河哈尼等各大城市提供網站開發制作服務。

新建一個基本的 Spring Boot 工程，命名為 cloud-customer。

配置文件如下，僅是改了服務名和端口號：

spring:
  application:
    name: cloud-customer
server:
  port: 8200
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8000/eureka/

創建一個 Customer 的實體類

@Data
@AllArgsConstructor
@NoArgsConstructor
@Document(collection = "customers")
public class Customer {
    @Id
    private String id;
    private String name;
    private String mobile;
}

數據訪問層直接繼承 ReactiveCrudRepository 我們便有了基本的 CRUD 能力

public interface CustomerMongoReactiveRepository extends ReactiveCrudRepository<Customer, String> {
}

因為我們只是示例，不做復雜的業務邏輯，所以省略了 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);
    }
}

到這里，我們的服務注冊中心和兩個微服務就都好了。但是，這兩個微服務之間還是完全獨立的，沒有相互間的服務調用。現在我們來實現之前說的需求：客戶服務與帳戶服務可以相互通信，以獲取客戶的所有帳戶，并通過客戶服務 API 方法返回。

首先創建一個 Java Config，這里我們不再使用 RestTemplate 來調用服務，而是 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 實現這個端點：

@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 里創建一個 DTO Account，因為和 cloud-account 里的完全一樣，就省略了。

感謝各位的閱讀，以上就是“Java Spring Cloud客戶服務創建方法是什么”的內容了，經過本文的學習后，相信大家對Java Spring Cloud客戶服務創建方法是什么這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是創新互聯，小編將為大家推送更多相關知識點的文章，歡迎關注！

新聞標題：JavaSpringCloud客戶服務創建方法是什么-創新互聯
文章起源：http://vcdvsql.cn/article26/ccspcg.html

成都網站建設公司_創新互聯，為您提供軟件開發、響應式網站、小程序開發、靜態網站、動態網站、網站營銷

廣告

聲明：本網站發布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網站立場，如需處理請聯系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經允許不得轉載，或轉載時需注明來源： 創新互聯