Skip to content

Commit ede1816

Browse files
dyc87112dyc87112
committed
Spring Cloud Alibaba基础教程：使用Nacos实现服务注册与发现
1 parent 4950ca2 commit ede1816

File tree

7 files changed

+241
-16
lines changed

7 files changed

+241
-16
lines changed

‎4-Finchley/alibaba-nacos-discovery-client-common/pom.xml

Lines changed: 74 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,74 @@
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.didispace</groupId>
7+
<artifactId>alibaba-nacos-discovery-client-common</artifactId>
8+
<version>0.0.1-SNAPSHOT</version>
9+
<packaging>jar</packaging>
10+
11+
<parent>
12+
<groupId>org.springframework.boot</groupId>
13+
<artifactId>spring-boot-starter-parent</artifactId>
14+
<version>2.0.5.RELEASE</version>
15+
<relativePath/> <!-- lookup parent from repository -->
16+
</parent>
17+
18+
<properties>
19+
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
20+
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
21+
<java.version>1.8</java.version>
22+
</properties>
23+
24+
<dependencies>
25+
<dependency>
26+
<groupId>org.springframework.boot</groupId>
27+
<artifactId>spring-boot-starter-web</artifactId>
28+
</dependency>
29+
<dependency>
30+
<groupId>org.springframework.cloud</groupId>
31+
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
32+
</dependency>
33+
34+
<dependency>
35+
<groupId>org.projectlombok</groupId>
36+
<artifactId>lombok</artifactId>
37+
<version>1.18.2</version>
38+
<optional>true</optional>
39+
</dependency>
40+
<dependency>
41+
<groupId>org.springframework.boot</groupId>
42+
<artifactId>spring-boot-starter-test</artifactId>
43+
<scope>test</scope>
44+
</dependency>
45+
</dependencies>
46+
47+
<dependencyManagement>
48+
<dependencies>
49+
<dependency>
50+
<groupId>org.springframework.cloud</groupId>
51+
<artifactId>spring-cloud-dependencies</artifactId>
52+
<version>Finchley.SR1</version>
53+
<type>pom</type>
54+
<scope>import</scope>
55+
</dependency>
56+
<dependency>
57+
<groupId>org.springframework.cloud</groupId>
58+
<artifactId>spring-cloud-alibaba-dependencies</artifactId>
59+
<version>0.2.1.RELEASE</version>
60+
<type>pom</type>
61+
<scope>import</scope>
62+
</dependency>
63+
</dependencies>
64+
</dependencyManagement>
65+
66+
<build>
67+
<plugins>
68+
<plugin>
69+
<groupId>org.springframework.boot</groupId>
70+
<artifactId>spring-boot-maven-plugin</artifactId>
71+
</plugin>
72+
</plugins>
73+
</build>
74+
</project>

‎4-Finchley/alibaba-nacos-discovery-client-common/src/main/java/com/didispace/alibaba/nacos/discovery/client/TestApplication.java

Lines changed: 41 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,41 @@
1+
package com.didispace.alibaba.nacos.discovery.client;
2+
3+
import lombok.extern.slf4j.Slf4j;
4+
import org.springframework.beans.factory.annotation.Autowired;
5+
import org.springframework.boot.SpringApplication;
6+
import org.springframework.boot.autoconfigure.SpringBootApplication;
7+
import org.springframework.cloud.client.ServiceInstance;
8+
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
9+
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
10+
import org.springframework.web.bind.annotation.GetMapping;
11+
import org.springframework.web.bind.annotation.RestController;
12+
import org.springframework.web.client.RestTemplate;
13+
14+
15+
@EnableDiscoveryClient
16+
@SpringBootApplication
17+
public class TestApplication {
18+
19+
public static void main(String[] args) {
20+
SpringApplication.run(TestApplication.class, args);
21+
}
22+
23+
@Slf4j
24+
@RestController
25+
static class TestController {
26+
27+
@Autowired
28+
LoadBalancerClient loadBalancerClient;
29+
30+
@GetMapping("/test")
31+
public String test() {
32+
// 通过spring cloud common中的负载均衡接口选取服务提供节点实现接口调用
33+
ServiceInstance serviceInstance = loadBalancerClient.choose("alibaba-nacos-discovery-server");
34+
String url = serviceInstance.getUri() + "/hello?name=" + "didi";
35+
RestTemplate restTemplate = new RestTemplate();
36+
String result = restTemplate.getForObject(url, String.class);
37+
return "Invoke : " + url + ", return : " + result;
38+
}
39+
}
40+
41+
}

‎4-Finchley/alibaba-nacos-discovery-client-common/src/main/resources/application.properties

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
spring.application.name=alibaba-nacos-discovery-client-common
2+
server.port=9000
3+
4+
spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848

‎4-Finchley/alibaba-nacos-discovery-server/pom.xml

