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就行

实现：

<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相关推荐

SpringCloud之Ribbon简单入门
提出疑问 ① 如何在配置Eureka Client注册中心时不去硬编码Eureka Server的地址? ② 在微服务不同模块间进行通信时,如何不去硬编码服务提供者的地址? ③ 当部署多个相同微服务时 ...
springcloud+springboot+Eureka+Feign+Ribbon+Hystrix+Zuul
Springcloud集成Eureka Eureka服务端和客户端本实例采用springboot,eureka和feign/ribbon,hystrix,zuul,mybatis,redis 1. ...
SpringCloud(二)——Eureka的使用和集群搭建
文章目录 1:Eureka是什么? 2:EurekaServer服务注册中心建立 3:将已有的微服务注册进Eureka服务中心 4:Eureka的集群模式 5:actuator微服务信息完善[可选择配 ...
SpringCloud[01]Eureka服务注册与发现
文章目录 Eureka服务注册与发现 1. Eureka基础知识 1. 什么是服务治理 2. 什么是服务注册与发现 3. Eureka包含两个组件:**Eureka Server** 和 **Eure ...
SpringCloud，Eureka，服务注册，微服务之间的项目调用
文章目录前言一.Eureka是什么? 二.项目实现步骤 1.项目外壳的搭建 2.Eureka注册中心服务搭建 3.Provider(提供者)服务搭建 4.Consumer(消费者)服务搭建总结 ...
浅谈SpringCloud (二) Eureka服务发现组件
上面学习到了如何由一个程序访问另一个程序,那么如果使用SpringCloud来进行访问,该如何访问呐? 可以借助Eureka服务发现组件进行访问. 可以借助官方文档:https://spring.io ...
javascript:正则表达式、一个表单验证的例子
阅读目录本文内容: 正则表达式: 利用正则表达式进行表单验证的例子: 回到顶部本文内容: 正则表达式正则表达式的使用方法正则表达式的特殊匹配字符正则表达式修饰符利用正则表达式进行表单验证的 ...
Spring+Spring Security+JSTL实现的表单登陆的例子
2019独角兽企业重金招聘Python工程师标准>>> Spring Security允许开发人员轻松地将安全功能集成到J2EE Web应用程序中,它通过Servlet过滤器实现&q ...
SpringCloud创建Eureka模块集群
1.说明本文详细介绍Spring Cloud创建Eureka模块集群的方法, 基于已经创建好的Spring Cloud Eureka Server模块, 请参考SpringCloud创建Eureka ...
SpringCloud创建Eureka Client服务注册
1.说明本文详细介绍微服务注册到Eureka的方法, 即Eureka Client注册到Eureka Server, 这里用任意一个Spring Cloud服务为例, 比如下面已经创建好的Confi ...

SpringCloud 单Eureka简单例子consumer-provider