為什么會(huì)有跨域問題

因?yàn)闉g覽器的同源政策，就會(huì)產(chǎn)生跨域。比如說發(fā)送的異步請(qǐng)求是不同的兩個(gè)源，就比如是不同的的兩個(gè)端口或者不同的兩個(gè)協(xié)議或者不同的域名。由于瀏覽器為了安全考慮，就會(huì)產(chǎn)生一個(gè)同源政策，不是同一個(gè)地方出來的是不允許進(jìn)行交互的。

常見的跨域解決方式

在控制層加入允許跨域的注解 @CrossOrigin

使用httpclient，不依賴瀏覽器

使用網(wǎng)關(guān) Gateway

注解：@CrossOrigin

在控制層加入允許跨域的注解，即可完成一個(gè)項(xiàng)目中前后端口跨域的問題

基于 Spring Boot + MyBatis Plus + Vue & Element 實(shí)現(xiàn)的后臺(tái)管理系統(tǒng) + 用戶小程序，支持 RBAC 動(dòng)態(tài)權(quán)限、多租戶、數(shù)據(jù)權(quán)限、工作流、三方登錄、支付、短信、商城等功能

網(wǎng)關(guān)整合

Spring Cloud Gateway作為Spring Cloud生態(tài)系統(tǒng)中的網(wǎng)關(guān)，目標(biāo)是替代Netflix Zuul，其 不僅提供統(tǒng)一的路由方式，并且還基于Filer鏈的方式提供了網(wǎng)關(guān)基本的功能，例如：安全、監(jiān) 控/埋點(diǎn)、限流等。

（1）路由

路由是網(wǎng)關(guān)最基礎(chǔ)的部分，路由信息有一個(gè)ID、一個(gè)目的URL、一組斷言和一組 Filter組成。如果斷言路由為真，則說明請(qǐng)求的URL和配置匹配

（2）斷言

Java8中的斷言函數(shù)。Spring Cloud Gateway中的斷言函數(shù)輸入類型是Spring5.0框 架中的ServerWebExchange。Spring Cloud Gateway中的斷言函數(shù)允許開發(fā)者去定義匹配來自 于http request中的任何信息，比如請(qǐng)求頭和參數(shù)等。

（3）過濾器

一個(gè)標(biāo)準(zhǔn)的Spring webFilter。Spring cloud gateway中的filter分為兩種類型的 Filter，分別是Gateway Filter和Global Filter。過濾器Filter將會(huì)對(duì)請(qǐng)求和響應(yīng)進(jìn)行修改處理

Spring cloud Gateway發(fā)出請(qǐng)求。然后再由Gateway Handler Mapping中找到與請(qǐng) 求相匹配的路由，將其發(fā)送到Gateway web handler。Handler再通過指定的過濾器鏈將請(qǐng)求發(fā) 送到實(shí)際的服務(wù)執(zhí)行業(yè)務(wù)邏輯，然后返回。

項(xiàng)目中使用

新建模塊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

配置文件

#服務(wù)端口
server.port=9090

> 基于 Spring Cloud Alibaba + Gateway + Nacos + RocketMQ + Vue & Element 實(shí)現(xiàn)的后臺(tái)管理系統(tǒng) + 用戶小程序，支持 RBAC 動(dòng)態(tài)權(quán)限、多租戶、數(shù)據(jù)權(quán)限、工作流、三方登錄、支付、短信、商城等功能
>
> * 項(xiàng)目地址：
> * 視頻教程：

