Spring Cloud 使用 Kubernetes 作为注册中心_HelloWood-CSDN博客

标签： | 发表时间：2020-11-08 18:13 | 作者：
出处：https://blog.csdn.net

Spring Cloud 可以使用 Kubernetes 作为注册中心，实现服务注册和发现

创建两个应用，Consumer 和 Provider，Provider 提供一个 REST 接口供 Consumer 调用

Provider

添加依赖

  • build.gradle
  dependencies {
    compile project(":discovery/common")

    implementation 'org.springframework.boot:spring-boot-starter-actuator'
    implementation 'org.springframework.boot:spring-boot-starter-web'
    implementation 'org.springframework.cloud:spring-cloud-starter-kubernetes-all'

    compileOnly 'org.projectlombok:lombok'
    annotationProcessor 'org.projectlombok:lombok'

    testImplementation 'org.springframework.boot:spring-boot-starter-test'
}
  
       
  • 1
    •    
  • 2
    •    
  • 3
    •    
  • 4
    •    
  • 5
    •    
  • 6
    •    
  • 7
    •    
  • 8
    •    
  • 9
    •    
  • 10
    •    
  • 11
    •    
  • 12

添加配置

  • application.properties

指定服务的名称，用于实现调用

  spring.application.name=provider-service
server.port=8082
  
       
  • 1
    •    
  • 2
  • ProviderApplication.java

添加  @EnableDiscoveryClient启用服务发现

  @SpringBootApplication
@EnableDiscoveryClient
public class ProviderApplication {

    public static void main(String[] args) {
        SpringApplication.run(ProviderApplication.class, args);
    }
}
  
       
  • 1
    •    
  • 2
    •    
  • 3
    •    
  • 4
    •    
  • 5
    •    
  • 6
    •    
  • 7
    •    
  • 8

添加接口

      @GetMapping("/ping")
    @ResponseBody
    public String ping() {
        try {
            return InetAddress.getLocalHost().getHostName();
        } catch (UnknownHostException e) {
            return "Pong";
        }
    }
  
       
  • 1
    •    
  • 2
    •    
  • 3
    •    
  • 4
    •    
  • 5
    •    
  • 6
    •    
  • 7
    •    
  • 8
    •    
  • 9

部署到 Kubernetes

  • Dockerfile
  FROM openjdk:8-jdk-alpine
VOLUME /tmp
ENV TZ=Asia/Shanghai
RUN ln -snf /usr/share/zoneinfo/$TZ /etc/localtime && echo $TZ > /etc/timezone
ARG JAR_FILE
ADD discovery/provider/build/libs/provider-0.0.1-SNAPSHOT.jar app.jar
ENTRYPOINT ["java","-Djava.security.egd=file:/dev/./urandom", "-Duser.timezone=GMT+08", "-jar","/app.jar"]
  
       
  • 1
    •    
  • 2
    •    
  • 3
    •    
  • 4
    •    
  • 5
    •    
  • 6
    •    
  • 7

构建并上传镜像

  • provider-service.yaml
  apiVersion: v1
kind: Service
metadata:
  name: provider-service
  labels:
    app.kubernetes.io/name: provider-service
spec:
  type: ClusterIP
  ports:
    - port: 8082
      targetPort: 8082
      protocol: TCP
      name: http
  selector:
    app.kubernetes.io/name: provider-service

---
apiVersion: apps/v1
kind: Deployment
metadata:
  name: provider-service
  labels:
    app.kubernetes.io/name: provider-service
spec:
  replicas: 1
  selector:
    matchLabels:
      app.kubernetes.io/name: provider-service
  template:
    metadata:
      labels:
        app.kubernetes.io/name: provider-service
        app.kubernetes.io/instance: sad-markhor
    spec:
      containers:
        - name: provider-service
          image: "docker.io/hellowoodes/spring-cloud-k8s-provider:1.2"
          imagePullPolicy: IfNotPresent
          ports:
            - name: http
              containerPort: 8082
              protocol: TCP
  
       
  • 1
    •    
  • 2
    •    
  • 3
    •    
  • 4
    •    
  • 5
    •    
  • 6
    •    
  • 7
    •    
  • 8
    •    
  • 9
    •    
  • 10
    •    
  • 11
    •    
  • 12
    •    
  • 13
    •    
  • 14
    •    
  • 15
    •    
  • 16
    •    
  • 17
    •    
  • 18
    •    
  • 19
    •    
  • 20
    •    
  • 21
    •    
  • 22
    •    
  • 23
    •    
  • 24
    •    
  • 25
    •    
  • 26
    •    
  • 27
    •    
  • 28
    •    
  • 29
    •    
  • 30
    •    
  • 31
    •    
  • 32
    •    
  • 33
    •    
  • 34
    •    
  • 35
    •    
  • 36
    •    
  • 37
    •    
  • 38
    •    
  • 39
    •    
  • 40
    •    
  • 41
    •    
  • 42

