spring cloud总结(一)--rest客户端与服务端

爱被打了一巴掌 2022-04-02 14:43 235阅读 0赞

**目录**

0说明

0.1本文类容来自尚硅谷

0.2目录结构

1继承的父项目microservicecloud

1.0目录结构

1.1pom.xml

2客户端及consumer模块

2.0目录结构

2.1application.yml里面的内容

2.1pom.xml

2.2启动类DeptConsumer80\_App.java

2.3controller层

2.4各个bean的注册

3服务端及dep这个模块

3.1目录结构如下

3.2application.yml内容如下

3.3pom.xml内容如下

3.4启动类DeptProvider8001\_App.java

3.5controller层

3.6service层

3.6.1DeptService.java(接口)

3.6.2接口的实现类DeptServiceImpl

3.7dao层

3.8mybatis的配置文件mybatis.cfg.xml

3.9映射文件DeptMapper.xml里面的内容

--------------------

# 0说明 #

##    0.1本文类容来自尚硅谷 ##

##    0.2目录结构 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xzeDIwMTc_size_16_color_FFFFFF_t_70][]

# 1继承的父项目microservicecloud #

##    1.0目录结构 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xzeDIwMTc_size_16_color_FFFFFF_t_70 1][]

##    1.1pom.xml ##

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    	<modelVersion>4.0.0</modelVersion>
    
    	<groupId>com.atguigu.springcloud</groupId>
    	<artifactId>microservicecloud</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<packaging>pom</packaging>
    
    
    	<properties>
    		<project.build.sourceEncoding>UTF-8</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.0.4</version>
    			</dependency>
    			<dependency>
    				<groupId>com.alibaba</groupId>
    				<artifactId>druid</artifactId>
    				<version>1.0.31</version>
    			</dependency>
    			<dependency>
    				<groupId>org.mybatis.spring.boot</groupId>
    				<artifactId>mybatis-spring-boot-starter</artifactId>
    				<version>1.3.0</version>
    			</dependency>
    			<dependency>
    				<groupId>ch.qos.logback</groupId>
    				<artifactId>logback-core</artifactId>
    				<version>1.2.3</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>microservicecloud</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>
    
    
    	<modules>
    		<module>microservicecloud-api</module>
    		<module>microservicecloud-provider-dept-8001</module>
    		<module>microservicecloud-consumer-dept-80</module>
    		<module>microservicecloud-eureka-7001</module>
    		<module>microservicecloud-eureka-7002</module>
    		<module>microservicecloud-eureka-7003</module>
    		<module>microservicecloud-provider-dept-8002</module>
    		<module>microservicecloud-provider-dept-8003</module>
    		<module>microservicecloud-consumer-dept-feign</module>
    		<module>microservicecloud-provider-dept-hystrix-8001</module>
    		<module>microservicecloud-consumer-hystrix-dashboard</module>
    		<module>microservicecloud-zuul-gateway-9527</module>
    		<module>microservicecloud-config-3344</module>
    		<module>microservicecloud-config-client-3355</module>
    		<module>microservicecloud-config-eureka-client-7001</module>
    		<module>microservicecloud-config-dept-client-8001</module>
    	</modules>
    
    </project>

# 2客户端及consumer模块 #

##     2.0目录结构 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xzeDIwMTc_size_16_color_FFFFFF_t_70 2][]

##     2.1application.yml里面的内容 ##

server:
      port: 80

##     2.1pom.xml ##

## 2.2启动类DeptConsumer80\_App.java ##

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.ribbon.RibbonClient;
    
    import com.atguigu.myrule.MySelfRule;
    
    @SpringBootApplication
    @EnableEurekaClient
    //在启动该微服务的时候就能去加载我们的自定义Ribbon配置类，从而使配置生效
    //@RibbonClient(name="MICROSERVICECLOUD-DEPT",configuration=MySelfRule.class)
    @RibbonClient(name="MICROSERVICECLOUD-DEPT",configuration=MySelfRule.class)
    public class DeptConsumer80_App
    {
    	public static void main(String[] args)
    	{
    		SpringApplication.run(DeptConsumer80_App.class, args);
    	}
    }

## 2.3controller层 ##

