Feign 本身支持Hystrix,不需要额外引入依赖。
(1)修改tensquare_qa模块的application.yml ,开启hystrix
feign:
hystrix:
enabled: true
(2)在com.tensquare.qa.client包下创建impl包,包下创建熔断实现类,实现自接口
LabelClient
@Component
public class LabelClientImpl implements LabelClient {
@Override
public Result findById(String id) {
return new Result(false, StatusCode.ERROR,"熔断器启动了");
}
}
(3)修改LabelClient的注解
@FeignClient(value="tensquare‐base",fallback = LabelClientImpl.class)
服务之间调用,如果不通就会调用实现方法
如果通,则会重新调用服务
微服务网关Zuul
不同的微服务一般有不同的网络地址,而外部的客户端可能需要调用多个服务的接口才
能完成一个业务需求。比如一个电影购票的收集APP,可能回调用电影分类微服务,用户
微服务,支付微服务等。如果客户端直接和微服务进行通信,会存在一下问题:
客户端会多次请求不同微服务,增加客户端的复杂性
存在跨域请求,在一定场景下处理相对复杂
认证复杂,每一个服务都需要独立认证
难以重构,随着项目的迭代,可能需要重新划分微服务,如果客户端直接和微服务通
信,那么重构会难以实施
某些微服务可能使用了其他协议,直接访问有一定困难
上述问题,都可以借助微服务网关解决。微服务网关是介于客户端和服务器端之间的中
间层,所有的外部请求都会先经过微服务网关。
什么是Zuul
Zuul是Netflix开源的微服务网关,他可以和Eureka,Ribbon,Hystrix等组件配合使
用。Zuul组件的核心是一系列的过滤器,这些过滤器可以完成以下功能:
身份认证和安全: 识别每一个资源的验证要求,并拒绝那些不符的请求
审查与监控:
动态路由:动态将请求路由到不同后端集群
压力测试:逐渐增加指向集群的流量,以了解性能
负载分配:为每一种负载类型分配对应容量,并弃用超出限定值的请求
静态响应处理:边缘位置进行响应,避免转发到内部集群
多区域弹性:跨域AWS Region进行请求路由,旨在实现ELB(ElasticLoad Balancing)使
用多样化
Spring Cloud对Zuul进行了整合和增强。
Zuul路由转发 管理后台微服务网关
(1)创建子模块tensquare_manager,pom.xml引入eureka-client 和zuul的依赖
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring‐cloud‐starter‐netflix‐eureka‐
client</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring‐cloud‐starter‐netflix‐zuul</artifactId>
</dependency>
</dependencies>
(2)创建application.yml
server:
port: 9011
spring:
application:
name: tensquare‐manager #指定服务名
eureka:
client:
serviceUrl: #Eureka客户端与Eureka服务端进行交互的地址
defaultZone: http://127.0.0.1:6868/eureka/
instance:
prefer‐ip‐address: true
zuul:
routes:
tensquare‐gathering: #活动
path: /gathering/** #配置请求URL的请求规则
serviceId: tensquare‐gathering #指定Eureka注册中心中的服务id
tensquare‐article: #文章
path: /article/** #配置请求URL的请求规则
serviceId: tensquare‐article #指定Eureka注册中心中的服务id
tensquare‐base: #基础
path: /base/** #配置请求URL的请求规则
serviceId: tensquare‐base #指定Eureka注册中心中的服务id
tensquare‐friend: #交友
path: /friend/** #配置请求URL的请求规则
serviceId: tensquare‐friend #指定Eureka注册中心中的服务id
tensquare‐qa: #问答
path: /qa/** #配置请求URL的请求规则
serviceId: tensquare‐qa #指定Eureka注册中心中的服务id
tensquare‐recruit: #招聘
path: /recruit/** #配置请求URL的请求规则
serviceId: tensquare‐recruit #指定Eureka注册中心中的服务id
tensquare‐spit: #吐槽
path: /spit/** #配置请求URL的请求规则
serviceId: tensquare‐spit #指定Eureka注册中心中的服务id
tensquare‐user: #用户
path: /user/** #配置请求URL的请求规则
serviceId: tensquare‐user #指定Eureka注册中心中的服务id
(3)编写启动类
@EnableZuulProxy
@SpringBootApplication
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
网站前台的微服务网关
(1)创建子模块tensquare_web,pom.xml引入依赖zuul
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud‐starter-netflix-eureka-
client</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud‐starter-netflix-zuul</artifactId>
</dependency>
</dependencies>
(2)创建application.yml
server:
port: 9012
spring:
application:
name: tensquare‐web #指定服务名
eureka:
client:
serviceUrl: #Eureka客户端与Eureka服务端进行交互的地址
defaultZone: http://127.0.0.1:6868/eureka/
instance:
prefer‐ip‐address: true
zuul:
routes:
tensquare‐gathering: #活动
path: /gathering/** #配置请求URL的请求规则
serviceId: tensquare‐gathering #指定Eureka注册中心中的服务id
tensquare‐article: #文章
path: /article/** #配置请求URL的请求规则
serviceId: tensquare‐article #指定Eureka注册中心中的服务id
tensquare‐base: #基础
path: /base/** #配置请求URL的请求规则
serviceId: tensquare‐base #指定Eureka注册中心中的服务id
tensquare‐friend: #交友
path: /friend/** #配置请求URL的请求规则
serviceId: tensquare‐friend #指定Eureka注册中心中的服务id
tensquare‐qa: #问答
path: /qa/** #配置请求URL的请求规则
serviceId: tensquare‐qa #指定Eureka注册中心中的服务id
tensquare‐recruit: #招聘
path: /recruit/** #配置请求URL的请求规则
serviceId: tensquare‐recruit #指定Eureka注册中心中的服务id
tensquare‐spit: #吐槽
path: /spit/** #配置请求URL的请求规则
serviceId: tensquare‐spit #指定Eureka注册中心中的服务id
tensquare‐user: #用户
path: /user/** #配置请求URL的请求规则
serviceId: tensquare‐user #指定Eureka注册中心中的服务id
tensquare‐search: #用户
path: /search/** #配置请求URL的请求规则
serviceId: tensquare‐search #指定Eureka注册中心中的服务id
(3)编写启动类
@EnableZuulProxy
@SpringBootApplication
public class WebApplication {
public static void main(String[] args) {
SpringApplication.run(WebApplication.class);
}
}
Zuul过滤器
在tensquare_web 创建一个简单的zuul过滤器
@Component
public class WebFilter extends ZuulFilter {
/**
* 表示在请求前pro或者后post执行
* @return
*/
@Override
public String filterType() {
return "pre";
}
/**
* 过滤器的执行顺序,数字越小,表示越先执行
* @return
*/
@Override
public int filterOrder() {
return 0;
}
/**
* 当前过滤器是否开启,true表示开启
* @return
*/
@Override
public boolean shouldFilter() {
return true;
}
/**
* 过滤器内执行的操作 return任何object的值表示继续执行
* setsendzullResponse(fallse)表示不再继续执行
* @return
* @throws ZuulException
*/
@Override
public Object run() throws ZuulException {
System.out.println("经过web过滤器了");
//得到request上下文
RequestContext currentContext = RequestContext.getCurrentContext();
//得到request域
HttpServletRequest request = currentContext.getRequest();
//得到头信息
String header = request.getHeader("Authorization");
//判断是否有头信息
if(header!=null&&"".equals(header)){
//把头信息继续向下传,因为请求转发头部信息会丢失,需要重新设置
currentContext.addZuulRequestHeader("Authorization",header);
}
return null;
}
}
管理后台过滤器实现token校验
修改tensquare_manager的过滤器, 因为是管理后台使用,所以需要在过滤器中对token进行验证。
(1)tensquare_manager引入tensquare_common依赖 ,因为需要用到其中的JWT工具类
<dependency>
<groupId>com.tensquare</groupId>
<artifactId>tensquare_common</artifactId>
<version>1.0‐SNAPSHOT</version>
</dependency>
(2)修改tensquare_manager配置文件application.yml
jwt:
config:
key: itcast
(3)修改tensquare_manager的启动类,添加bean
@Bean
public JwtUtil jwtUtil(){
return new JwtUtil();
}
(4)tensquare_manager编写过滤器类
@Component
public class ManagerFilter extends ZuulFilter {
@Autowired
private JwtUtil jwtUtil;
@Override
public String filterType() {//过滤器类型
return "pre";//前置过滤器
}
@Override
public int filterOrder() {
return 0;//优先级,数字越大,优先级越低
}
@Override
public boolean shouldFilter() {
return true;//过滤器开关,true表示开启
}
@Override
public Object run() throws ZuulException {
System.out.println("Zuul过滤器");
RequestContext requestContext=RequestContext.getCurrentContext(); //得到request上下文
HttpServletRequest request = requestContext.getRequest(); //得到request域
//OPTIONS是预请求,浏览器会发起两次请求,参数为OPTIONS的第一次请求,他的作用是用于试探性的服务器响应是否正确,即是否能接受真正的请求,如果在options请求之后获取到的响应是拒绝性质的,例如500等http状态,那么它就会停止第二次的真正请求的访问
if(request.getMethod().equals("OPTIONS")){
return null;
}
String url=request.getRequestURL().toString(); //请求地址带有admin/login放行
if(url.indexOf("/admin/login")>0){
System.out.println("登陆页面"+url);
return null;
}
String authHeader =(String)request.getHeader("Authorization");//从请求头中获取授权
获取头信息
if(authHeader!=null && authHeader.startsWith("Bearer ") ){ //授权信息是Bearer 开头,下一步解析token
String token = authHeader.substring(7); //剪切加密头部
Claims claims = jwtUtil.parseJWT(token); //解析token
if(claims!=null){
if("admin".equals(claims.get("roles"))){ //claims中的roles角色是admin,重新添加头部信息
requestContext.addZuulRequestHeader("Authorization",authHeader);
System.out.println("token 验证通过,添加了头信
息"+authHeader);
return null;
}
}
}
requestContext.setSendZuulResponse(false);//终止运行
requestContext.setResponseStatusCode(401);//http状态码
requestContext.setResponseBody("无权访问");
requestContext.getResponse().setContentType("text/html;charset=UTF‐8");
return null;
}
}
集中配置组件SpringCloudConfig
(1)浏览器打开gitee.com,注册用户 ,注册后登陆码云管理控制台
(2)创建项目 tensquare-config (点击右上角的加号 ,下拉菜单选择创建项目)
(3)上传配置文件,将tensquare_base工程的application.yml改名为base-dev.yml后上传
文件命名规则:
{application}-{profile}.yml或{application}-{profile}.properties
application为应用名称 profile指的开发环境(用于区分开发环境,测试环境、生产环境等)
列如:base-dev.yml
(4)复制git地址 ,备用
配置中心微服务
(1)创建工程模块 配置中心微服务 tensquare_config ,pom.xml引入依赖
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring‐cloud‐config‐server</artifactId>
</dependency>
</dependencies>
(2)创建启动类ConfigServerApplication
@EnableConfigServer //开启配置服务
@SpringBootApplication
public class ConfigServerApplication {
public static void main(String[] args) {
SpringApplication.run(ConfigServerApplication.class, args);
}
}
(3)编写配置文件application.yml
spring:
application:
name: tensquare‐config
cloud:
config:
server:
git:
uri: https://gitee.com/chuanzhiliubei/tensquare‐config.git
server:
port: 12000
(4)浏览器测试:http://localhost:12000/base-dev.yml 可以看到配置内容
配置客户端
(1)在tensquare_base工程添加依赖
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring‐cloud‐starter‐config</artifactId>
</dependency>
(2)添加bootstrap.yml ,删除application.yml
spring:
cloud:
config:
name: base
profile: dev
label: master
uri: http://127.0.0.1:12000
(3)测试: 启动工程tensquare_eureka tensquare_config tensquare_base,看是否可以正常运行
消息总线组件SpringCloudBus --配置服务端
(1)修改tensquare_config工程的pom.xml,引用依赖
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring‐cloud‐bus</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring‐cloud‐stream‐binder‐rabbit</artifactId>
</dependency>
(2)修改application.yml ,添加配置
rabbitmq:
host: 192.168.184.135
management: #暴露触发消息总线的地址
endpoints:
web:
exposure:
include: bus‐refresh
配置客户端
(1)修改tensquare_base工程 ,引入依赖
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring‐cloud‐bus</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring‐cloud‐stream‐binder‐rabbit</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring‐boot‐starter‐actuator</artifactId>
</dependency>
(2)在码云的配置文件中配置rabbitMQ的地址:
rabbitmq:
host: 192.168.184.135
(3)启动tensquare_eureka 、tensquare_config和tensquare_base 看是否正常运行
(4)修改码云上的配置文件 ,将数据库连接IP 改为127.0.0.1 ,在本地部署一份数据库。
(4)postman测试 Url: http://127.0.0.1:12000/actuator/bus-refresh Method:post
(5)再次观察输出的数据是否是读取了本地的mysql数据。
自定义配置的读取
(1)修改码云上的配置文件,增加自定义配置
sms:
ip: 127.0.0.1
(2)在tensquare_base工程中新建controller
@RestController
public class TestController {
@Value("${sms.ip}")
private String ip;
@RequestMapping(value = "/ip", method = RequestMethod.GET)
public String ip() {
return ip;
}
}
(3)运行测试看是否能够读取配置信息 ,OK.
(4)修改码云上的配置文件中的自定义配置
sms:
ip: 192.168.184.134
(5)通过postman测试 Url: http://127.0.0.1:12000/actuator/bus-refresh Method:post
测试后观察,发现并没有更新信息。 自定义配置需要加注解
这是因为我们的 controller少了一个注解@RefreshScope 此注解用于刷新配置
@RefreshScope
@RestController
public class TestControl@Value("${sms.ip}")
private String ip;
@RequestMapping(valupublic String ip() {
return ip;
}
}
网友评论