Pengehadan semasa dan pemutus litar perkhidmatan seni bina perkhidmatan mikro rangka kerja Java

Dalam rangka kerja Java, pengehadan arus perkhidmatan dan pemutus litar adalah penting untuk memastikan kestabilan sistem: Pengehadan arus perkhidmatan: Gunakan RateLimiter untuk mengehadkan bilangan permintaan serentak untuk mengelakkan beban sistem. Pemutus litar: Gunakan Hystrix untuk mematikan perkhidmatan yang gagal dengan cepat untuk mengelakkan penyebaran kerosakan. Kes praktikal: Permintaan serentak API /api/v1/pengguna yang mengehadkan semasa ialah 100/saat, dan ralat 503 dikembalikan apabila perkhidmatan tidak tersedia Ini boleh dilaksanakan melalui RateLimiter dan Hystrix.

Penghadan arus perkhidmatan seni bina perkhidmatan mikro dan pemutus litar dalam rangka kerja Java

Dalam seni bina perkhidmatan mikro, pengehadan arus perkhidmatan dan pemutus litar adalah penting untuk memastikan kestabilan dan kebolehpercayaan sistem. Artikel ini akan memperkenalkan cara untuk melaksanakan pengehadan arus perkhidmatan dan pemutus litar dalam rangka kerja Java.

Pendikit perkhidmatan

Pendikit perkhidmatan merujuk kepada mengehadkan bilangan permintaan serentak untuk mengelakkan beban sistem. Kita boleh menggunakan RateLimiter untuk melaksanakan pengehadan semasa perkhidmatan.

// 初始化 RateLimiter
RateLimiter rateLimiter = RateLimiter.create(100); // 每秒允许 100 个请求

// 在控制器方法中使用限流
@PostMapping("/api/v1/users")
public ResponseEntity<User> createUser(@RequestBody User user) {
    // 尝试获取令牌
    if (!rateLimiter.tryAcquire()) {
        return ResponseEntity.status(HttpStatus.TOO_MANY_REQUESTS).build();
    }

    // 处理请求逻辑
    // ...
}

Litar

Litar merujuk kepada mematikan perkhidmatan dengan cepat apabila kegagalan perkhidmatan berlaku untuk mengelakkan kegagalan merebak ke perkhidmatan lain. Kita boleh menggunakan Hystrix untuk melaksanakan pemutus litar.

// 初始化 HystrixCommand
HystrixCommand<ResponseEntity<User>> createUserCommand = new HystrixCommand<>() {
    @Override
    protected ResponseEntity<User> run() {
        // 处理请求逻辑
        // ...
    }

    @Override
    protected ResponseEntity<User> getFallback() {
        return ResponseEntity.status(HttpStatus.SERVICE_UNAVAILABLE).build();
    }
};

// 在控制器方法中使用熔断
@PostMapping("/api/v1/users")
public ResponseEntity<User> createUser(@RequestBody User user) {
    // 执行 HystrixCommand
    return createUserCommand.execute();
}

Kes praktikal

Berikut ialah kes praktikal yang menunjukkan cara menggunakan teknologi di atas untuk melaksanakan pengehadan arus perkhidmatan dan pemutus litar:

Keperluan: Permintaan serentak bagi pengehad semasa, API 100/saat adalah dan apabila perkhidmatan tidak tersedia Apabila digunakan, ralat 503 dikembalikan. /api/v1/users

Pelaksanaan:

// 初始化 RateLimiter 和 HystrixCommand
final RateLimiter rateLimiter = RateLimiter.create(100); // 每秒允许 100 个请求
final HystrixCommand<ResponseEntity<User>> createUserCommand = new HystrixCommand<>() {
    @Override
    protected ResponseEntity<User> run() throws Exception {
        // 处理请求逻辑
        // ...
    }

    @Override
    protected ResponseEntity<User> getFallback() {
        return ResponseEntity.status(HttpStatus.SERVICE_UNAVAILABLE).build();
    }
};

// 在控制器方法中使用限流和熔断
@PostMapping("/api/v1/users")
public ResponseEntity<User> createUser(@RequestBody User user) {
    if (!rateLimiter.tryAcquire()) {
        return ResponseEntity.status(HttpStatus.TOO_MANY_REQUESTS).build();
    }

    return createUserCommand.execute();
}

Atas ialah kandungan terperinci Pengehadan semasa dan pemutus litar perkhidmatan seni bina perkhidmatan mikro rangka kerja Java. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!