本地服务调用k8s环境中的springcloud微服务实战(代码片段)

author author     2022-12-03     348

关键词:

欢迎访问我的GitHub

  • 下图是典型的微服务在Kubernetes环境的部署情况(简化版):

  • 在开发阶段,如果服务B还在开发中,部署情况如下图所示:

  • 此时的服务B如何才能访问到注册中心和服务A呢?

常规手段:通过service访问对应的pod

  • 通常情况下,从外部访问kubernetes内部pod服务的方法是创建service,再通过访问service的方式来访问对应的Pod,但是这样做会变更kubernetes环境现有配置,例如原本注册中心对应的service type是ClusterIP,这里只有改成NodePort或者LoadBalancer才能让外部访问到,又例如服务A原本没有service,这里为了外部访问只能为其创建service。

  • 如果这个Kubernetes环境是生产环境,上述改动都是不允许的,如果是开发环境,又会造成开发和生产环境有大量不一样的配置,因此,创建service虽然可行但并不是好方案。

更适合本地开发的方案:kubefwd服务

  • 比service更适合本地开发的方案是使用kubectl port-forward命令在本地电脑创建kubefwd服务,例如将对当前电脑8081端口的请求,可以kubefwd转发到kubernetes上的注册中心Pod的8080端口;

  • 有了kubefwd,我们在开发服务B的时候,只要把发往注册中心和服务A的请求都kubefwd服务转发到kubernetes上去就可以了,如下图:

  • 理论分析就到此吧,接下来一起实战本地服务调用K8S环境中的微服务。

实战环境

  • 以下是本次实战所需的环境,请确保您的kubernetes是正常可用的:
  1. kubernetes:
  2. kubectl:1.7.0
  3. kubernetes所在Linux服务器:CentOS7.4
  4. 本地环境:win10专业版64位
  5. SpringCloud:Edgware.SR1
镜像名 角色 镜像对应的源码
bolingcavalry/eureka-server:0.0.1-SNAPSHOT 注册中心 eureka-server工程
bolingcavalry/service-provider:0.0.1-SNAPSHOT 服务A,提供http服务 service-provider工程

源码下载

  • 本次实战的注册中心(eureka-server)、服务A(service-provider)、服务B(service-consumer)都在GitHub提供了对应的源码,地址和链接信息如下表所示:
名称 链接 备注
项目主页 https://github.com/zq2599/blog_demos 该项目在GitHub上的主页
git仓库地址(https) https://github.com/zq2599/blog_demos.git 该项目源码的仓库地址,https协议
git仓库地址(ssh) git@github.com:zq2599/blog_demos.git 该项目源码的仓库地址,ssh协议
  • 这个git项目中有多个文件夹,本章源码在springcloudscaledemo这个文件夹下,如下图红框所示:

实战

  • 本次实战的步骤是将注册中心和服务A部署到kubernetes环境,然后在本地运行服务B,看服务B能否正常注册和调用服务A。<br>

  • 注册中心、服务A、服务B与源码工程的对应关系如下:

角色 源码工程 备注
注册中心 eureka-server eureka注册中心服务,部署在kubernetes
服务A service-provider springboot工程,部署在kubernetes,在eureka注册,提供http接口getuserinfo
服务B service-consumer springboot工程,部署在本地windows电脑上,提供http接口user
  • 注意:以下的操作都在本地的windows电脑上完成
  • 创建注册中心的deployment,执行以下命令:
kubectl run my-eureka --image=bolingcavalry/eureka-server:0.0.1-SNAPSHOT --replicas=1
  • 创建名为eurekahost的服务,对应的pod是刚刚创建的my-eureka:
kubectl expose deployment my-eureka --name=eurekahost --port=8080
  • 创建服务A的deployment:
kubectl run my-provider --image=bolingcavalry/service-provider:0.0.1-SNAPSHOT --replicas=1
  • 查看pod的名字:
c:\\software\\kubectl>kubectl get pods
NAME                           READY     STATUS    RESTARTS   AGE
my-eureka-7f958f96b7-drgt6     1/1       Running   0          25m
my-provider-78dcc87bcc-s7cvq   1/1       Running   0          19m
  • 我这里注册中心pod名字是my-eureka-7f958f96b7-drgt6,服务A的pod名字是my-provider-78dcc87bcc-s7cvq

  • 通过kubefwd服务将本地8081端口的请求转发到my-eureka-7f958f96b7-drgt6的8080端口:

