fix:修复java-agent注入时plugin.enable格式不对 (#165)

polarismesh · Jan 30, 2024 · 6c44f4b · 6c44f4b
1 parent 930b90a
commit 6c44f4b
Show file tree

Hide file tree

Showing 10 changed files with 214 additions and 5 deletions.
diff --git a/deploy/kubernetes_v1.21/helm/templates/controller-configmap-javaagent.yaml b/deploy/kubernetes_v1.21/helm/templates/controller-configmap-javaagent.yaml
@@ -104,4 +104,54 @@ data:
     # 指标上报监听端口
     spring.cloud.polaris.stat.port=0
     # 指标上报暴露的 http path
-    spring.cloud.polaris.stat.path=/metrics
+    spring.cloud.polaris.stat.path=/metrics
+
+  springcloudhoxton-default-properties: |+
+    # 应用名称
+    spring.application.name={{ .MicroserviceName }}
+    # 配置北极星服务端地址
+    spring.cloud.polaris.address=grpc\://{{ .PolarisServerIP }}\:{{ .PolarisDiscoverPort }}
+    spring.cloud.polaris.enabled=true
+    
+    # 启用 Java Agent 的 Spring Cloud Tencent 注册发现能力
+    spring.cloud.discovery.enabled=true
+    # 配置服务注册发现的命名空间信息
+    spring.cloud.polaris.discovery.namespace=default
+    # 启用从北极星
+    spring.cloud.polaris.discovery.enabled=true
+    spring.cloud.polaris.discovery.register=true
+    
+    ## 是否启用北极星的 LoadBalancer
+    spring.cloud.polaris.loadbalancer.enabled=true
+    #spring.cloud.polaris.loadbalancer.discoveryType=POLARIS
+    #spring.cloud.polaris.loadbalancer.strategy=random
+    
+    ## 是否启用北极星服务路由能力
+    spring.cloud.polaris.router.enabled=false
+    # 是否启用北极星的自定义路由能力
+    spring.cloud.polaris.router.rule-router.enabled=false
+    # 是否启用北极星的元数据路由能力
+    spring.cloud.polaris.router.metadata-router.enabled=false
+    # 是否启用北极星的就近路由能力
+    spring.cloud.polaris.router.nearby-router.enabled=false
+    
+    ## 是否启用北极星的服务限流能力
+    spring.cloud.polaris.ratelimit.enabled=false
+    # 设置触发限流时的提示信息
+    # spring.cloud.polaris.ratelimit.rejectRequestTips=""
+    # 设置触发限流时的响应码
+    spring.cloud.polaris.ratelimit.rejectHttpCode=429
+    # 设置限流匀速排队最大排队时间
+    spring.cloud.polaris.ratelimit.maxQueuingTime=1000
+    
+    ## RPC 调用增强
+    spring.cloud.tencent.rpc-enhancement.enabled=false
+    # 开启 RPC 调用结果上报
+    spring.cloud.tencent.rpc-enhancement.reporter.enabled=false
+    
+    # 配置北极星监控指标上报
+    spring.cloud.polaris.stat.enabled=false
+    # 指标上报监听端口
+    spring.cloud.polaris.stat.port=0
+    # 指标上报暴露的 http path
+    spring.cloud.polaris.stat.path=/metrics
diff --git a/deploy/kubernetes_v1.21/helm/templates/controller-statefulset.yaml b/deploy/kubernetes_v1.21/helm/templates/controller-statefulset.yaml
@@ -68,6 +68,8 @@ spec:
                 path: mesh-config
               - key: dns-config
                 path: dns-config
+              - key: java-agent-config
+                path: java-agent-config
               - key: values
                 path: values
         - name: config-volume

diff --git a/deploy/kubernetes_v1.21/kubernetes/javaagent-configmap.yaml b/deploy/kubernetes_v1.21/kubernetes/javaagent-configmap.yaml
@@ -104,4 +104,54 @@ data:
     # 指标上报监听端口
     spring.cloud.polaris.stat.port=0
     # 指标上报暴露的 http path
-    spring.cloud.polaris.stat.path=/metrics
+    spring.cloud.polaris.stat.path=/metrics
+
+  springcloudhoxton-default-properties: |+
+    # 应用名称
+    spring.application.name={{ .MicroserviceName }}
+    # 配置北极星服务端地址
+    spring.cloud.polaris.address=grpc\://{{ .PolarisServerIP }}\:{{ .PolarisDiscoverPort }}
+    spring.cloud.polaris.enabled=true
+    
+    # 启用 Java Agent 的 Spring Cloud Tencent 注册发现能力
+    spring.cloud.discovery.enabled=true
+    # 配置服务注册发现的命名空间信息
+    spring.cloud.polaris.discovery.namespace=default
+    # 启用从北极星
+    spring.cloud.polaris.discovery.enabled=true
+    spring.cloud.polaris.discovery.register=true
+    
+    ## 是否启用北极星的 LoadBalancer
+    spring.cloud.polaris.loadbalancer.enabled=true
+    #spring.cloud.polaris.loadbalancer.discoveryType=POLARIS
+    #spring.cloud.polaris.loadbalancer.strategy=random
+    
+    ## 是否启用北极星服务路由能力
+    spring.cloud.polaris.router.enabled=false
+    # 是否启用北极星的自定义路由能力
+    spring.cloud.polaris.router.rule-router.enabled=false
+    # 是否启用北极星的元数据路由能力
+    spring.cloud.polaris.router.metadata-router.enabled=false
+    # 是否启用北极星的就近路由能力
+    spring.cloud.polaris.router.nearby-router.enabled=false
+    
+    ## 是否启用北极星的服务限流能力
+    spring.cloud.polaris.ratelimit.enabled=false
+    # 设置触发限流时的提示信息
+    # spring.cloud.polaris.ratelimit.rejectRequestTips=""
+    # 设置触发限流时的响应码
+    spring.cloud.polaris.ratelimit.rejectHttpCode=429
+    # 设置限流匀速排队最大排队时间
+    spring.cloud.polaris.ratelimit.maxQueuingTime=1000
+    
+    ## RPC 调用增强
+    spring.cloud.tencent.rpc-enhancement.enabled=false
+    # 开启 RPC 调用结果上报
+    spring.cloud.tencent.rpc-enhancement.reporter.enabled=false
+    
+    # 配置北极星监控指标上报
+    spring.cloud.polaris.stat.enabled=false
+    # 指标上报监听端口
+    spring.cloud.polaris.stat.port=0
+    # 指标上报暴露的 http path
+    spring.cloud.polaris.stat.path=/metrics
diff --git a/deploy/kubernetes_v1.21/kubernetes/polaris-controller.yaml b/deploy/kubernetes_v1.21/kubernetes/polaris-controller.yaml
@@ -66,6 +66,8 @@ spec:
                 path: mesh-config
               - key: dns-config
                 path: dns-config
+              - key: java-agent-config
+                path: java-agent-config
               - key: values
                 path: values
         - name: config-volume

diff --git a/deploy/kubernetes_v1.22/helm/templates/controller-configmap-javaagent.yaml b/deploy/kubernetes_v1.22/helm/templates/controller-configmap-javaagent.yaml
@@ -104,4 +104,55 @@ data:
     # 指标上报监听端口
     spring.cloud.polaris.stat.port=0
     # 指标上报暴露的 http path
-    spring.cloud.polaris.stat.path=/metrics
+    spring.cloud.polaris.stat.path=/metrics
+
+  springcloudhoxton-default-properties: |+
+    # 应用名称
+    spring.application.name={{ .MicroserviceName }}
+    # 配置北极星服务端地址
+    spring.cloud.polaris.address=grpc\://{{ .PolarisServerIP }}\:{{ .PolarisDiscoverPort }}
+    spring.cloud.polaris.enabled=true
+    
+    # 启用 Java Agent 的 Spring Cloud Tencent 注册发现能力
+    spring.cloud.discovery.enabled=true
+    # 配置服务注册发现的命名空间信息
+    spring.cloud.polaris.discovery.namespace=default
+    # 启用从北极星
+    spring.cloud.polaris.discovery.enabled=true
+    spring.cloud.polaris.discovery.register=true
+    
+    ## 是否启用北极星的 LoadBalancer
+    spring.cloud.polaris.loadbalancer.enabled=true
+    #spring.cloud.polaris.loadbalancer.discoveryType=POLARIS
+    #spring.cloud.polaris.loadbalancer.strategy=random
+    
+    ## 是否启用北极星服务路由能力
+    spring.cloud.polaris.router.enabled=false
+    # 是否启用北极星的自定义路由能力
+    spring.cloud.polaris.router.rule-router.enabled=false
+    # 是否启用北极星的元数据路由能力
+    spring.cloud.polaris.router.metadata-router.enabled=false
+    # 是否启用北极星的就近路由能力
+    spring.cloud.polaris.router.nearby-router.enabled=false
+    
+    ## 是否启用北极星的服务限流能力
+    spring.cloud.polaris.ratelimit.enabled=false
+    # 设置触发限流时的提示信息
+    # spring.cloud.polaris.ratelimit.rejectRequestTips=""
+    # 设置触发限流时的响应码
+    spring.cloud.polaris.ratelimit.rejectHttpCode=429
+    # 设置限流匀速排队最大排队时间
+    spring.cloud.polaris.ratelimit.maxQueuingTime=1000
+    
+    ## RPC 调用增强
+    spring.cloud.tencent.rpc-enhancement.enabled=false
+    # 开启 RPC 调用结果上报
+    spring.cloud.tencent.rpc-enhancement.reporter.enabled=false
+    
+    # 配置北极星监控指标上报
+    spring.cloud.polaris.stat.enabled=false
+    # 指标上报监听端口
+    spring.cloud.polaris.stat.port=0
+    # 指标上报暴露的 http path
+    spring.cloud.polaris.stat.path=/metrics
+
diff --git a/deploy/kubernetes_v1.22/helm/templates/controller-statefulset.yaml b/deploy/kubernetes_v1.22/helm/templates/controller-statefulset.yaml
@@ -68,6 +68,8 @@ spec:
                 path: mesh-config
               - key: dns-config
                 path: dns-config
+              - key: java-agent-config
+                path: java-agent-config
               - key: values
                 path: values
         - name: config-volume

diff --git a/deploy/kubernetes_v1.22/kubernetes/javaagent-configmap.yaml b/deploy/kubernetes_v1.22/kubernetes/javaagent-configmap.yaml
@@ -99,6 +99,56 @@ data:
     # 开启 RPC 调用结果上报
     spring.cloud.tencent.rpc-enhancement.reporter.enabled=false
     
+    # 配置北极星监控指标上报
+    spring.cloud.polaris.stat.enabled=false
+    # 指标上报监听端口
+    spring.cloud.polaris.stat.port=0
+    # 指标上报暴露的 http path
+    spring.cloud.polaris.stat.path=/metrics
+
+  springcloudhoxton-default-properties: |+
+    # 应用名称
+    spring.application.name={{ .MicroserviceName }}
+    # 配置北极星服务端地址
+    spring.cloud.polaris.address=grpc\://{{ .PolarisServerIP }}\:{{ .PolarisDiscoverPort }}
+    spring.cloud.polaris.enabled=true
+    
+    # 启用 Java Agent 的 Spring Cloud Tencent 注册发现能力
+    spring.cloud.discovery.enabled=true
+    # 配置服务注册发现的命名空间信息
+    spring.cloud.polaris.discovery.namespace=default
+    # 启用从北极星
+    spring.cloud.polaris.discovery.enabled=true
+    spring.cloud.polaris.discovery.register=true
+    
+    ## 是否启用北极星的 LoadBalancer
+    spring.cloud.polaris.loadbalancer.enabled=true
+    #spring.cloud.polaris.loadbalancer.discoveryType=POLARIS
+    #spring.cloud.polaris.loadbalancer.strategy=random
+    
+    ## 是否启用北极星服务路由能力
+    spring.cloud.polaris.router.enabled=false
+    # 是否启用北极星的自定义路由能力
+    spring.cloud.polaris.router.rule-router.enabled=false
+    # 是否启用北极星的元数据路由能力
+    spring.cloud.polaris.router.metadata-router.enabled=false
+    # 是否启用北极星的就近路由能力
+    spring.cloud.polaris.router.nearby-router.enabled=false
+    
+    ## 是否启用北极星的服务限流能力
+    spring.cloud.polaris.ratelimit.enabled=false
+    # 设置触发限流时的提示信息
+    # spring.cloud.polaris.ratelimit.rejectRequestTips=""
+    # 设置触发限流时的响应码
+    spring.cloud.polaris.ratelimit.rejectHttpCode=429
+    # 设置限流匀速排队最大排队时间
+    spring.cloud.polaris.ratelimit.maxQueuingTime=1000
+    
+    ## RPC 调用增强
+    spring.cloud.tencent.rpc-enhancement.enabled=false
+    # 开启 RPC 调用结果上报
+    spring.cloud.tencent.rpc-enhancement.reporter.enabled=false
+    
     # 配置北极星监控指标上报
     spring.cloud.polaris.stat.enabled=false
     # 指标上报监听端口

diff --git a/deploy/kubernetes_v1.22/kubernetes/polaris-controller.yaml b/deploy/kubernetes_v1.22/kubernetes/polaris-controller.yaml
@@ -122,6 +122,8 @@ spec:
                 path: mesh-config
               - key: dns-config
                 path: dns-config
+              - key: java-agent-config
+                path: java-agent-config
               - key: values
                 path: values
         - name: config-volume

diff --git a/pkg/inject/pkg/kube/inject/apply/javaagent/patch.go b/pkg/inject/pkg/kube/inject/apply/javaagent/patch.go
@@ -99,7 +99,7 @@ func (pb *PodPatchBuilder) handleJavaAgentInit(opt *inject.PatchOptions, pod *co
 	}
 	add.Env = append(add.Env, corev1.EnvVar{
 		Name:  "JAVA_AGENT_PLUGIN_TYPE",
-		Value: pluginType,
+		Value: "plugins.enable=" + pluginType,
 	})
 	kubeClient := opt.KubeClient
 	pluginCm, err := kubeClient.CoreV1().ConfigMaps(util.RootNamespace).Get(context.Background(),

diff --git a/pkg/inject/pkg/kube/inject/webhook.go b/pkg/inject/pkg/kube/inject/webhook.go
@@ -586,7 +586,7 @@ func (wh *Webhook) createPatch(sidecarMode utils.SidecarMode, pod *corev1.Pod, p
 
 	patchBuilder, ok := _PatchBuilders[utils.ParseSidecarModeName(sidecarMode)]
 	if !ok {
-		return nil, errors.NewInternalError(fmt.Errorf("sidecar-mode %s not found target patch builder", sidecarMode))
+		return nil, errors.NewInternalError(fmt.Errorf("sidecar-mode %+v not found target patch builder", sidecarMode))
 	}
 	if sidecarMode != utils.SidecarForMesh {
 		delete(annotations, utils.SidecarEnvoyMetadata)