高可用配置中心

admin-service/pom.xml

@@ -69,6 +69,10 @@
             <groupId>org.jolokia</groupId>
             <artifactId>jolokia-core</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
+        </dependency>
     </dependencies>
 
     <build>

admin-service/src/main/java/com/diagbot/AdminServiceApplication.java

@@ -6,6 +6,7 @@ import de.codecentric.boot.admin.server.config.EnableAdminServer;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.context.config.annotation.RefreshScope;
 import org.springframework.cloud.netflix.hystrix.EnableHystrix;
 import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
 import org.springframework.cloud.netflix.turbine.EnableTurbine;
@@ -27,6 +28,7 @@ import org.springframework.security.web.authentication.SavedRequestAwareAuthenti
 @EnableAdminServer
 @Configuration
 @EnableAutoConfiguration
+@RefreshScope
 public class AdminServiceApplication {
 
     public static void main(String[] args) {

admin-service/src/main/resources/bootstrap.yml

@@ -3,11 +3,19 @@ spring:
     name: admin-service
   cloud:
     config:
-      uri: http://${myuri}:8769
+#      uri: http://${myuri}:8769
       fail-fast: true
+      discovery:
+        enabled: true
+        serviceId: config-server
   profiles:
       active: local
 
+eureka:
+  client:
+    serviceUrl:
+      defaultZone: http://${myuri}:8761/eureka/
+
 myuri: localhost
 
 

bi-service/pom.xml

@@ -113,6 +113,11 @@
             <artifactId>logstash-logback-encoder</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
+        </dependency>
+
         <!-- mybatis-plus begin -->
         <dependency>
             <groupId>com.baomidou</groupId>

bi-service/src/main/java/com/diagbot/BiServiceApplication.java

@@ -3,6 +3,7 @@ package com.diagbot;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
+import org.springframework.cloud.context.config.annotation.RefreshScope;
 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
 import org.springframework.cloud.netflix.hystrix.EnableHystrix;
 import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
@@ -19,6 +20,7 @@ import org.springframework.cloud.openfeign.EnableFeignClients;
 @EnableHystrixDashboard
 @EnableHystrix
 @EnableCircuitBreaker
+@RefreshScope
 public class BiServiceApplication {
 
     public static void main(String[] args) {

bi-service/src/main/resources/bootstrap.yml

@@ -3,9 +3,17 @@ spring:
     name: bi-service
   cloud:
     config:
-      uri: http://${myuri}:8769
+#      uri: http://${myuri}:8769
       fail-fast: true
+      discovery:
+        enabled: true
+        serviceId: config-server
   profiles:
       active: local
 
+eureka:
+  client:
+    serviceUrl:
+      defaultZone: http://${myuri}:8761/eureka/
+
 myuri: localhost

config-server/src/main/resources/application.yml

@@ -21,6 +21,14 @@ spring:
      active: native
   application:
     name: config-server
+  #mq
+  rabbitmq:
+    host: localhost
+    port: 5672
+    username: guest
+    password: guest
+    publisher-confirms: true
+    virtual-host: /
 
 # port
 server:

config-server/src/main/resources/shared/admin-service-dev.yml

@@ -22,6 +22,14 @@ spring:
 #    user:
 #      name: ${security2.user.name}
 #      password: ${security2.user.password}
+  #mq
+  rabbitmq:
+    host: 192.168.2.236
+    port: 5672
+    username: lantone
+    password: lantone
+    publisher-confirms: true
+    virtual-host: /
 
 eureka:
   instance:

config-server/src/main/resources/shared/admin-service-local.yml

@@ -22,6 +22,14 @@ spring:
 #    user:
 #      name: ${security2.user.name}
 #      password: ${security2.user.password}
+  #mq
+  rabbitmq:
+    host: localhost
+    port: 5672
+    username: guest
+    password: guest
+    publisher-confirms: true
+    virtual-host: /
 
 eureka:
   instance:

config-server/src/main/resources/shared/admin-service-pro.yml

@@ -22,6 +22,14 @@ spring:
     user:
       name: ${security2.user.name}
       password: ${security2.user.password}
+  #mq
+  rabbitmq:
+    host: 192.168.2.236
+    port: 5672
+    username: lantone
+    password: lantone
+    publisher-confirms: true
+    virtual-host: /
 
 eureka:
   instance:

config-server/src/main/resources/shared/application-dev.yml

@@ -18,8 +18,8 @@ eureka:
     health-check-url-path: /actuator/health #2.0后actuator的地址发生了变化
   client:
     registryFetchIntervalSeconds: 5
-    serviceUrl:
-      defaultZone: http://eureka1:8761/eureka/
+#    serviceUrl:
+#      defaultZone: http://eureka1:8761/eureka/
 
 #endpoints:
 #  health:

config-server/src/main/resources/shared/application-local.yml

@@ -18,8 +18,8 @@ eureka:
     health-check-url-path: /actuator/health #2.0后actuator的地址发生了变化
   client:
     registryFetchIntervalSeconds: 5
-    serviceUrl:
-      defaultZone: http://localhost:8761/eureka/
+#    serviceUrl:
+#      defaultZone: http://localhost:8761/eureka/
 
 #endpoints:
 #  health:

diagbotman-service/pom.xml

@@ -113,6 +113,11 @@
             <artifactId>logstash-logback-encoder</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
+        </dependency>
+
         <!-- mybatis-plus begin -->
         <dependency>
             <groupId>com.baomidou</groupId>

diagbotman-service/src/main/java/com/diagbot/DiagbotmanServiceApplication.java

@@ -3,6 +3,7 @@ package com.diagbot;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
+import org.springframework.cloud.context.config.annotation.RefreshScope;
 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
 import org.springframework.cloud.netflix.hystrix.EnableHystrix;
 import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
@@ -19,6 +20,7 @@ import org.springframework.cloud.openfeign.EnableFeignClients;
 @EnableHystrixDashboard
 @EnableHystrix
 @EnableCircuitBreaker
+@RefreshScope
 public class DiagbotmanServiceApplication {
 
     public static void main(String[] args) {

diagbotman-service/src/main/resources/bootstrap.yml

@@ -3,9 +3,17 @@ spring:
     name: diagbotman-service
   cloud:
     config:
-      uri: http://${myuri}:8769
+#      uri: http://${myuri}:8769
       fail-fast: true
+      discovery:
+        enabled: true
+        serviceId: config-server
   profiles:
       active: local
 
-myuri: localhost
+eureka:
+  client:
+    serviceUrl:
+      defaultZone: http://${myuri}:8761/eureka/
+
+myuri: localhost

docker-compose.yml

@@ -37,7 +37,7 @@ services:
 #      - "data/diagbotcloud/logs:/logs"
     environment:
       - spring.profiles.active=dev
-      - myuri=config1
+      - myuri=eureka1
     restart: always
   user-service:
     image: 192.168.2.236:5000/diagbotcloud/user-service:0.0.1-SNAPSHOT
@@ -49,7 +49,7 @@ services:
 #      - "data/diagbotcloud/logs:/logs"
     environment:
       - spring.profiles.active=dev
-      - myuri=config1
+      - myuri=eureka1
     restart: always
   log-service:
     image: 192.168.2.236:5000/diagbotcloud/log-service:0.0.1-SNAPSHOT
@@ -61,7 +61,7 @@ services:
 #      - "data/diagbotcloud/logs:/logs"
     environment:
       - spring.profiles.active=dev
-      - myuri=config1
+      - myuri=eureka1
     restart: always
   monitor-service:
     image: 192.168.2.236:5000/diagbotcloud/monitor-service:0.0.1-SNAPSHOT
@@ -77,7 +77,7 @@ services:
       - "8766:8766"
     environment:
       - spring.profiles.active=dev
-      - myuri=config1
+      - myuri=eureka1
     restart: always
   admin-service:
     image: 192.168.2.236:5000/diagbotcloud/admin-service:0.0.1-SNAPSHOT
@@ -91,7 +91,7 @@ services:
       - "9998:9998"
     environment:
       - spring.profiles.active=dev
-      - myuri=config1
+      - myuri=eureka1
     restart: always
   gateway-service:
     image: 192.168.2.236:5000/diagbotcloud/gateway-service:0.0.1-SNAPSHOT
@@ -106,5 +106,5 @@ services:
       - "5050:5050"
     environment:
       - spring.profiles.active=dev
-      - myuri=config1
+      - myuri=eureka1
     restart: always

feedback-service/pom.xml

@@ -113,6 +113,11 @@
             <artifactId>logstash-logback-encoder</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
+        </dependency>
+
         <!-- mybatis-plus begin -->
         <dependency>
             <groupId>com.baomidou</groupId>

feedback-service/src/main/java/com/diagbot/FeedbackServiceApplication.java

@@ -3,6 +3,7 @@ package com.diagbot;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
+import org.springframework.cloud.context.config.annotation.RefreshScope;
 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
 import org.springframework.cloud.netflix.hystrix.EnableHystrix;
 import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
@@ -19,6 +20,7 @@ import org.springframework.cloud.openfeign.EnableFeignClients;
 @EnableHystrixDashboard
 @EnableHystrix
 @EnableCircuitBreaker
+@RefreshScope
 public class FeedbackServiceApplication {
 
     public static void main(String[] args) {

feedback-service/src/main/resources/bootstrap.yml

@@ -3,9 +3,17 @@ spring:
     name: feedback-service
   cloud:
     config:
-      uri: http://${myuri}:8769
+#      uri: http://${myuri}:8769
       fail-fast: true
+      discovery:
+        enabled: true
+        serviceId: config-server
   profiles:
       active: local
 
+eureka:
+  client:
+    serviceUrl:
+      defaultZone: http://${myuri}:8761/eureka/
+
 myuri: localhost

gateway-service/pom.xml

@@ -42,6 +42,11 @@
             <artifactId>logstash-logback-encoder</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
+        </dependency>
+
         <!--swagger-->
         <dependency>
             <groupId>io.springfox</groupId>

gateway-service/src/main/java/com/diagbot/GatewayServiceApplication.java

@@ -2,6 +2,7 @@ package com.diagbot;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.context.config.annotation.RefreshScope;
 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
 import org.springframework.cloud.netflix.zuul.EnableZuulProxy;
 
@@ -13,6 +14,7 @@ import org.springframework.cloud.netflix.zuul.EnableZuulProxy;
 @SpringBootApplication
 @EnableZuulProxy
 @EnableEurekaClient
+@RefreshScope
 public class GatewayServiceApplication {
 
     public static void main(String[] args) {

gateway-service/src/main/resources/bootstrap.yml

@@ -3,12 +3,19 @@ spring:
     name: gateway-service
   cloud:
     config:
-      uri: http://${myuri}:8769
+#      uri: http://${myuri}:8769
       fail-fast: true
+      discovery:
+        enabled: true
+        serviceId: config-server
   profiles:
       active: local
 
-myuri: localhost
+eureka:
+  client:
+    serviceUrl:
+      defaultZone: http://${myuri}:8761/eureka/
 
+myuri: localhost
 
 

knowledge-service/pom.xml

@@ -113,6 +113,11 @@
             <artifactId>logstash-logback-encoder</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
+        </dependency>
+
         <!-- mybatis-plus begin -->
         <dependency>
             <groupId>com.baomidou</groupId>

knowledge-service/src/main/java/com/diagbot/KnowledgeServiceApplication.java

@@ -3,6 +3,7 @@ package com.diagbot;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
+import org.springframework.cloud.context.config.annotation.RefreshScope;
 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
 import org.springframework.cloud.netflix.hystrix.EnableHystrix;
 import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
@@ -14,6 +15,7 @@ import org.springframework.cloud.openfeign.EnableFeignClients;
 @EnableHystrixDashboard
 @EnableHystrix
 @EnableCircuitBreaker
+@RefreshScope
 public class KnowledgeServiceApplication {
 
     public static void main(String[] args) {

knowledge-service/src/main/resources/bootstrap.yml

@@ -3,9 +3,17 @@ spring:
     name: knowledge-service
   cloud:
     config:
-      uri: http://${myuri}:8769
+#      uri: http://${myuri}:8769
       fail-fast: true
+      discovery:
+        enabled: true
+        serviceId: config-server
   profiles:
       active: local
 
+eureka:
+  client:
+    serviceUrl:
+      defaultZone: http://${myuri}:8761/eureka/
+
 myuri: localhost

log-service/pom.xml

@@ -113,6 +113,11 @@
             <artifactId>logstash-logback-encoder</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
+        </dependency>
+
         <!-- mybatis-plus begin -->
         <dependency>
             <groupId>com.baomidou</groupId>

log-service/src/main/java/com/diagbot/LogServiceApplication.java

@@ -3,6 +3,7 @@ package com.diagbot;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
+import org.springframework.cloud.context.config.annotation.RefreshScope;
 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
 import org.springframework.cloud.netflix.hystrix.EnableHystrix;
 import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
@@ -19,6 +20,7 @@ import org.springframework.cloud.openfeign.EnableFeignClients;
 @EnableHystrix
 @EnableHystrixDashboard
 @EnableCircuitBreaker
+@RefreshScope
 public class LogServiceApplication {
 
 	public static void main(String[] args) {

log-service/src/main/resources/bootstrap.yml

@@ -3,9 +3,17 @@ spring:
     name: logger-service
   cloud:
     config:
-      uri: http://${myuri}:8769
+#      uri: http://${myuri}:8769
       fail-fast: true
+      discovery:
+        enabled: true
+        serviceId: config-server
   profiles:
       active: local
 
+eureka:
+  client:
+    serviceUrl:
+      defaultZone: http://${myuri}:8761/eureka/
+
 myuri: localhost

monitor-service/pom.xml

@@ -51,6 +51,10 @@
             <artifactId>logstash-logback-encoder</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
+        </dependency>
     </dependencies>
 
     <build>

monitor-service/src/main/java/com/diagbot/MonitorServiceApplication.java

@@ -3,6 +3,7 @@ package com.diagbot;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
+import org.springframework.cloud.context.config.annotation.RefreshScope;
 import org.springframework.cloud.netflix.hystrix.EnableHystrix;
 import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
 import org.springframework.cloud.netflix.turbine.EnableTurbine;
@@ -12,6 +13,7 @@ import org.springframework.cloud.netflix.turbine.EnableTurbine;
 @EnableHystrixDashboard
 @EnableHystrix
 @EnableCircuitBreaker
+@RefreshScope
 public class MonitorServiceApplication {
 
     public static void main(String[] args) {

uaa-service/pom.xml

@@ -65,6 +65,10 @@
             <groupId>net.logstash.logback</groupId>
             <artifactId>logstash-logback-encoder</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
+        </dependency>
 
         <!-- mybatis-plus begin -->
         <dependency>

uaa-service/src/main/java/com/diagbot/UaaServiceApplication.java

@@ -2,10 +2,12 @@ package com.diagbot;
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.context.config.annotation.RefreshScope;
 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
 
 @SpringBootApplication
 @EnableEurekaClient
+@RefreshScope
 public class UaaServiceApplication {
 
 	public static void main(String[] args) {

uaa-service/src/main/resources/bootstrap.yml

@@ -3,11 +3,19 @@ spring:
     name: uaa-service
   cloud:
     config:
-      uri: http://${myuri}:8769
+#      uri: http://${myuri}:8769
       fail-fast: true
+      discovery:
+        enabled: true
+        serviceId: config-server
   profiles:
       active: local
 
+eureka:
+  client:
+    serviceUrl:
+      defaultZone: http://${myuri}:8761/eureka/
+
 myuri: localhost
 
 management:

user-service/pom.xml

@@ -113,6 +113,11 @@
             <artifactId>logstash-logback-encoder</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-bus-amqp</artifactId>
+        </dependency>
+
         <!-- mybatis-plus begin -->
         <dependency>
             <groupId>com.baomidou</groupId>

user-service/src/main/java/com/diagbot/UserServiceApplication.java

@@ -5,6 +5,7 @@ import org.springframework.beans.factory.annotation.Value;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.cloud.client.circuitbreaker.EnableCircuitBreaker;
+import org.springframework.cloud.context.config.annotation.RefreshScope;
 import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
 import org.springframework.cloud.netflix.hystrix.EnableHystrix;
 import org.springframework.cloud.netflix.hystrix.dashboard.EnableHystrixDashboard;
@@ -25,6 +26,7 @@ import org.springframework.web.bind.annotation.RestController;
 @EnableHystrixDashboard
 @EnableHystrix
 @EnableCircuitBreaker
+@RefreshScope
 public class UserServiceApplication {
 
 	public static void main(String[] args) {

user-service/src/main/resources/bootstrap.yml

@@ -3,9 +3,17 @@ spring:
     name: user-service
   cloud:
     config:
-      uri: http://${myuri}:8769
+#      uri: http://${myuri}:8769
       fail-fast: true
+      discovery:
+        enabled: true
+        serviceId: config-server
   profiles:
       active: local
 
+eureka:
+  client:
+    serviceUrl:
+      defaultZone: http://${myuri}:8761/eureka/
+
 myuri: localhost