这篇文章主要给大家介绍了关于微服务领域Spring Boot自动伸缩的实现方法，文中通过示例代码介绍的非常详细，对大家学习或者使用spring boot具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧前言 spring boot spring boot actuator spring cloud netflix eureka jenkins ci 它是如何工作的 动态端口分配 spring:
application:
name: example-service
server:
port: ${port:0}
eureka:
instance:
instanceid: ${spring.cloud.client.hostname}:${spring.application.name}:${random.int[1,999999]}启用actuator的metric <dependency>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-starter-actuator</artifactid>
</dependency>优雅地停止应用程序 启用eureka自动发现 <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-netflix-eureka-server</artifactid>
</dependency>@springbootapplication
@enableeurekaserver
public class discoveryapp {
public static void main(string[] args) {
new springapplicationbuilder(discoveryapp.class).run(args);
}
}spring:
application:
name: discovery-service
server:
port: ${port:8761}
eureka:
instance:
hostname: localhost
client:
registerwitheureka: false
fetchregistry: false
serviceurl:
defaultzone: http://localhost:8761/eureka/from openjdk:8-jre-alpine
env app_file discovery-service-1.0-snapshot.jar
env app_home /usr/apps
expose 8761
copy target/$app_file $app_home/
workdir $app_home
entrypoint ["sh", "-c"]
cmd ["exec java -jar $app_file"]为弹性伸缩构建一个jenkins流水线 pipeline {
agent any
triggers {
cron('* * * * *')
}
environment {
service_name = "example-service"
metrics_endpoint = "/actuator/metrics/tomcat.threads.busy?tag=name:http-nio-auto-1"
shutdown_endpoint = "/actuator/shutdown"
}
stages { ... }
}使用eureka整合jenkins流水线 stage('calculate') {
steps {
script {
def response = httprequest "http://192.168.99.100:8761/eureka/apps/${env.service_name}"
def app = printxml(response.content)
def index = 0
env["instance_count"] = app.instance.size()
app.instance.each {
if (it.status == 'up') {
def address = "http://${it.ipaddr}:${it.port}"
env["instance_${index++}"] = address
}
}
}
}
}
@noncps
def printxml(string text) {
return new xmlslurper(false, false).parsetext(text)
}使用spring boot actuator整合jenkins流水线 stage('metrics') {
steps {
script {
def count = env.instance_count
for(def i=0;i 100)
return "up"
else if (value.tointeger() < 20)
return "down"
else
return "none"
}关闭应用程序实例 stage('scaling') {
steps {
script {
if (env.scale_type == 'down') {
def ip = env["instance_0"] + env.shutdown_endpoint
httprequest url: ip, contenttype: 'application_json', httpmode: 'post'
} else if (env.scale_type == 'up') {
build job: 'spring-boot-run-pipeline'
}
currentbuild.description = env.scale_type
}
}
}pipeline {
agent any
tools {
maven 'm3'
}
stages {
stage('checkout') {
steps {
git url: 'https://github.com/piomin/sample-spring-boot-autoscaler.git', credentialsid: 'github-piomin', branch: 'master'
}
}
stage('build') {
steps {
dir('example-service') {
sh 'mvn clean package'
}
}
}
stage('run') {
steps {
dir('example-service') {
sh 'nohup java -jar -deureka_url=http://192.168.99.100:8761/eureka target/example-service-1.0-snapshot.jar 1>/dev/null 2>logs/runlog &'
}
}
}
}
}扩展到多个机器 build job:'spring-boot-run-pipeline', parameters:[string(name: 'agent', value:"slave-1")]pipeline {
agent {
label "${params.agent}"
}
stages { ... }
}pipeline {
agent any
triggers {
cron('* * * * *')
}
environment {
service_name = "example-service"
metrics_endpoint = "/actuator/metrics/tomcat.threads.busy?tag=name:http-nio-auto-1"
shutdown_endpoint = "/actuator/shutdown"
agent_192.168.99.102 = "slave-1"
agent_192.168.99.103 = "slave-2"
}
stages { ... }
}总结 CodeAE代码之家 的支持。 
编程语言
发布于：2021-10-08 12:08
|
阅读数：382
|
评论：0
QQ好友和群
QQ空间