# 服務(wù)名
spring.application.name=service-gateway
# nacos服務(wù)地址 默認(rèn)8848
spring.cloud.nacos.discovery.server-addr=127.0.0.1:8888
#使用服務(wù)發(fā)現(xiàn)路由
spring.cloud.gateway.discovery.locator.enabled=true
#設(shè)置路由id
spring.cloud.gateway.routes[0].id=service-hosp
#設(shè)置路由的uri  lb負(fù)載均衡
spring.cloud.gateway.routes[0].uri=lb://service-hosp
#設(shè)置路由斷言,代理servicerId為auth-service的/auth/路徑
spring.cloud.gateway.routes[0].predicates= Path=/*/hosp/**
 
#設(shè)置路由id
spring.cloud.gateway.routes[1].id=service-cmn
#設(shè)置路由的uri
spring.cloud.gateway.routes[1].uri=lb://service-cmn
#設(shè)置路由斷言,代理servicerId為auth-service的/auth/路徑
spring.cloud.gateway.routes[1].predicates= Path=/*/cmn/**
#設(shè)置路由id
spring.cloud.gateway.routes[2].id=service-hosp
#設(shè)置路由的uri
spring.cloud.gateway.routes[2].uri=lb://service-hosp
#設(shè)置路由斷言,代理servicerId為auth-service的/auth/路徑
spring.cloud.gateway.routes[2].predicates= Path=/*/userlogin/**

創(chuàng)建啟動(dòng)類

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

修改前端.evn文件，改成訪問網(wǎng)關(guān)端口號(hào)

做集群部署時(shí)，他會(huì)根據(jù)名稱實(shí)現(xiàn)負(fù)載均衡

跨域理解：發(fā)送請(qǐng)求后，網(wǎng)關(guān)過濾器會(huì)進(jìn)行請(qǐng)求攔截，將跨域放行，轉(zhuǎn)發(fā)到服務(wù)器中

跨域配置類

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

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

returnnewCorsWebFilter(source);
}
}

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

Httpclient

常見的使用場(chǎng)景：多系統(tǒng)之間接口的交互、爬蟲

http原生請(qǐng)求，獲取百度首頁代碼

publicclassHttpTest{
@Test
publicvoidtest1()throwsException{
Stringurl="https://www.badu.com";
URLurl1=newURL(url);
//url連接
URLConnectionurlConnection=url1.openConnection();
HttpURLConnectionhttpURLConnection=(HttpURLConnection)urlConnection;
//獲取httpURLConnection輸入流
InputStreamis=httpURLConnection.getInputStream();
//轉(zhuǎn)換為字符串
InputStreamReaderreader=newInputStreamReader(is,StandardCharsets.UTF_8);
BufferedReaderbr=newBufferedReader(reader);
Stringline;
//將字符串一行一行讀取出來
while((line=br.readLine())!=null){
System.out.println(line);
}
}
}
//設(shè)置請(qǐng)求類型
httpURLConnection.setRequestMethod("GET");
//請(qǐng)求包含請(qǐng)求行、空格、請(qǐng)求頭、請(qǐng)求體
//設(shè)置請(qǐng)求頭編碼
httpURLConnection.setRequestProperty("Accept-Charset","utf-8");

使用HttpClient發(fā)送請(qǐng)求、接收響應(yīng)

創(chuàng)建HttpClient對(duì)象。

創(chuàng)建請(qǐng)求方法的實(shí)例，并指定請(qǐng)求URL。如果需要發(fā)送GET請(qǐng)求，創(chuàng)建HttpGet對(duì)象；如果需要發(fā)送POST請(qǐng)求，創(chuàng)建HttpPost對(duì)象。

如果需要發(fā)送請(qǐng)求參數(shù)，可調(diào)用HttpGet、HttpPost共同的setParams(HetpParams params)方法來添加請(qǐng)求參數(shù)；對(duì)于HttpPost對(duì)象而言，也可調(diào)用setEntity(HttpEntity entity)方法來設(shè)置請(qǐng)求參數(shù)。

調(diào)用HttpClient對(duì)象的execute(HttpUriRequest request)發(fā)送請(qǐng)求，該方法返回一個(gè)HttpResponse。

調(diào)用HttpResponse的getAllHeaders()、getHeaders(String name)等方法可獲取服務(wù)器的響應(yīng)頭；調(diào)用HttpResponse的getEntity()方法可獲取HttpEntity對(duì)象，該對(duì)象包裝了服務(wù)器的響應(yīng)內(nèi)容。程序可通過該對(duì)象獲取服務(wù)器的響應(yīng)內(nèi)容。

釋放連接。無論執(zhí)行方法是否成功，都必須釋放連接

集成測(cè)試，添加依賴

org.apache.httpcomponents
httpclient
4.5.13

@Test
publicvoidtest2(){
//可關(guān)閉的httpclient客戶端，相當(dāng)于打開一個(gè)瀏覽器
CloseableHttpClientclient=HttpClients.createDefault();
Stringurl="https://www.baidu.com";
//構(gòu)造httpGet請(qǐng)求對(duì)象
HttpGethttpGet=newHttpGet(url);
//響應(yīng)
CloseableHttpResponseresponse=null;
try{
response=client.execute(httpGet);
//獲取內(nèi)容
Stringresult=EntityUtils.toString(response.getEntity(),"utf-8");
System.out.println(result);
}catch(Exceptione){
e.printStackTrace();
}finally{
//關(guān)閉流
if(client!=null){
try{
client.close();
}catch(IOExceptione){
e.printStackTrace();
}
}
}
}

項(xiàng)目中使用，系統(tǒng)調(diào)用平臺(tái)接口保存信息，根據(jù)傳入josn數(shù)據(jù)保存信息

系統(tǒng)中

@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("數(shù)據(jù)異常",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工具類

/**
*封裝同步請(qǐng)求
*@paramparamMap
*@paramurl
*@return
*/
publicstaticJSONObjectsendRequest(MapparamMap,Stringurl){
Stringresult="";
try{
//封裝post參數(shù)
StringBuilderpostdata=newStringBuilder();
for(Map.Entryparam:paramMap.entrySet()){
postdata.append(param.getKey()).append("=")
.append(param.getValue()).append("&");
}
log.info(String.format("-->發(fā)送請(qǐng)求：postdata%1s",postdata));
byte[]reqData=postdata.toString().getBytes("utf-8");
byte[]respdata=HttpUtil.doPost(url,reqData);
result=newString(respdata);
log.info(String.format("-->應(yīng)答結(jié)果：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;
}
}

對(duì)應(yīng)平臺(tái)接口

@RestController
@RequestMapping("/api/hosp")
publicclassApiController{
@Autowired
privateHospitalServicehospitalService;
@ApiOperation(value="上傳醫(yī)院")
@PostMapping("saveHospital")
publicRsaveHospital(HttpServletRequestrequest){
//通過request取到前端接口傳過來的值
MapparameterMap=request.getParameterMap();
//將數(shù)組值轉(zhuǎn)換成一個(gè)值
MapparamMap=HttpRequestHelper.switchMap(parameterMap);
//將map集合轉(zhuǎn)成josn字符串
StringmapStr=JSONObject.toJSONString(paramMap);
//josn字符串轉(zhuǎn)成對(duì)象
Hospitalhospital=JSONObject.parseObject(mapStr,Hospital.class);
//加入MongoDB中
hospitalService.saveHosp(hospital);
returnR.ok();
}
}

即可完成不同系統(tǒng)中的相互調(diào)用

審核編輯：湯梓紅