在本文中,您将学习如何运行Spring Boot微服务,这些服务在Knative上相互通信。我还向您展示了如何使用GraalVM准备Spring Boot应用程序的本机映像。然后我们将使用Skaffold和jibmaven插件在Kubernetes上运行它。
本文是我关于Knative系列文章的第二篇。在Knative上发布了第一个SpringBoot之后,您问我在扩展到零后有很长的应用程序启动时间。这就是为什么我通过使用GraalVM将其编译为本机映像来解决这个Spring Boot问题。在无服务器serverless方法中,启动时间问题似乎是一个重要的问题。
在Knative上,您可以运行任何类型的应用程序,而不仅仅是函数。在本文中,当我编写“微服务”时,实际上,我考虑的是服务对服务的通信。
源代码
如果你想自己试试,你可以随时看看我的源代码:https://github.com/piomin/sample-spring-boot-graalvm.git。为此,您需要克隆我的GitHub存储库。那你应该听从我的指示。
作为本文中的微服务示例,我使用了两个应用程序callme service和caller service。它们都公开了一个端点,该端点打印应用程序pod的名称。调用方服务应用程序还调用callme服务应用程序公开的端点。
在Kubernetes上,这两个应用程序都将作为Knative服务部署在多个版本中。我们还将使用Knative路由在这些修订版中分配流量。下图说明了我们的示例系统的体系结构。
准备Spring Boot微服务
我们有两个简单的Spring Boot应用程序,它们公开一个REST端点、运行状况检查,并运行内存中的H2数据库。我们使用Hibernate和Lombok。因此,我们需要在Maven pom.xml
中包含以下依赖项列表。
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
<groupId>com.h2database</groupId>
<artifactId>h2</artifactId>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.16</version>
</dependency>
每次调用ping端点时,它都会创建一个事件并将其存储在H2数据库中。REST端点返回Kubernetes中pod和命名空间的名称以及事件的id。该方法在我们对集群的手动测试中很有用。
@RestController
@RequestMapping("/callme")
public class CallmeController {
@Value("${spring.application.name}")
private String appName;
@Value("${POD_NAME}")
private String podName;
@Value("${POD_NAMESPACE}")
private String podNamespace;
@Autowired
private CallmeRepository repository;
@GetMapping("/ping")
public String ping() {
Callme c = repository.save(new Callme(new Date(), podName));
return appName + "(id=" + c.getId() + "): " + podName + " in " + podNamespace;
}
}
这是我们的模型课——Callme
。调用者服务应用程序中的模型类非常类似。
@Entity
@Getter
@Setter
@NoArgsConstructor
@RequiredArgsConstructor
public class Callme {
@Id
@GeneratedValue
private Integer id;
@Temporal(TemporalType.TIMESTAMP)
@NonNull
private Date addDate;
@NonNull
private String podName;
}
另外,让我们看看CallerController
中ping
方法的第一个版本。稍后我们将在讨论通信和跟踪时对其进行修改。现在,理解这个方法还调用callme服务公开的ping方法并返回整个响应是很重要的。
@GetMapping("/ping")
public String ping() {
Caller c = repository.save(new Caller(new Date(), podName));
String callme = callme();
return appName + "(id=" + c.getId() + "): " + podName + " in " + podNamespace
+ " is calling " + callme;
}
使用GraalVM准备Spring Boot本机映像
Spring Native支持使用GraalVM本机编译器将Spring应用程序编译为本机可执行文件。有关此项目的更多详细信息,请参阅其文档:https://docs.spring.io/spring-native/docs/current/reference/htmlsingle/
这是我们应用程序的主要类。
@SpringBootApplication
public class CallmeApplication {
public static void main(String[] args) {
SpringApplication.run(CallmeApplication.class, args);
}
}
Hibernate在运行时做很多动态的事情。因此,我们需要使用Hibernate在构建时增强应用程序中的实体。我们需要将以下Maven插件添加到我们的构建中。
<plugin>
<groupId>org.hibernate.orm.tooling</groupId>
<artifactId>hibernate-enhance-maven-plugin</artifactId>
<version>${hibernate.version}</version>
<executions>
<execution>
<configuration>
<failOnError>true</failOnError>
<enableLazyInitialization>true</enableLazyInitialization>
<enableDirtyTracking>true</enableDirtyTracking>
<enableExtendedEnhancement>false</enableExtendedEnhancement>
</configuration>
<goals>
<goal>enhance</goal>
</goals>
</execution>
</executions>
</plugin>
在本文中,我使用的是最新版本的Spring Native–0.9.0。因为springnative是积极开发的,所以后续版本之间有很大的变化。如果您将它与其他基于早期版本的文章进行比较,我们不必禁用proxyBeansMethods
、排除SpringDataWebAutoConfiguration
、将spring上下文索引器添加到依赖项或创建hibernate.properties
。酷!我还可以使用Buildpacks来构建本机映像。
所以,现在我们只需要添加以下依赖项。
<dependency>
<groupId>org.springframework.experimental</groupId>
<artifactId>spring-native</artifactId>
<version>0.9.0</version>
</dependency>
Spring AOT插件执行改进本机映像兼容性和占用空间所需的提前转换。
<plugin>
<groupId>org.springframework.experimental</groupId>
<artifactId>spring-aot-maven-plugin</artifactId>
<version>${spring.native.version}</version>
<executions>
<execution>
<id>test-generate</id>
<goals>
<goal>test-generate</goal>
</goals>
</execution>
<execution>
<id>generate</id>
<goals>
<goal>generate</goal>
</goals>
</execution>
</executions>
</plugin>
使用Buildpacks在Knative上运行本机映像
使用Builpacks创建本机映像是我们的主要选择。尽管它需要一个Docker守护进程,但它在每个操作系统上都能正常工作。但是,我们需要使用最新的稳定版本的springboot。在这种情况下,它是2.4.3。您还可以使用springbootmaven插件在Maven pom.xml
中配置Buildpacks。因为我们需要一步到位地在Kubernetes上构建和部署应用程序,所以我更喜欢Skaffold中的配置。我们使用PakeToBuildPack/builder:tiny
。还需要使用BP_BOOT_NATIVE_IMAGE
环境变量启用本机生成选项。
apiVersion: skaffold/v2beta11
kind: Config
metadata:
name: callme-service
build:
artifacts:
- image: piomin/callme-service
buildpacks:
builder: paketobuildpacks/builder:tiny
env:
- BP_BOOT_NATIVE_IMAGE=true
deploy:
kubectl:
manifests:
- k8s/ksvc.yaml
Skaffold配置引用了我们的Knative服务清单。这是非常不典型的,因为我们需要将pod和名称空间名称注入到容器中。我们还允许每个pod最多10个并发请求。如果超过此值,则可以放大许多正在运行的实例。
apiVersion: serving.knative.dev/v1
kind: Service
metadata:
name: callme-service
spec:
template:
spec:
containerConcurrency: 10
containers:
- name: callme
image: piomin/callme-service
ports:
- containerPort: 8080
env:
- name: POD_NAME
valueFrom:
fieldRef:
fieldPath: metadata.name
- name: POD_NAMESPACE
valueFrom:
fieldRef:
fieldPath: metadata.namespace
默认情况下,Knative不允许使用Kubernetes fieldRef特性。为了启用它,我们需要更新knative服务命名空间中的knative features ConfigMap。所需的属性名为kubernetes.podspec-fieldref
。
kind: ConfigMap
apiVersion: v1
metadata:
annotations:
namespace: knative-serving
labels:
serving.knative.dev/release: v0.16.0
data:
kubernetes.podspec-fieldref: enabled
最后,我们可以使用以下命令在Knative上构建和部署Spring-Boot微服务。
$ skaffold run
使用Jib在Knative上运行本机映像
与我上一篇关于Knative的文章一样,我们将使用Skaffold和Jib在Kubernetes上构建和运行我们的应用程序。幸运的是,jibmaven插件已经引入了对GraalVM“原生图像”的支持。Jib-GraalVM本机映像扩展期望本机映像maven插件完成生成“本机映像”(使用本机映像native-image:native-image). 然后扩展只需将二进制文件复制到容器映像中,并将其设置为可执行文件。
当然,与Java字节码不同,本机映像不是可移植的,而是特定于平台的。本机映像Maven插件不支持交叉编译,因此本机映像应该构建在与运行时体系结构相同的操作系统上。因为我在ubuntu20.10上构建了我的应用程序的GraalVM映像,所以我应该使用相同的基本Docker映像来运行容器化的微服务。在这种情况下,我选择了图像ubuntu:20.10 as 如下所示。
<plugin>
<groupId>com.google.cloud.tools</groupId>
<artifactId>jib-maven-plugin</artifactId>
<version>2.8.0</version>
<dependencies>
<dependency>
<groupId>com.google.cloud.tools</groupId>
<artifactId>jib-native-image-extension-maven</artifactId>
<version>0.1.0</version>
</dependency>
</dependencies>
<configuration>
<from>
<image>ubuntu:20.10</image>
</from>
<pluginExtensions>
<pluginExtension>
<implementation>com.google.cloud.tools.jib.maven.extension.nativeimage.JibNativeImageExtension</implementation>
</pluginExtension>
</pluginExtensions>
</configuration>
</plugin>
如果您使用jibmaven插件,首先需要构建一个本机映像。为了构建应用程序的本机映像,我们还需要包含一个本机映像maven插件。当然,您需要使用graalvmjdk构建我们的应用程序。
<plugin>
<groupId>org.graalvm.nativeimage</groupId>
<artifactId>native-image-maven-plugin</artifactId>
<version>21.0.0.2</version>
<executions>
<execution>
<goals>
<goal>native-image</goal>
</goals>
<phase>package</phase>
</execution>
</executions>
</plugin>
因此,本节的最后一部分只是运行Maven构建。在我的配置中,需要在本机映像配置文件下激活本机映像maven插件。
$ mvn clean package -Pnative-image
生成之后,callme服务的本机映像在目标目录中可见。
skafold的配置是典型的。我们只需要启用Jib作为构建工具。
apiVersion: skaffold/v2beta11
kind: Config
metadata:
name: callme-service
build:
artifacts:
- image: piomin/callme-service
jib: {}
deploy:
kubectl:
manifests:
- k8s/ksvc.yaml
最后,我们可以使用以下命令在Knative上构建和部署Spring-Boot微服务。
$ skaffold run
网络上微服务间的通信
我在Knative上部署了每个应用程序的两个修订版。作为比较,部署的应用程序的第一个版本是用OpenJDK编译的。只有最新版本是基于GraalVM本地映像的。因此,我们可以比较两个版本的启动时间。
让我们看看部署了两个版本的应用程序之后的修订列表。流量被分成60%到最新版本,40%到每个应用程序的前一版本。
在幕后,Knative创建了Kubernetes服务和多个部署。每次修订都有一个部署。此外,还有多个服务,但每次修订都有一个服务。该服务是ExternalName服务类型。假设您仍然希望在多个修订版之间分割流量,那么您应该在通信中完全使用该服务。服务的名称是callme service。但是,我们应该使用带有命名空间名称和svc.cluster.local
后缀的FQDN名称。
我们可以使用Spring RestTemplate来调用callme服务公开的端点。为了保证对整个请求路径的跟踪,我们需要在后续调用之间传播Zipkin头。对于通信,我们将使用具有完全限定的内部域名的服务(callme service.serverless.svc.cluster.local
),如前所述。
@RestController
@RequestMapping("/caller")
public class CallerController {
private RestTemplate restTemplate;
CallerController(RestTemplate restTemplate) {
this.restTemplate = restTemplate;
}
@Value("${spring.application.name}")
private String appName;
@Value("${POD_NAME}")
private String podName;
@Value("${POD_NAMESPACE}")
private String podNamespace;
@Autowired
private CallerRepository repository;
@GetMapping("/ping")
public String ping(@RequestHeader HttpHeaders headers) {
Caller c = repository.save(new Caller(new Date(), podName));
String callme = callme(headers);
return appName + "(id=" + c.getId() + "): " + podName + " in " + podNamespace
+ " is calling " + callme;
}
private String callme(HttpHeaders headers) {
MultiValueMap<String, String> map = new LinkedMultiValueMap<>();
Set<String> headerNames = headers.keySet();
headerNames.forEach(it -> map.put(it, headers.get(it)));
HttpEntity httpEntity = new HttpEntity(map);
ResponseEntity<String> entity = restTemplate
.exchange("http://callme-service.serverless.svc.cluster.local/callme/ping",
HttpMethod.GET, httpEntity, String.class);
return entity.getBody();
}
}
为了测试微服务之间的通信,我们只需要通过Knative路由调用调用方服务。
让我们对调用方服务GET/caller/ping
端点执行一些测试调用。我们应该使用网址http://caller-service-serverless.apps.cluster-d556.d556.sandbox262.opentlc.com/caller/ping
在第一个to requests caller服务中,调用最新版本的callme服务(用GraalVM编译)。在第三个请求中,它与旧版本的callme服务(用OpenJDK编译)通信。让我们比较一下同一应用程序的这两个版本的启动时间。
对于GraalVM,我们有0.3秒而不是5.9秒。我们还应该记住,我们的应用程序启动了一个内存中的嵌入式H2数据库。
用Jaeger配置跟踪
为了启用对Knative的跟踪,我们需要更新Knative服务命名空间中的Knative跟踪ConfigMap。当然,我们首先需要在集群中安装Jaeger。
apiVersion: operator.knative.dev/v1alpha1
kind: KnativeServing
metadata:
name: knative-tracing
namespace: knative-serving
spec:
sample-rate: "1"
backend: zipkin
zipkin-endpoint: http://jaeger-collector.knative-serving.svc.cluster.local:9411/api/v2/spans
debug: "false"
你也可以使用Helm来安装Jaeger。使用此选项,您需要执行以下Helm命令。
$ helm repo add jaegertracing https://jaegertracing.github.io/helm-charts
$ helm install jaeger jaegertracing/jaeger
Knative会自动创建Zipkin span头。我们唯一的目标是在调用方服务和callme服务应用程序之间传播HTTP报头。在我的配置中,Knative向Jaeger发送100%的跟踪。让我们看看knative微服务网格中GET/caller/ping
端点的一些跟踪。
我们还可以查看每个请求的详细视图。
结论
在Knative上运行微服务时,需要考虑以下几点。我把重点放在与沟通和追踪有关的方面。我还展示了SpringBoot不需要在几秒钟内启动。使用GraalVM,它可以在毫秒内启动,因此您可以肯定地将其视为一个无服务器serverless框架。
原文地址:https://piotrminkowski.com/2021/03/05/microservices-on-knative-with-spring-boot-and-graalvm/
除特别注明外,本站所有文章均为老K的Java博客原创,转载请注明出处来自https://javakk.com/2044.html
暂无评论