137.【SpringCloud-快速搭建】
微服务框架搭建
- (一)、SpringCloud-Parent
- 1.创建一个SpringBoot项目
- 2.导入我们的依赖
- (二)、SpringCloud-API (实体类)
- 1.创建一个SpringBoot项目
- 2.导入我们的依赖
- 3.创建我们的实体类
- (三)、SpringCloud-dept (业务A)
- 1.创建一个SpringBoot项目
- 2.导入我们的依赖
- 3.配置我们的配置信息
- 4.配置我们的MVC框架
- (1).Dao层和XML
- (2).server和serverImpl
- (3).controller
- 5.测试
- (1).测试查询
- (2).测试添加
- (3).查询全部
- (四)、SpringCloud-counsmer (用户)
- 1.创建一个SpringBoot项目
- 2.导入我们的依赖
- 3.配置我们的配置信息
- 4.配置我们的MVC框架
- (1).controller
- 5.测试
- (1).查询全部
- (2).测试添加
- (3).测试查找
- (五)、==⭐配置Eureka注册中心 (服务端)⭐==
- 1.创建一个SpringBoot项目
- 2.导入我们的依赖
- 3.配置我们的配置信息
- 4.添加注册中心注解
- 5.测试
- (六)、SpringCloud-Provider (服务提供者)
- 1.创建一个SpringBoot项目
- 2.导入我们的依赖
- 3.配置我们的配置信息
- 4.向注册中心注册服务
- 5.测试
- (七)、SpringCloud-Provider (服务提供者完整版)
- 1.导入我们的依赖
- 2.配置我们的配置文件
- 3.配置我们的MVC三层框架
- (1).dao层和mapper的配置
- (2).server和serverImpl的配置
- (3).controller的配置
- 4.向注册中心注册服务
- (八)、SpringCloud-Consumer (消费者-完整版)
- 1.导入我们的依赖
- 2.配置我们的配置文件
- 3.配置我们的MVC框架
- 4.向注册中心注册服务
- 5.测试
(一)、SpringCloud-Parent
1.创建一个SpringBoot项目
然后只保留这四个文件
2.导入我们的依赖
<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><!--1.⭐ 这个是后面我们有多少子项目,然后都写在这里进行统一管理。 --><modules><module>demo01</module><module>demo02</module></modules><!--2.⭐ 这个是我们本父类的三大件 --><groupId>com.jsxs</groupId><artifactId>SpringCloundTest</artifactId><version>0.0.1-SNAPSHOT</version><name>SpringCloundTest</name><description>SpringCloud-parent</description><!--3.⭐ 进行统一管理我们的版本信息 --><properties><java.version>1.8</java.version><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><!--4. ⭐ 更改打包方式--><packaging>pom</packaging><!--5. 使用依赖管理--><dependencyManagement><!--6. ⭐创建依赖项--><dependencies><!-- SpringCloud 的依赖--><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>Hoxton.SR8</version><type>pom</type><scope>import</scope></dependency><!-- SpringBoot 的依赖--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-dependencies</artifactId><version>2.3.3.RELEASE</version><type>pom</type><scope>import</scope></dependency><!-- MySql 数据库--><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.10</version></dependency><!--SpringBoot 启动器--><dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>1.3.2</version></dependency><!--日志测试~--><dependency><groupId>ch.qos.logback</groupId><artifactId>logback-core</artifactId><version>1.2.3</version></dependency><!--junit--><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>${junit.version}</version></dependency><!-- log4j--><dependency><groupId>log4j</groupId><artifactId>log4j</artifactId><version>${log4j.version}</version></dependency><!-- lombok --><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><version>${lombok.version}</version></dependency></dependencies></dependencyManagement>
</project>
(二)、SpringCloud-API (实体类)
这里的API相当于是我们实体类,实体类全部放在这!!! 实体类不需要启动类和测试类,所以我们需要把这个实体类的启动类给手动删除。
1.创建一个SpringBoot项目
2.导入我们的依赖
<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><!--1. ⭐指定他的父亲 --><parent><groupId>com.jsxs</groupId><artifactId>SpringCloundTest</artifactId><version>0.0.1-SNAPSHOT</version></parent><!--2. ⭐三件套 --><groupId>com.jsxs</groupId><artifactId>demo01</artifactId><version>0.0.1-SNAPSHOT</version><name>demo01</name><description>Demo project for Spring Boot</description><!--3. ⭐指定版本 --><properties><java.version>1.8</java.version></properties><!--4. ⭐依赖性 --><dependencies><dependency><groupId>log4j</groupId><artifactId>log4j</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>
3.创建我们的实体类
package com.jsxs.pojo;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.Accessors;import java.io.Serializable;/*** @Author Jsxs* @Date 2023/10/15 19:08* @PackageName:com.jsxs.pojo* @ClassName: Dept* @Description: TODO* @Version 1.0*/@Data
@NoArgsConstructor
@AllArgsConstructor
@Accessors(chain = true) //目的是为了打开链式写法,
public class Dept implements Serializable { // 实体类在网络通信的时候,一定要进行序列化,否则会报错 ORM关系private Long deptno; // 主键private String dname; //部门的名字// 这里的数据存在哪个数据库里面。微服务: 一个服务对应一个数据库,同一个信息可能存在不同的数据库中。private String db_source;
}
(三)、SpringCloud-dept (业务A)
这里是我们的一个业务:
1.创建一个SpringBoot项目
2.导入我们的依赖
<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><!--1.⭐指定我们的父类 --><parent><groupId>com.jsxs</groupId><artifactId>SpringCloundTest</artifactId><version>0.0.1-SNAPSHOT</version></parent><!--2.⭐三件套 --><groupId>com.jsxs</groupId><artifactId>demo02</artifactId><version>0.0.1-SNAPSHOT</version><name>demo02</name><description>Demo project for Spring Boot</description><!--4.⭐版本控制 --><properties><java.version>1.8</java.version></properties><!--5.⭐依赖 --><dependencies><!--6.⭐⭐ 引入我们的实体类数据-》API --><dependency><groupId>com.jsxs</groupId><artifactId>demo01</artifactId><version>0.0.1-SNAPSHOT</version></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><scope>test</scope></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.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId></dependency><!-- test--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-test</artifactId></dependency><!-- jetty--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-jetty</artifactId></dependency><!-- 热部署工具--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency></dependencies>
</project>
3.配置我们的配置信息
server:port: 8081
# Mybatis的配置
mybatis:type-aliases-package: com.jsxs.pojo # 起别名mapper-locations: classpath:mybatis/mapper/*.xml # 路径配置# Spring的配置
spring:application:name: SpringCloud-provider-deptdatasource:url: jdbc:mysql://localhost:3306/db01?useUnicode=true&characterEncoding=utf-8username: rootpassword: 121788driver-class-name: com.mysql.jdbc.Drivertype: com.alibaba.druid.pool.DruidDataSource
4.配置我们的MVC框架
(1).Dao层和XML
com/jsxs/dao/DeptDao.java
package com.jsxs.dao;import com.jsxs.pojo.Dept;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Repository;import java.util.List;/*** @Author Jsxs* @Date 2023/10/15 19:29* @PackageName:com.jsxs.dao* @ClassName: DeptDao* @Description: TODO* @Version 1.0*/
@Mapper
@Repository
public interface DeptDao {public boolean addDept(Dept dept);public Dept queryById(Long id);public List<Dept> all();
}
mybatis/mapper/DeptMapper.xml
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD Mapper 3.0//EN""https://mybatis.org/dtd/mybatis-3-mapper.dtd"><!-- 1. 我们首先要绑定工作空间-->
<mapper namespace="com.jsxs.dao.DeptDao"><!-- 2. 我们编写SQL语句 --><insert id="addDept" parameterType="com.jsxs.pojo.Dept">insert into dept(deptno,dname,db_source)values(#{deptno},#{dname},DATABASE())</insert><select id="queryById" resultType="com.jsxs.pojo.Dept" parameterType="Long">select *from dept where deptno=#{id}</select><select id="all" resultType="com.jsxs.pojo.Dept">select *from dept</select>
</mapper>
(2).server和serverImpl
com/jsxs/service/DeptService.java
package com.jsxs.service;import com.jsxs.pojo.Dept;
import org.springframework.stereotype.Service;import java.util.List;/*** @Author Jsxs* @Date 2023/10/15 19:56* @PackageName:com.jsxs.dao.service* @ClassName: DeptService* @Description: TODO* @Version 1.0*/
public interface DeptService {public boolean addDept(Dept dept);public Dept queryById(Long id);public List<Dept> all();
}
com/jsxs/service/DeptServiceImpl.java
package com.jsxs.service;import com.jsxs.dao.DeptDao;
import com.jsxs.pojo.Dept;
import org.springframework.stereotype.Service;import javax.annotation.Resource;
import java.util.List;/*** @Author Jsxs* @Date 2023/10/15 19:57* @PackageName:com.jsxs.dao.service* @ClassName: DeptServiceImpl* @Description: TODO* @Version 1.0*/@Service
public class DeptServiceImpl implements DeptService {@Resourceprivate DeptDao deptDao;@Overridepublic boolean addDept(Dept dept) {return deptDao.addDept(dept);}@Overridepublic Dept queryById(Long id) {return deptDao.queryById(id);}@Overridepublic List<Dept> all() {return deptDao.all();}
}
(3).controller
com/jsxs/controller/DeptController.java
package com.jsxs.controller;import com.jsxs.pojo.Dept;
import com.jsxs.service.DeptService;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;import javax.annotation.Resource;
import java.util.List;/*** @Author Jsxs* @Date 2023/10/15 19:59* @PackageName:com.jsxs.controller* @ClassName: DeptController* @Description: TODO* @Version 1.0*/@RestController
public class DeptController {@Resourceprivate DeptService deptService;@PostMapping("/dept/add")public Boolean addDept(Dept dept) {boolean flag = deptService.addDept(dept);return flag;}@GetMapping("/dept/queryById/{id}")public Dept queryById(@PathVariable("id") Long id) {Dept dept = deptService.queryById(id);return dept;}@GetMapping("/dept/all")public List<Dept> all() {List<Dept> all = deptService.all();return all;}
}
5.测试
(1).测试查询
http://localhost:8081/dept/queryById/1
(2).测试添加
http://localhost:8081/dept/add?deptno=1&dname=李明&db_source=db01
(3).查询全部
(四)、SpringCloud-counsmer (用户)
用户使用业务A
1.创建一个SpringBoot项目
2.导入我们的依赖
<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><!--1. ⭐ 引入我们的父项目 --><parent><groupId>com.jsxs</groupId><artifactId>SpringCloundTest</artifactId><version>0.0.1-SNAPSHOT</version></parent><!--2. ⭐本项目的三件套 --><groupId>com.jsxs</groupId><artifactId>demo03</artifactId><version>0.0.1-SNAPSHOT</version><name>demo03</name><description>Demo project for Spring Boot</description><properties><java.version>1.8</java.version></properties><!--3.⭐ 依赖选项 --><dependencies><!--1. ⭐⭐ 这个引入我们的实体类 --><dependency><groupId>com.jsxs</groupId><artifactId>demo01</artifactId><version>0.0.1-SNAPSHOT</version></dependency><!-- 热部署工具--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId></dependency><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>
3.配置我们的配置信息
server:port: 80
com/jsxs/config/ConfigBean.java
提供多种便捷访问远程 访问http服务的方法,简单的Rest
package com.jsxs.config;import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;/*** @Author Jsxs* @Date 2023/10/15 21:16* @PackageName:com.jsxs.config* @ClassName: ConfigBean* @Description: TODO* @Version 1.0*/
@Configuration
public class ConfigBean {// 把RestTemplate注入到Spring中去@Beanpublic RestTemplate getRestTemplate() {return new RestTemplate();}
}
4.配置我们的MVC框架
因为我们的用户层,只需要控制层即可。不需要业务逻辑层什么的。
(1).controller
package com.jsxs.controller;import com.jsxs.pojo.Dept;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;import javax.annotation.Resource;
import java.util.List;/*** @Author Jsxs* @Date 2023/10/15 21:21* @PackageName:com.jsxs.controller* @ClassName: DeptConsumerController* @Description: TODO* @Version 1.0*/
@RestController
public class DeptConsumerController {@Resource// (URI url, 实体 map,Class<T> responseType) 地址---- 实体 ----返回类型.classprivate RestTemplate restTemplate; // 提供多种便捷访问远程 访问http服务的方法,简单的Rest// 设置服务层的前缀为常量private static final String REST_URL_PREFIX = "http://localhost:8081";// 根据id进行数据的查找// 用户层的这个访问路径可以随意写,没有必要和服务层的路径完全一致@RequestMapping("/consumer/dept/get/{id}")public Dept get(@PathVariable("id") Long deptno) {// 这里返回的是: 服务层的路径return restTemplate.getForObject(REST_URL_PREFIX + "/dept/queryById/" + deptno, Dept.class);}// 添加数据@RequestMapping("/consumer/dept/add")public boolean add(Dept dept) {return restTemplate.postForObject(REST_URL_PREFIX + "/dept/add", dept, Boolean.class);}// 查找全部数据@RequestMapping("/consumer/dept/all")public List<Dept> all() {return restTemplate.getForObject(REST_URL_PREFIX + "/dept/all", List.class);}
}
5.测试
==启动
(1).查询全部
(2).测试添加
(3).测试查找
以上的微服务框架并未使用我们的注册中心,不能说是真正的微服务框架的!!!
(五)、⭐配置Eureka注册中心 (服务端)⭐
1.创建一个SpringBoot项目
2.导入我们的依赖
<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><!--1.⭐引入我们的父类 --><parent><groupId>com.jsxs</groupId><artifactId>SpringCloundTest</artifactId><version>0.0.1-SNAPSHOT</version></parent><!--2.⭐自己的三件套 --><groupId>com.jsxs</groupId><artifactId>eureka-7001</artifactId><version>0.0.1-SNAPSHOT</version><name>eureka-7001</name><description>Demo project for Spring Boot</description><properties><java.version>1.8</java.version></properties><!--3.⭐导入我们的依赖 --><dependencies><!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-eureka-server --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-eureka-server</artifactId><version>1.4.6.RELEASE</version></dependency><!-- 热部署工具 --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-test</artifactId><scope>test</scope></dependency></dependencies></project>
3.配置我们的配置信息
server:port: 7001eureka:instance:prefer-ip-address: truehostname: localhostclient:register-with-eureka: false # 是否将自己注册进注册中心fetch-registry: false # 是否是注册中心: 是service-url:defaultzone: http://${eureka.instance.hostname}:${server.port}/eureka/
4.添加注册中心注解
package com.jsxs;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;@SpringBootApplication// ⭐⭐ 开启我们的Eureka服务端
@EnableEurekaServerpublic class Eureka7001Application {public static void main(String[] args) {SpringApplication.run(Eureka7001Application.class, args);}}
5.测试
(六)、SpringCloud-Provider (服务提供者)
1.创建一个SpringBoot项目
2.导入我们的依赖
<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><!--1.引入我们的父类 --><parent><groupId>com.jsxs</groupId><artifactId>SpringCloundTest</artifactId><version>0.0.1-SNAPSHOT</version></parent><!--2.自己的三件套 --><groupId>com.jsxs</groupId><artifactId>eureka-provider-8001</artifactId><version>0.0.1-SNAPSHOT</version><name>eureka-provider-8001</name><description>Demo project for Spring Boot</description><properties><java.version>1.8</java.version></properties><!--3.依赖 --><dependencies><!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-eureka --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-eureka</artifactId><version>1.4.6.RELEASE</version></dependency><!-- ⭐一定要添加web的驱动,要不然启动不成功!!! --><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><scope>test</scope></dependency></dependencies></project>
3.配置我们的配置信息
server:port: 8001# Spring的配置
spring:application:name: SpringCloud-provider-dept# Eureka 服务注册到哪里?
eureka:client:service-url:defaultZone: http://localhost:7001/eureka/instance:instance-id: jsxs-01
4.向注册中心注册服务
package com.jsxs;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;@SpringBootApplication@EnableEurekaClientpublic class EurekaProvider8001Application {public static void main(String[] args) {SpringApplication.run(EurekaProvider8001Application.class, args);}}
5.测试
(七)、SpringCloud-Provider (服务提供者完整版)
1.导入我们的依赖
<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><!--1.⭐指定我们的父类 --><parent><groupId>com.jsxs</groupId><artifactId>SpringCloundTest</artifactId><version>0.0.1-SNAPSHOT</version></parent><!--2.⭐三件套 --><groupId>com.jsxs</groupId><artifactId>demo02</artifactId><version>0.0.1-SNAPSHOT</version><name>demo02</name><description>Demo project for Spring Boot</description><!--4.⭐版本控制 --><properties><java.version>1.8</java.version></properties><!--5.⭐依赖 --><dependencies><!--6.⭐⭐ 引入我们的实体类数据-》API --><dependency><groupId>com.jsxs</groupId><artifactId>demo01</artifactId><version>0.0.1-SNAPSHOT</version></dependency><!-- 7. ⭐⭐⭐ eureka客户端的和监视器 --><!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-eureka --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-eureka</artifactId><version>1.4.6.RELEASE</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><scope>test</scope></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.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId></dependency><!-- test--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-test</artifactId></dependency><!-- jetty--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-jetty</artifactId></dependency><!-- 热部署工具--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.junit.jupiter</groupId><artifactId>junit-jupiter</artifactId><scope>test</scope></dependency></dependencies>
</project>
2.配置我们的配置文件
server:port: 8081
# Mybatis的配置
mybatis:type-aliases-package: com.jsxs.pojo # 起别名mapper-locations: classpath:mybatis/mapper/*.xml # 路径配置# Spring的配置
spring:application:name: SpringCloud-provider-deptdatasource:url: jdbc:mysql://localhost:3306/db01?useUnicode=true&characterEncoding=utf-8username: rootpassword: 121788driver-class-name: com.mysql.jdbc.Drivertype: com.alibaba.druid.pool.DruidDataSourceeureka:client:service-url: defaultZone: http://localhost:7001/eureka/ #注册到这个注册中心instance:instance-id: jsxs-dept-eureka-8081 # 服务者的id为这个info:app.name: jsxs-springcloudcompany.name: pdd
3.配置我们的MVC三层框架
(1).dao层和mapper的配置
com/jsxs/dao/DeptDao.java
package com.jsxs.dao;import com.jsxs.pojo.Dept;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Repository;import java.util.List;/*** @Author Jsxs* @Date 2023/10/15 19:29* @PackageName:com.jsxs.dao* @ClassName: DeptDao* @Description: TODO* @Version 1.0*/
@Mapper
@Repository
public interface DeptDao {public boolean addDept(Dept dept);public Dept queryById(Long id);public List<Dept> all();
}
mybatis/mapper/DeptMapper.xml
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD Mapper 3.0//EN""https://mybatis.org/dtd/mybatis-3-mapper.dtd"><!-- 1. 我们首先要绑定工作空间-->
<mapper namespace="com.jsxs.dao.DeptDao"><!-- 2. 我们编写SQL语句 --><insert id="addDept" parameterType="com.jsxs.pojo.Dept">insert into dept(deptno,dname,db_source)values(#{deptno},#{dname},DATABASE())</insert><select id="queryById" resultType="com.jsxs.pojo.Dept" parameterType="Long">select *from dept where deptno=#{id}</select><select id="all" resultType="com.jsxs.pojo.Dept">select *from dept</select>
</mapper>
(2).server和serverImpl的配置
com/jsxs/service/DeptService.java
package com.jsxs.service;import com.jsxs.pojo.Dept;
import org.springframework.stereotype.Service;import java.util.List;/*** @Author Jsxs* @Date 2023/10/15 19:56* @PackageName:com.jsxs.dao.service* @ClassName: DeptService* @Description: TODO* @Version 1.0*/
public interface DeptService {public boolean addDept(Dept dept);public Dept queryById(Long id);public List<Dept> all();
}
com/jsxs/service/DeptServiceImpl.java
package com.jsxs.service;import com.jsxs.dao.DeptDao;
import com.jsxs.pojo.Dept;
import org.springframework.stereotype.Service;import javax.annotation.Resource;
import java.util.List;/*** @Author Jsxs* @Date 2023/10/15 19:57* @PackageName:com.jsxs.dao.service* @ClassName: DeptServiceImpl* @Description: TODO* @Version 1.0*/@Service
public class DeptServiceImpl implements DeptService {@Resourceprivate DeptDao deptDao;@Overridepublic boolean addDept(Dept dept) {return deptDao.addDept(dept);}@Overridepublic Dept queryById(Long id) {return deptDao.queryById(id);}@Overridepublic List<Dept> all() {return deptDao.all();}
}
(3).controller的配置
com/jsxs/controller/DeptController.java
package com.jsxs.controller;import com.jsxs.pojo.Dept;
import com.jsxs.service.DeptService;
import org.springframework.stereotype.Controller;
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.RestController;import javax.annotation.Resource;
import java.util.List;/*** @Author Jsxs* @Date 2023/10/15 19:59* @PackageName:com.jsxs.controller* @ClassName: DeptController* @Description: TODO* @Version 1.0*/@RestController
public class DeptController {@Resourceprivate DeptService deptService;@PostMapping("/dept/add")public Boolean addDept(Dept dept) {boolean flag = deptService.addDept(dept);return flag;}@GetMapping("/dept/queryById/{id}")public Dept queryById(@PathVariable("id") Long id) {Dept dept = deptService.queryById(id);return dept;}@GetMapping("/dept/all")public List<Dept> all() {List<Dept> all = deptService.all();return all;}
}
4.向注册中心注册服务
com/jsxs/Demo02Application.java
package com.jsxs;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;@SpringBootApplication@EnableEurekaClientpublic class Demo02Application {public static void main(String[] args) {SpringApplication.run(Demo02Application.class, args);}}
(八)、SpringCloud-Consumer (消费者-完整版)
1.导入我们的依赖
<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><!--1. ⭐ 引入我们的父项目 --><parent><groupId>com.jsxs</groupId><artifactId>SpringCloundTest</artifactId><version>0.0.1-SNAPSHOT</version></parent><!--2. 本项目的三件套 --><groupId>com.jsxs</groupId><artifactId>demo03</artifactId><version>0.0.1-SNAPSHOT</version><name>demo03</name><description>Demo project for Spring Boot</description><properties><java.version>1.8</java.version></properties><!--3.⭐ 依赖选项 --><dependencies><!--1.这个引入我们的实体类 --><dependency><groupId>com.jsxs</groupId><artifactId>demo01</artifactId><version>0.0.1-SNAPSHOT</version></dependency><!--2.引入我们的erueka和监视器 --><!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-eureka --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-eureka</artifactId><version>1.4.6.RELEASE</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-actuator</artifactId></dependency><!-- 热部署工具--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-test</artifactId><scope>test</scope></dependency><dependency><groupId>junit</groupId><artifactId>junit</artifactId><scope>test</scope></dependency></dependencies><build><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId></plugin></plugins></build></project>
2.配置我们的配置文件
server:port: 80eureka:client:service-url:defaultZone: http://localhost:7001/eureka/ #像那一个注册中心注册自己instance:instance-id: jsxs-dept-eureka-80 # 编号
spring:application:name: SpringCloud-counsumer-dept
3.配置我们的MVC框架
com/jsxs/config/ConfigBean.java
package com.jsxs.config;import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;/*** @Author Jsxs* @Date 2023/10/15 21:16* @PackageName:com.jsxs.config* @ClassName: ConfigBean* @Description: TODO* @Version 1.0*/
@Configuration
public class ConfigBean {// 把RestTemplate注入到Spring中去@Beanpublic RestTemplate getRestTemplate() {return new RestTemplate();}
}
com/jsxs/controller/DeptConsumerController.java
package com.jsxs.controller;import com.jsxs.pojo.Dept;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;import javax.annotation.Resource;
import java.util.List;/*** @Author Jsxs* @Date 2023/10/15 21:21* @PackageName:com.jsxs.controller* @ClassName: DeptConsumerController* @Description: TODO* @Version 1.0*/
@RestController
public class DeptConsumerController {@Resource// (URI url, 实体 map,Class<T> responseType) 地址---- 实体 ----返回类型.classprivate RestTemplate restTemplate; // 提供多种便捷访问远程 访问http服务的方法,简单的Rest// 设置服务层的前缀为常量private static final String REST_URL_PREFIX = "http://localhost:8081";// 根据id进行数据的查找// 用户层的这个访问路径可以随意写,没有必要和服务层的路径完全一致@RequestMapping("/consumer/dept/get/{id}")public Dept get(@PathVariable("id") Long deptno) {// 这里返回的是: 服务层的路径return restTemplate.getForObject(REST_URL_PREFIX + "/dept/queryById/" + deptno, Dept.class);}// 添加数据@RequestMapping("/consumer/dept/add")public boolean add(Dept dept) {return restTemplate.postForObject(REST_URL_PREFIX + "/dept/add", dept, Boolean.class);}// 查找全部数据@RequestMapping("/consumer/dept/all")public List<Dept> all() {return restTemplate.getForObject(REST_URL_PREFIX + "/dept/all", List.class);}
}
4.向注册中心注册服务
package com.jsxs;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;@SpringBootApplication@EnableEurekaClientpublic class Demo03Application {public static void main(String[] args) {SpringApplication.run(Demo03Application.class, args);}}
5.测试
- 先开启注册中心: eureka->7001;
- 然后开启我们的服务提供者: demo2->8081;
- 最后开启我们的服务消费者: demo3->80
相关文章:

137.【SpringCloud-快速搭建】
微服务框架搭建 (一)、SpringCloud-Parent1.创建一个SpringBoot项目2.导入我们的依赖 (二)、SpringCloud-API (实体类)1.创建一个SpringBoot项目2.导入我们的依赖3.创建我们的实体类 (三)、SpringCloud-dept (业务A)1.创建一个SpringBoot项目2.导入我们的依赖3.配置我们的配置信…...

计算机网络第2章-CDN(4)
视频流和内容分发网 HTTP流和DASH 在HTTP流中,视频只是存储在HTTP服务器中作为一个普通的文件,每个文件有有一个特定的URL。当用户要看视频时,客户与服务器之间创建一个TCP连接并发送HTTP GET请求。 HTTP流具有严重缺陷,即所有…...

Linux常见的指令合集
Linux指令合集 认识linuxlinux基础指令1.pwd 命令2. ls 命令3.cd 命令4. man 命令5. grep 命令6. ps 命令7. kill 命令8. netstat 命令9. date 查看当前系统时间10. echo 打印选项 -e linux文件操作指令1. mkdir 命令2. rmdir 命令3. touch 命令4. rm 命令5. mv 命令6. cp 命令…...

字符串_哈希
参考文章: E. Compress Words(字符串hash)_z听歌的小孩z的博客-CSDN博客 字符串哈希 - OI Wiki (oi-wiki.org) 板子: #include<bits/stdc.h> using namespace std; const int N2e450; typedef long long ll; const int mod1e97; typedef unsig…...

python 之enumerate()函数
文章目录 enumerate() 是 Python 中的一个内置函数,它用于在遍历可迭代对象(如列表、元组、字符串等)时同时获取每个元素的索引和值。这个函数非常有用,因为它允许您在迭代过程中轻松地访问元素的索引,而不需要手动维护…...

【LeetCode刷题(数据结构与算法)】:用队列实现栈
请你仅使用两个队列实现一个后入先出(LIFO)的栈,并支持普通栈的全部四种操作(push、top、pop 和 empty) 实现 MyStack 类: void push(int x) 将元素 x 压入栈顶 int pop() 移除并返回栈顶元素 int top() 返…...

“客户端到服务器的数据传递”和“服务器上的数据传递”这两种数据传递的方式的区别
“客户端到服务器的数据传递”和“服务器上的数据传递”这两种数据传递方式的主要区别如下: 数据的流动方向: 在“客户端到服务器的数据传递”中,数据是从客户端(如浏览器)流向服务器。在“服务器上的数据传递”中&…...

LCR 181 字符串中的单词反转
题目来源: leetcode题目,网址:LCR 181. 字符串中的单词反转 - 力扣(LeetCode) 解题思路: 倒叙遍历,获得每个单词的起始位置与终止位置,然后将每次遇到的单词插入结果中。 解题…...

百度OCR识别图片文本字符串——物联网上位机软件
一、开发背景 根据项目需求,我们需要完成LED显示屏实时显示歌词的效果。最优的方法是调用歌曲播放器的API获取歌词,但是由于这个开发资格不是很好申请,因此我们采用其他方案,即通过OCR识别获取歌词,并投射到LED显示屏上…...

JAVA学习(6)-全网最详细~
🌈write in front🌈 🧸大家好,我是Aileen🧸.希望你看完之后,能对你有所帮助,不足请指正!共同学习交流. 🆔本文由Aileen_0v0🧸 原创 CSDN首发🐒 如…...

睿趣科技:未来抖音开网店还有前景吗
随着科技的快速发展,电商平台已经成为了人们生活中不可或缺的一部分。在中国,抖音作为一个短视频平台,近年来迅速崛起,吸引了大量的用户和商家。那么,在未来,抖音是否还能为商家提供一个有效的电商平台呢?…...

第六章 应用层 | 计算机网络(谢希仁 第八版)
文章目录 第六章 应用层6.1 域名系统DNS6.1.1 域名系统概述6.1.2 互联网的域名结构6.1.3 域名服务器 6.2 文件传送协议6.2.1 FTP概述6.2.2 FTP的基本工作原理6.2.3 简单文件传送协议TFTP 6.3 远程终端协议TELNET6.4 万维网www6.4.1 万维网概述6.4.2 统一资源定位符URL6.4.3 超文…...

c++ lambda 表达式
1. 简介 lambda(匿名函数)是C11引入的一种函数对象,它允许我们在需要函数的地方创建一个临时的、匿名的函数。lambda表达式表示一个可以执行的代码单元,可以理解为一个未命名的内联函数。Lambda函数可以用于简化代码、提高可读性…...

Go语言入门心法(七): 并发与通道
Go语言入门心法(一): 基础语法 Go语言入门心法(二): 结构体 Go语言入门心法(三): 接口 Go语言入门心法(四): 异常体系 Go语言入门心法(五): 函数 一: go语言并发与通道...

前端组件封装:构建模块化、可维护和可重用的前端应用
前端组件封装:构建模块化、可维护和可重用的前端应用 前端开发领域的快速演进已经将前端应用的规模和复杂性提升到了一个新的水平。在这个背景下,前端组件封装成为了一项关键实践,旨在构建模块化、可维护和可重用的前端应用。在本文中&#…...

GPT绘制流程图咒语
【咒语】下面是我的一篇论文选取部分,为了让读者更好理解,我准备画一张图,请你阅读后为我设计一下这个图应该怎么画,更有说服力,更容易理解 论文片段: 多模态数据融合研究的基础在于有效的数据采集。首先&a…...

【扩散模型从原理到实战】Chapter1 扩散模型简介
文章目录 1.1 扩散模型的原理生成模型扩散过程DDPM的扩散过程前向过程反向过程优化目标 1.2 扩散模型的发展开始扩散:DDPM加速生成:采样器刷新记录:基于CLIP的多模态图像生成引爆网络:基于CLIP的多模态图像生成再次“出圈”&#…...

使用轮廓分数提升时间序列聚类的表现
我们将使用轮廓分数和一些距离指标来执行时间序列聚类实验,并且进行可视化 让我们看看下面的时间序列: 如果沿着y轴移动序列添加随机噪声,并随机化这些序列,那么它们几乎无法分辨,如下图所示-现在很难将时间序列列分组为簇: 上面…...

蔬菜水果生鲜配送团购商城小程序的作用是什么
蔬菜水果是人们生活所需品,从业者众多,无论小摊贩还是超市商场都有不少人每天光临,当然这些只是自然流量,在实际经营中,蔬菜水果商家还是面临着一些难题。 对蔬菜水果商家而言,线下门店是重要的࿰…...

金融用户实践|分布式存储支持数据仓库业务系统性能验证
作者:深耕行业的 SmartX 金融团队 闫海涛 估值是指对资产或负债的价值进行评估的过程,这对于投资决策具有重要意义。每个金融公司资管业务人员都期望能够实现实时的业务估值,快速获取最新的数据和指标,从而做出更明智的投资决策。…...

代码随想录二刷 Day41
509. 斐波那契数 这个题简单入门,注意下N小于等于1的情况就可以 class Solution { public:int fib(int n) {if (n < 1) return n; //这句不写的话test能过但是另外的过不了vector<int> result(n 1); //定义存放dp结果的数组,还要定义大小r…...

C++项目实战——基于多设计模式下的同步异步日志系统-⑪-日志器管理类与全局建造者类设计(单例模式)
文章目录 专栏导读日志器建造者类完善单例日志器管理类设计思想单例日志器管理类设计全局建造者类设计日志器类、建造者类整理日志器管理类测试 专栏导读 🌸作者简介:花想云 ,在读本科生一枚,C/C领域新星创作者,新星计…...

Hadoop3教程(十四):MapReduce中的排序
文章目录 (99)WritableComparable排序什么是排序什么时候需要排序排序有哪些分类如何实现自定义排序 (100)全排序案例案例需求思路分析实际代码 (101)二次排序案例(102) 区内排序案例…...

测试需要写测试用例吗?
如何理解软件的质量 我们都知道,一个软件从无到有要经过需求设计、编码实现、测试验证、部署发布这四个主要环节。 需求来源于用户反馈、市场调研或者商业判断。意指在市场行为中,部分人群存在某些诉求或痛点,只要想办法满足这些人群的诉求…...

Qt 视口和窗口的区别
视口和窗口 绘图设备的物理坐标是基本的坐标系,通过QPainter的平移、旋转等变换可以得到更容易操作的逻辑坐标 为了实现更方便的坐标,QPainter还提供了视口(Viewport)和窗口(Window)坐标系,通过QPainter内部的坐标变换矩阵自动转换为绘图设…...

使用Git将GitHub仓库下载到本地
前记: git svn sourcetree gitee github gitlab gitblit gitbucket gitolite gogs 版本控制 | 仓库管理 ---- 系列工程笔记. Platform:Windows 10 Git version:git version 2.32.0.windows.1 Function:使用Git将GitHub仓库下载…...

前端需要了解的浏览器缓存知识
文章目录 前言为什么需要缓存?DNS缓存缓存读写顺序缓存位置memory cache(浏览器本地缓存)disk cache(硬盘缓存)重点!!! 缓存策略 - 强缓存和协商缓存1)强缓存ExpiresCach…...

自动驾驶:控制算法概述
自动驾驶:控制算法概述 常见控制算法PID算法LQR算法MPC算法 自动驾驶控制算法横向控制纵向控制 参考文献 常见控制算法 PID算法 PID(Proportional-Integral-Derivative)控制是一种经典的反馈控制算法,通常用于稳定性和响应速度要…...

【Mysql】Mysql的字符集和比较规则(三)
字符集和比较规则简介 字符集简介 我们知道在计算机中只能以二进制的方式对数据进行存储,那么他们之间是怎样对应并进行转换的?我们需要了解两个概念: 字符范围:我们可以将哪些字符转换成二进制数据,也就是规定好字…...

【SpringCloud-11】SCA-sentinel
sentinel是一个流量控制、熔断降级的组件,可以替换第一代中的hystrix。 hystrix用起来没有那么方便: 1、要在调用方引入hystrix,没有ui界面进行配置,需要在代码中进行配置,侵入了业务代码。 2、还要自己搭建监控平台…...