欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识！
您现在的位置是： 首页  >  IT编程

初识SpringCloud微服务

程序员文章站 2022-04-28 13:01:28
微服务是一种架构方式，最终肯定需要技术架构去实施。 微服务的实现方式很多，但是最火的莫过于Spring Cloud了。为什么？ 后台硬：作为Spring家族的一员，有整个Spring全家桶靠山，背景十分强大。 技术强：Spring作为Java领域的前辈，可以说是功力深厚。有强力的技术团队支撑，一般人 ......

微服务是一种架构方式，最终肯定需要技术架构去实施。

微服务的实现方式很多，但是最火的莫过于spring cloud了。为什么？

  • 后台硬：作为spring家族的一员，有整个spring全家桶靠山，背景十分强大。

  • 技术强：spring作为java领域的前辈，可以说是功力深厚。有强力的技术团队支撑，一般人还真比不了

  • 群众基础好：可以说大多数程序员的成长都伴随着spring框架，试问：现在有几家公司开发不用spring？springcloud与spring的各个框架无缝整合，对大家来说一切都是熟悉的配方，熟悉的味道。

  • 使用方便：相信大家都体会到了springboot给我们开发带来的便利，而springcloud完全支持springboot的开发，用很少的配置就能完成微服务框架的搭建

一:简介

springcloud是spring旗下的项目之一，

spring最擅长的就是集成，把世界上最好的框架拿过来，集成到自己的项目中。

springcloud也是一样，它将现在非常流行的一些技术整合到一起，实现了诸如：配置管理，服务发现，智能路由，负载均衡，熔断器，控制总线，集群状态等等功能。其主要涉及的组件包括：

netflix

  • eureka：注册中心

  • zuul：服务网关

  • ribbon：负载均衡

  • feign：服务调用

  • hystix：熔断器

以上只是其中一部分，架构图：

初识SpringCloud微服务

二:微服务场景模拟

  首先，我们需要模拟一个服务调用的场景。方便后面学习微服务架构

 2.1.服务提供者

 我们新建一个项目，对外提供查询用户的服务。

 2.1.1.spring脚手架创建工程

 借助于spring提供的快速搭建工具：

初识SpringCloud微服务

 填写项目信息：

初识SpringCloud微服务

 添加web依赖：

 初识SpringCloud微服务

 添加mybatis依赖：

初识SpringCloud微服务

  填写项目位置：

初识SpringCloud微服务

 生成的项目结构：

初识SpringCloud微服务

 依赖也已经全部自动引入：

<?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>com.leyou.demo</groupid>
<artifactid>user-service-demo</artifactid>
<version>0.0.1-snapshot</version>
<packaging>jar</packaging>

<name>user-service-demo</name>
<description>demo project for spring boot</description>

<parent>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-starter-parent</artifactid>
<version>2.0.1.release</version>
<relativepath/> <!-- lookup parent from repository -->
</parent>

<properties>
<project.build.sourceencoding>utf-8</project.build.sourceencoding>
<project.reporting.outputencoding>utf-8</project.reporting.outputencoding>
<java.version>1.8</java.version>
</properties>

<dependencies>
<dependency>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-starter-jdbc</artifactid>
</dependency>
<dependency>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-starter-web</artifactid>
</dependency>
<dependency>
<groupid>org.mybatis.spring.boot</groupid>
<artifactid>mybatis-spring-boot-starter</artifactid>
<version>1.3.2</version>
</dependency>
<dependency>
<groupid>mysql</groupid>
<artifactid>mysql-connector-java</artifactid>
<scope>runtime</scope>
</dependency>
<dependency>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-starter-test</artifactid>
<scope>test</scope>
</dependency>
</dependencies>

<build>
<plugins>
<plugin>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-maven-plugin</artifactid>
</plugin>
</plugins>
</build>
</project>

 当然，因为要使用通用mapper，所以我们需要手动加一条依赖：

<dependency>
    <groupid>tk.mybatis</groupid>
    <artifactid>mapper-spring-boot-starter</artifactid>
    <version>2.0.2</version>
</dependency>

 非常快捷啊！

 2.1.2.编写代码

 添加一个对外查询的接口：

@restcontroller
@requestmapping("user")
public class usercontroller {
​
    @autowired
    private userservice userservice;
​
    @getmapping("/{id}")
    public user querybyid(@pathvariable("id") long id) {
        return this.userservice.querybyid(id);
    }
}

 service：

@service
public class userservice {
​
    @autowired
    private usermapper usermapper;
​
    public user querybyid(long id) {
        return this.usermapper.selectbyprimarykey(id);
    }
}

mapper:

@mapper
public interface usermapper extends tk.mybatis.mapper.common.mapper<user>{
}

实体类：

