Java Spring Cloud怎么創(chuàng)建賬戶服務

本篇內(nèi)容介紹了“Java Spring Cloud怎么創(chuàng)建賬戶服務”的有關知識，在實際案例的操作過程中，不少人都會遇到這樣的困境，接下來就讓小編帶領大家學習一下如何處理這些情況吧！希望大家仔細閱讀，能夠?qū)W有所成！

賬戶服務

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

最終 pom.xml 中應有以下依賴坐標：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-mongodb-reactive</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-webflux</artifactId>
</dependency>
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
<dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <optional>true</optional>
</dependency>
<dependency>
    <groupId>io.projectreactor</groupId>
    <artifactId>reactor-test</artifactId>
    <scope>test</scope>
</dependency>

配置文件 application.yml

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

創(chuàng)建賬戶的實體類，其中 @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<Account, String> {
    Flux<Account> findByCustomerId(String customerId);
}

為賬戶服務創(chuàng)建對應的 Controller，這里只簡單提供一個查詢客戶的所有賬戶的接口。為了在后面測試負載均衡，這里加上了調(diào)用時間戳的打印。

@RequestMapping("/account")
@RestController
public class AccountController {
    @Autowired
    private AccountMongoReactiveRepository repository;
    @GetMapping("/customer/{customer}")
    public Flux<Account> findByCustomer(@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怎么創(chuàng)建賬戶服務”的內(nèi)容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關的知識可以關注億速云網(wǎng)站，小編將為大家輸出更多高質(zhì)量的實用文章！