SpringCloud

版本选择

建议使用F或G开头的

创建项目需要的工作

• maven设置打包方式

• 导入依赖文本

  • SpringCloud，provider和consumer都需要加spring-cloud包，并且要设置

    • <dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>Greenwich.SR3</version><type>pom</type><scope>runtime</scope> </dependency>

  • web

  • 数据库之类包

  • 热部署
• create table dept (deptno bigint auto_increment,dname varchar(60) null,db_source varchar(60) null,constraint dept_pkprimary key (deptno) )character set utf8 collate utf8_general_ci;
• use db01; insert into dept ( dname, db_source) values ('开发部',database());

  ​

provider和consumer例子

provider

搭建一个基础环境springboot+mybatis+druid

• 遇到一个bug，打包错误

• 提示说无法配置数据源，但是跟数据源并没有什么关系，扫描不到数据源的问题，因为跟视频做，pom的作用是maven分项目管理，需要有一个父项目

• 所以会导致配置失败的问题

• 经过这次试错

• 先确保导入maven包是没问题的

• 更改了pom启动项目，不会刷新pom，先手动刷新，再启动项目，都要确保maven没问题

• Druid数据源的crud项目

• 准备dao层依赖文本

  • jdbc
  • mybatis
  • mysql
  • druid
  • druid-start
• <!--数据库--> <!--jdbc--> <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-jdbc</artifactId> </dependency><!--mybatis--> <dependency><groupId>org.mybatis.spring.boot</groupId><artifactId>mybatis-spring-boot-starter</artifactId><version>2.1.3</version> </dependency> <!--mysql--> <dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><scope>runtime</scope> </dependency> <!--druid--> <dependency><groupId>com.alibaba</groupId><artifactId>druid</artifactId><version>1.1.10</version> </dependency> <dependency><groupId>com.alibaba</groupId><artifactId>druid-spring-boot-starter</artifactId><version>1.1.9</version> </dependency> <!--log4j--> <dependency><groupId>log4j</groupId><artifactId>log4j</artifactId><version>1.2.17</version> </dependency>

• druid-spring-boot-starter是可以不加的，作为一个可视化的后台管理，可以通过配置文件的配置，或javaconfig方式的配置形式配置，二者只能选其一，

• 加了druid-spring-boot-starter可以用配置文件配置，不加就只能通过javaconfig配置方式配置

• 如果使用两种方式配置，会优先使用自定义配置的配置

• 确保成功进行一个简单的测试

• 测试数据源

• http://localhost:8080/druid/index.html

• 写一个简单的test

• @SpringBootTest class Demo2ApplicationTests {@AutowiredJdbcTemplate jdbcTemplate;@Testvoid contextLoads() {for (Map<String, Object> stringObjectMap : jdbcTemplate.queryForList("select * from dept")) {System.out.println(stringObjectMap);}} }

• 设置热部署

• <!--devtools--> <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-devtools</artifactId><scope>runtime</scope><optional>true</optional> </dependency><plugins><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><configuration><fork>true</fork><addResources>true</addResources></configuration></plugin></plugins>

• application

• ### db config ### spring.datasource.type=com.alibaba.druid.pool.DruidDataSource spring.datasource.driverClassName=com.mysql.cj.jdbc.Driver spring.datasource.url=jdbc:mysql://localhost:3306/db01?useUnicode=true&characterEncoding=utf8&currentSchema=public spring.datasource.username=root spring.datasource.password=123456#spring.datasource.druid.filters=stat,log4jserver.port=8001#初始化时建立物理连接的个数 spring.datasource.druid.initial-size=5 #最小连接池数量 spring.datasource.druid.min-idle=5 #最大连接池数量 maxIdle已经不再使用 spring.datasource.druid.max-active=20 #获取连接时最大等待时间，单位毫秒 spring.datasource.druid.max-wait=60000#spring.datasource.druid.stat-view-servlet.login-username=admin #spring.datasource.druid.stat-view-servlet.login-password=admin### mybatis config ### mybatis.mapper-locations=classpath:mybatis/mapper/*.xml mybatis.type-aliases-package=com.haoyun.pojo.Dept

• deptMapper

