一、什么时接口网关
接口网关作用是拦截请求，解决跨域问题，类似于nginx的反向代理。
在SpringCloud中用的是zuul来搭建接口网关。把所有的请求接口都由路由统一进行接收、转发、返回。
代码地址:
链接:https://pan.baidu.com/s/1CyiZR-z63OK9jq6HNXPHaQ 密码:b8sm
此案例是在上3章的基础上进行修改的。如果有不太清楚，先把上三章代码弄明白。
二、新建路由功能项目
1.建springboot2.0项目
2.项目目录如下
image.png
三、pom.xm配制文件
主要加上下图，其它都跟注册中心一样
路由引用包
<?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 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.joychen</groupId>
<artifactId>zuul</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>zuul</name>
<description>myzuul</description>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.0.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
<spring-cloud.version>Finchley.M8</spring-cloud.version>
</properties>
<dependencies>
<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>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-config</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-zuul</artifactId>
</dependency>
<!--<dependency>-->
<!--<groupId>org.springframework.boot</groupId>-->
<!--<artifactId>spring-boot-starter-security</artifactId>-->
<!--</dependency>-->
</dependencies>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>${spring-cloud.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>
</project>
四、application.yml
spring:
application:
name: service-zuul
zuul:
routes:
api-manber:
path: /api-manber/** #过滤地址一会员地址
# url: http://localhost:7879
serviceId: manber-server #这里用serviceId 或 service-id都可以 manber-server是在注册中心注册过的微服务名称
api-order:
path: /api-order/** #过滤地址二
url: http://localhost:7880
# serviceId: order-server #定单微服务名称
server:
port: 7888 #本路由服务器端口
eureka:
client:
serviceUrl:
defaultZone: http://localhost:7878/eureka/ #这个是注册中心的地址
五、启动App类，和过滤类
image.png
package com.joychen.zuul;
import com.joychen.zuul.filter.AccessFilter;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.zuul.EnableZuulProxy;
import org.springframework.context.annotation.Bean;
@EnableZuulProxy
@EnableEurekaClient
@SpringBootApplication
public class ZuulApplication {
public static void main(String[] args) {
SpringApplication.run(ZuulApplication.class, args);
}
@Bean //这个过滤器可以加也可以不加，加了就可去写AccessFilter
public AccessFilter accessFilter() {
return new AccessFilter();
}
}
AccessFilter代码如下
其中run方法中可以什么都不写，直接返回null就可以了。代表什么都不过滤
在运行演示的时候我直接返回null进行演示
package com.joychen.zuul.filter;
import javax.servlet.http.HttpServletRequest;
import org.springframework.util.StringUtils;
import com.netflix.zuul.ZuulFilter;
import com.netflix.zuul.context.RequestContext;
public class AccessFilter extends ZuulFilter {
@Override
public Object run() {
RequestContext ctx = RequestContext.getCurrentContext();
HttpServletRequest request = ctx.getRequest();
System.out.println(String.format("%s demoFilter request to %s", request.getMethod(), request.getRequestURL().toString()));
String username = request.getParameter("username");// 获取请求的参数
if(!StringUtils.isEmpty(username)&&username.equals("joychen")){//通过
ctx.setSendZuulResponse(true);// 对该请求进行路由
ctx.setResponseStatusCode(200);
ctx.set("isSuccess", true);// 设值，让下一个Filter看到上一个Filter的状态
return ctx.getResponse();
}else{
ctx.setSendZuulResponse(false);// 过滤该请求，不对其进行路由
ctx.setResponseStatusCode(401);// 返回错误码
ctx.setResponseBody("{\"result\":\"username is not correct!\"}");// 返回错误内容
ctx.set("isSuccess", false);
return null;
}
}
@Override
public boolean shouldFilter() {
return false;// 是否执行该过滤器，此处为true，说明需要过滤
}
@Override
public int filterOrder() {
return 0;// 优先级为0，数字越大，优先级越低
}
/*
pre：可以在请求被路由之前调用
route：在路由请求时候被调用
post：在route和error过滤器之后被调用
error：处理请求时发生错误时被调用
*/
@Override
public String filterType() {
return "pre";// 前置过滤器
}
}
六、启动测试
一、通过注册中心进行跳转。当我输入
http://localhost:7888/api-manber/member
会通过前置api-manber会找到微服务中的manber-server进行转发去访问member接口 如下图划出部份
image.png
二、直接通过url进行跳转
当我输入http://localhost:7888/api-order/getOrderName
会通过前置api-order 找到对应的url 如下图划出部份
image.png
网友评论