三种跨域解决方案：HttpClient、注解、网关

为什么会有跨域问题

因为浏览器的同源政策，就会产生跨域。比如说发送的异步请求是不同的两个源，就比如是不同的的两个端口或者不同的两个协议或者不同的域名。由于浏览器为了安全考虑，就会产生一个同源政策，不是同一个地方出来的是不允许进行交互的。

常见的跨域解决方式

在控制层加入允许跨域的注解 @CrossOrigin

使用httpclient，不依赖浏览器

使用网关 Gateway

注解：@CrossOrigin

在控制层加入允许跨域的注解，即可完成一个项目中前后端口跨域的问题

基于 Spring Boot + MyBatis Plus + Vue & Element 实现的后台管理系统 + 用户小程序，支持 RBAC 动态权限、多租户、数据权限、工作流、三方登录、支付、短信、商城等功能

网关整合

Spring Cloud Gateway作为Spring Cloud生态系统中的网关，目标是替代Netflix Zuul，其 不仅提供统一的路由方式，并且还基于Filer链的方式提供了网关基本的功能，例如：安全、监 控/埋点、限流等。

（1）路由

路由是网关最基础的部分，路由信息有一个ID、一个目的URL、一组断言和一组 Filter组成。如果断言路由为真，则说明请求的URL和配置匹配

（2）断言

Java8中的断言函数。Spring Cloud Gateway中的断言函数输入类型是Spring5.0框 架中的ServerWebExchange。Spring Cloud Gateway中的断言函数允许开发者去定义匹配来自 于http request中的任何信息，比如请求头和参数等。

（3）过滤器

一个标准的Spring webFilter。Spring cloud gateway中的filter分为两种类型的 Filter，分别是Gateway Filter和Global Filter。过滤器Filter将会对请求和响应进行修改处理

Spring cloud Gateway发出请求。然后再由Gateway Handler Mapping中找到与请 求相匹配的路由，将其发送到Gateway web handler。Handler再通过指定的过滤器链将请求发 送到实际的服务执行业务逻辑，然后返回。

项目中使用

新建模块service_gateway

 

com.lzq
service_utils
0.0.1-SNAPSHOT


org.springframework.cloud
spring-cloud-starter-gateway

 

com.alibaba.cloud
spring-cloud-starter-alibaba-nacos-discovery

配置文件

#服务端口
server.port=9090

> 基于 Spring Cloud Alibaba + Gateway + Nacos + RocketMQ + Vue & Element 实现的后台管理系统 + 用户小程序，支持 RBAC 动态权限、多租户、数据权限、工作流、三方登录、支付、短信、商城等功能
>
> * 项目地址：
> * 视频教程：

