SpringCloud学习笔记-zuul网关
公司目前使用的是dubbo方式实现微服务,想试水改造接口层服务为Spring Cloud, 以下是网络拓补图。
第一层负载均衡可以用nginx或者zuul(即有2层zuul), 本图画的是nginx。
Zuul的作用就是路由转发和过滤, 即将请求转发到微服务或拦截请求; Zuul默认集成了负载均衡功能。
下面创建一个zuul工程:
打开IntelliJ Idea ---> New Project ---> 选择Spring Initializr ---> 设置包名 ---> 勾选web、zuul、Eureka Discovery -> 设置存储路径。
一、 路由:
在入口类添加注解@EnableZuulProxy, 即打开zuul功能;
-
@SpringBootApplication
-
@EnableEurekaClient
-
@EnableZuulProxy
-
public class SpringZuulDemoApplication {
-
-
public static void main(String[] args) {
-
SpringApplication.run(SpringZuulDemoApplication.class, args);
-
}
-
}
修改配置文件, 指定注册中心地址和路由规则zuul.routes, 建议使用微服务名称命名子节点。
启动Eureka注册中心、service-hello1、service-ribbon-consumer1和当前服务。
在浏览器输入:http://localhost:13000/servicehello1/hello?param=“test”
以/servicehello1/开头的请求会被转发到service-hello1服务, 以/consumer1/开头的请求会被转发到service-ribbon-consumer1服务。 PS: 如果是集群服务, 那么会转发到不同的ip/port。
http://localhost:13000/servicehello1/hello?param=“test”最终会执行doHello函数。
-
@RestController(value = "/servicehello1")
-
public class ZuulTestController {
-
@Value("${server.port}")
-
String port; //在application.yml文件里赋的值
-
-
@RequestMapping("helloworld")
-
public String doHello(@RequestParam String param) {
-
return "servicehello1! " + param + ":" + "port is " + port;
-
}
-
}
二、过滤, zuul可以实现验签功能和自定义过滤功能, 功能跟SpringMVC的拦截器一样。
在zuuldemo工程里新建一个Java类, PS:可以定义多个过滤类,设置不同的filterOrder(即执行时序), 基类都是ZuulFilter;
下面定义2个拦截器类, filterOrder值为0和1。
-
public class DemoFilter extends ZuulFilter {
-
private static Logger logger = LoggerFactory.getLogger(DemoFilter.class);
-
-
@Override
-
public String filterType() {
-
return "pre"; //枚举值:pre, routing, post, error
-
}
-
-
@Override
-
public int filterOrder() {
-
return 1; //优先级, 0是最高优先级即最先执行
-
}
-
-
@Override
-
public boolean shouldFilter() {
-
return true; //写逻辑,是否需要执行过滤。true会执行run函数,false不执行run函数
-
}
-
-
@Override
-
public Object run() {
-
logger.info("----------------this is DemoFilter----------");
-
-
RequestContext ctx = RequestContext.getCurrentContext();
-
HttpServletRequest request = ctx.getRequest();
-
logger.info(String.format("%s %s", request.getMethod(), request.getRequestURL().toString()));
-
-
Object accessToken = request.getParameter("token");
-
if(accessToken == null) { //判断释放有token自动
-
logger.warn("token is empty");
-
ctx.setSendZuulResponse(false);
-
ctx.setResponseStatusCode(401);
-
try {
-
ctx.getResponse().getWriter().write("token is empty");
-
}catch (Exception e){}
-
-
return null;
-
}
-
return null;
-
}
-
}
和
-
@Component
-
public class Demo1Filter extends ZuulFilter{
-
private static Logger logger = LoggerFactory.getLogger(DemoFilter.class);
-
-
@Override
-
public String filterType() {
-
return "pre"; //枚举值:pre, routing, post, error
-
}
-
-
@Override
-
public int filterOrder() {
-
return 0; //优先级, 0是最高优先级即最先执行
-
}
-
-
@Override
-
public boolean shouldFilter() {
-
return true; //写逻辑,是否需要执行过滤。true会执行run函数,false不执行run函数
-
}
-
-
@Override
-
public Object run() {
-
logger.info("----------------this is Demo1Filter----------");
-
return null;
-
}
-
}
filterType:表示过滤类型。 pre表示路由之前, routing表示路由当中, post表示路由之后, error表示路由发生错误。
filterOrder: 执行时序, 值是0,1,2....N等自然数。 0的优先级最高,即最先执行。
shouldFilter: 是否需要执行run函数。
run:拦截器的具体实现;
在浏览器输入: localhost:13000/servicehello1/hello?param="test"会显示拦截器的返回值, 即请求被成功拦截。
-
2017-11-28 13:04:07.837 INFO 28824 --- [trap-executor-0] c.n.d.s.r.aws.ConfigClusterResolver : Resolving eureka endpoints via configuration
-
2017-11-28 13:05:31.720 INFO 28824 --- [io-13000-exec-3] com.example.springzuuldemo.DemoFilter : ----------------this is Demo1Filter----------
-
2017-11-28 13:05:31.720 INFO 28824 --- [io-13000-exec-3] com.example.springzuuldemo.DemoFilter : ----------------this is DemoFilter----------
-
2017-11-28 13:05:31.720 INFO 28824 --- [io-13000-exec-3] com.example.springzuuldemo.DemoFilter : GET http://localhost:13000/servicehello1/hello
-
2017-11-28 13:05:31.761 INFO 28824 --- [io-13000-exec-3] s.c.a.AnnotationConfigApplicationContext : Refreshing
在浏览器输入: localhost:13000/servicehello1/hello?param="test"¶m="123" , 即符合拦截器规则后执行了service-hello1服务的hello接口。
综上, zuul包装了微服务, 微服务对调用者是透明的, 即调用者不知道访问了哪个微服务。 zuul可以理解为路由器和过滤器的综合体。
参考代码:http://download.csdn.net/download/brycegao321/10138936
最新文章
- Vi命令:如何删除全部内容?
- Passing JavaScript Objects to Managed Code
- cocos2dx中加入unzip
- 浅析Mysql数据回滚错误的解决方法
- 用MFC完成一个简单的猜数字游戏: 输入的四位数中,位置和数字都正确为A,数字相同而位置不同的为B。
- springmvc+mybatis如何分层
- find: missing argument to `-exec'
- HTTP2协议之HPACK--之头部压缩规范介绍
- LeetCode算法题-Subdomain Visit Count(Java实现)
- .NETCore+EF+MySql+Autofac简单三层架构
- java实现字符串数字部分自增
- pytorch简介
- 内网gitlab11.2升级至11.4.5
- 用python完成带有进度条的圆周率计算
- WKWebView 加载本地HTML随笔
- 强大的shell(一键redis,mysql,php,openresty,jdk)
- 深度学习课程笔记(九)VAE 相关推导和应用
- POJ 1733 Parity game(种类并查集)
- WPF如何设置Image.Source为资源图片
- Centos 7 安装后设置
热门文章
- python3 pygame 坦克自动移动
- 【Codeforces Round #445 (Div. 2) B】Vlad and Cafes
- C语言深度剖析-----函数
- programming-challenges Crypt Kicker (110204) 题解
- 各种排序算法的分析及java实现 分类: B10_计算机基础 2015-02-03 20:09 186人阅读 评论(0) 收藏
- Html表单使用实例
- JS实现页面table鼠标移动改变tr行颜色,单击tr选中复选框功能
- IfSpeed 带宽计算
- ETL概述 分类: H2_ORACLE 2013-08-23 10:36 344人阅读 评论(0) 收藏
- 用SQL找出前N名