本篇内容介绍了“Java Spring Cloud怎么创建账户服务”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
创新互联 - 成都服务器托管,四川服务器租用,成都服务器租用,四川网通托管,绵阳服务器托管,德阳服务器托管,遂宁服务器托管,绵阳服务器托管,四川云主机,成都云主机,西南云主机,成都服务器托管,西南服务器托管,四川/成都大带宽,机柜大带宽、租用·托管,四川老牌IDC服务商
账户服务
新建一个基本的 Spring Boot 工程,命名为 cloud-account。
最终 pom.xml 中应有以下依赖坐标:
org.springframework.boot spring-boot-starter-data-MongoDB-reactive org.springframework.boot spring-boot-starter-webflux org.springframework.cloud spring-cloud-starter-netflix-eureka-client org.projectlombok lombok true io.projectreactor reactor-test test
配置文件 application.yml
spring: application: name: cloud-account server: port: 8100 eureka: client: service-url: defaultZone: http://localhost:8000/eureka/
创建账户的实体类,其中 @AllArgsConstructor
、@NoArgsConstructor
和 @Data
都是 Lombok 提供注解,不了解的可以自行学习,这里不多说了。
@AllArgsConstructor @NoArgsConstructor @Data @Document(collection = "accounts") public class Account { @Id private String id; private String customerId; private Double amount; }
我们使用 Spring Data Reactive。与非响应式 Spring Data 的 CrudReposity
对应的,响应式的 Spring Data 也提供了相应的 Repository 库:ReactiveCrudReposity
,我们也可以使用它的子接口 ReactiveMongoRepository
public interface AccountMongoReactiveRepository extends ReactiveCrudRepository{ Flux findByCustomerId(String customerId); }
为账户服务创建对应的 Controller,这里只简单提供一个查询客户的所有账户的接口。为了在后面测试负载均衡,这里加上了调用时间戳的打印。
@RequestMapping("/account") @RestController public class AccountController { @Autowired private AccountMongoReactiveRepository repository; @GetMapping("/customer/{customer}") public FluxfindByCustomer(@PathVariable(name = "customer") String customer) { System.out.println("Customer => " + customer + " [ " + LocalDateTime.now().format(DateTimeFormatter.ofPattern("HH:mm:ss.SSS")) + " ]"); return repository.findByCustomerId(customer); } }
“Java Spring Cloud怎么创建账户服务”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注创新互联网站,小编将为大家输出更多高质量的实用文章!
网站标题:JavaSpringCloud怎么创建账户服务
地址分享:http://scyingshan.cn/article/ijooij.html