@table(name = "tb_user")
public class user implements serializable {
​
    private static final long serialversionuid = 1l;
​
    @id
    @generatedvalue(strategy = generationtype.identity)
    private long id;
​
    // 用户名
    private string username;
​
    // 密码
    private string password;
​
    // 姓名
    private string name;
​
    // 年龄
    private integer age;
​
    // 性别，1男性，2女性
    private integer sex;
​
    // 出生日期
    private date birthday;
​
    // 创建时间
    private date created;
​
    // 更新时间
    private date updated;
​
    // 备注
    private string note;
​
   // 。。。省略getters和setters
}
​

属性文件,这里我们采用了yaml语法，而不是properties：

server:
  port: 8081
spring:
  datasource:
    url: jdbc:mysql://localhost:3306/mydb01
    username: root
    password: 123
    hikari:
      maximum-pool-size: 20
      minimum-idle: 10
mybatis:
  type-aliases-package: com.leyou.userservice.pojo

项目结构：

初识SpringCloud微服务

2.1.3.启动并测试：

启动项目，访问接口：

初识SpringCloud微服务

2.2.服务调用者

2.2.1.创建工程

与上面类似，这里不再赘述，需要注意的是，我们调用user-service的功能，因此不需要mybatis相关依赖了。

pom：

<?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>com.leyou.demo</groupid>
<artifactid>user-consumer-demo</artifactid>
<version>0.0.1-snapshot</version>
<packaging>jar</packaging>

<name>user-consumer-demo</name>
<description>demo project for spring boot</description>

<parent>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-starter-parent</artifactid>
<version>2.0.1.release</version>
<relativepath/> <!-- lookup parent from repository -->
</parent>

<properties>
<project.build.sourceencoding>utf-8</project.build.sourceencoding>
<project.reporting.outputencoding>utf-8</project.reporting.outputencoding>
<java.version>1.8</java.version>
</properties>

<dependencies>
<dependency>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-starter-web</artifactid>
</dependency>
<!-- 添加okhttp支持 -->
<dependency>
<groupid>com.squareup.okhttp3</groupid>
<artifactid>okhttp</artifactid>
<version>3.9.0</version>
</dependency>
</dependencies>

<build>
<plugins>
<plugin>
<groupid>org.springframework.boot</groupid>
<artifactid>spring-boot-maven-plugin</artifactid>
</plugin>
</plugins>
</build>

</project>

2.2.2.编写代码

首先在启动类中注册resttemplate：

@springbootapplication
public class userconsumerdemoapplication {

@bean
public resttemplate resttemplate() {
// 这次我们使用了okhttp客户端,只需要注入工厂即可
return new resttemplate(new okhttp3clienthttprequestfactory());
}

public static void main(string[] args) {
springapplication.run(userconsumerdemoapplication.class, args);
}
}

然后编写userdao，注意，这里不是调用mapper查数据库，而是通过resttemplate远程查询user-service-demo中的接口：

@component
public class userdao {

@autowired
private resttemplate resttemplate;

public user queryuserbyid(long id){
string url = "http://localhost:8081/user/" + id;
return this.resttemplate.getforobject(url, user.class);
}
}

然后编写user-service，循环查询userdao信息：

@service
public class userservice {

@autowired
private userdao userdao;

public list<user> queruserbyids(list<long> ids){
list<user> users = new arraylist<>();
for (long id : ids) {
user user = this.userdao.queryuserbyid(id);
users.add(user);
}
return users;
}
}

编写controller：

@restcontroller
@requestmapping("consume")
public class consumercontroller {

@autowired
private userservice userservice;

@getmapping
public list<user> consume(@requestparam("ids") list<long> ids) {
return this.userservice.queryuserbyids(ids);
}
}

2.2.3.启动测试：

因为我们没有配置端口，那么默认就是8080，我们访问：

初识SpringCloud微服务

一个简单的远程服务调用案例就实现了。

简单回顾一下，刚才我们写了什么：

  • use-service-demo：一个提供根据id查询用户的微服务

  • consumer-demo：一个服务调用者，通过resttemplate远程调用user-service-demo

流程如下：

初识SpringCloud微服务

存在什么问题？

  • 在consumer中，我们把url地址硬编码到了代码中，不方便后期维护

  • consumer需要记忆user-service的地址，如果出现变更，可能得不到通知，地址将失效

  • consumer不清楚user-service的状态，服务宕机也不知道

  • user-service只有1台服务，不具备高可用性

  • 即便user-service形成集群，consumer还需自己实现负载均衡

其实上面说的问题，概括一下就是分布式服务必然要面临的问题：

  • 服务管理

    • 如何自动注册和发现

    • 如何实现状态监管

    • 如何实现动态路由

  • 服务如何实现负载均衡--- (动态路由)

  • 服务如何解决容灾问题

  • 服务如何实现统一配置

以上的问题，我们都将在eureka注册中心中得到答案。

上一篇： 简单的C# Socket通信实例

下一篇： 都穷，都穷

推荐阅读