SpringCloud（一）项目整体架构搭建

- 日理万妓 2022-04-01 11:59 303阅读 0赞

# springcloud学习总结 #

## 1、项目整体架构搭建 ##

**一、新建maven父工程，用来管理项目的jar**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDAxOTQ1_size_16_color_FFFFFF_t_70]  
**如图所示，点击next**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDAxOTQ1_size_16_color_FFFFFF_t_70 1]  
**继续next next 直到finish**

**编写pom文件，管理子模块jar依赖**

<properties>
    		
            <project.build.sourceEncoding>UTF8</project.build.sourceEncoding>
            
            <maven.compiler.source>1.8</maven.compiler.source>
            <maven.compiler.target>1.8</maven.compiler.target>
            <junit.version>4.12</junit.version>
            <log4j.version>1.2.17</log4j.version>
            <lombok.version>1.16.18</lombok.version>
        </properties>
    	<dependencyManagement>
            <dependencies>
            
            	
                <dependency>
                    <groupId>org.springframework.cloud</groupId>
                    <artifactId>spring-cloud-dependencies</artifactId>
                    <version>Dalston.SR1</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
                
                
                <dependency>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-dependencies</artifactId>
                    <version>1.5.9.RELEASE</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
                
                <dependency>
                    <groupId>mysql</groupId>
                    <artifactId>mysql-connector-java</artifactId>
                    <version>5.1.47</version>
                </dependency>
                
                <dependency>
                    <groupId>com.alibaba</groupId>
                    <artifactId>druid</artifactId>
                    <version>1.1.10</version>
                </dependency>
                
                <dependency>
                    <groupId>org.mybatis.spring.boot</groupId>
                    <artifactId>mybatis-spring-bootstarter</artifactId>
                    <version>1.3.2</version>
                </dependency>
                
                <dependency>
                    <groupId>ch.qos.logback</groupId>
                    <artifactId>logback-core</artifactId>
                    <version>1.1.11</version>
                </dependency>
                
                <dependency>
                    <groupId>junit</groupId>
                    <artifactId>junit</artifactId>
                    <version>${ junit.version}</version>
                    <scope>test</scope>
                </dependency>
                
                <dependency>
                    <groupId>log4j</groupId>
                    <artifactId>log4j</artifactId>
                    <version>${ log4j.version}</version>
                </dependency>
                
            </dependencies>
        </dependencyManagement>
    
        <build>
            <finalName>springcloud</finalName>
            <resources>
                <resource>
                    <directory>src/main/resources</directory>
                    <filtering>true</filtering>
                </resource>
            </resources>
            <plugins>
            	
            	
                <plugin>
                    <groupId>org.apache.maven.plugins</groupId>
                    <artifactId>maven-resources-plugin</artifactId>
                    <configuration>
                        <delimiters>
                            <delimit>$</delimit>
                        </delimiters>
                    </configuration>
                </plugin>
            </plugins>
        </build>

**二、新建服务实例api模块**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDAxOTQ1_size_16_color_FFFFFF_t_70 2]

**修改pom文件，增加依赖**

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

**新增实体类Dept**

package com.atguigu.springcloud.entities;
    import java.io.Serializable;
    import lombok.AllArgsConstructor;
    import lombok.Data;
    import lombok.Getter;
    import lombok.NoArgsConstructor;
    import lombok.Setter;
    import lombok.experimental.Accessors;
    @NoArgsConstructor
    //@AllArgsConstructor
    @Data
    @Accessors(chain=true)
    public class Dept implements Serializable// entity --orm--- db_table
    { 
    	private Long 	deptno; // 主键
    	private String 	dname; // 部门名称
    	private String 	db_source;// 来自那个数据库，因为微服务架构可以一个服务对应一个数据库，同一个信息被存储到不同数据库
    	public Dept(String dname)
    	{ 
    		super();
    		this.dname = dname;
    	}
    }

**三、新建服务注册中心eureka7001模块**

**New Module**

**修改pom文件**

<dependencies>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-eureka-server</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>springloaded</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
            </dependency>
        </dependencies>

**编写application.yml文件**

server: 
      port: 7001
     
    eureka: 
      instance:
        hostname: eureka7001.com #eureka服务端的实例名称
        #注意：这里要在hosts文件里面编写配置映射  后面需要配置eureka集群以及路由，索性一次性配置完成
        #127.0.0.1       eureka7001.com
    	#127.0.0.1       eureka7002.com
    	#127.0.0.1       eureka7003.com
    	#127.0.0.1       zuul5555.com
      client: 
        register-with-eureka: false     #false表示不向注册中心注册自己。
        fetch-registry: false     #false表示自己端就是注册中心，我的职责就是维护服务实例，并不需要去检索服务
        service-url:
         
          #设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址（单机）。
          
          defaultZone: http://${ eureka.instance.hostname}:${ server.port}/eureka/

**增加主启动类**

