SpringCloud入门(二) ------基于RestTemplate搭建微服务工程
RestTemplate:RestTemplate提供了多种便捷访问远程Http服务的方法,是一种简单便捷的访问restful服务模板类,是Spring提供的用于访问Rest服务的客户端模板工具集。搭建微服务工程:1. 微服务工程首先是个maven的聚合项目:用idea file ----> new ---->new Project,先创建一个空的工程2.创建父工程,...
·
RestTemplate:
RestTemplate提供了多种便捷访问远程Http服务的方法,
是一种简单便捷的访问restful服务模板类,是Spring提供的用于访问Rest服务的客户端模板工具集。
搭建微服务工程:
1. 微服务工程首先是个maven的聚合项目:
用idea file ----> new ----> new Project,先创建一个空的工程
2.创建父工程,引入一些必备的jar
在里面创建module,是一个maven的项目,将src文件夹删除,在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.jym</groupId>
<artifactId>jymcloudservice</artifactId>
<packaging>pom</packaging>
<version>1.0-SNAPSHOT</version>
<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.1.6</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.1.11</version>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
</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>
<modules>
<module>../jymcloudservice-common</module>
<module>../jymcloudservice-provider</module>
<module>../jymcloudservice-consumer</module>
</modules>
</project>
3.接下来创建一个服务和调用者都需要的资源,主要方一些实体类,以及工具类等,注意创建的路径要跟父工程在同一目录下
这里简单写了一个实体类,对应数据库表的。
创建完成后,要mvn install一下,方便服务与消费者引用依赖,否则本地库没有
4.创建服务的提供者,创建方式与上面一致
一个简单的ssm框架:
主要的代码:
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>
<parent>
<artifactId>jymcloudservice</artifactId>
<groupId>com.jym</groupId>
<version>1.0-SNAPSHOT</version>
<relativePath>../jymcloudservice/pom.xml</relativePath>
</parent>
<groupId>com.jym</groupId>
<artifactId>jymcloudservice-provider</artifactId>
<version>1.0-SNAPSHOT</version>
<dependencies>
<dependency>
<artifactId>jymcloudservice-common</artifactId>
<groupId>com.jym</groupId>
<version>1.0-SNAPSHOT</version>
</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.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.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>3.5.2</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-devtools</artifactId>
<version>1.5.12.RELEASE</version>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.1.1</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.1.9</version>
</dependency>
</dependencies>
</project>
yml文件:
server:
port: 8001
mybatis:
config-location: classpath:mybatis/mybatis.cfg.xml # mybatis配置文件所在路径
type-aliases-package: com.jym.jymcloudservice.entity # 所有Entity别名类所在包
mapper-locations:
- classpath:mybatis/mapper/*.xml # mapper映射文件
spring:
application:
name: jymservicecloud-dept
datasource:
type: com.alibaba.druid.pool.DruidDataSource # 当前数据源操作类型
driver-class-name: com.mysql.jdbc.Driver # mysql驱动包
url: jdbc:mysql://localhost:3306/clouddb01?useSSL=true&serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8 # 数据库名称
username: root
password: admin
dbcp2:
min-idle: 5 # 数据库连接池的最小维持连接数
initial-size: 5 # 初始化连接数
max-total: 5 # 最大连接数
max-wait-millis: 200 # 等待连接获取的最大超时时间
mapper文件:
<?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.jym.deptprovider.dao.DeptDao">
<select id="findById" resultType="com.jym.jymcloudservice.entity.Dept" parameterType="Long">
select deptno,dname,db_source from dept where deptno=#{deptno};
</select>
<select id="findAll" resultType="java.util.List">
select deptno,dname,db_source from dept;
</select>
</mapper>
controller:
package com.jym.deptprovider.controller;
import com.jym.deptprovider.service.DeptService;
import com.jym.jymcloudservice.entity.Dept;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;
/**
* @program: cloudTest
* @description:
* @author: jym
* @create: 2020/02/25
*/
@RestController
@RequestMapping("/dept")
public class DeptController {
@Autowired
private DeptService deptService;
@RequestMapping(value = "get/{id}",method = RequestMethod.GET)
public Dept get (@PathVariable long id) {
return deptService.get(id);
}
@RequestMapping(value = "/list",method = RequestMethod.GET)
public List<Dept> list () {
return deptService.list();
}
}
浏览器调用成功。。。
5.创建服务的调用者
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">
<parent>
<artifactId>jymcloudservice</artifactId>
<groupId>com.jym</groupId>
<version>1.0-SNAPSHOT</version>
<relativePath>../jymcloudservice/pom.xml</relativePath>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>jymcloudservice-consumer</artifactId>
<dependencies>
<dependency>
<artifactId>jymcloudservice-common</artifactId>
<groupId>com.jym</groupId>
<version>1.0-SNAPSHOT</version>
</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.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>
<version>1.5.12.RELEASE</version>
</dependency>
</dependencies>
</project>
yml:
server:
port: 8002
因为要用到RestTemplate 调用,所以需要配置类,将RestTemplate 注入IOC容器
package com.jym.deptconsumer.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;
/**
* @program: cloudTest
* @description:
* @author: jym
* @create: 2020/02/26
*/
@Configuration
public class JymConfigBean {
@Bean
public RestTemplate restTemplate () {
return new RestTemplate();
}
}
启动类: 将扫面配置类
package com.jym.deptconsumer;
import com.jym.deptconsumer.config.JymConfigBean;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
/**
* @program: cloudTest
* @description:
* @author: jym
* @create: 2020/02/26
*/
@SpringBootApplication
public class JymConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(JymConsumerApplication.class,args);
}
@Bean
public JymConfigBean jymConfigBean () {
return new JymConfigBean();
}
}
controller:
package com.jym.deptconsumer.controller;
import com.jym.jymcloudservice.entity.Dept;
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.RequestMethod;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
import java.util.List;
/**
* @program: cloudTest
* @description:
* @author: jym
* @create: 2020/02/26
*/
@RestController
@RequestMapping("/dept")
public class DeptConsumerController {
@Autowired
private RestTemplate restTemplate;
@RequestMapping(value = "/get/{id}")
public Dept get (@PathVariable long id) {
Dept dept = restTemplate.getForObject("http://localhost:8001/dept/get/1", Dept.class);
return dept;
}
@RequestMapping(value = "/list",method = RequestMethod.GET)
public List<Dept> get () {
List list = restTemplate.getForObject("http://localhost:8001/dept/list", List.class);
return list;
}
}
rest 调用成功
学习年限不足,知识过浅,说的不对请见谅。
世界上有10种人,一种是懂二进制的,一种是不懂二进制的。
更多推荐
已为社区贡献10条内容
所有评论(0)