天天看点

springCloud 学习第一篇(介绍以及Rest 学习:服务者 与消费者 环境搭建)

什么是SpringCloud?

springCloud ,基于springBoot 提供了一套微服务解决方案,包括服务注册与发现,配置中心全链路监控,服务网关,负载均衡,熔断器等组件,除了基于netFlix 的开源组件做高度抽象封装之外,还有一些选型中立的开源组件

SpringCloud 利用SpringBoot 的开发便利性,巧妙地简化了分布式系统基础实施开发,SpringCloud 为开发人员提供了快速构建分布式系统的一些工具,包括配置管理,服务发现,断路器,路由,微代理,实际总线,全局锁,决策竞选,分布式会话等,都可以用Springboot 的开发风格做到一键启动和部署

SpringBoot 并没有重复造轮子,它只是将目前各家公司开发的比较成熟,经得起实际考验的服务框架组合起来,通过SpringBoot 风格再封装,屏蔽掉了复杂的配置和实现原理,最终给开发者留出了一套简单易懂,易部署和易维护的分布式系统开发工具包

SpringCloud 是分布式微服务结构下的一站式解决方案,是各个微服务架构落地技术的集合体,俗称微服务全家桶。

SpringCloud 和SpringBoot 关系

Springboot 专注快速方便的开发单个个体微服务

SpringCloud 是关注全局的微服务协调整理治理框架,它将Springboot 开发的一个个单体微服务整合并管理起来,为各个微服务之间提供:配置管理,服务发现,断路器,路由,微代理,事件总线,全局锁,决策竞选分布式会话等等集成服务。

SpringBoot 可以离开Springboot 独立使用,开发项目,但是SpringCloud 离不开Springboot,属于依赖关系

Springboot 专注于快速,方便的开发个个体微服务,SpringCloud 关注全局的服务治理框架

Dubbo 和SpringCloud 对比

springCloud 学习第一篇(介绍以及Rest 学习:服务者 与消费者 环境搭建)

最大区别: SpringCloud抛弃 了Dubbo的RPC通信,采用的是基于HTTP的REST方式。

严格来说,这两种方式各有优劣。虽然从- -定程度上来说,后者牺牲了服务调用的性能,但也避免了上面提到的原

生RPC带来的问题。而且REST相比RPC更为灵活, 服务提供方和调用方的依赖只依靠- -纸契约, 不存在代码级别的

强依赖,这在强调快速演化的微服务环境下,显得更加合适。

品牌机与组装机的区别

很明显,Spring Cloud的功能比DUBBO更加强大,涵盖面更广,而且作为Spring的拳头项目,它也能够与Spring

Framework、Spring Boot、Spring Data、Spring Batch等其他Spring项目完美融合,这些对于微服务而言是至

关重要的。使用Dubbo构建的微服务架构就像组装电脑,各环节我们的选择自由度很高,但是最终结果很有可能

因为一条内存质量不行就点不亮了,总是让人不怎么放心,但是如果你是一名高手, 那这些都不是问题;而Spring

Cloud就像品牌机,在Spring Source的整合下,做了大量的兼容性测试,保证了机器拥有更高的稳定性,但是如

果要在使用非原装组件外的东西,就需要对其基础有足够的了解。

社区支持与更新力度

最为重要的是,DUBBO停止了5年左右的更新,虽然2017.7重启了。 对于技术发展的新需求,需要由开发者自行

拓展升级(比如当当网弄出了DubboX),这对于很 多想要采用微服务架构的中小软件组织,显然是不太合适的,

中小公司没有这么强大的技术能力去修改Dubbo源码+周边的一整套解决方案, 并不是每一个公司都有阿里的大牛

+真实的线上生产环境测试过。

在没有使用 微服务开发的时候我们得传统得网站

springCloud 学习第一篇(介绍以及Rest 学习:服务者 与消费者 环境搭建)

总结:

曾风靡国内的开源RPC服务框架Dubbo在重启维护后,令许多用户为之雀跃,但同时,也迎来了一些质疑的声

音。互联网技术发展迅速, Dubbo是否还能跟上时代? Dubbo与Spring Cloud相比又有何优势和差异?是否会

有相关举措保证Dubbo的后续更新频率?

人物: Dubbo重启维护开发的刘军,主要负责人之一

刘军,阿里巴巴中间件高级研发工程师,主导了Dubbo重启维护以后的几个发版计划,专注于高性能RPC框架

Rest学习之环境搭建案例

创建一个maven 得父工程

springCloud 学习第一篇(介绍以及Rest 学习:服务者 与消费者 环境搭建)

导入父工程得依赖

<?xml version="1.0" encoding="UTF-8"?>
<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>org.example</groupId>
    <artifactId>SpringCloud</artifactId>
    <version>1.0-SNAPSHOT</version>
