From 10937b5f19246bd11bcd82b68dd097bfd7360794 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=98=AD=E9=A3=9E?= <zhaofei.zzx@alibaba-inc.com>
Date: Wed, 16 Aug 2023 14:04:16 +0800
Subject: [PATCH 1/2] fix schedule task print old value of name when nacos
config update
---
.../alibabacloud/mse/demo/AController.java | 7 +++---
.../alibabacloud/mse/demo/bean/Consumer.java | 24 +++++++++++++++++++
2 files changed, 28 insertions(+), 3 deletions(-)
create mode 100644 mse-quickstart-demo/consumer/src/main/java/com/alibabacloud/mse/demo/bean/Consumer.java
diff --git a/mse-quickstart-demo/consumer/src/main/java/com/alibabacloud/mse/demo/AController.java b/mse-quickstart-demo/consumer/src/main/java/com/alibabacloud/mse/demo/AController.java
index 94786c77..f360d6c9 100644
--- a/mse-quickstart-demo/consumer/src/main/java/com/alibabacloud/mse/demo/AController.java
+++ b/mse-quickstart-demo/consumer/src/main/java/com/alibabacloud/mse/demo/AController.java
@@ -1,5 +1,6 @@
package com.alibabacloud.mse.demo;
+import com.alibabacloud.mse.demo.bean.Consumer;
import com.alibabacloud.mse.demo.service.HelloServiceB;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.beans.factory.annotation.Autowired;
@@ -26,9 +27,9 @@ public class AController {
@Reference(application = "${dubbo.application.id}", version = "1.0.0")
private HelloServiceB helloServiceB;
- @Value("${name:123}")
- private String name;
+ @Autowired
+ private Consumer consumer;
@Autowired
RestTemplate restTemplate;
@@ -50,7 +51,7 @@ private void printConfig() {
EXECUTOR_SERVICE.scheduleWithFixedDelay(new Runnable() {
@Override
public void run() {
- System.out.println(name);
+ System.out.println(consumer.getName());
}
},0,2, TimeUnit.SECONDS);
}
diff --git a/mse-quickstart-demo/consumer/src/main/java/com/alibabacloud/mse/demo/bean/Consumer.java b/mse-quickstart-demo/consumer/src/main/java/com/alibabacloud/mse/demo/bean/Consumer.java
new file mode 100644
index 00000000..6f821df7
--- /dev/null
+++ b/mse-quickstart-demo/consumer/src/main/java/com/alibabacloud/mse/demo/bean/Consumer.java
@@ -0,0 +1,24 @@
+package com.alibabacloud.mse.demo.bean;
+
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.cloud.context.config.annotation.RefreshScope;
+import org.springframework.stereotype.Component;
+
+/**
+ * @Author : zhaofei
+ * @create 2023/8/16 14:00
+ */
+@Component
+@RefreshScope
+@ConfigurationProperties()
+public class Consumer {
+ private String name = "123";
+
+ public String getName() {
+ return name;
+ }
+
+ public void setName(String name) {
+ this.name = name;
+ }
+}
From 538f64c4b905a5bd67fbed957ed2aa8fa6c672ac Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=98=AD=E9=A3=9E?= <zhaozx@nuaa.edu.cn>
Date: Wed, 16 Aug 2023 14:20:48 +0800
Subject: [PATCH 2/2] update user
---
.../main/java/com/alibabacloud/mse/demo/bean/Consumer.java | 4 ----
1 file changed, 4 deletions(-)
diff --git a/mse-quickstart-demo/consumer/src/main/java/com/alibabacloud/mse/demo/bean/Consumer.java b/mse-quickstart-demo/consumer/src/main/java/com/alibabacloud/mse/demo/bean/Consumer.java
index 6f821df7..f929c467 100644
--- a/mse-quickstart-demo/consumer/src/main/java/com/alibabacloud/mse/demo/bean/Consumer.java
+++ b/mse-quickstart-demo/consumer/src/main/java/com/alibabacloud/mse/demo/bean/Consumer.java
@@ -4,10 +4,6 @@
import org.springframework.cloud.context.config.annotation.RefreshScope;
import org.springframework.stereotype.Component;
-/**
- * @Author : zhaofei
- * @create 2023/8/16 14:00
- */
@Component
@RefreshScope
@ConfigurationProperties()