SpringCloud-----SpringCloud簡化版(原型)
阿新 • • 發佈:2018-12-04
1、概念
服務A通過org.springframework.web.client.RestTemplate來呼叫服務B的程式介面,
實現服務之間的呼叫
2、工程結構
3、父pom.xml(microcloud)
<?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.zemel</groupId> <artifactId>microcloud</artifactId> <version>1.0.0</version> <packaging>pom</packaging> <name>microcloud</name> <url>http://maven.apache.org</url> <properties> <jdk.version>1.8</jdk.version> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> </properties> <dependencyManagement> <dependencies> <dependency> <!-- SpringCloud離不開SpringBoot ,必須配置此依賴包 --> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-dependencies</artifactId> <version>1.5.4.RELEASE</version> <type>pom</type> <scope>import</scope> </dependency> <!-- 此演示工程未用到該管理包 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>Finchley.SR2</version> <type>pom</type> <scope>import</scope> </dependency> <dependency> <groupId>com.alibaba</groupId> <artifactId>druid</artifactId> <version>1.0.31</version> </dependency> </dependencies> </dependencyManagement> <dependencies> <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.boot</groupId> <artifactId>spring-boot-starter-thymeleaf</artifactId> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-test</artifactId> <scope>test</scope> </dependency> <!--熱載入 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-devtools</artifactId> <optional>true</optional> </dependency> <!-- 可要,可不要 --> <dependency> <groupId>org.springframework</groupId> <artifactId>springloaded</artifactId> </dependency> </dependencies> <build> <finalName>microcloud</finalName> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId> <configuration> <source>${jdk.version}</source> <target>${jdk.version}</target> <encoding>${project.build.sourceEncoding}</encoding> </configuration> </plugin> <!-- 主要功能進行專案的打包釋出處理 --> <!-- <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> <configuration> <mainClass>com.zemel.micorboot.App</mainClass> </configuration> <executions> <execution> <goals> <goal>repackage</goal> </goals> </execution> </executions> </plugin> --> </plugins> </build> <modules> <module>microcloud-api</module> <module>micro-provider-dept-8001</module> <module>microcloud-consumer-80</module> </modules> </project>
4、microcloud-api的
pom.xml
<?xml version="1.0"?> <project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd" xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>com.zemel</groupId> <artifactId>microcloud</artifactId> <version>1.0.0</version> </parent> <artifactId>microcloud-api</artifactId> <name>microcloud-api</name> <url>http://maven.apache.org</url> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> </properties> <dependencies> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <scope>test</scope> </dependency> </dependencies> </project>
Dept.java
package com.zemel.vo; import java.io.Serializable; public class Dept implements Serializable { /** * */ private static final long serialVersionUID = 1L; private Long deptno; private String dname; private String loc; public Long getDeptno() { return deptno; } public void setDeptno(Long deptno) { this.deptno = deptno; } public String getDname() { return dname; } public void setDname(String dname) { this.dname = dname; } public String getLoc() { return loc; } public void setLoc(String loc) { this.loc = loc; } @Override public String toString() { return "Dept [deptno=" + deptno + ", dname=" + dname + ", loc=" + loc + "]"; } }
5、microcloud-provider-dept-8001
pom.xml
<?xml version="1.0"?>
<project
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"
xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.zemel</groupId>
<artifactId>microcloud</artifactId>
<version>1.0.0</version>
</parent>
<artifactId>microcloud-provider-dept-8001</artifactId>
<name>microcloud-provider-dept-8001</name>
<url>http://maven.apache.org</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>com.zemel</groupId>
<artifactId>microcloud-api</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-core</artifactId>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
</dependency>
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>1.3.0</version>
</dependency>
</dependencies>
</project>
application.yml
server:
port: 8001
mybatis:
config-location: classpath:mybatis/mybatis.cfg.xml # mybatis配置檔案所在路徑
type-aliases-package: com.zemel.vo # 定義所有操作類的別名所在包
mapper-locations: # 所有的mapper對映檔案
- classpath:mybatis/mapper/**/*.xml
spring:
datasource:
type: com.alibaba.druid.pool.DruidDataSource # 配置當前要使用的資料來源的操作型別
driver-class-name: org.gjt.mm.mysql.Driver # 配置MySQL的驅動程式類
url: jdbc:mysql://localhost:3306/mldn8001 # 資料庫連線地址
username: root # 資料庫使用者名稱
password: 123456 # 資料庫連線密碼
dbcp2: # 進行資料庫連線池的配置
min-idle: 5 # 資料庫連線池的最小維持連線數
initial-size: 5 # 初始化提供的連線數
max-total: 5 # 最大的連線數
max-wait-millis: 200 # 等待連接獲取的最大超時時間
mybatis.cfg.xml
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration> <!-- 進行Mybatis的相應的環境的屬性定義 -->
<settings> <!-- 在本專案之中開啟二級快取 -->
<setting name="cacheEnabled" value="true"/>
</settings>
</configuration>
resources/mapper/com/zemel/Dept.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.zemel.dao.IDeptDao">
<select id="findById" resultType="Dept" parameterType="long">
SELECT deptno,dname,loc FROM dept WHERE deptno=#{deptno} ;
</select>
<select id="findAll" resultType="Dept">
SELECT deptno,dname,loc FROM dept ;
</select>
<insert id="doCreate" parameterType="Dept">
INSERT INTO dept(dname,loc) VALUES (#{dname},database()) ;
</insert>
</mapper>
logback.xml
<?xml version="1.0" encoding="UTF-8"?>
<configuration scan="true">
<property name="APP" value="${project.artifactId}" />
<property name="LOG_HOME" value="/data/www/log/${APP}" />
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%d{yy-MM-dd.HH:mm:ss.SSS} [%-16t] %-5p %-22c{0} %X{ServiceId} - %m%n</pattern>
</encoder>
</appender>
<appender name="DETAIL"
class="ch.qos.logback.core.rolling.RollingFileAppender" additivity="false">
<File>${LOG_HOME}/${APP}_detail.log</File>
<encoder>
<pattern>%d{yy-MM-dd.HH:mm:ss.SSS} [%-16t] %-5p %-22c{0} %X{ServiceId} - %m%n</pattern>
</encoder>
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<fileNamePattern>${LOG_HOME}/${APP}_detail.log.%d{yyyyMMdd}</fileNamePattern>
</rollingPolicy>
</appender>
<appender name="ACCESS"
class="ch.qos.logback.core.rolling.RollingFileAppender" additivity="false">
<File>${LOG_HOME}/${APP}_access.log</File>
<encoder>
<pattern>%d{yy-MM-dd.HH:mm:ss.SSS};%X{ServiceId};%m%n</pattern>
</encoder>
<rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
<fileNamePattern>${LOG_HOME}/${APP}_access.log.%d{yyyyMMdd}</fileNamePattern>
</rollingPolicy>
</appender>
<logger name="ACCESS">
<appender-ref ref="ACCESS" />
</logger>
<logger name="druid.sql.Statement" level="DEBUG" />
<logger name="cn.zemel.dao" level="TRACE" />
<root level="INFO">
<appender-ref ref="DETAIL" />
<appender-ref ref="CONSOLE" />
</root>
</configuration>
IDeptDao.java
package com.zemel.dao;
import java.util.List;
import org.apache.ibatis.annotations.Mapper;
import com.zemel.vo.Dept;
@Mapper
public interface IDeptDao {
boolean doCreate(Dept vo);
Dept findById(Long id);
List<Dept> findAll();
}
IDeptService.java
package com.zemel.service;
import java.util.List;
import com.zemel.vo.Dept;
public interface IDeptService {
Dept get(long id);
boolean add(Dept dept);
List<Dept> list();
}
DeptServiceImpl.java
package com.zemel.service.impl;
import java.util.List;
import javax.annotation.Resource;
import org.springframework.stereotype.Service;
import com.zemel.dao.IDeptDao;
import com.zemel.service.IDeptService;
import com.zemel.vo.Dept;
@Service
public class DeptServiceImpl implements IDeptService{
@Resource
private IDeptDao deptDao;
@Override
public Dept get(long id) {
return this.deptDao.findById(id);
}
@Override
public boolean add(Dept dept) {
return this.deptDao.doCreate(dept);
}
@Override
public List<Dept> list() {
return this.deptDao.findAll();
}
}
DeptRest.java
package com.zemel.rest;
import java.util.List;
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.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import com.zemel.service.IDeptService;
import com.zemel.vo.Dept;
@RestController
@RequestMapping("/dept")
public class DeptRest {
@Autowired
private IDeptService deptService;
@GetMapping("/get/{id}")
public Dept get(@PathVariable("id") long id){
return deptService.get(id);
}
@GetMapping("/list")
public List<Dept> list(){
return this.deptService.list();
}
@PostMapping("/add")
public Object add(@RequestBody Dept dept){
return this.deptService.add(dept);
}
}
IDeptServiceTest.java
package com.zemel.service;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import com.zemel.vo.Dept;
// 註釋部分可配置可不配置
//@SpringBootTest(classes=Dept8001App.class)
//@WebAppConfiguration
@SpringBootTest
@RunWith(SpringJUnit4ClassRunner.class)
public class IDeptServiceTest {
@Autowired
private IDeptService deptService;
@Test
public void testGet() {
System.out.println(deptService.get(1));
}
@Test
public void testAdd() {
Dept dept = new Dept();
dept.setDname("測試部:"+System.currentTimeMillis());
dept.setLoc("位置-"+System.currentTimeMillis());
System.out.println(this.deptService.add(dept));
}
@Test
public void testList() {
System.out.println(this.deptService.list());
}
}
6、microcloud-consumer-80(服務提供者B)
pom.xml
<?xml version="1.0"?>
<project
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"
xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.zemel</groupId>
<artifactId>microcloud</artifactId>
<version>1.0.0</version>
</parent>
<artifactId>microcloud-consumer-80</artifactId>
<name>microcloud-consumer-80</name>
<url>http://maven.apache.org</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>com.zemel</groupId>
<artifactId>microcloud-api</artifactId>
<version>1.0.0</version>
</dependency>
</dependencies>
>
</project>
application.yml
server:
port: 80
RestConfig.java
package com.zemel.consumer.config;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;
@Configuration
public class RestConfig {
@Bean
public RestTemplate getRestTemplate(){
return new RestTemplate();
}
}
DeptController.java
package com.zemel.consumer.controller;
import java.util.List;
import javax.annotation.Resource;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
import com.zemel.vo.Dept;
@RestController
@RequestMapping("/consumer/dept")
public class DeptController {
static final String DEPT_GET_URL = "http://dept-8001.com:8001/dept/get/";
static final String DEPT_LIST_URL = "http://dept-8001.com:8001/dept/list/";
static final String DEPT_ADD_URL = "http://dept-8001.com:8001/dept/add/";
@Resource
private RestTemplate restTemplate;
@GetMapping("/get")
public Object getDept(long id){
return this.restTemplate.getForEntity(DEPT_GET_URL+id, Dept.class);
}
@GetMapping("/list")
public Object list(){
return this.restTemplate.getForObject(DEPT_LIST_URL, List.class);
}
@GetMapping("/add")
public Object add(@RequestBody Dept dept){
return this.restTemplate.postForObject(DEPT_ADD_URL, dept, Boolean.class);
}
}
Consumer80App.java
package com.zemel.consumer;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/**
* Hello world!
*
*/
@SpringBootApplication
public class Consumer80App {
public static void main(String[] args) {
SpringApplication.run(Consumer80App.class, args);
}
}
7、修改C:\Windows\System32\drivers\etc\hosts檔案
編輯新增
127.0.0.1 dept-8001.com
127.0.0.1 client.com
8、啟動服務8001、啟動服務80
訪問介面:http://client.com/consumer/dept/get?id=1
最終顯示資料,測試通過。
總結:服務8001提供服務介面,服務80通過Rest介面呼叫