package com.atguigu.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
    
    @SpringBootApplication
    @EnableEurekaServer // EurekaServer服务器端启动类,接受其它微服务注册进来
    public class EurekaServer7001_App
    { 
     public static void main(String[] args)
     { 
     	SpringApplication.run(EurekaServer7001_App.class, args);
     }
    }

**四、新建服务提供者provider8001模块**

**New Module**

修改pom文件

<dependencies>
            
            <dependency>
                <groupId>springcloud</groupId>
                <artifactId>springcloud-api</artifactId>
                <version>${ project.version}</version>
            </dependency>
    
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</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-config</artifactId>
            </dependency>
    
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid</artifactId>
            </dependency>
            <dependency>
                <groupId>ch.qos.logback</groupId>
                <artifactId>logback-core</artifactId>
            </dependency>
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-jetty</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-test</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>springloaded</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
            </dependency>
        </dependencies>

**编写application.yml文件**

server:
      port: 8001
      
    mybatis:
      config-location: classpath:mybatis/mybatis.cfg.xml        # mybatis配置文件所在路径
      type-aliases-package: com.atguigu.springcloud.entities    # 所有Entity别名类所在包
      mapper-locations:
      - classpath:mybatis/mapper/**/*.xml                       # mapper映射文件
        
    spring:
       application:
       #特别重要！！
        name: microservicecloud-dept 
       datasource:
        type: com.alibaba.druid.pool.DruidDataSource            # 当前数据源操作类型
        driver-class-name: com.mysql.jdbc.Driver              # mysql驱动包
        url: jdbc:mysql://localhost:3306/cloudDB01              # 数据库名称
        username: root
        password: 123321
        dbcp2:
          min-idle: 5                                           # 数据库连接池的最小维持连接数
          initial-size: 5                                       # 初始化连接数
          max-total: 5                                          # 最大连接数
          max-wait-millis: 200                                  # 等待连接获取的最大超时时间
          
    eureka:
      client: #客户端注册进eureka服务列表内
        service-url:
          defaultZone: http://localhost:7001/eureka/
      instance:
        instance-id: microservicecloud-dept8001 #自定义服务名称信息
        prefer-ip-address: true     #访问路径可以显示IP地址
    #
    #当在eureka里面点击服务名字时，返回json而不是404
    info:
      app.name: atguigu-microservicecloud
      company.name: www.atguigu.com
      
      #可能是我父pom里面的插件配置的有问题，以下两个变量的值我没取到
      build.artifactId: $project.artifactId$
      build.version: $project.version$

**业务逻辑编写**  
**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.atguigu.springcloud.dao.DeptDao">
    
    	<select id="findById" resultType="com.atguigu.springcloud.entities.Dept" parameterType="java.lang.Long">
    		select deptno,dname,db_source from dept where deptno=#{ deptno};
    	</select>
    	<select id="findAll" resultType="com.atguigu.springcloud.entities.Dept">
    		select deptno,dname,db_source from dept;
    	</select>
    	<insert id="addDept" parameterType="com.atguigu.springcloud.entities.Dept">
    		INSERT INTO dept(dname,db_source) VALUES(#{ dname},DATABASE());
    	</insert>
    
    </mapper>

**dao**

package com.atguigu.springcloud.dao;
    
    import java.util.List;
    
    import org.apache.ibatis.annotations.Mapper;
    
    import com.atguigu.springcloud.entities.Dept;
    
    @Mapper
    public interface DeptDao
    { 
    	public boolean addDept(Dept dept);
    
    	public Dept findById(Long id);
    
    	public List<Dept> findAll();
    }

**service**

package com.atguigu.springcloud.service.impl;
    
    import java.util.List;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    
    import com.atguigu.springcloud.dao.DeptDao;
    import com.atguigu.springcloud.entities.Dept;
    import com.atguigu.springcloud.service.DeptService;
    
    @Service
    public class DeptServiceImpl implements DeptService
    { 
    	@Autowired
    	private DeptDao dao;
    	
    	@Override
    	public boolean add(Dept dept)
    	{ 
    		return dao.addDept(dept);
    	}
    
    	@Override
    	public Dept get(Long id)
    	{ 
    		return dao.findById(id);
    	}
    
    	@Override
    	public List<Dept> list()
    	{ 
    		return dao.findAll();
    	}
    
    }

**controller**

package com.atguigu.springcloud.controller;
    
    import java.util.List;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.cloud.client.ServiceInstance;
    import org.springframework.cloud.client.discovery.DiscoveryClient;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RequestBody;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.RestController;
    
    import com.atguigu.springcloud.entities.Dept;
    import com.atguigu.springcloud.service.DeptService;
    
    @RestController
    public class DeptController
    { 
    	@Autowired
    	private DeptService service;
    	
    	@RequestMapping(value = "/dept/add", method=RequestMethod.POST)
    	public boolean add(@RequestBody Dept dept)
    	{ 
    		return service.add(dept);
    	}
    
    	@RequestMapping(value = "/dept/get/{id}", method = RequestMethod.GET)
    	public Dept get(@PathVariable("id") Long id)
    	{ 
    		return service.get(id);
    	}
    
    	@RequestMapping(value = "/dept/list", method = RequestMethod.GET)
    	public List<Dept> list()
    	{ 
    		return service.list();
    	}
    }

**主启动类**

package com.atguigu.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    
    @SpringBootApplication
    @EnableEurekaClient //本服务启动后会自动注册进eureka服务中
    public class DeptProvider8001_App
    { 
    	public static void main(String[] args)
    	{ 
    		SpringApplication.run(DeptProvider8001_App.class, args);
    	}
    }

**provider项目结构**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDAxOTQ1_size_16_color_FFFFFF_t_70 3]

