Skip to content

Commit 5466f6a

Browse files
ityouknowityouknow
committed
consul
add spirng cloud consul example
1 parent 27ebfb3 commit 5466f6a

File tree

18 files changed

+410
-1
lines changed

18 files changed

+410
-1
lines changed

‎README.md

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,8 @@ Spring Cloud使用的各种示例，以最简单、最实用为标准
2727
- [spring-cloud-zuul](https://github.com/ityouknow/spring-cloud-starter/tree/master/spring-cloud-zuul)：Spring Cloud Zuul使用高级篇 Filter 鉴权 熔断 重试
2828
- [spring-cloud-sleuth-zipkin](https://github.com/ityouknow/spring-cloud-starter/tree/master/spring-cloud-sleuth-zipkin)： 利用Sleuth、Zipkin对Spring Cloud应用进行服务追踪分析
2929
- [spring-boot-admin-eureka](https://github.com/ityouknow/spring-cloud-starter/tree/master/spring-boot-admin-eureka)： 使用Spring Boot Admin 对Spring Cloud集群进行监控示例
30+
- [spring-cloud-consul](https://github.com/ityouknow/spring-cloud-starter/tree/master/spring-cloud-consul)： Spring Cloud 使用 Consul 作为服务中心示例
31+
3032

3133
学习系列：
3234

‎README_EN.md

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -20,4 +20,5 @@ Spring Cloud Examples, Use the simplest and most useful scene demo.
2020
- [gateway-service-zuul](https://github.com/ityouknow/spring-cloud-starter/tree/master/gateway-service-zuul)：gateway service using zuul
2121
- [spring-cloud-zuul](https://github.com/ityouknow/spring-cloud-starter/tree/master/spring-cloud-zuul)：Spring Cloud Zuul Filter authentication rallback retry
2222
- [spring-cloud-sleuth-zipkin](https://github.com/ityouknow/spring-cloud-starter/tree/master/spring-cloud-sleuth-zipkin)： Using Sleuth, Zipkin provides service tracking analysis of applications
23-
- [spring-boot-admin-eureka](https://github.com/ityouknow/spring-cloud-starter/tree/master/spring-boot-admin-eureka)： Use Spring Boot Admin Monitor Spring Cloud Apps
23+
- [spring-boot-admin-eureka](https://github.com/ityouknow/spring-cloud-starter/tree/master/spring-boot-admin-eureka)： Use Spring Boot Admin Monitor Spring Cloud Apps
24+
- [spring-cloud-consul](https://github.com/ityouknow/spring-cloud-starter/tree/master/spring-cloud-consul)： spring cloud consul example

‎spring-cloud-consul/spring-cloud-consul-consumer/pom.xml

Lines changed: 70 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,70 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
3+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4+
<modelVersion>4.0.0</modelVersion>
5+
6+
<groupId>com.neo</groupId>
7+
<artifactId>spring-cloud-consul-consumer</artifactId>
8+
<version>0.0.1-SNAPSHOT</version>
9+
<packaging>jar</packaging>
10+
11+
<name>spring-cloud-consul-consumer</name>
12+
<description>Demo project for Spring Boot</description>
13+
14+
<parent>
15+
<groupId>org.springframework.boot</groupId>
16+
<artifactId>spring-boot-starter-parent</artifactId>
17+
<version>2.0.3.RELEASE</version>
18+
<relativePath/> <!-- lookup parent from repository -->
19+
</parent>
20+
21+
<properties>
22+
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
23+
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
24+
<java.version>1.8</java.version>
25+
<spring-cloud.version>Finchley.RELEASE</spring-cloud.version>
26+
</properties>
27+
28+
<dependencies>
29+
<dependency>
30+
<groupId>org.springframework.boot</groupId>
31+
<artifactId>spring-boot-starter-actuator</artifactId>
32+
</dependency>
33+
<dependency>
34+
<groupId>org.springframework.cloud</groupId>
35+
<artifactId>spring-cloud-starter-consul-discovery</artifactId>
36+
</dependency>
37+
<dependency>
38+
<groupId>org.springframework.boot</groupId>
39+
<artifactId>spring-boot-starter-web</artifactId>
40+
</dependency>
41+
<dependency>
42+
<groupId>org.springframework.boot</groupId>
43+
<artifactId>spring-boot-starter-test</artifactId>
44+
<scope>test</scope>
45+
</dependency>
46+
</dependencies>
47+
48+
<dependencyManagement>
49+
<dependencies>
50+
<dependency>
51+
<groupId>org.springframework.cloud</groupId>
52+
<artifactId>spring-cloud-dependencies</artifactId>
53+
<version>${spring-cloud.version}</version>
54+
<type>pom</type>
55+
<scope>import</scope>
56+
</dependency>
57+
</dependencies>
58+
</dependencyManagement>
59+
60+
<build>
61+
<plugins>
62+
<plugin>
63+
<groupId>org.springframework.boot</groupId>
64+
<artifactId>spring-boot-maven-plugin</artifactId>
65+
</plugin>
66+
</plugins>
67+
</build>
68+
69+
70+
</project>

‎spring-cloud-consul/spring-cloud-consul-consumer/src/main/java/com/neo/consul/ConsulConsumerApplication.java

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
package com.neo.consul;
2+
3+
import org.springframework.boot.SpringApplication;
4+
import org.springframework.boot.autoconfigure.SpringBootApplication;
5+
6+
@SpringBootApplication
7+
public class ConsulConsumerApplication {
8+
9+
public static void main(String[] args) {
10+
SpringApplication.run(ConsulConsumerApplication.class, args);
11+
}
12+
}

‎spring-cloud-consul/spring-cloud-consul-consumer/src/main/java/com/neo/consul/web/CallHelloController.java

Lines changed: 31 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,31 @@
1+
package com.neo.consul.web;
2+
3+
import org.springframework.beans.factory.annotation.Autowired;
4+
import org.springframework.cloud.client.ServiceInstance;
5+
import org.springframework.cloud.client.discovery.DiscoveryClient;
6+
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
7+
import org.springframework.cloud.consul.discovery.ConsulDiscoveryClient;
8+
import org.springframework.web.bind.annotation.RequestMapping;
9+
import org.springframework.web.bind.annotation.RestController;
10+
import org.springframework.web.client.RestTemplate;
11+
12+
import java.util.List;
13+
14+
@RestController
15+
public class CallHelloController {
16+
17+
@Autowired
18+
private LoadBalancerClient loadBalancer;
19+
20+
@RequestMapping("/call")
21+
public String call() {
22+
ServiceInstance serviceInstance = loadBalancer.choose("service-producer");
23+
System.out.println("服务地址：" + serviceInstance.getUri());
24+
System.out.println("服务名称：" + serviceInstance.getServiceId());
25+
26+
String callServiceResult = new RestTemplate().getForObject(serviceInstance.getUri().toString() + "/hello", String.class);
27+
System.out.println(callServiceResult);
28+
return callServiceResult;
29+
}
30+
31+
}

‎spring-cloud-consul/spring-cloud-consul-consumer/src/main/java/com/neo/consul/web/ServiceController.java

Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,33 @@
1+
package com.neo.consul.web;
2+
3+
import org.springframework.beans.factory.annotation.Autowired;
4+
import org.springframework.cloud.client.discovery.DiscoveryClient;
5+
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
6+
import org.springframework.web.bind.annotation.RequestMapping;
7+
import org.springframework.web.bind.annotation.RestController;
8+
9+
@RestController
10+
public class ServiceController {
11+
12+
@Autowired
13+
private LoadBalancerClient loadBalancer;
14+
@Autowired
15+
private DiscoveryClient discoveryClient;
16+
17+
/**
18+
* 获取所有服务
19+
*/
20+
@RequestMapping("/services")
21+
public Object services() {
22+
return discoveryClient.getInstances("service-producer");
23+
}
24+
25+
/**
26+
* 从所有服务中选择一个服务（轮询）
27+
*/
28+
@RequestMapping("/discover")
29+
public Object discover() {
30+
return loadBalancer.choose("service-producer").getUri().toString();
31+
}
32+
33+
}

‎spring-cloud-consul/spring-cloud-consul-consumer/src/main/resources/application.properties

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,6 @@
1+
spring.application.name=spring-cloud-consul-consumer
2+
server.port=8503
3+
spring.cloud.consul.host=127.0.0.1
4+
spring.cloud.consul.port=8500
5+
#\u8BBE\u7F6E\u4E0D\u9700\u8981\u6CE8\u518C\u5230consul\u4E2D
6+
spring.cloud.consul.discovery.register=false

‎spring-cloud-consul/spring-cloud-consul-consumer/src/test/java/com/neo/consul/ConsulConsumerApplicationTests.java

Lines changed: 16 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,16 @@
1+
package com.neo.consul;
2+
3+
import org.junit.Test;
4+
import org.junit.runner.RunWith;
5+
import org.springframework.boot.test.context.SpringBootTest;
6+
import org.springframework.test.context.junit4.SpringRunner;
7+
8+
@RunWith(SpringRunner.class)
9+
@SpringBootTest
10+
public class ConsulConsumerApplicationTests {
11+
12+
@Test
13+
public void contextLoads() {
14+
}
15+
16+
}

‎spring-cloud-consul/spring-cloud-consul-producer-2/pom.xml

Lines changed: 70 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,70 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
3+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
4+
<modelVersion>4.0.0</modelVersion>
5+
6+
<groupId>com.neo</groupId>
7+
<artifactId>spring-cloud-consul-producer-2</artifactId>
8+
<version>0.0.1-SNAPSHOT</version>
9+
<packaging>jar</packaging>
10+
11+
<name>spring-cloud-consul-producer-2</name>
12+
<description>Demo project for Spring Boot</description>
13+
14+
<parent>
15+
<groupId>org.springframework.boot</groupId>
16+
<artifactId>spring-boot-starter-parent</artifactId>
17+
<version>2.0.3.RELEASE</version>
18+
<relativePath/> <!-- lookup parent from repository -->
19+
</parent>
20+
21+
<properties>
22+
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
23+
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
24+
<java.version>1.8</java.version>
25+
<spring-cloud.version>Finchley.RELEASE</spring-cloud.version>
26+
</properties>
27+
28+
<dependencies>
29+
<dependency>
30+
<groupId>org.springframework.boot</groupId>
31+
<artifactId>spring-boot-starter-actuator</artifactId>
32+
</dependency>
33+
<dependency>
34+
<groupId>org.springframework.cloud</groupId>
35+
<artifactId>spring-cloud-starter-consul-discovery</artifactId>
36+
</dependency>
37+
<dependency>
38+
<groupId>org.springframework.boot</groupId>
39+
<artifactId>spring-boot-starter-web</artifactId>
40+
</dependency>
41+
<dependency>
42+
<groupId>org.springframework.boot</groupId>
43+
<artifactId>spring-boot-starter-test</artifactId>
44+
<scope>test</scope>
45+
</dependency>
46+
</dependencies>
47+
48+
<dependencyManagement>
49+
<dependencies>
50+
<dependency>
51+
<groupId>org.springframework.cloud</groupId>
52+
<artifactId>spring-cloud-dependencies</artifactId>
53+
<version>${spring-cloud.version}</version>
54+
<type>pom</type>
55+
<scope>import</scope>
56+
</dependency>
57+
</dependencies>
58+
</dependencyManagement>
59+
60+
<build>
61+
<plugins>
62+
<plugin>
63+
<groupId>org.springframework.boot</groupId>
64+
<artifactId>spring-boot-maven-plugin</artifactId>
65+
</plugin>
66+
</plugins>
67+
</build>
68+
69+
70+
</project>

‎spring-cloud-consul/spring-cloud-consul-producer-2/src/main/java/com/neo/consul/ConsulProducerApplication.java

Lines changed: 14 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,14 @@
1+
package com.neo.consul;
2+
3+
import org.springframework.boot.SpringApplication;
4+
import org.springframework.boot.autoconfigure.SpringBootApplication;
5+
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
6+
7+
@SpringBootApplication
8+
@EnableDiscoveryClient
9+
public class ConsulProducerApplication {
10+
11+
public static void main(String[] args) {
12+
SpringApplication.run(ConsulProducerApplication.class, args);
13+
}
14+
}

0 commit comments

Comments
 (0)