kubectl port-forward my-eureka-7f958f96b7-drgt6 8081:8080
  • 此时用浏览器访问本机的8081端口,就能访问到注册中心了,如下图:

  • 通过kubefwd服务将本地8082端口的请求转发到my-provider-78dcc87bcc-s7cvq的8080端口:
kubectl port-forward my-provider-78dcc87bcc-s7cvq 8082:8080
  • 此时用浏览器访问本机的8082端口,就能调用服务A的http接口了,地址是:http://localhost:8082/getuserinfo?id=101&name=Tom

  • 此时注册中心和服务A都可以在本地访问了,可以在本地开发服务B的代码了,详细源码请按照前面给出的地址下载,这里只贴出关键代码,首先是配置信息application.yml,这是个普通的SpringCloud工程的配置,要注意的是eureka的地址和端口要改成localhost:8081,这样请求才会被kubefwd服务转发到kubernetes上去:

server:
  port: 8080
spring:
  application:
    name: service-consumer
eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8081/eureka/
  instance:
    prefer-ip-address: true
  • 服务B调用服务A用的是FeignClient的方式,在FeignClient的注解中,要用url参数指明服务A的地址是http://localhost:8082,这样对服务A的请求才会被转发到kubernetes上去:
@FeignClient(name = "microservice-provider-user", url = "http://localhost:8082")
public interface UserFeignClient 

    @RequestMapping(value = "/getuserinfo", method = RequestMethod.GET)
    String getUserInfoWithRequestParam(@RequestParam("id") String id, @RequestParam("name") String name);

  • 做一个controller类,接收到web请求后,就会调用服务A的getuserinfo接口,然后将服务A返回的内容加个前缀返回:
@RestController
public class UserFacadeController 

    @Autowired
    private UserFeignClient userFeignClient;

    @GetMapping("/user/id/name")
    public String getUserInfo(@PathVariable("id") final String id, @PathVariable("name") final String name) 
        return "1. ---" + userFeignClient.getUserInfoWithRequestParam(id, name);
    

  • 在本地运行此工程,去看注册中心页面,发现已经注册成功:

  • 在浏览器输入:http://localhost:8080/user/aaa/bbb ,可见服务B的返回内容中有调用服务A时返回的信息,所以调用成功: 实战完成,从注册到远程调用都一切正常。

一点小遗憾

  • 在使用kubectl port-forward命令的时候,本来是想执行以下命令的,这样可以将本地请求转发到my-eureka的deployment上去,就不用指定具体的pod了(pod的名字不如deployment固定):
kubectl port-forward deployment/my-eureka 8081:8080
  • 但是在windows环境下此命令会报错"error: invalid resource name "deployment/my-eureka": [may not contain /]",也就是名字不能带有斜杠,但是上述命令是官方文档上列举出来的,地址是:https://kubernetes.io/docs/tasks/access-application-cluster/port-forward-access-application-cluster/ ,如下图:

同样的困惑

  • 这里有一篇文章,文中作者也是在本地调用kubernetes服务时,同样是用kubectl port-forward解决了问题:https://imti.co/kubernetes-port-forwarding :

  • 此文章的配图是比较细致清晰的,在此转载了:

  • 至此,本地服务调用K8S环境中的SpringCloud微服务实战已完成,当您开发微服务时如遇到类似场景,希望本文能够给您一些参考。

欢迎关注51CTO博客:程序员欣宸

springcloud微服务电商系统在kubernetes集群中上线详细教程(代码片段)

Kubernetes集群部署Springcloud微服务商务系统文章目录Kubernetes集群部署Springcloud微服务商务系统1.微服务架构及理论概述1.1.单体架构与微服务架构的区别1.2.微服务组件架构图1.3.微服务注册中心1.4.不同的部署环境对于程序配置文件如... 查看详情

从微服务角度对比springcloud与dubbo,k8s

SpringCloud与Dubbo对比:SpringCloud与K8S对比:参考《深入理解SpringCloud与微服务构建》 查看详情

springcloud微服务安全实战-7-11pinpoint+springboot环境搭建

微服务的最后一个组件,调用链监控,一个请求进来以后,经过N多个微服务,例如a调用了b。b又调用了c,那么在这个过程中看到,整个的调用的链路,然后每一段调用所耗费的时间,帮你去分析你的系统如果出现瓶颈以后,瓶... 查看详情

springcloud——eureka本地集群搭建以及实现微服务的负载均衡调用(代码片段)

什么是服务治理?SpringCloud封装了Netflix公司开发的Eureka模块来实现服务治理在传统的rpc远程调用框架中,管理每个服务与服务之间依赖关系比较复杂,所以需要使用服务治理,管理服务与服务之间依赖关系,可以实... 查看详情

