vlambda博客
学习文章列表

<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency>

<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-consul-discovery</artifactId></dependency>

 instance: instanceId: ${spring.cloud.client.hostname}:${spring.application.name}:${random.value}

 cloud: consul: discovery: instanceId: ${spring.cloud.client.hostname}:${spring.application.name}:${random.value}

<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId></dependency>

@SpringBootApplication@EnableEurekaServerclass DiscoveryServerApplicationfun main(args: Array<String>) { runApplication<DiscoveryServerApplication>(*args)}

$ docker run -d --name=consul -e CONSUL_BIND_INTERFACE=eth0 -p 8500:8500 consul:1.7.2

spring: application: name: config-server profiles: active: native,vault cloud: config: server: native: searchLocations: classpath:/config-repo vault: host: 192.168.99.100 authentication: TOKEN token: spring-microservices-course

$ docker run -d --name vault --cap-add=IPC_LOCK -e 'VAULT_DEV_ROOT_TOKEN_ID=spring-microservices-course' -p 8200:8200 vault:1.4.0

spring: application: name: callme-service cloud: config: discovery: enabled: true serviceId: config-server consul: host: 192.168.99.100 config:
 format: YAML

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-webflux</artifactId></dependency><dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-openfeign</artifactId></dependency>

@SpringBootApplication@EnableFeignClientsclass InterCallerServiceApplication { @Bean @LoadBalanced fun template(): RestTemplate = RestTemplateBuilder() .setReadTimeout(Duration.ofMillis(100)) .setConnectTimeout(Duration.ofMillis(100)) .build() @Bean @LoadBalanced fun clientBuilder(): WebClient.Builder { val tcpClient: TcpClient = TcpClient.create() .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 100) .doOnConnected { conn -> conn.addHandlerLast(ReadTimeoutHandler(100, TimeUnit.MILLISECONDS)) } val connector = ReactorClientHttpConnector(HttpClient.from(tcpClient)) return WebClient.builder().clientConnector(connector) }}

spring: cloud: loadbalancer: cache: ttl: 1s ribbon: enabled: falseeureka: client:
 registryFetchIntervalSeconds: 1

<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-circuitbreaker-resilience4j</artifactId></dependency>

@Beanfun defaultCustomizer(): Customizer<Resilience4JCircuitBreakerFactory> { return Customizer { factory: Resilience4JCircuitBreakerFactory -> factory.configureDefault { id: String? -> Resilience4JConfigBuilder(id) .timeLimiterConfig(TimeLimiterConfig.custom() .timeoutDuration(Duration.ofMillis(500)) .build()) .circuitBreakerConfig(CircuitBreakerConfig.custom() .slidingWindowSize(10) .failureRateThreshold(33.3F) .slowCallRateThreshold(33.3F) .build()) .build() } }}

@RestController@RequestMapping("/caller")class CallerController(private val template: RestTemplate, private val factory: Resilience4JCircuitBreakerFactory) { private var id: Int = 0 @PostMapping("/random-send/{message}") fun randomSend(@PathVariable message: String): CallmeResponse? { val request = CallmeRequest(++id, message) val circuit = factory.create("random-circuit") return circuit.run { template.postForObject("http://inter-callme-service/callme/random-call", request, CallmeResponse::class.java) } }
}

<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-gateway</artifactId></dependency><dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-actuator</artifactId></dependency><dependency> <groupId>org.jetbrains.kotlin</groupId> <artifactId>kotlin-reflect</artifactId></dependency><dependency> <groupId>org.jetbrains.kotlin</groupId> <artifactId>kotlin-stdlib</artifactId></dependency><dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId></dependency><dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis-reactive</artifactId></dependency><dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-circuitbreaker-reactor-resilience4j</artifactId></dependency>

spring: application: name: api-gateway cloud: gateway: discovery: locator: enabled: true  lowerCaseServiceId: true routes: - id: inter-callme-service uri: lb://inter-callme-service predicates: - Path=/api/callme/** filters: - RewritePath=/api(?/?.*), $\{path} - name: RequestRateLimiter args: redis-rate-limiter.replenishRate: 20 redis-rate-limiter.burstCapacity: 40 - name: CircuitBreaker args: name: sampleSlowCircuitBreaker fallbackUri: forward:/fallback/test - id: inter-caller-service uri: lb://inter-caller-service predicates: - Path=/api/caller/** filters: - StripPrefix=1 - name: RequestRateLimiter args: redis-rate-limiter.replenishRate: 20 redis-rate-limiter.burstCapacity: 40 loadbalancer: ribbon: enabled: false redis: host: 192.168.99.100management: endpoints.web.exposure.include: '*' endpoint: health: show-details: always

@SpringBootApplicationclass ApiGatewayApplication { @Bean fun keyResolver(): KeyResolver = KeyResolver { _ -> Mono.just("1") } @Bean fun defaultCustomizer(): Customizer<ReactiveResilience4JCircuitBreakerFactory> { return Customizer { factory: ReactiveResilience4JCircuitBreakerFactory -> factory.configureDefault { id: String? -> Resilience4JConfigBuilder(id) .timeLimiterConfig(TimeLimiterConfig.custom() .timeoutDuration(Duration.ofMillis(500)) .build()) .circuitBreakerConfig(CircuitBreakerConfig.custom() .slidingWindowSize(10) .failureRateThreshold(33.3F) .slowCallRateThreshold(33.3F) .build()) .build() } } }}fun main(args: Array<String>) { runApplication<ApiGatewayApplication>(*args)
}