Skip to content

Commit b06ca8c

Browse files
mercyblitzmercyblitz
committed
Add Lesson 7
1 parent 45b3d4a commit b06ca8c

File tree

18 files changed

+963
-0
lines changed

18 files changed

+963
-0
lines changed

‎spring-cloud/lesson-7/README.md

Lines changed: 431 additions & 0 deletions
Large diffs are not rendered by default.

‎spring-cloud/lesson-7/[课件] Spring Cloud Netflix Ribbon 源码解读.pdf

2.73 MB
Binary file not shown.

‎spring-cloud/lesson-7/spring-cloud-lesson-7/.gitignore

Lines changed: 24 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,24 @@
1+
target/
2+
!.mvn/wrapper/maven-wrapper.jar
3+
4+
### STS ###
5+
.apt_generated
6+
.classpath
7+
.factorypath
8+
.project
9+
.settings
10+
.springBeans
11+
12+
### IntelliJ IDEA ###
13+
.idea
14+
*.iws
15+
*.iml
16+
*.ipr
17+
18+
### NetBeans ###
19+
nbproject/private/
20+
build/
21+
nbbuild/
22+
dist/
23+
nbdist/
24+
.nb-gradle/

‎spring-cloud/lesson-7/spring-cloud-lesson-7/pom.xml

Lines changed: 84 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,84 @@
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.segumentfault</groupId>
7+
<artifactId>spring-cloud-lesson-7</artifactId>
8+
<version>0.0.1-SNAPSHOT</version>
9+
<modules>
10+
<module>user-api</module>
11+
<module>user-ribbon-client</module>
12+
<module>user-service-provider</module>
13+
</modules>
14+
<packaging>pom</packaging>
15+
16+
<name>spring-cloud-lesson-7</name>
17+
<description>Demo project for Spring Boot</description>
18+
19+
<parent>
20+
<groupId>org.springframework.boot</groupId>
21+
<artifactId>spring-boot-starter-parent</artifactId>
22+
<version>1.5.8.RELEASE</version>
23+
<relativePath/> <!-- lookup parent from repository -->
24+
</parent>
25+
26+
<properties>
27+
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
28+
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
29+
<java.version>1.8</java.version>
30+
<spring-cloud.version>Edgware.RELEASE</spring-cloud.version>
31+
</properties>
32+
33+
<dependencies>
34+
<dependency>
35+
<groupId>org.springframework.boot</groupId>
36+
<artifactId>spring-boot-starter-actuator</artifactId>
37+
</dependency>
38+
<dependency>
39+
<groupId>org.springframework.cloud</groupId>
40+
<artifactId>spring-cloud-starter-eureka</artifactId>
41+
</dependency>
42+
<dependency>
43+
<groupId>org.springframework.cloud</groupId>
44+
<artifactId>spring-cloud-starter-eureka-server</artifactId>
45+
</dependency>
46+
<dependency>
47+
<groupId>org.springframework.cloud</groupId>
48+
<artifactId>spring-cloud-starter-ribbon</artifactId>
49+
</dependency>
50+
<dependency>
51+
<groupId>org.springframework.boot</groupId>
52+
<artifactId>spring-boot-starter-web</artifactId>
53+
</dependency>
54+
55+
<dependency>
56+
<groupId>org.springframework.boot</groupId>
57+
<artifactId>spring-boot-starter-test</artifactId>
58+
<scope>test</scope>
59+
</dependency>
60+
</dependencies>
61+
62+
<dependencyManagement>
63+
<dependencies>
64+
<dependency>
65+
<groupId>org.springframework.cloud</groupId>
66+
<artifactId>spring-cloud-dependencies</artifactId>
67+
<version>${spring-cloud.version}</version>
68+
<type>pom</type>
69+
<scope>import</scope>
70+
</dependency>
71+
</dependencies>
72+
</dependencyManagement>
73+
74+
<build>
75+
<plugins>
76+
<plugin>
77+
<groupId>org.springframework.boot</groupId>
78+
<artifactId>spring-boot-maven-plugin</artifactId>
79+
</plugin>
80+
</plugins>
81+
</build>
82+
83+
84+
</project>

‎spring-cloud/lesson-7/spring-cloud-lesson-7/user-api/pom.xml

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,15 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<project xmlns="http://maven.apache.org/POM/4.0.0"
3+
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5+
<parent>
6+
<artifactId>spring-cloud-lesson-7</artifactId>
7+
<groupId>com.segumentfault</groupId>
8+
<version>0.0.1-SNAPSHOT</version>
9+
</parent>
10+
<modelVersion>4.0.0</modelVersion>
11+
12+
<artifactId>user-api</artifactId>
13+
14+
15+
</project>

‎spring-cloud/lesson-7/spring-cloud-lesson-7/user-api/src/main/java/com/segumentfault/spring/cloud/lesson7/api/UserService.java

Lines changed: 31 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,31 @@
1+
package com.segumentfault.spring.cloud.lesson7.api;
2+
3+
import com.segumentfault.spring.cloud.lesson7.domain.User;
4+
5+
import java.util.List;
6+
7+
/**
8+
* 用户服务
9+
*
10+
* @author <a href="mailto:mercyblitz@gmail.com">Mercy</a>
11+
* @since 1.0.0
12+
*/
13+
public interface UserService {
14+
15+
/**
16+
* 保存用户
17+
*
18+
* @param user
19+
* @return
20+
*/
21+
boolean saveUser(User user);
22+
23+
24+
/**
25+
* 查询所有的用户列表
26+
*
27+
* @return non-null
28+
*/
29+
List<User> findAll();
30+
31+
}

