本篇内容介绍了“Java Spring Cloud怎么创建账户服务”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
创新互联:2013年至今为各行业开拓出企业自己的“网站建设”服务,为上千余家公司企业提供了专业的成都做网站、成都网站设计、网页设计和网站推广服务, 按需定制设计由设计师亲自精心设计,设计的效果完全按照客户的要求,并适当的提出合理的建议,拥有的视觉效果,策划师分析客户的同行竞争对手,根据客户的实际情况给出合理的网站构架,制作客户同行业具有领先地位的。新建一个基本的 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怎么创建账户服务”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注创新互联-成都网站建设公司网站,小编将为大家输出更多高质量的实用文章!