**依次启动 eureka provider**

**输入http://locahlost:8001/dept/list查看查到的值**

**五、新建服务消费者consumer80模块**

**New Module**

**修改pom文件**

<dependencies>
            <dependency>
                <groupId>springcloud</groupId>
                <artifactId>springcloud-api</artifactId>
                <version>${ project.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-eureka</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-config</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>springloaded</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
            </dependency>
        </dependencies>

**修改application.yml文件**

server:
      port: 80
     
    eureka:
      client:
      	#不将本服务注册进eureka
        register-with-eureka: false
        service-url:
          defaultZone: http://eureka7001.com:7001/eureka/

**编写配置类**

package com.atguigu.springcloud.cfgbeans;
    
    import org.springframework.cloud.client.loadbalancer.LoadBalanced;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.web.client.RestTemplate;
    
    import com.netflix.loadbalancer.IRule;
    import com.netflix.loadbalancer.RetryRule;
    
    @Configuration
    public class ConfigBean //boot -->spring applicationContext.xml --- @Configuration配置 ConfigBean = applicationContext.xml
    {  
    	//注入此类，用来消费者调用服务提供者提供的服务
    	@Bean
    	public RestTemplate getRestTemplate()
    	{ 
    		return new RestTemplate();
    	}

**服务处理类**

package com.atguigu.springcloud.controller;
    
    import java.util.List;
    
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.PathVariable;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    import org.springframework.web.client.RestTemplate;
    
    import com.atguigu.springcloud.entities.Dept;
    
    @RestController
    public class DeptController_Consumer
    { 
    
    	private static final String REST_URL_PREFIX = "http://localhost:8001";
    	/** * 使用 使用restTemplate访问restful接口非常的简单粗暴无脑。 (url, requestMap, * ResponseBean.class)这三个参数分别代表 REST请求地址、请求参数、HTTP响应转换被转换成的对象类型。 */
    	@Autowired
    	private RestTemplate restTemplate;
    
    	@RequestMapping(value = "/consumer/dept/add")
    	public boolean add(Dept dept)
    	{ 
    		return restTemplate.postForObject(REST_URL_PREFIX + "/dept/add", dept, Boolean.class);
    	}
    
    	@RequestMapping(value = "/consumer/dept/get/{id}")
    	public Dept get(@PathVariable("id") Long id)
    	{ 
    		return restTemplate.getForObject(REST_URL_PREFIX + "/dept/get/" + id, Dept.class);
    	}
    
    	@SuppressWarnings("unchecked")
    	@RequestMapping(value = "/consumer/dept/list")
    	public List<Dept> list()
    	{ 
    		return restTemplate.getForObject(REST_URL_PREFIX + "/dept/list", List.class);
    	}
    }

编写主启动类

package com.atguigu.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    //import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
    //import org.springframework.cloud.netflix.ribbon.RibbonClient;
    
    //import com.atguigu.myrule.MySelfRule;
    
    @SpringBootApplication
    @EnableEurekaClient
    public class DeptConsumer80_App
    { 
    	public static void main(String[] args)
    	{ 
    		SpringApplication.run(DeptConsumer80_App.class, args);
    	}
    }

**服务消费者项目结构** ***myrule在后介绍。这里用不到***  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDAxOTQ1_size_16_color_FFFFFF_t_70 4]

**启动consumer**

**此时，基本的服务注册与消费基本已经完成。输入http://localhost:80/consumer/dept/list可查看是否可以得到信息**

**后续：服务注册中心集群搭建…**

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDAxOTQ1_size_16_color_FFFFFF_t_70]: /images/20220401/b15d83548b9549a7a7da9329e45a8c58.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDAxOTQ1_size_16_color_FFFFFF_t_70 1]: /images/20220401/62865558b6844f44a00f3688cf91786e.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDAxOTQ1_size_16_color_FFFFFF_t_70 2]: /images/20220401/073cf5a11a984328b223d1521a679536.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDAxOTQ1_size_16_color_FFFFFF_t_70 3]: /images/20220401/131df03663eb4f91b19ee806e86e3041.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQxMDAxOTQ1_size_16_color_FFFFFF_t_70 4]: /images/20220401/8a6b2079730a4b5f969ad5aa7744787f.png