# Spring Cloud Netflix 微服务实战：在线订货平台

🎉 源码地址：https://github.com/cookob/online-ordering-platform 🎉

# 项目需求

客户端：针对普通用户，用户登录、用户退出、商品订购、我的订单。

后台管理系统：针对管理员，管理员登录、管理员退出、添加商品、查询商品、修改商品、删除商品、订单处理、添加用户、查询用户、删除用户。

                      |--用户登录
                      |--用户退出
            |--客户端--
            |         |--商品订购
            |         |--我的订单
在线订货平台--
            |
            |              |--管理员登录
            |              |--管理员退出
            |              |--添加用户
            |              |--查询用户
            |              |--删除用户
            |--后台管理系统--
                           |--添加商品
                           |--查询商品
                           |--修改商品
                           |--删除商品
                           |--订单处理

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

需求了解完之后，接下来设计系统架构，首先分配出4个服务提供者，account、goods、order、user。

account 提供账户服务：用户和管理的登录退出。 goods 提供商品服务：添加商品、删除商品、修改商品、查询商品。 order 提供订单服务：添加订单、查询订单、删除订单、处理订单。 user 提供用户服务：添加用户、查询用户、删除用户。这四个服务提供者只是提供对数据的管理，不提供视图信息。

接下来再分离出一个服务消费者，来调用以上四个服务提供者，服务消费者包含了客户端的前端页面和后台接口、后台管理系统的前端页面和后台接口。用户 / 管理员直接访问的资源都保存在服务消费者中，服务消费者根据具体的需求调用四个服务提供者的业务逻辑，通过 Feign 实现负载均衡。

四个服务提供者和一个服务消费者都需要在注册中心进行注册，同时可以使用配置中心来对配置文件进行统一集中管理。

# 创建父工程，pom.xml

<parent>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-parent</artifactId>
  <version>2.0.7.RELEASE</version>
</parent>

<dependencies>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
  </dependency>
  <!-- JDK 9 缺失jar -->
  <dependency>
    <groupId>javax.xml.bind</groupId>
    <artifactId>jaxb-api</artifactId>
    <version>2.3.0</version>
  </dependency>

  <dependency>
    <groupId>com.sun.xml.bind</groupId>
    <artifactId>jaxb-impl</artifactId>
    <version>2.3.0</version>
  </dependency>

  <dependency>
    <groupId>com.sun.xml.bind</groupId>
    <artifactId>jaxb-core</artifactId>
    <version>2.3.0</version>
  </dependency>

  <dependency>
    <groupId>javax.activation</groupId>
    <artifactId>activation</artifactId>
    <version>1.1.1</version>
  </dependency>

  <dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <optional>true</optional>
  </dependency>
</dependencies>

<dependencyManagement>
  <dependencies>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-dependencies</artifactId>
      <version>Finchley.SR2</version>
      <type>pom</type>
      <scope>import</scope>
    </dependency>
  </dependencies>
</dependencyManagement>

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54

# 注册中心

pom.xml

<dependencies>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
    <version>2.0.2.RELEASE</version>
  </dependency>
</dependencies>

1
2
3
4
5
6
7

application.yml

server:
  port: 8761
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/
    register-with-eureka: false
    fetch-registry: false

1
2
3
4
5
6
7
8

启动类

package com.minichn;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