Consumer

添加依赖

  • build.gradle
  dependencies {
    compile project(":discovery/common")

    implementation 'org.springframework.boot:spring-boot-starter-actuator'
    implementation 'org.springframework.boot:spring-boot-starter-web'

    implementation 'org.springframework.cloud:spring-cloud-starter-kubernetes-all'
    implementation 'org.springframework.cloud:spring-cloud-starter-openfeign'
    implementation 'org.springframework.cloud:spring-cloud-starter-netflix-ribbon'
    implementation 'io.github.openfeign:feign-java8'

    compileOnly 'org.projectlombok:lombok'
    annotationProcessor 'org.projectlombok:lombok'

    testImplementation 'org.springframework.boot:spring-boot-starter-test'
}
  
       
  • 1
    •    
  • 2
    •    
  • 3
    •    
  • 4
    •    
  • 5
    •    
  • 6
    •    
  • 7
    •    
  • 8
    •    
  • 9
    •    
  • 10
    •    
  • 11
    •    
  • 12
    •    
  • 13
    •    
  • 14
    •    
  • 15
    •    
  • 16

不同的是 Consumer 还添加了 Feign 和 Ribbon 的依赖

添加配置

  • application.properties
  spring.application.name=consumer-service
server.port=8081
  
       
  • 1
    •    
  • 2
  • ConsumerApplication.java

启用服务发现和 Feign 远程调用

  @SpringBootApplication
@EnableDiscoveryClient
@EnableFeignClients
public class ConsumerApplication {

    public static void main(String[] args) {
        SpringApplication.run(ConsumerApplication.class, args);
    }

}
  
       
  • 1
    •    
  • 2
    •    
  • 3
    •    
  • 4
    •    
  • 5
    •    
  • 6
    •    
  • 7
    •    
  • 8
    •    
  • 9
    •    
  • 10

添加接口

  • ConsumerController.java
  @RestController
@Slf4j
public class ConsumerController {

    @Autowired
    private DiscoveryClient discoveryClient;

    @Autowired
    private ProviderClient providerClient;


    @GetMapping("/service")
    public Object getClient() {
        return discoveryClient.getServices();
    }

    @GetMapping("/instance")
    public List<ServiceInstance> getInstance(String instanceId) {
        return discoveryClient.getInstances(instanceId);
    }

    @GetMapping("/ping")
    public OperationResponse ping() {
        return OperationResponse
                .builder()
                .success(true)
                .data(providerClient.ping())
                .build();
    }
}
  
       
  • 1
    •    
  • 2
    •    
  • 3
    •    
  • 4
    •    
  • 5
    •    
  • 6
    •    
  • 7
    •    
  • 8
    •    
  • 9
    •    
  • 10
    •    
  • 11
    •    
  • 12
    •    
  • 13
    •    
  • 14
    •    
  • 15
    •    
  • 16
    •    
  • 17
    •    
  • 18
    •    
  • 19
    •    
  • 20
    •    
  • 21
    •    
  • 22
    •    
  • 23
    •    
  • 24
    •    
  • 25
    •    
  • 26
    •    
  • 27
    •    
  • 28
    •    
  • 29
    •    
  • 30
  • ProviderClient.java
  @FeignClient(name = "provider-service", fallback = ProviderClientFallback.class)
public interface ProviderClient {

    @RequestMapping(value = "/ping", method = RequestMethod.GET)
    String ping();
}

@Component
class ProviderClientFallback implements ProviderClient {

    @Override
    public String ping() {
        return "Error";
    }
}
  
       
  • 1
    •    
  • 2
    •    
  • 3
    •    
  • 4
    •    
  • 5
    •    
  • 6
    •    
  • 7
    •    
  • 8
    •    
  • 9
    •    
  • 10
    •    
  • 11
    •    
  • 12
    •    
  • 13
    •    
  • 14
    •    
  • 15

部署到 Kubernetes

  • Dockerfile
  FROM openjdk:8-jdk-alpine