<!--打包方式-->
    <packaging>pom</packaging>
    <properties>
        <java.version>1.8</java.version>
        <springboot.version>2.3.4.RELEASE</springboot.version>
        <springcloud.version>1.4.6.RELEASE</springcloud.version>
        <mysql.version>8.0.21</mysql.version>
        <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>
        <mysql.version>5.1.47</mysql.version>
        <druid.version>1.1.16</druid.version>
        <mybatis.spring.boot.version>1.3.0</mybatis.spring.boot.version>
    </properties>
    <dependencyManagement>
        <dependencies>
            <!-- 下面三个基本是微服务架构的标配 -->
            <!--spring boot 2.2.2-->
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-dependencies</artifactId>
                <version>2.1.4.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <!--spring cloud Hoxton.SR1-->
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-dependencies</artifactId>
                <version>Greenwich.SR1</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>
            <!--spring cloud 阿里巴巴-->
            <dependency>
                <groupId>com.alibaba.cloud</groupId>
                <artifactId>spring-cloud-alibaba-dependencies</artifactId>
                <version>2.1.0.RELEASE</version>
                <type>pom</type>
                <scope>import</scope>
            </dependency>

            <!--mysql-->
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>${mysql.version}</version>
                <scope>runtime</scope>
            </dependency>
            <!-- druid-->
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid</artifactId>
                <version>${druid.version}</version>
            </dependency>
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>${mybatis.spring.boot.version}</version>
            </dependency>
            <!--junit-->
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>${junit.version}</version>
            </dependency>
            <!--log4j-->
            <dependency>
                <groupId>log4j</groupId>
                <artifactId>log4j</artifactId>
                <version>${log4j.version}</version>
            </dependency>

            <!-- https://mvnrepository.com/artifact/org.projectlombok/lombok -->
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <version>1.18.12</version>
                <scope>provided</scope>
            </dependency>
            <!-- https://mvnrepository.com/artifact/org.mybatis.spring.boot/mybatis-spring-boot-starter -->
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>2.1.3</version>
            </dependency>

        </dependencies>
 </dependencyManagement>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
        <resources>
            <resource>
                <directory>src/main/java</directory><!--所在的目录-->
                <includes><!--包括目录下的.properties,.xml文件都会扫描到-->
                    <include>**/*.properties</include>
                    <include>**/*.xml</include>
                </includes>
                <filtering>false</filtering>
            </resource>
        </resources>
    </build>
</project>
      

创建第一个子模块 Springcloud-api 得

springCloud 学习第一篇(介绍以及Rest 学习:服务者 与消费者 环境搭建)

导入Springcloud-api 得依赖

<?xml version="1.0" encoding="UTF-8"?>
<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">
    <parent>
        <artifactId>SpringCloud</artifactId>
        <groupId>org.example</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>SpringCloud-api</artifactId>
<dependencies>
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
    </dependency>
</dependencies>

</project>
      

实体类

springCloud 学习第一篇(介绍以及Rest 学习:服务者 与消费者 环境搭建)

在我们得api 里写我们得实体类

package com.jj.pojo;

import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.Accessors;

import java.io.Serializable;

/**
 * @author fjj
 * @date 2021/4/16 17:06
 */
@Data
@NoArgsConstructor
@Accessors(chain = true) //链式写法
public class Dept  implements Serializable {
    //dept 得实体类
    private Long deptno;
    private String dname;
    private String db_source;

    public Dept(String dname) {
        this.dname = dname;
    }
}
      

创建我们得dept 服务者得模块

springCloud 学习第一篇(介绍以及Rest 学习:服务者 与消费者 环境搭建)

导入依赖 pom.xm

<?xml version="1.0" encoding="UTF-8"?>
<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">
    <parent>
        <artifactId>SpringCloud</artifactId>
        <groupId>org.example</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>spring-cloud-provider-dept-8001</artifactId>

<dependencies>
<!--    拿到需要得实体类,所以要配置api module-->
    <dependency>
        <groupId>org.example</groupId>
        <artifactId>SpringCloud-api</artifactId>
        <version>1.0-SNAPSHOT</version>
    </dependency>
<!--junit-->
    <dependency>
        <groupId>junit</groupId>
        <artifactId>junit</artifactId>
        <scope>test</scope>
    </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-test</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-jetty</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-devtools</artifactId>
    </dependency>
</dependencies>
</project>
      

编写我们服务者得 三层架构

yml 得配置

server:
  port: 8001
  #mybatis 配置
mybatis:
  type-aliases-package: com.jj.pojo