及DeptController\_Consumer.java里面的内容

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";
    	private static final String REST_URL_PREFIX = "http://MICROSERVICECLOUD-DEPT";
    
    	/**
    	 * 使用 使用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);
    	}
    
    	// 测试@EnableDiscoveryClient,消费端可以调用服务发现
    	@RequestMapping(value = "/consumer/dept/discovery")
    	public Object discovery()
    	{
    		return restTemplate.getForObject(REST_URL_PREFIX + "/dept/discovery", Object.class);
    	}
    
    }

## 2.4各个bean的注册 ##

及ConfigBean.java里面的内容

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
    	@LoadBalanced//Spring Cloud Ribbon是基于Netflix Ribbon实现的一套客户端       负载均衡的工具。
    	public RestTemplate getRestTemplate()
    	{
    		return new RestTemplate();
    	}
    	
    	@Bean
    	public IRule myRule()
    	{
    		//return new RoundRobinRule();
    		//return new RandomRule();//达到的目的，用我们重新选择的随机算法替代默认的轮询。
    		return new RetryRule();
    	}
    }

# 3服务端及dep这个模块 #

## 3.1目录结构如下 ##

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xzeDIwMTc_size_16_color_FFFFFF_t_70 3][]

## 3.2application.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: org.gjt.mm.mysql.Driver              # mysql驱动包
        url: jdbc:mysql://localhost:3306/cloudDB01              # 数据库名称
        username: root
        password: 123456
        dbcp2:
          min-idle: 5                                           # 数据库连接池的最小维持连接数
          initial-size: 5                                       # 初始化连接数
          max-total: 5                                          # 最大连接数
          max-wait-millis: 200                                  # 等待连接获取的最大超时时间
          
    eureka:
      client: #客户端注册进eureka服务列表内
        service-url: 
          #defaultZone: http://localhost:7001/eureka
           defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/      
      instance:
        instance-id: microservicecloud-dept8001
        prefer-ip-address: true     #访问路径可以显示IP地址     
     
    info: 
      app.name: atguigu-microservicecloud
      company.name: www.atguigu.com
      build.artifactId: $project.artifactId$
      build.version: $project.version$

## 3.3pom.xml内容如下 ##

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    	<modelVersion>4.0.0</modelVersion>
    
    	<parent>
    		<groupId>com.atguigu.springcloud</groupId>
    		<artifactId>microservicecloud</artifactId>
    		<version>0.0.1-SNAPSHOT</version>
    	</parent>
    
    	<artifactId>microservicecloud-provider-dept-8001</artifactId>
    
    	<dependencies>
    		
    		<dependency>
    			<groupId>com.atguigu.springcloud</groupId>
    			<artifactId>microservicecloud-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>
    
    </project>

## 3.4启动类DeptProvider8001\_App.java ##

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服务中
    @EnableDiscoveryClient //服务发现
    public class DeptProvider8001_App
    {
    	public static void main(String[] args)
    	{
    		SpringApplication.run(DeptProvider8001_App.class, args);
    	}
    }

## 3.5controller层 ##

即DeptController.java类里面的内容

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;
    	@Autowired
    	private DiscoveryClient client;
    
    	@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();
    	}
    
    	
    //	@Autowired
    //	private DiscoveryClient client;
    	@RequestMapping(value = "/dept/discovery", method = RequestMethod.GET)
    	public Object discovery()
    	{
    		List<String> list = client.getServices();
    		System.out.println("**********" + list);
    
    		List<ServiceInstance> srvList = client.getInstances("MICROSERVICECLOUD-DEPT");
    		for (ServiceInstance element : srvList) {
    			System.out.println(element.getServiceId() + "\t" + element.getHost() + "\t" + element.getPort() + "\t"
    					+ element.getUri());
    		}
    		return this.client;
    	}
    
    }

## 3.6service层 ##

###     3.6.1DeptService.java(接口) ###

package com.atguigu.springcloud.service;
    
    import java.util.List;
    
    import com.atguigu.springcloud.entities.Dept;
    
    public interface DeptService
    {
    	public boolean add(Dept dept);
    
    	public Dept get(Long id);
    
    	public List<Dept> list();
    }

### 3.6.2接口的实现类DeptServiceImpl ###

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();
    	}
    
    }

## 3.7dao层 ##

接口类DeptDao.java里面的内容

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();
    }

## 3.8mybatis的配置文件mybatis.cfg.xml ##

<?xml version="1.0" encoding="UTF-8" ?>
    <!DOCTYPE configuration
      PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
      "http://mybatis.org/dtd/mybatis-3-config.dtd">
    
    <configuration>
    
    	<settings>
    		<setting name="cacheEnabled" value="true" />
    	</settings>
    
    </configuration>

## 3.9映射文件DeptMapper.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="Dept" parameterType="Long">
    		select deptno,dname,db_source from dept where deptno=#{deptno};
    	</select>
    	<select id="findAll" resultType="Dept">
    		select deptno,dname,db_source from dept;
    	</select>
    	<insert id="addDept" parameterType="Dept">
    		INSERT INTO dept(dname,db_source) VALUES(#{dname},DATABASE());
    	</insert>
    
    </mapper>

到此，spingcloud的rest微服务案例的demo代码已经完全呈现

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xzeDIwMTc_size_16_color_FFFFFF_t_70]: /images/20220402/e12bd8be81d04813afbfd73b26d16d0c.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xzeDIwMTc_size_16_color_FFFFFF_t_70 1]: /images/20220402/8347bb2897384f899c87990f0697e781.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xzeDIwMTc_size_16_color_FFFFFF_t_70 2]: /images/20220402/ea6fdccee6bc4e43b06fd8cfde5c9fbc.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2xzeDIwMTc_size_16_color_FFFFFF_t_70 3]: /images/20220402/1604b5c4d6c14177b11094d6a6840814.png