spring cloud(一) 从一个简单的springboot服务开始

目录

一、 为什么要使用微服务呢?它相比传统的单体应用有什么优缺点呢?

从单体应用和微服务的区别开始说起吧。简单来说,传统的单体应用就是把项目所需的全部文件打包在一起,而微服务指的是将功能拆分成可以独立运行的服务,分开部署,服务之间通过一些轻量级的通信机制进行通信,这些服务一起构建器整个系统。单从介绍来看微服务似乎有故意把简单的问题复杂化的嫌疑,但是经手过传统的单体应用的小伙伴肯定都深有体会,随着项目的不断开发,项目的维护成本越来越高,很多功能相互调用,牵一发而动全身。不仅如此,编译调试的过程也越来越慢。对于新的需求想用全新的技术栈提高开发效率也是非常困难。那么微服务的出现正是为了解决日益复杂庞大的单体应用所导致的项目维护难,升级难的问题。
那么列举一下微服务的优点吧:

  1. 易于开发和维护:因为一个微服务通常只专注一个特定的业务功能,所以它的业务比较清晰,代码量相对较少,开发和维护单个微服务相对简单。
  2. 技术栈不受限:多个微服务之间通过轻量级的通信机制进行通信,每个微服务完全可以选择更适合此项业务的技术栈。
  3. 更合理利用资源:多个微服务分开部署,可以针对io密集型的服务,和cpu密集型的服务部署在特定的服务器上。可针对某个特定的服务升级内存或增加节点。
  4. 复用性强: 就像堆积木一样,通用性强的服务可以用在多个项目中。

微服务的确定:

  1. 运维困难: 更多的服务意味着需要投入更多的精力去维护项目,与传统的只需要保证一个服务正常运行相比,保证成吨的服务正常运行显然要更费劲。
  2. 分布式固有的复杂性:在分布式系统中,网络延迟,分布式事务,服务之间的容错等都是技术挑战。
  3. 接口的维护成本高: 微服务之间通过api进行通信,如果修改某个服务的api将导致其他使用此api的服务做出相应的调整。
  4. 重复的工作: 一些功能有可能多个服务都需要,此时可能会多个服务都实现同样的功能。

二、 微服务带来了曙光,也带来了挑战,那么应对这些挑战我们需要一些设计原则

  1. 单一职责原则
    一个服务只干一件事了。
  2. 服务自治原则
    每个服务得有基本的自理能力吧。开发、测试、部署、运行都应该可以独立完成。
  3. 轻量级通信原则
    一定要轻啊,带宽很重要。也要满足跨平台的特性,常用的协议有:REST,AMQP,STOMP,MQTT
  4. 微服务的粒度
    如何确定服务的边界这是尝尝争论的焦点。需要考虑的因素很多,如业务本身,团队的情况等等。

三、本系列实现微服务的技术选择

  1. spring-cloud 可以很好的和springboot一起工作,属于主流的解决方案,文档丰富社区活跃。
  2. docker 出于方便,快捷以及易用性考虑选择docker作为微服务的运行平台。

四、 先从springboot开始实现一个简单的服务间调用吧

场景介绍: 我们实现两个服务,一个生产者服务,一个消费者服务。消费者调用生产者并获取一个用户信息。
技术选择:java版本:1.8,springboot版本:2.0.5.RELEASE,ORM:JPA,数据库:h2,依赖管理工具:maven,开发工具:idea

1. 新建一个项目product_server

新建空项目product_server

2. 添加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.yshmsoft</groupId>
    <artifactId>product_server</artifactId>
    <version>1.0-SNAPSHOT</version>

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

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>
        <dependency>
            <groupId>com.h2database</groupId>
            <artifactId>h2</artifactId>
        </dependency>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

3. 在classpath下建立schema.sql建表语句和data.sql数据语句,并添加如下内容:

// schema.sql
drop table user if exists;
create table user(
  id bigint generated by default as identity,
  name varchar(20),
  age int(3),
  money decimal(10,2),
  primary key(id)
);

