这篇文章主要讲解了“Java Spring Cloud客户服务创建方法是什么”，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习“Java Spring Cloud客户服务创建方法是什么”吧！
新建一个基本的 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客户服务创建方法是什么这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是亿速云，小编将为大家推送更多相关知识点的文章，欢迎关注！
亿速云「云服务器」，即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘，价格低至29元/月。点击查看>>
免责声明：本站发布的内容（图片、视频和文字）以原创、转载和分享为主，文章观点不代表本网站立场，如果涉及侵权请联系站长邮箱：is@yisu.com进行举报，并提供相关证据，一经查实，将立刻删除涉嫌侵权内容。
原文链接：http://blog.itpub.net/69952307/viewspace-2679180/