# 服务名
spring.application.name=service-gateway
# nacos服务地址 默认8848
spring.cloud.nacos.discovery.server-addr=127.0.0.1:8888
#使用服务发现路由
spring.cloud.gateway.discovery.locator.enabled=true
#设置路由id
spring.cloud.gateway.routes[0].id=service-hosp
#设置路由的uri  lb负载均衡
spring.cloud.gateway.routes[0].uri=lb://service-hosp
#设置路由断言,代理servicerId为auth-service的/auth/路径
spring.cloud.gateway.routes[0].predicates= Path=/*/hosp/**
 
#设置路由id
spring.cloud.gateway.routes[1].id=service-cmn
#设置路由的uri
spring.cloud.gateway.routes[1].uri=lb://service-cmn
#设置路由断言,代理servicerId为auth-service的/auth/路径
spring.cloud.gateway.routes[1].predicates= Path=/*/cmn/**
#设置路由id
spring.cloud.gateway.routes[2].id=service-hosp
#设置路由的uri
spring.cloud.gateway.routes[2].uri=lb://service-hosp
#设置路由断言,代理servicerId为auth-service的/auth/路径
spring.cloud.gateway.routes[2].predicates= Path=/*/userlogin/**

创建启动类

@SpringBootApplication
publicclassApiGatewayApplication{
publicstaticvoidmain(String[]args){
SpringApplication.run(ApiGatewayApplication.class,args);
}
}

修改前端.evn文件，改成访问网关端口号

做集群部署时，他会根据名称实现负载均衡

跨域理解：发送请求后，网关过滤器会进行请求拦截，将跨域放行，转发到服务器中

跨域配置类

@Configuration
publicclassCorsConfig{
@Bean
publicCorsWebFiltercorsFilter(){
CorsConfigurationconfig=newCorsConfiguration();
config.addAllowedMethod("*");
config.addAllowedOrigin("*");
config.addAllowedHeader("*");

UrlBasedCorsConfigurationSourcesource=newUrlBasedCorsConfigurationSource(newPathPatternParser());
source.registerCorsConfiguration("/**",config);

returnnewCorsWebFilter(source);
}
}

若之前采用注解跨域,需要将@CrossOrigin去掉

Httpclient

常见的使用场景：多系统之间接口的交互、爬虫

http原生请求，获取百度首页代码

publicclassHttpTest{
@Test
publicvoidtest1()throwsException{
Stringurl="https://www.badu.com";
URLurl1=newURL(url);
//url连接
URLConnectionurlConnection=url1.openConnection();
HttpURLConnectionhttpURLConnection=(HttpURLConnection)urlConnection;
//获取httpURLConnection输入流
InputStreamis=httpURLConnection.getInputStream();
//转换为字符串
InputStreamReaderreader=newInputStreamReader(is,StandardCharsets.UTF_8);
BufferedReaderbr=newBufferedReader(reader);
Stringline;
//将字符串一行一行读取出来
while((line=br.readLine())!=null){
System.out.println(line);
}
}
}
//设置请求类型
httpURLConnection.setRequestMethod("GET");
//请求包含请求行、空格、请求头、请求体
//设置请求头编码
httpURLConnection.setRequestProperty("Accept-Charset","utf-8");

使用HttpClient发送请求、接收响应

创建HttpClient对象。

创建请求方法的实例，并指定请求URL。如果需要发送GET请求，创建HttpGet对象；如果需要发送POST请求，创建HttpPost对象。

如果需要发送请求参数，可调用HttpGet、HttpPost共同的setParams(HetpParams params)方法来添加请求参数；对于HttpPost对象而言，也可调用setEntity(HttpEntity entity)方法来设置请求参数。

调用HttpClient对象的execute(HttpUriRequest request)发送请求，该方法返回一个HttpResponse。

调用HttpResponse的getAllHeaders()、getHeaders(String name)等方法可获取服务器的响应头；调用HttpResponse的getEntity()方法可获取HttpEntity对象，该对象包装了服务器的响应内容。程序可通过该对象获取服务器的响应内容。

释放连接。无论执行方法是否成功，都必须释放连接

集成测试，添加依赖

org.apache.httpcomponents
httpclient
4.5.13

@Test
publicvoidtest2(){
//可关闭的httpclient客户端，相当于打开一个浏览器
CloseableHttpClientclient=HttpClients.createDefault();
Stringurl="https://www.baidu.com";
//构造httpGet请求对象
HttpGethttpGet=newHttpGet(url);
//响应
CloseableHttpResponseresponse=null;
try{
response=client.execute(httpGet);
//获取内容
Stringresult=EntityUtils.toString(response.getEntity(),"utf-8");
System.out.println(result);
}catch(Exceptione){
e.printStackTrace();
}finally{
//关闭流
if(client!=null){
try{
client.close();
}catch(IOExceptione){
e.printStackTrace();
}
}
}
}

项目中使用，系统调用平台接口保存信息，根据传入josn数据保存信息

系统中

@RequestMapping(value="/hospital/save",method=RequestMethod.POST)
publicStringsaveHospital(Stringdata,HttpServletRequestrequest){
try{
apiService.saveHospital(data);
}catch(YyghExceptione){
returnthis.failurePage(e.getMessage(),request);
}catch(Exceptione){
returnthis.failurePage("数据异常",request);
}
returnthis.successPage(null,request);
}

saveHospital方法

@Override
publicbooleansaveHospital(Stringdata){
JSONObjectjsonObject=JSONObject.parseObject(data);
MapparamMap=newHashMap<>();
paramMap.put("hoscode","10000");
paramMap.put("hosname",jsonObject.getString("hosname"))
//图片
paramMap.put("logoData",jsonObject.getString("logoData"));
//http://localhost:8201/api/hosp/saveHospital
//httpclient
JSONObjectrespone=
HttpRequestHelper.sendRequest(paramMap,this.getApiUrl()+"/api/hosp/saveHospital");
System.out.println(respone.toJSONString());

if(null!=respone&&200==respone.getIntValue("code")){
returntrue;
}else{
thrownewYyghException(respone.getString("message"),201);
}
}

HttpRequestHelper工具类

/**
*封装同步请求
*@paramparamMap
*@paramurl
*@return
*/
publicstaticJSONObjectsendRequest(MapparamMap,Stringurl){
Stringresult="";
try{
//封装post参数
StringBuilderpostdata=newStringBuilder();
for(Map.Entryparam:paramMap.entrySet()){
postdata.append(param.getKey()).append("=")
.append(param.getValue()).append("&");
}
log.info(String.format("-->发送请求：postdata%1s",postdata));
byte[]reqData=postdata.toString().getBytes("utf-8");
byte[]respdata=HttpUtil.doPost(url,reqData);
result=newString(respdata);
log.info(String.format("-->应答结果：resultdata%1s",result));
}catch(Exceptionex){
ex.printStackTrace();
}
returnJSONObject.parseObject(result);
}