• <?xml version="1.0" encoding="UTF-8" ?> <!DOCTYPE mapperPUBLIC "-//mybatis.org//DTD Mapper 3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.haoyun.dao.DeptDao"><insert id="insertDept" parameterType="com.haoyun.pojo.Dept">insert into dept ( dname, db_source)values (#{dname}, #{db_source});</insert><select id="selectAll" resultType="com.haoyun.pojo.Dept">select * from dept</select><select id="selectById" resultType="com.haoyun.pojo.Dept" parameterType="long">select * from dept where deptno=#{deptno}</select> </mapper>

• DeptDao

• @Mapper @Repository public interface DeptDao {boolean insertDept(Dept dept);List<Dept> selectAll();Dept selectById(long deptno); }

• DruidConfig

• package com.haoyun.config;import com.alibaba.druid.pool.DruidDataSource; import com.alibaba.druid.support.http.StatViewServlet; import com.alibaba.druid.support.http.WebStatFilter; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.boot.web.servlet.FilterRegistrationBean; import org.springframework.boot.web.servlet.ServletRegistrationBean; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration;import javax.sql.DataSource;@Configuration public class DruidConfig {@Bean@ConfigurationProperties(prefix = "spring.datasource")public DataSource getDataSource() {return new DruidDataSource();}@Beanpublic ServletRegistrationBean druidStatViewServlet() {//ServletRegistrationBean提供类的进行注册ServletRegistrationBean servletRegistrationBean =new ServletRegistrationBean(new StatViewServlet(), "/druid/*");//添加初始化参数：initParams//白名单：servletRegistrationBean.addInitParameter("allow", "127.0.0.1");//IP黑名单（同时存在时，deny优先于allow）//如果满足deny，就提示：sorry，you are not permitted to view this pageservletRegistrationBean.addInitParameter("deny", "192.168.1.73");//登录查看信息的账号和密码servletRegistrationBean.addInitParameter("loginUsername", "admin");servletRegistrationBean.addInitParameter("loginPassword", "123456");servletRegistrationBean.addInitParameter("resetEnable", "false");return servletRegistrationBean;}@Beanpublic FilterRegistrationBean druidStatFilter() {FilterRegistrationBean filterRegistrationBean =new FilterRegistrationBean(new WebStatFilter());//添加过滤规则filterRegistrationBean.addUrlPatterns("/*");//添加需要忽略的格式信息filterRegistrationBean.addInitParameter("exclusions", "*.js,*.gif," +"*.jpg,*.png, *.css,*.ico,/druid/*");return filterRegistrationBean;}}

• DeptServiceImpl

• @Service public class DeptServiceImpl implements DeptService {@AutowiredDeptDao deptDao;@Overridepublic boolean insertDept(Dept dept) {return deptDao.insertDept(dept);}@Overridepublic List<Dept> selectAll() {return deptDao.selectAll();}@Overridepublic Dept selectById(long deptno) {return deptDao.selectById(deptno);} }

• DeptController

• @RestController @RequestMapping("/dept") public class DeptController {@AutowiredDeptServiceImpl deptDao;@RequestMapping("/all")public List<Dept> all(){return deptDao.selectAll();}@PostMapping("/add")//由于是通过http rest方式交互，必须加上@RequestBody//必须使用post，consumer端通过postForObject传输的public boolean add( @RequestBody Dept dept){return deptDao.insertDept(dept);}@RequestMapping("/get/{id}")private Dept get(@PathVariable long id){return deptDao.selectById(id);}}

• 因为加了@RequestBody，直接访问服务端的add会报400错误，但是通过客户端访问是没问题的

• provider测试

• http://localhost:8001/dept/add?dname=%E6%B5%8B%E8%AF%95&db_source=db01 http://localhost:8080/consumer/add?dname=sadfa&db_source=db01

consumer

消费者不需要连接数据库，

消费者不应该有Service层

使用RestFul风格请求，

主要流程：

• 导入maven
  • web
  • spring-cloud
• Configuration
  • 注册RestTemplate的bean
• controller
  • 连接上provider就行

实现：

• pom

• <dependencies><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.projectlombok</groupId><artifactId>lombok</artifactId><optional>true</optional></dependency><!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-dependencies --><dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>Greenwich.SR3</version><type>pom</type><scope>runtime</scope></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-test</artifactId><scope>test</scope><exclusions><exclusion><groupId>org.junit.vintage</groupId><artifactId>junit-vintage-engine</artifactId></exclusion></exclusions></dependency></dependencies>

• spring-cloud-dependencies下载失败，要加

• <type>pom</type><scope>runtime</scope>

• config

• @Configuration public class ConfigBean {@Beanpublic RestTemplate getRestTemplate(){return new RestTemplate();} }

• 注册bean

• @RestController @RequestMapping("/consumer") public class DeptConsumerController {@AutowiredRestTemplate restTemplate;private static final String REST_URL_PREFIX = "http://localhost:8001";@RequestMapping("/all")public List<Dept> all(){return restTemplate.getForObject(REST_URL_PREFIX+"/dept/all", List.class);}@RequestMapping("/add")public boolean add(Dept dept){System.out.println("============="+dept);return restTemplate.postForObject(REST_URL_PREFIX+"/dept/add",dept,Boolean.class);}@RequestMapping("/get/{id}")private Dept get(@PathVariable("id") long id){return restTemplate.getForObject(REST_URL_PREFIX+"/dept/get/"+id,Dept.class,id);}}

• url一定要对上和respond要对上，要不然会报404，或500错误

• 设置端口为8080，一般用户都要使用默认端口，不让用户多设置

Eureka服务注册与发现

Eureka作为服务注册与发现，是C S架构的,client,Server

遵循AP原则

NetFlix的核心模块，基于Rest服务，用于定位服务，以实现云端中间层服务发现和故障转移，有了服务注册与发现，只需要使用服务的标识符，就可以访问到服务，不需要修改服务调用的配置文件，类似于Dubbo的Zookeeper注册中心

EurekaServer作为服务注册功能的服务器

心跳机制，维护人员可以通过Eureka监控系统中各个微服务是否正常运行，各个注册的微服务定时给Eureka发送信号，如果Eureka长时没收到信号就判定为这个微服务出问题，移除服务节点，默认周期为90秒

Eureka包含两个组件：EurekaServer和EurekaClient

三个角色：

• EurekaServer
• EurekaProvider
• EurekaConsumer

EurekaServer

流程：

• 导入依赖
• 编写配置文件
• 开启功能@enable
• 配置类

实现：

• 导入依赖

• 根据三种不同的角色导入不同的依赖

• 也可以直接创建项目的时候选

• <dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-server</artifactId> </dependency>

• 配置

• server.port=7001 eureka.instance.hostname=localhost #服务实例化名称 eureka.client.register-with-eureka=false #是否向服务端口注册自己 eureka.client.fetch-registry=false #表示自己为注册中心 eureka.client.service-url.serviceUrl=http://${eureka.instance.hostname}:${server.port}/eureka/

• 设置serviceurl

• 源码中需要传递一个map

• 通过源码查找默认的serviceUrl是怎么写的

• 滑倒上面有一个DefaultURl

• 默认端口号8761，加上prefix，/eureka加/

• 是默认的格式

• 所以更改serviceUrl就要以这个格式

• 配置启动类

• @SpringBootApplication @EnableEurekaServer /*开启EnableEurekaServer启动类，可以接收服务端的注册*/ public class SpringCloudEurekaApplication {public static void main(String[] args) {SpringApplication.run(SpringCloudEurekaApplication.class, args);}}

• 访问

• instances currently registered with Eureka

• 当前注册实例

EurekaProvider

• 导入依赖：

• 三种依赖，一种带server，一种client，一种什么都不带的就是Provider的就是了

• 好像改版了，什么都不带的maven不知道为什么加载不进来

• 就使用了client后缀的，spring-cloud-starter-eureka-client

• <dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-netflix-eureka-client</artifactId><version>2.2.5.RELEASE</version> </dependency>

• 主要也就三个操作

  • 导入依赖
  • 配置文件
  • 启动类@EnableEurekaClient
• eureka.client.service-url.defaultZone=http://localhost:7001/eureka/ eureka.instance.instance-id=springCloud-provider-dept8001
• @SpringBootApplication @EnableEurekaClient public class Demo2Application {public static void main(String[] args) {SpringApplication.run(Demo2Application.class, args);}}

• 因为中间更改了DefaultZone，server在心跳时间内没收到这个provider的心跳信息，判定为失效，作为安全期间，实例没有被消除，信息被保存了

• 这是Eureka的自我保护机制，没有接收到微服务的心跳，会保存微服务的信息，微服务突然失效是十分危险的，因为i微服务本身是健康的，此时不应该注销这个微服务，Eureka通过自我保护机制，当短时间丢失过多节点，可能发生了网络分区故障，这个节点就会进入自我保护机制，自我保护机制会保存注册表中的信息，不再删除注册表中的数据，网络故障结束后会自动推出自我保护机制

• 宁可保留错误的服务注册信息，也不销毁任何可能健康的服务实例

• 使用eureka.server.enable-self-preservation = false 可以禁用自我保护机制

• 这还不是真正的自我保护机制

视频还演示了通过获取Eureka的信息

总结

以上是生活随笔为你收集整理的SpringCloud 单Eureka简单例子consumer-provider的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。