#  config-location: classpath:mybatis/mybatis-config.xml
  mapper-locations: classpath:mybatis/mapper/*.xml
  #spring 得配置
spring:
  application:
    name: springcloud-proviser-dept-8001springcloud-proviser-dept
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT
    username: root
    password: 123456
    type: com.alibaba.druid.pool.DruidDataSource
      

mapper 类

package com.jj.mapper;

import com.jj.pojo.Dept;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Repository;

import java.util.List;

/**
 * @author fjj
 * @date 2021/2/20 18:25
 */
@Mapper
@Repository
public interface Deptmapper {
    //添加
    public boolean adddept(Dept dept);
    //通过id 查询
    public Dept querybyid(int id);
    //全查
    public List<Dept> queryall();
}
      

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.jj.mapper.Deptmapper">
<!--    添加-->
    <insert id="adddept" parameterType="Dept">
        insert into dept(dname,db_source)
        values (#{dname},DATABASE())
    </insert>
<!--    通过id查询-->
    <select id="querybyid" resultType="Dept" parameterType="int">
        select * from dept where deptno =#{deptno}
    </select>
<!--    全查-->
    <select id="queryall" resultType="Dept">
        select * from dept
    </select>
</mapper>
      

service 层

package com.jj.service;

import com.jj.mapper.Deptmapper;
import com.jj.pojo.Dept;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * @author fjj
 * @date 2021/2/20 18:31
 */
@Service
public class Deptserviceimpl implements Deptservice {
   //注入
    @Autowired
   Deptmapper deptmapper;

    @Override
    public boolean adddept(Dept dept) {
        return deptmapper.adddept(dept);
    }

    @Override
    public Dept querybyid(int id) {
        return deptmapper.querybyid(id);
    }

    @Override
    public List<Dept> queryall() {
        return deptmapper.queryall();
    }
}
      

控制层

package com.jj.Controller;

import com.jj.pojo.Dept;
import com.jj.service.Deptserviceimpl;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.List;


/**
 * @author fjj
 * @date 2021/2/20 18:35
 */
@RestController
public class DeptController {
    //注入
    @Autowired
    private Deptserviceimpl deptserviceimpl;
    //添加
    @GetMapping("/dept/add")
    public boolean addDept(Dept dept){
        return  deptserviceimpl.adddept(dept);
    }
    //通过id 获取
    @GetMapping("/dept/get/{id}")
    public Dept get(@PathVariable("id") int id){
        return  deptserviceimpl.querybyid(id);
    }
    //全查
    @GetMapping("/dept/list")
    public List<Dept> queryAll(){
        return deptserviceimpl.queryall();
    }
}
      

结果

添加

springCloud 学习第一篇(介绍以及Rest 学习:服务者 与消费者 环境搭建)
springCloud 学习第一篇(介绍以及Rest 学习:服务者 与消费者 环境搭建)

通过id 查询

springCloud 学习第一篇(介绍以及Rest 学习:服务者 与消费者 环境搭建)

全查

springCloud 学习第一篇(介绍以及Rest 学习:服务者 与消费者 环境搭建)

创建消费者得模块

springCloud 学习第一篇(介绍以及Rest 学习:服务者 与消费者 环境搭建)

导入我们消费者需要得依赖

<?xml version="1.0" encoding="UTF-8"?>
<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">
    <parent>
        <artifactId>SpringCloud</artifactId>
        <groupId>org.example</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>

    <artifactId>springcloud-consumer-dept-80</artifactId>
<dependencies>
<!--    拿到我们得实体类-->
    <!--    拿到需要得实体类,所以要配置api module-->
    <dependency>
        <groupId>org.example</groupId>
        <artifactId>SpringCloud-api</artifactId>
        <version>1.0-SNAPSHOT</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
</dependencies>

</project>
      

**注入我们消费者得config **

消费者代码

写config 把注入到我们

package config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

/**
 * @author fjj
 * @date 2021/4/19 11:07
 */

@Configuration
public class RestConfig {
    @Bean

    public RestTemplate getRestTemplate(){

        return new RestTemplate();
    }

}
      

控制层

package com.jj.demo.controller;

import com.jj.pojo.Dept;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.validation.annotation.Validated;
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 java.awt.*;
import java.util.List;

/**
 * @author fjj
 * @date 2021/2/21 17:03
 */
@RestController
public class DeptConsumer {
    //注入rest 模板
    @Autowired
   private RestTemplate rtstTemplate;
    //url
    private static final String url="http://localhost:8001";
    //全查
    @RequestMapping("/consumer/dept/list")
public List<Dept> list(){
        return rtstTemplate.getForObject(url+"/dept/list",List.class);
    }
    //通过id
    @RequestMapping("consumer/dept/get/{id}")
    public Dept getid(@PathVariable("id") int id){
        return rtstTemplate.getForObject(url+"dept/get/"+id,Dept.class);
    }
}
      

效果

springCloud 学习第一篇(介绍以及Rest 学习:服务者 与消费者 环境搭建)