@SpringBootApplication
@EnableEurekaServer
public class RegistryCenterApplication {
    public static void main(String[] args) {
        SpringApplication.run(RegistryCenterApplication.class,args);
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13

# 配置中心(本地配置)

pom.xml

<dependencies>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-config-server</artifactId>
    <version>2.0.2.RELEASE</version>
  </dependency>
</dependencies>

1
2
3
4
5
6
7

application.yml

server:
  port: 8762
spring:
  application:
    name: nativeconfigserver
  profiles:
    active: native
  cloud:
    config:
      server:
        native:
          search-locations: classpath:/shared

1
2
3
4
5
6
7
8
9
10
11
12

在 shared 路径下创建各个微服务对应的配置文件

client-dev.yml

server:
  port: 8030
spring:
  application:
    name: client
  thymeleaf:
    prefix: classpath:/static/
    suffix: .html
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/
  instance:
    prefer-ip-address: true

1
2
3
4
5
6
7
8
9
10
11
12
13
14

goods-dev.yml

server:
  port: 8020
spring:
  application:
    name: goods
  datasource:
    name: orderingsystem
    url: jdbc:mysql://localhost:3306/orderingsystem?useUnicode=true&characterEncoding=UTF-8
    username: username
    password: password
eureka:
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/
  instance:
    prefer-ip-address: true
mybatis:
  mapper-locations: classpath:/mapping/*.xml
  type-aliases-package: com.minichn.entity

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

启动类

package com.minichn;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.config.server.EnableConfigServer;

@SpringBootApplication
@EnableConfigServer
public class NativeConfigServerApplication {
    public static void main(String[] args) {
        SpringApplication.run(NativeConfigServerApplication.class,args);
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13

# 服务提供者 order

pom.xml

<dependencies>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    <version>2.0.2.RELEASE</version>
  </dependency>

  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-config</artifactId>
    <version>2.0.2.RELEASE</version>
  </dependency>
</dependencies>

1
2
3
4
5
6
7
8
9
10
11
12
13

bootstrap.yml

spring:
  application:
    name: order
  profiles:
    active: dev
  cloud:
    config:
      uri: http://localhost:8762
      fail-fast: true

1
2
3
4
5
6
7
8
9

Handler

package com.minichn.controller;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/order")
public class OrderHandler {

    @Value("${server.port}")
    private String port;

    @GetMapping("/index")
    public String index(){
        return "order的端口："+this.port;
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

启动类

package com.minichn;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class OrderApplication {
    public static void main(String[] args) {
        SpringApplication.run(OrderApplication.class,args);
    }
}

1
2
3
4
5
6
7
8
9
10
11

# 服务提供者 goods

pom.xml

<dependencies>
  
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    <version>2.0.2.RELEASE</version>
  </dependency>

  <dependency>
    <groupId>org.mybatis.spring.boot</groupId>
    <artifactId>mybatis-spring-boot-starter</artifactId>
    <version>1.3.1</version>
  </dependency>

  <dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.11</version>
  </dependency>

  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-config</artifactId>
    <version>2.0.2.RELEASE</version>
  </dependency>
</dependencies>

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

bootstrap.yml

spring:
  application:
    name: goods
  profiles:
    active: dev
  cloud:
    config:
      uri: http://localhost:8762
      fail-fast: true

1
2
3
4
5
6
7
8
9

Handler

package com.minichn.controller;

import com.minichn.entity.Goods;
import com.minichn.repository.GoodsRepository;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;

@RestController
@RequestMapping("/goods")
public class GoodsHandler {
    @Value("${server.port}")
    private String port;

    @Autowired
    private GoodsRepository goodsRepository;

    @GetMapping("/index")
    public String index(){
        return this.port;
    }

    @GetMapping("/findAll/{index}/{limit}")
    public List<Goods> findAll(@PathVariable("index") int index,@PathVariable("limit") int limit){
        return goodsRepository.findAll(index, limit);
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32

启动类

package com.minichn;

import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
@MapperScan("com.minichn.repository")
public class GoodsApplication {
    public static void main(String[] args) {
        SpringApplication.run(GoodsApplication.class,args);
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13

Goods 实体类

package com.minichn.entity;

import lombok.Data;

@Data
public class Goods {
    private long id;
    private String name;
    private double price;
    private String details;
}

1
2
3
4
5
6
7
8
9
10
11

创建 GoodsRepository 接口

package com.minichn.repository;

import com.minichn.entity.Goods;

import java.util.List;

public interface GoodsRepository {
    public List<Goods> findAll(int index,int limit);
    public int count();
    public Goods findById(long id);
    public void save(Goods goods);
    public void update(Goods goods);
    public void deleteById(long id);
}

1
2
3
4
5
6
7
8
9
10
11
12
13
14

resources 路径下创建 mapping 文件夹，存放 Mapper.xml

<?xml version="1.0" encoding="UTF-8" ?>
        <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.minichn.repository.GoodsRepository">

    <select id="findAll" resultType="Goods">
        select * from t_goods limit #{param1},#{param2}
    </select>

    <select id="count" resultType="int">
        select count(id) from t_goods
    </select>

    <select id="findById" parameterType="long" resultType="Goods">
        select * from t_goods where id = #{id}
    </select>

    <insert id="save" parameterType="Goods">
        insert into t_goods(name,price,details) values(#{name},#{price},#{details})
    </insert>

    <update id="update" parameterType="Goods">
        update t_goods set name = #{name},price = #{price},details = #{details} where id = #{id}
    </update>

    <delete id="deleteById" parameterType="long">
        delete from t_goods where id = #{id}
    </delete>
</mapper>

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

# 服务消费者 client

pom.xml

<dependencies>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    <version>2.0.2.RELEASE</version>
  </dependency>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-openfeign</artifactId>
    <version>2.0.2.RELEASE</version>
  </dependency>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-thymeleaf</artifactId>
  </dependency>
  <dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-config</artifactId>
    <version>2.0.2.RELEASE</version>
  </dependency>
</dependencies>

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

bootstrap.yml

spring:
  application:
    name: client
  profiles:
    active: dev
  cloud:
    config:
      uri: http://localhost:8762
      fail-fast: true

1
2
3
4
5
6
7
8
9

启动类

package com.minichn;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.openfeign.EnableFeignClients;

@SpringBootApplication
@EnableFeignClients
public class ClientApplication {
    public static void main(String[] args) {
        SpringApplication.run(ClientApplication.class,args);
    }
}

1
2
3
4
5
6
7
8
9
10
11
12
13

← Spring Cloud Netflix 入门 Spring Cloud Alibaba →