//data.sql 
insert into user(id,name,age,money) values (1, 'user1', 18, 233.22);
insert into user(id,name,age,money) values (2, 'user2', 22, 21133.22);
insert into user(id,name,age,money) values (3, 'user3', 34, 23333.22);
insert into user(id,name,age,money) values (4, 'user4', 54, 555233.22);
insert into user(id,name,age,money) values (5, 'user5', 19, 2332313.22);
insert into user(id,name,age,money) values (6, 'user6', 33, 2335522.22);

4. 新建User实体

package com.yshmsoft.entity;

import javax.persistence.*;
import java.math.BigDecimal;
@Entity
public class User {
    @Id
    @GeneratedValue(strategy = GenerationType.AUTO)
    private Long id;
    @Column
    private String name;
    @Column
    private Integer age;
    @Column
    private BigDecimal money;
    //getter setter
}

5. 新建UserDao

package com.yshmsoft.dao;

import com.yshmsoft.entity.User;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;

@Repository
public interface UserDao extends JpaRepository<User,Long> {
}

6.新建UserController

package com.yshmsoft.controller;

import com.yshmsoft.dao.UserDao;
import com.yshmsoft.entity.User;
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.RestController;

@RestController
public class UserController {
    @Autowired
    UserDao userDao;
    @GetMapping("/{id}")
    public User getUserById(@PathVariable Long id) {
        return userDao.findById(id);
    }
}

7.编写application.yml

server:
  port: 8080
spring:
  datasource:
    platform: h2
    schema: classpath:schema.sql
    data: classpath:data.sql
  jpa:
    generate-ddl: false
    show-sql: true
    hibernate:
      ddl-auto: none
logging:
  level:
    root: info
    org.hibernate: info

8.添加启动类

  package com.yshmsoft;

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

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

9. 运行项目并访问http://localhost:8080/1

访问结果

10. 新建一个comsume_server模块

新建模块

comsume_server模块

11. 同上一个项目一样配置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.yshmsoft</groupId>
    <artifactId>consome_server</artifactId>
    <version>1.0-SNAPSHOT</version>

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

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <java.version>1.8</java.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
    </dependencies>
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
            </plugin>
        </plugins>
    </build>
</project>

12. 新建User类

package com.yshmsoft.entity;

import java.math.BigDecimal;

public class User {
    private Long id;
    private String name;
    private Integer age;
    private BigDecimal money;
    // getter setter
}

13.创建消费者Controller

package com.yshmsoft.controller;

import com.yshmsoft.entity.User;
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.RestController;
import org.springframework.web.client.RestTemplate;

@RestController
public class UserController {
    @Autowired
    RestTemplate restTemplate; //spring 提供的RestTemplate,方便调用Rest接口
    @GetMapping("/user/{id}")
    User getUserById(@PathVariable Long id) {
        User user = restTemplate.getForObject("http://localhost:8080/" + id, User.class);
        return user;
    }
}

14. 创建配置文件application.yml

server:
  port: 8000
logging:
  level:
    root: info

15. 创建启动类

package com.yshmsoft;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
import org.springframework.web.client.RestTemplate;

@SpringBootApplication
public class ConsumeApplication {

    @Bean
    public RestTemplate restTemplate() {
        return new RestTemplate();
    }

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

16 启动项目并访问http://localhost:8000/user/1

访问成功示例

到此完成第一个示例的编写。

五、 谈一谈上面的示例

完成了一个简单的微服务之间调用,上面这种微服务的实现方式会面临什么问题呢?

  1. 上面的例子中生产者的api是写死的,当生产者的api地址改变时消费者要跟着改变。
  2. 这种方式服务的伸缩性比较差,服务对单个服务的依赖性较强
  3. 每次新建一个服务都要配置api地址心累。

接下来我们开始spring cloud的学习吧,看看spring cloud为我们提供的解决方案。敬请期待。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 204,793评论 6 478
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 87,567评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 151,342评论 0 338
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,825评论 1 277
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,814评论 5 368
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,680评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,033评论 3 399
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,687评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 42,175评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,668评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,775评论 1 332
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,419评论 4 321
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,020评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,978评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,206评论 1 260
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,092评论 2 351
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,510评论 2 343

推荐阅读更多精彩内容