VOLUME /tmp
ENV TZ=Asia/Shanghai
RUN ln -snf /usr/share/zoneinfo/$TZ /etc/localtime && echo $TZ > /etc/timezone
ARG JAR_FILE
ADD discovery/consumer/build/libs/consumer-0.0.1-SNAPSHOT.jar app.jar
ENTRYPOINT ["java","-Djava.security.egd=file:/dev/./urandom", "-Duser.timezone=GMT+08", "-jar","/app.jar"]
  
       
  • 1
    •    
  • 2
    •    
  • 3
    •    
  • 4
    •    
  • 5
    •    
  • 6
    •    
  • 7

构建并上传镜像

  • consumer-service.yaml
  apiVersion: v1
kind: Service
metadata:
  name: consumer-service
  labels:
    app.kubernetes.io/name: consumer-service
spec:
  type: NodePort
  ports:
    - port: 8081
      nodePort: 30081
      protocol: TCP
      name: http
  selector:
    app.kubernetes.io/name: consumer-service

---

apiVersion: apps/v1
kind: Deployment
metadata:
  name: consumer-service
  labels:
    app.kubernetes.io/name: consumer-service
spec:
  replicas: 1
  selector:
    matchLabels:
      app.kubernetes.io/name: consumer-service
  template:
    metadata:
      labels:
        app.kubernetes.io/name: consumer-service
    spec:
      containers:
        - name: consumer-service
          image: "docker.io/hellowoodes/spring-cloud-k8s-consumer:1.2"
          imagePullPolicy: IfNotPresent
          ports:
            - name: http
              containerPort: 8081
              protocol: TCP
  
       
  • 1
    •    
  • 2
    •    
  • 3
    •    
  • 4
    •    
  • 5
    •    
  • 6
    •    
  • 7
    •    
  • 8
    •    
  • 9
    •    
  • 10
    •    
  • 11
    •    
  • 12
    •    
  • 13
    •    
  • 14
    •    
  • 15
    •    
  • 16
    •    
  • 17
    •    
  • 18
    •    
  • 19
    •    
  • 20
    •    
  • 21
    •    
  • 22
    •    
  • 23
    •    
  • 24
    •    
  • 25
    •    
  • 26
    •    
  • 27
    •    
  • 28
    •    
  • 29
    •    
  • 30
    •    
  • 31
    •    
  • 32
    •    
  • 33
    •    
  • 34
    •    
  • 35
    •    
  • 36
    •    
  • 37
    •    
  • 38
    •    
  • 39
    •    
  • 40
    •    
  • 41
    •    
  • 42

部署测试

部署

  kubectl apply -f discovery/provider/provider-service.yaml
kubectl apply -f discovery/consumer/consumer-service.yaml
  
       
  • 1
    •    
  • 2

测试

待部署完成后，访问  ${NODE_IP}:30081/${PATH}即可得到服务信息

测试接口

  • ping
  curl http://192.168.0.110:30081/ping
{"success":true,"message":null,"data":"provider-service-bb8844f9b-c74rj"}%
  
       
  • 1
    •    
  • 2
  • service
  curl http://192.168.0.110:30081/service
["backend","consumer-service","kubernetes","provider-service","traefik","traefik-dashboard"]%
  
       
  • 1
    •    
  • 2
  • instance
  curl http://192.168.0.110:30081/instance\?instanceId\=provider-service

[{"instanceId":"87f35232-cb2a-4a35-a094-f4577bce195e","serviceId":"provider-service","secure":false,"metadata":{"app.kubernetes.io/name":"provider-service","kubectl.kubernetes.io/last-applied-configuration":"{\"apiVersion\":\"v1\",\"kind\":\"Service\",\"metadata\":{\"annotations\":{},\"labels\":{\"app.kubernetes.io/name\":\"provider-service\"},\"name\":\"provider-service\",\"namespace\":\"default\"},\"spec\":{\"ports\":[{\"name\":\"http\",\"port\":8082,\"protocol\":\"TCP\",\"targetPort\":8082}],\"selector\":{\"app.kubernetes.io/name\":\"provider-service\"},\"type\":\"ClusterIP\"}}\n","port.http":"8082"},"uri":"http://10.32.0.8:8082","scheme":"http://","host":"10.32.0.8","port":8082}]%
  
       
  • 1
    •    
  • 2
    •    
  • 3

添加 Provider-Service 实例

  kubectl scale deploy/provider-service --replicas=3
  
       
  • 1

待扩容完成后，多次访问 ping 接口，会看到在轮询访问每个 Provider 实例，每次返回的实例 ID 都不一样

  curl http://192.168.0.110:30081/ping
{"success":true,"message":null,"data":"provider-service-bb8844f9b-lm589"}%

curl http://192.168.0.110:30081/ping
{"success":true,"message":null,"data":"provider-service-bb8844f9b-n5szb"}%

