Spring Cloud构建微服务架构（七）消息总线(Rabbit、Kafka)

deadliving · Oct 2, 2016 · 98248ab · 98248ab
1 parent 769276c
commit 98248ab
Show file tree

Hide file tree

Showing 11 changed files with 234 additions and 0 deletions.
diff --git a/Chapter1-1-7/config-client-eureka-kafka/pom.xml b/Chapter1-1-7/config-client-eureka-kafka/pom.xml
@@ -0,0 +1,78 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+
+	<groupId>com.didispace</groupId>
+	<artifactId>config-client-eureka-kafka</artifactId>
+	<version>1.0.0</version>
+	<packaging>jar</packaging>
+
+	<name>config-client-eureka-kafka</name>
+	<description>Spring Cloud project</description>
+
+	<parent>
+		<groupId>org.springframework.boot</groupId>
+		<artifactId>spring-boot-starter-parent</artifactId>
+		<version>1.3.7.RELEASE</version>
+		<relativePath/> <!-- lookup parent from repository -->
+	</parent>
+
+	<properties>
+		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+		<java.version>1.8</java.version>
+	</properties>
+
+	<dependencies>
+		<dependency>
+			<groupId>org.springframework.retry</groupId>
+			<artifactId>spring-retry</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-web</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-aop</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.boot</groupId>
+			<artifactId>spring-boot-starter-actuator</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-config</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-eureka</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-bus-kafka</artifactId>
+		</dependency>
+	</dependencies>
+
+	<dependencyManagement>
+		<dependencies>
+			<dependency>
+				<groupId>org.springframework.cloud</groupId>
+				<artifactId>spring-cloud-dependencies</artifactId>
+				<version>Brixton.SR5</version>
+				<type>pom</type>
+				<scope>import</scope>
+			</dependency>
+		</dependencies>
+	</dependencyManagement>
+
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.springframework.boot</groupId>
+				<artifactId>spring-boot-maven-plugin</artifactId>
+			</plugin>
+		</plugins>
+	</build>
+
+</project>
diff --git a/Chapter1-1-7/config-client-eureka-kafka/src/main/java/com/didispace/Application.java b/Chapter1-1-7/config-client-eureka-kafka/src/main/java/com/didispace/Application.java
@@ -0,0 +1,15 @@
+package com.didispace;
+
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.builder.SpringApplicationBuilder;
+import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+
+@EnableDiscoveryClient
+@SpringBootApplication
+public class Application {
+
+	public static void main(String[] args) {
+		new SpringApplicationBuilder(Application.class).web(true).run(args);
+	}
+
+}
diff --git a/Chapter1-1-7/config-client-eureka-kafka/src/main/java/com/didispace/web/TestController.java b/Chapter1-1-7/config-client-eureka-kafka/src/main/java/com/didispace/web/TestController.java
@@ -0,0 +1,28 @@
+package com.didispace.web;
+
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.cloud.context.config.annotation.RefreshScope;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RefreshScope
+@RestController
+public class TestController {
+
+    @Value("${from}")
+    private String from;
+
+    @RequestMapping("/from")
+    public String from() {
+        return this.from;
+    }
+
+    public void setFrom(String from) {
+        this.from = from;
+    }
+
+    public String getFrom() {
+        return from;
+    }
+
+}
diff --git a/Chapter1-1-7/config-client-eureka-kafka/src/main/resources/bootstrap.properties b/Chapter1-1-7/config-client-eureka-kafka/src/main/resources/bootstrap.properties
@@ -0,0 +1,16 @@
+spring.application.name=didispace
+server.port=7002
+
+eureka.client.serviceUrl.defaultZone=http://localhost:1111/eureka/
+
+spring.cloud.config.discovery.enabled=true
+spring.cloud.config.discovery.serviceId=config-server
+spring.cloud.config.profile=dev
+
+spring.cloud.config.failFast=true
+
+#kafka
+spring.cloud.stream.kafka.binder.zk-nodes=localhost:2181
+spring.cloud.stream.kafka.binder.brokers=localhost:9092
+
+spring.cloud.bus.trace.enabled=true
diff --git a/Chapter1-1-7/config-server-eureka-kafka/pom.xml b/Chapter1-1-7/config-server-eureka-kafka/pom.xml
@@ -0,0 +1,62 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+	<modelVersion>4.0.0</modelVersion>
+
+	<groupId>com.didispace</groupId>
+	<artifactId>config-server-eureka-kafka</artifactId>
+	<version>1.0.0</version>
+	<packaging>jar</packaging>
+
+	<name>config-server-eureka-kafka</name>
+	<description>Spring Cloud project</description>
+
+	<parent>
+		<groupId>org.springframework.boot</groupId>
+		<artifactId>spring-boot-starter-parent</artifactId>
+		<version>1.3.7.RELEASE</version>
+		<relativePath/> <!-- lookup parent from repository -->
+	</parent>
+
+	<properties>
+		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+		<java.version>1.8</java.version>
+	</properties>
+
+	<dependencies>
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-config-server</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-eureka</artifactId>
+		</dependency>
+		<dependency>
+			<groupId>org.springframework.cloud</groupId>
+			<artifactId>spring-cloud-starter-bus-kafka</artifactId>
+		</dependency>
+	</dependencies>
+
+	<dependencyManagement>
+		<dependencies>
+			<dependency>
+				<groupId>org.springframework.cloud</groupId>
+				<artifactId>spring-cloud-dependencies</artifactId>
+				<version>Brixton.SR5</version>
+				<type>pom</type>
+				<scope>import</scope>
+			</dependency>
+		</dependencies>
+	</dependencyManagement>
+
+	<build>
+		<plugins>
+			<plugin>
+				<groupId>org.springframework.boot</groupId>
+				<artifactId>spring-boot-maven-plugin</artifactId>
+			</plugin>
+		</plugins>
+	</build>
+
+</project>
diff --git a/Chapter1-1-7/config-server-eureka-kafka/src/main/java/com/didispace/Application.java b/Chapter1-1-7/config-server-eureka-kafka/src/main/java/com/didispace/Application.java
@@ -0,0 +1,17 @@
+package com.didispace;
+
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.builder.SpringApplicationBuilder;
+import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
+import org.springframework.cloud.config.server.EnableConfigServer;
+
+@EnableDiscoveryClient
+@EnableConfigServer
+@SpringBootApplication
+public class Application {
+
+	public static void main(String[] args) {
+		new SpringApplicationBuilder(Application.class).web(true).run(args);
+	}
+
+}
diff --git a/Chapter1-1-7/config-server-eureka-kafka/src/main/resources/application.properties b/Chapter1-1-7/config-server-eureka-kafka/src/main/resources/application.properties
@@ -0,0 +1,14 @@
+spring.application.name=config-server
+server.port=7001
+
+eureka.client.serviceUrl.defaultZone=http://localhost:1111/eureka/
+
+# git¹ÜÀíÅäÖÃ
+spring.cloud.config.server.git.uri=http://git.oschina.net/didispace/SpringCloud-Learning/
+spring.cloud.config.server.git.searchPaths=Chapter1-1-7/config-repo
+spring.cloud.config.server.git.username=username
+spring.cloud.config.server.git.password=password
+
+#kafka
+spring.cloud.stream.kafka.binder.zk-nodes=localhost:2181
+spring.cloud.stream.kafka.binder.brokers=localhost:9092
diff --git a/Chapter1-1-7/config-server-eureka-kafka/src/main/resources/didispace-dev.properties b/Chapter1-1-7/config-server-eureka-kafka/src/main/resources/didispace-dev.properties
@@ -0,0 +1 @@
+from=local-dev
diff --git a/Chapter1-1-7/config-server-eureka-kafka/src/main/resources/didispace-prod.properties b/Chapter1-1-7/config-server-eureka-kafka/src/main/resources/didispace-prod.properties
@@ -0,0 +1 @@
+from=local-prod
diff --git a/Chapter1-1-7/config-server-eureka-kafka/src/main/resources/didispace-test.properties b/Chapter1-1-7/config-server-eureka-kafka/src/main/resources/didispace-test.properties
@@ -0,0 +1 @@
+from=local-test
diff --git a/Chapter1-1-7/config-server-eureka-kafka/src/main/resources/didispace.properties b/Chapter1-1-7/config-server-eureka-kafka/src/main/resources/didispace.properties
@@ -0,0 +1 @@
+from=local