使用SpringCloud构建简单的服务者和消费者

0.SpringCloud的特点

Springcloud具有下列特点:

  • 约定优于配置;
  • 开箱即用,快速启动(springboot可以以jar或war的方式启动)
  • 适用于多种环境(Pc Server、Docker)
  • 组件轻量,选型中立(例如注册中心可以是Eureka、Consul、Zookeeper)
  • 组件丰富,功能齐全(注册中心,配置中心,智能路由,负载均衡,熔断机制)

    1.创建springboot的项目

    springcloud分布式项目里面的每个小项目都是springboot项目,所以首先搭建springboot项目(这里不主要讲),有两种方法,我使用的编辑器是inteiilij idea.
  • 方法一:
    File—— new Project ——左侧选择Spring Initializr(如果没有这个选项,在插件里面搜索spring boot并安装,之后重启idea),右侧选择jdk版本,default选项不用管,之后接着下一步下一步选择依赖(具体方法网上写的有,可以参考:http://blog.csdn.net/yxl8359026/article/details/51464041)
  • 方法二:
    直接到http://start.spring.io/ 填写项目信息和依赖的服务,之后生成一个压缩包,解压缩就是一个maven类的项目,直接导入编辑工具即可。
    至此服务者microservice-simple-provider-user和消费者microservice-simple-consumer-movie创建完毕。

    2.配置springboot的application.yml配置文件

    默认生成之后是application.properties格式的文件,直接把后缀名改为yml结尾的即可,yml格式的是类似于树型结构的配置文件,示例如下:
    1
    2
    3
    4
    5
    6
    7
    8
    9
    10
    11
    12
    13
    14
    15
    16
    17
    18
    19
    server:
    port: 7900
    spring:
    jpa:
    generate-ddl: false
    show-sql: true
    hibernate:
    ddl-auto: none
    datasource:
    platform: h2
    schema: classpath:schema.sql
    data: classpath:data.sql
    logging:
    level:
    root: INFO
    org.hibernate: INFO
    org.hibernate.type.descriptor.sql.BasicBinder: TRACE
    org.hibernate.type.descriptor.sql.BasicExtractor: TRACE
    com.catchu: DEBUG

这种yml的配置文件首先需要idea识别你的maven工程,才会给出提示,不然不会提示,自己写的话容易出错(yml对格式要求比较严),树型配置文件,与我们熟悉的properties的差不多,比如server:port:7900就相当于server.port=7900。上面配置的意思是配置端口为7900,配置jpa和数据源(为模拟简便使用h2数据库),配置日志级别。

3.开发服务提供者

为模拟简单,这里直接用controller调用dao,不在写业务层,dao直接继承JpaRepository。

1
2
3
4
5
6
7
8
9
10
11
12
13
package com.catchu.microservice.dao;
import com.catchu.microservice.entity.User;
import org.springframework.data.jpa.repository.JpaRepository;
import org.springframework.stereotype.Repository;
/**
* @author 刘俊重
* @Description 用户数据访问层
* @date 18:06
*/
@Repository
public interface UserDao extends JpaRepository<User,Long>{

}

controller代码如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
package com.catchu.microservice.controller;
import com.catchu.microservice.dao.UserDao;
import com.catchu.microservice.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;
/**
* @author 刘俊重
* @Description
* @date 18:09
*/
@RestController
public class UserController {
@Autowired
private UserDao userDao;
@GetMapping("/simple/{id}")
public User findUserbyId(@PathVariable Long id){
return userDao.findOne(id);
}
}

至此提供者写完了,直接运行根包下面的main项目即可,不用单独配置tomcat,浏览器访问http://localhost:7900/simple/3 接收到返回的数据。

4.开发服务消费者

同样是先配置application.yml文件,本例中配置一下端口即可,随后在main方法中创建RestTemplate示例对象,来调用服务者的接口。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
@SpringBootApplication
public class MicroserviceSimpleConsumerMovieApplication {
/**
* @Description 在这里创建RestTemplate实例供其他调用者调用消费者
* @Author 刘俊重
* @Date 2017/10/30
*/
@Bean
public RestTemplate restTemplate(){
return new RestTemplate();
}
public static void main(String[] args) { SpringApplication.run(MicroserviceSimpleConsumerMovieApplication.class, args);
}
}

在消费者的控制层中调用服务者的控制层。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
/**
* @author 刘俊重
* @Description 电影服务控制层
* @date 18:29
*/
@RestController
public class MovieController {
/**
* @Description restTemplate名字与MicroserviceSimpleConsumerMovieApplication里面@bean创建的对象名要一样
*/
@Autowired
private RestTemplate restTemplate;

@Value("${user.userServicePath}")
private String userServicePath;
/**
* @Description 使用restTemplate对象调用服务者——用户模块
*/
@GetMapping("/simple/{id}")
public User findUserById(@PathVariable Long id){
return restTemplate.getForObject(userServicePath+id, User.class);
}
}

到这里消费者已经写好了,直接启动main方法,访问http://localhost:7901/simple/3 就可以看到调用了7900端口下的服务。
总结:首先创建服务的提供者和消费者两个项目,之后修改配置文件,编写服务者和消费者。两个项目是独立的单元,都有自己的控制层,业务层,可以独立部署运行,但它们之前的服务又互相调用;同时服务依赖太严重又会导致不稳定,之后介绍使用注册中心的服务注册和发现。
代码地址:https://gitee.com/catchu/springcloud-study

刘俊重 wechat
欢迎关注我的微信公众号
坚持原创技术分享