curl http://192.168.0.110:30081/ping
{"success":true,"message":null,"data":"provider-service-bb8844f9b-c74rj"}%

相关 [spring cloud kubernetes] 推荐：

Spring Cloud Kubernetes指南

- -
当我们构建微服务解决方案时，SpringCloud和Kubernetes都是最佳解决方案，因为它们为解决最常见的挑战提供组件. 但是，如果我们决定选择Kubernetes作为我们的解决方案的主要容器管理器和部署平台，我们仍然可以主要通过SpringCloudKubernetes项目使用SpringCloud的有趣特性.

拥抱Kubernetes,再见了Spring Cloud - 简书

- -
相信很多开发者在熟悉微服务工作后，才发现：. 以为用 Spring Cloud 已经成功打造了微服务架构帝国，殊不知引入了 k8s 后，却和 Cloud Native 的生态发展脱轨. 从 2013 年的 Spring Boot. 2012年10月，Mike Youngstrom在Spring jira中创建了一个功能需求，要求在Spring框架中支持无容器Web应用程序体系结构.

spring cloud项目改造为spring-cloud-kubernetes项目_水中加点糖-CSDN博客

- -
(一)基础k8s yaml脚本发布. (二)helm+shell脚本优化大量冗余配置发布. (三)jenkins用户审核的流水化方式部署. (四)service mesh(istio)服务网格化发布. (五)istio对项目进行金丝雀部署. spring-cloud-kubernetes之开发环境搭建.

Spring Cloud 使用 Kubernetes 作为注册中心_HelloWood-CSDN博客

- -
Spring Cloud 可以使用 Kubernetes 作为注册中心，实现服务注册和发现. 创建两个应用，Consumer 和 Provider，Provider 提供一个 REST 接口供 Consumer 调用. 指定服务的名称，用于实现调用. 添加  @EnableDiscoveryClient启用服务发现.

部署微服务的时候，Spring Cloud 和 Kubernetes 哪个更好？ - DockOne.io

- -
【编者的话】本文比较了当下最火热的两大微服务开发平台：Spring Cloud和Kubernetes的优缺点，并指出结合二者的优点来组合使用，将在微服务旅程上获得更大成功. 当我们需要部署微服务的时候，哪个更好. Spring Cloud还是Kubernetes. 答案是都可以，只是各自有其优势. Kubernetes都宣称自己是开发和运行微服务的最佳环境，但是它们的本质非常不一样，所追求的目标也不同.

大话 Spring Cloud

- - IT瘾-dev
研究了一段时间spring boot了准备向spirng cloud进发，公司架构和项目也全面拥抱了Spring Cloud. 在使用了一段时间后发现Spring Cloud从技术架构上降低了对大型系统构建的要求，使我们以非常低的成本（技术或者硬件）搭建一套高效、分布式、容错的平台，但Spring Cloud也不是没有缺点，小型独立的项目不适合使用.

Spring Cloud限流详解 | Spring Cloud|周立

- -
限流往往是一个绕不开的话题. 本文详细探讨在Spring Cloud中如何实现限流. Zuul上实现限流是个不错的选择，只需要编写一个过滤器就可以了，关键在于如何实现限流的算法. 常见的限流算法有漏桶算法以及令牌桶算法. https://www.cnblogs.com/LBSer/p/4083131.html，写得通俗易懂，你值得拥有，我就不拽文了.

spring-cloud-kubernetes的服务发现和轮询实战(含熔断)_程序员欣宸的博客-CSDN博客

- -
本文是《spring-cloud-kubernetes实战系列》的第四篇，主要内容是在kubernetes上部署两个应用：Web-Service和Account-Service，通过spring-cloud-kubernetes提供的注册发现能力，实现Web-Service调用Account-Service提供的http服务；.

使用istio对spring cloud kubernetes项目进行金丝雀发布_水中加点糖-CSDN博客_istio springcloud

- -
(一)基础k8s yaml脚本发布. (二)helm+shell脚本优化大量冗余配置发布. (三)jenkins用户审核的流水化方式部署. (四)service mesh(istio)服务网格化发布. (五)istio对项目进行金丝雀部署. spring-cloud-kubernetes之开发环境搭建.

spring cloud kubernetes在pod模式下服务调用源码解析_水中加点糖-CSDN博客

- -
之所以只看pod模式下的服务调用链路，是因为在service模式下不会走缓存，效率低，并且负载均衡模式不能由spring cloud框架所控制，不太灵活. feign调用时用的org.springframework.cloud.openfeign.loadbalancer.FeignBlockingLoadBalancerClient中的execute方法调用的.