k8s部署微服务springcloud从0-1(微服务各个组件镜像构建)

Dockerfile构建服务1.构建jdk1.8镜像FROMubuntuMAINTAINERrolinRUNmkdir/usr/local/jdkWORKDIR/usr/local/jdkADDjdk-8u231-linux-x64.tar.gz/usr/local/jdkENVJAVA_HOME/usr/local/jdk/jdk1.8.0_231ENVJRE_HOME/usr/local/jd 查看详情

docker运行springcloud使用外部ip

参考技术A在多机器上docker部署SpringCloud发现有一个问题,即在docker容器内部,SpringCloudeureka实例只能获取到docker内部网络的IP,如172.x.x.x,并将其注册到注册中心,此时其他服务通过该IP在docker外部无法访问该服务。以下有两种解... 查看详情

微服务架构springcloud之hytrix

分布式系统面临的问题复杂分布式体系结构中的应用程序有数十个依赖,每个依赖关系将在某些时候将不可避免地失败。  服务雪崩  多个微服务之间调用的时候,假设微服务A调用微服务B和微服务C,微服务B和微服务C又... 查看详情

k8s部署微服务springcloud从0-1(eureka实现)

Eureka服务搭建1.pom配置文件<?xmlversion="1.0"encoding="UTF-8"?><projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.a 查看详情

docker+k8s+springcloud微服务集群部署实例

fromtypingimportList#这道题不是很难,但是限制条件有很多。#用递归的方法可以很容易的想到。只需要四层递归就好了。#每次进行加上限制条件。过滤每一层就好了。、classSolution:defrestoreIpAddresses(self,s:str)->List[str]:self.IP_lists=[]self... 查看详情

springcloud微服务(06):config组件,实现配置统一管理

...上,如果一个配置发生变化,需要修改很多的服务配置。springcloud提供配置中心,来解决这个场景问题。系统中的通用配置存储在相同的地址:GitHub,Gitee,本地配置服务等,然后配置中心读取配置以restful发布出来,其它服务可以... 查看详情

linux12devops-->11jenkins+docker+springcloud微服务持续集成(代码片段)

文章目录Jenkins+Docker+SpringCloud微服务持续集成大致流程说明:一、SpringCloud微服务源码概述微服务项目结构:数据库结构微服务配置分析:本地部署(1)-SpringCloud微服务部署本地部署微服务本地部署(2)-前端静态web... 查看详情

springcloud中微服务之间的调用以及eureka的自我保护机制

我自己搭建了一个客户端微服务:所以现在有两个微服务,我们所实现的就是微服务1和微服务2之间的调用注册中心就不用多说了,具体看一下两个微服务在project-solr中的constroller中:@RestController//这里使此Constroller中所有的方法... 查看详情

k8s部署微服务springcloud从0-1(zuul网关的实现)

Zuul实现一.新建项目并配置文件<?xmlversion="1.0"encoding="UTF-8"?><projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apa 查看详情

springcloud——服务降级熔断hystrix(代码片段)

一、概述分布式系统面临的问题复杂分布式体系结构中的应用程序有数十个依赖关系,每个依赖关系在某些时候将不可避免地失败。服务雪崩多个微服务之间调用的时候,假设微服务A调用微服务B和微服务C,微服务B... 查看详情

springcloud——服务降级熔断hystrix(代码片段)

一、概述分布式系统面临的问题复杂分布式体系结构中的应用程序有数十个依赖关系,每个依赖关系在某些时候将不可避免地失败。服务雪崩多个微服务之间调用的时候,假设微服务A调用微服务B和微服务C,微服务B... 查看详情

blazor+dapr+k8s微服务之服务调用

 1.1  Dapr环境配置1.1.1       在开发机安装DockerDesktop并启用Kubernetes安装过程略,安装好后效果如下:(左下角两个绿色指示Docker和K8s正在运行) 1.1.2       在开发机安装DaprCli安装命令:powershell-Command... 查看详情

微服务~原始真解springcloud——知道微服务中如何调用接口吗?(代码片段)

...服务,一起学习一起进步。👀本期介绍主要介绍SpringCloud——Feign调用微服务中的接口文章 查看详情

springcloud之微服务实用篇2(代码片段)

在之前我们学习微服务中的两个组件,一个是注册中心,一个负载均衡器。今天,我们主要学习三个内容,分别是:Nacos配置管理、Feign远程调用、Gateway服务网关。目录一、Nacos配置管理1.1、Nacos实现配置管理1.... 查看详情