Lines changed: 74 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,74 @@
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.didispace</groupId>
7+
<artifactId>alibaba-nacos-discovery-server</artifactId>
8+
<version>0.0.1-SNAPSHOT</version>
9+
<packaging>jar</packaging>
10+
11+
<parent>
12+
<groupId>org.springframework.boot</groupId>
13+
<artifactId>spring-boot-starter-parent</artifactId>
14+
<version>2.0.5.RELEASE</version>
15+
<relativePath/> <!-- lookup parent from repository -->
16+
</parent>
17+
18+
<properties>
19+
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
20+
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
21+
<java.version>1.8</java.version>
22+
</properties>
23+
24+
<dependencies>
25+
<dependency>
26+
<groupId>org.springframework.boot</groupId>
27+
<artifactId>spring-boot-starter-web</artifactId>
28+
</dependency>
29+
<dependency>
30+
<groupId>org.springframework.cloud</groupId>
31+
<artifactId>spring-cloud-starter-alibaba-nacos-discovery</artifactId>
32+
</dependency>
33+
34+
<dependency>
35+
<groupId>org.projectlombok</groupId>
36+
<artifactId>lombok</artifactId>
37+
<version>1.18.2</version>
38+
<optional>true</optional>
39+
</dependency>
40+
<dependency>
41+
<groupId>org.springframework.boot</groupId>
42+
<artifactId>spring-boot-starter-test</artifactId>
43+
<scope>test</scope>
44+
</dependency>
45+
</dependencies>
46+
47+
<dependencyManagement>
48+
<dependencies>
49+
<dependency>
50+
<groupId>org.springframework.cloud</groupId>
51+
<artifactId>spring-cloud-dependencies</artifactId>
52+
<version>Finchley.SR1</version>
53+
<type>pom</type>
54+
<scope>import</scope>
55+
</dependency>
56+
<dependency>
57+
<groupId>org.springframework.cloud</groupId>
58+
<artifactId>spring-cloud-alibaba-dependencies</artifactId>
59+
<version>0.2.1.RELEASE</version>
60+
<type>pom</type>
61+
<scope>import</scope>
62+
</dependency>
63+
</dependencies>
64+
</dependencyManagement>
65+
66+
<build>
67+
<plugins>
68+
<plugin>
69+
<groupId>org.springframework.boot</groupId>
70+
<artifactId>spring-boot-maven-plugin</artifactId>
71+
</plugin>
72+
</plugins>
73+
</build>
74+
</project>

‎4-Finchley/alibaba-nacos-discovery-server/src/main/java/com/didispace/alibaba/nacos/discovery/server/TestApplication.java

Lines changed: 33 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,33 @@
1+
package com.didispace.alibaba.nacos.discovery.server;
2+
3+
import lombok.extern.slf4j.Slf4j;
4+
import org.springframework.beans.factory.annotation.Autowired;
5+
import org.springframework.boot.SpringApplication;
6+
import org.springframework.boot.autoconfigure.SpringBootApplication;
7+
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
8+
import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
9+
import org.springframework.web.bind.annotation.GetMapping;
10+
import org.springframework.web.bind.annotation.RequestParam;
11+
import org.springframework.web.bind.annotation.RestController;
12+
13+
14+
@EnableDiscoveryClient
15+
@SpringBootApplication
16+
public class TestApplication {
17+
18+
public static void main(String[] args) {
19+
SpringApplication.run(TestApplication.class, args);
20+
}
21+
22+
@Slf4j
23+
@RestController
24+
static class TestController {
25+
26+
@GetMapping("/hello")
27+
public String hello(@RequestParam String name) {
28+
return "hello " + name;
29+
}
30+
31+
}
32+
33+
}

‎4-Finchley/alibaba-nacos-discovery-server/src/main/resources/application.properties

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,4 @@
1+
spring.application.name=alibaba-nacos-discovery-server
2+
server.port=8001
3+
4+
spring.cloud.nacos.discovery.server-addr=127.0.0.1:8848

‎4-Finchley/pom.xml

Lines changed: 11 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -9,23 +9,18 @@
99
<version>1.0</version>
1010

1111
<modules>
12-
<!-- 消费自己的消息 -->
13-
<module>stream-consumer-self</module>
14-
<!-- 消息重试 -->
15-
<module>stream-exception-handler-1</module>
16-
<!-- 自定义错误处理逻辑 -->
17-
<module>stream-exception-handler-2</module>
18-
<!-- 使用DLQ队列（RabbitMQ） -->
19-
<module>stream-exception-handler-3</module>
20-
<!-- 重入队列（RabbitMQ） -->
21-
<module>stream-exception-handler-4</module>
22-
23-
<!-- @StreamListener根据内容路由 -->
24-
<module>stream-content-route</module>
25-
26-
<!-- 使用延迟消息实现定时任务（RabbitMQ）-->
27-
<module>stream-delayed-message</module>
12+
<!-- spring cloud alibaba专题-->
13+
<module>alibaba-nacos-discovery-server</module> <!-- 使用Nacos实现服务注册与发现：服务提供方-->
14+
<module>alibaba-nacos-discovery-client-common</module> <!-- 使用Nacos实现服务注册与发现：服务消费方（spring cloud common接口实现负载均衡）-->
2815

16+
<!--spring cloud stream专题-->
17+
<module>stream-consumer-self</module> <!-- 消费自己的消息 -->
18+
<module>stream-exception-handler-1</module> <!-- 消息重试 -->
19+
<module>stream-exception-handler-2</module> <!-- 自定义错误处理逻辑 -->
20+
<module>stream-exception-handler-3</module> <!-- 使用DLQ队列（RabbitMQ） -->
21+
<module>stream-exception-handler-4</module> <!-- 重入队列（RabbitMQ） -->
22+
<module>stream-content-route</module> <!-- @StreamListener根据内容路由 -->
23+
<module>stream-delayed-message</module> <!-- 使用延迟消息实现定时任务（RabbitMQ）-->
2924
</modules>
3025

3126
</project>

0 commit comments

Comments
 (0)