‎spring-cloud/lesson-7/spring-cloud-lesson-7/user-api/src/main/java/com/segumentfault/spring/cloud/lesson7/domain/User.java

Lines changed: 36 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,36 @@
1+
package com.segumentfault.spring.cloud.lesson7.domain;
2+
3+
/**
4+
* 用户模型
5+
*
6+
* @author <a href="mailto:mercyblitz@gmail.com">Mercy</a>
7+
* @since 1.0.0
8+
*/
9+
public class User {
10+
11+
/**
12+
* ID
13+
*/
14+
private Long id;
15+
16+
/**
17+
* 用户名称
18+
*/
19+
private String name;
20+
21+
public Long getId() {
22+
return id;
23+
}
24+
25+
public void setId(Long id) {
26+
this.id = id;
27+
}
28+
29+
public String getName() {
30+
return name;
31+
}
32+
33+
public void setName(String name) {
34+
this.name = name;
35+
}
36+
}

‎spring-cloud/lesson-7/spring-cloud-lesson-7/user-ribbon-client/pom.xml

Lines changed: 26 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,26 @@
1+
<?xml version="1.0" encoding="UTF-8"?>
2+
<project xmlns="http://maven.apache.org/POM/4.0.0"
3+
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5+
<parent>
6+
<artifactId>spring-cloud-lesson-7</artifactId>
7+
<groupId>com.segumentfault</groupId>
8+
<version>0.0.1-SNAPSHOT</version>
9+
</parent>
10+
<modelVersion>4.0.0</modelVersion>
11+
12+
<artifactId>user-ribbon-client</artifactId>
13+
14+
15+
<dependencies>
16+
17+
<!-- 依赖 用户 API -->
18+
<dependency>
19+
<groupId>com.segumentfault</groupId>
20+
<artifactId>user-api</artifactId>
21+
<version>${project.version}</version>
22+
</dependency>
23+
24+
</dependencies>
25+
26+
</project>

‎spring-cloud/lesson-7/spring-cloud-lesson-7/user-ribbon-client/src/main/java/com/segumentfault/spring/cloud/lesson7/user/ribbon/client/UserRibbonClientApplication.java

Lines changed: 41 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,41 @@
1+
package com.segumentfault.spring.cloud.lesson7.user.ribbon.client;
2+
3+
import com.netflix.loadbalancer.IPing;
4+
import com.netflix.loadbalancer.IRule;
5+
import com.segumentfault.spring.cloud.lesson7.user.ribbon.client.ping.MyPing;
6+
import com.segumentfault.spring.cloud.lesson7.user.ribbon.client.rule.MyRule;
7+
import org.springframework.boot.SpringApplication;
8+
import org.springframework.boot.autoconfigure.SpringBootApplication;
9+
import org.springframework.cloud.netflix.ribbon.RibbonClient;
10+
import org.springframework.context.annotation.Bean;
11+
import org.springframework.web.util.UriComponentsBuilder;
12+
13+
import java.util.HashMap;
14+
import java.util.Map;
15+
16+
/**
17+
* 引导类
18+
*
19+
* @author <a href="mailto:mercyblitz@gmail.com">Mercy</a>
20+
* @since 0.0.1
21+
*/
22+
@SpringBootApplication
23+
@RibbonClient("user-service-provider") // 指定目标应用名称
24+
public class UserRibbonClientApplication {
25+
26+
public static void main(String[] args) {
27+
SpringApplication.run(UserRibbonClientApplication.class, args);
28+
}
29+
30+
/**
31+
* 将 {@link MyRule} 暴露成 {@link Bean}
32+
*
33+
* @return {@link MyRule}
34+
*/
35+
@Bean
36+
public IRule myRule() {
37+
return new MyRule();
38+
}
39+
40+
41+
}

‎spring-cloud/lesson-7/spring-cloud-lesson-7/user-ribbon-client/src/main/java/com/segumentfault/spring/cloud/lesson7/user/ribbon/client/ping/MyPing.java

Lines changed: 41 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,41 @@
1+
package com.segumentfault.spring.cloud.lesson7.user.ribbon.client.ping;
2+
3+
import com.netflix.loadbalancer.IPing;
4+
import com.netflix.loadbalancer.Server;
5+
import org.springframework.http.HttpStatus;
6+
import org.springframework.http.ResponseEntity;
7+
import org.springframework.web.client.RestTemplate;
8+
import org.springframework.web.util.UriComponentsBuilder;
9+
10+
import java.net.URI;
11+
12+
/**
13+
* 实现 {@link IPing} 接口：检查对象 /health 是否正常状态码:200
14+
*
15+
* @author <a href="mailto:mercyblitz@gmail.com">Mercy</a>
16+
* @since 0.0.1
17+
*/
18+
public class MyPing implements IPing {
19+
20+
@Override
21+
public boolean isAlive(Server server) {
22+
23+
String host = server.getHost();
24+
int port = server.getPort();
25+
// /health endpoint
26+
// 通过 Spring 组件来实现URL 拼装
27+
UriComponentsBuilder builder = UriComponentsBuilder.newInstance();
28+
builder.scheme("http");
29+
builder.host(host);
30+
builder.port(port);
31+
builder.path("/health");
32+
URI uri = builder.build().toUri();
33+
34+
RestTemplate restTemplate = new RestTemplate();
35+
36+
ResponseEntity responseEntity = restTemplate.getForEntity(uri, String.class);
37+
// 当响应状态等于 200 时，返回 true ，否则 false
38+
return HttpStatus.OK.equals(responseEntity.getStatusCode());
39+
}
40+
41+
}

0 commit comments

Comments
 (0)