HttpUtil工具类

publicstaticbyte[]send(StringstrUrl,Stringreqmethod,byte[]reqData){
try{
URLurl=newURL(strUrl);
HttpURLConnectionhttpcon=(HttpURLConnection)url.openConnection();
httpcon.setDoOutput(true);
httpcon.setDoInput(true);
httpcon.setUseCaches(false);
httpcon.setInstanceFollowRedirects(true);
httpcon.setConnectTimeout(CONN_TIMEOUT);
httpcon.setReadTimeout(READ_TIMEOUT);
httpcon.setRequestMethod(reqmethod);
httpcon.connect();
if(reqmethod.equalsIgnoreCase(POST)){
OutputStreamos=httpcon.getOutputStream();
os.write(reqData);
os.flush();
os.close();
}
BufferedReaderin=newBufferedReader(newInputStreamReader(httpcon.getInputStream(),"utf-8"));
StringinputLine;
StringBuilderbankXmlBuffer=newStringBuilder();
while((inputLine=in.readLine())!=null){
bankXmlBuffer.append(inputLine);
}
in.close();
httpcon.disconnect();
returnbankXmlBuffer.toString().getBytes();
}catch(Exceptionex){
log.error(ex.toString(),ex);
returnnull;
}
}

对应平台接口

@RestController
@RequestMapping("/api/hosp")
publicclassApiController{
@Autowired
privateHospitalServicehospitalService;
@ApiOperation(value="上传医院")
@PostMapping("saveHospital")
publicRsaveHospital(HttpServletRequestrequest){
//通过request取到前端接口传过来的值
MapparameterMap=request.getParameterMap();
//将数组值转换成一个值
MapparamMap=HttpRequestHelper.switchMap(parameterMap);
//将map集合转成josn字符串
StringmapStr=JSONObject.toJSONString(paramMap);
//josn字符串转成对象
Hospitalhospital=JSONObject.parseObject(mapStr,Hospital.class);
//加入MongoDB中
hospitalService.saveHosp(hospital);
returnR.ok();
}
}

即可完成不同系统中的相互调用

审核编辑：汤梓红