目录
前言
1.引入openfeign相关依赖
2.开启openFeign远程调用，在启动类头加上注解即可
3. 提供远程调用接口，接口名称必须与controler名称保持一致
4.远程调用关键代码
4.1 注入restTemplate
4.2 配置拦截器
4.3 设置请求头
4.4 获取请求结果
4.5 远程调用的完整代码：
5.实现效果
前言
因为其他各个服务都做了授权认证，如果不带Authorization，或者无效的请求头Authorization，都无法通过验证，即请求接口失败。
1.引入openfeign相关依赖
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-openfeign</artifactId>
<version>3.0.0</version>
</dependency>
<2.开启openFeign远程调用，在启动类头加上注解即可
3. 提供远程调用接口，接口名称必须与controler名称保持一致
4.远程调用关键代码
4.1 注入restTemplate
package com.example.mq.config;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.example.common.interpretor.AuthorizationHeaderInterceptor;
import com.example.securityservice.config.ResourceServerConfig;
import com.example.securityservice.config.TokenConfig;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.client.RestTemplate;
/**
* 通过扫描包的方式注入注解，降低代码的耦合度
*/
@ComponentScan(basePackages = "com.example.securityservice.config")
@Configuration
public class LoadAuthorizationConfig {
private Logger logger = LoggerFactory.getLogger(LoadAuthorizationConfig.class);
@Bean
public RestTemplate restTemplate(){
RestTemplate restTemplate = new RestTemplate();
return restTemplate;
}
}
4.2 配置拦截器
在远程调用的请求头加入 Authorization请求头，降低代码的重复率。
package com.example.mq.interpretor;
import org.springframework.http.HttpRequest;
import org.springframework.http.client.ClientHttpRequestExecution;
import org.springframework.http.client.ClientHttpRequestInterceptor;
import org.springframework.http.client.ClientHttpResponse;
import java.io.IOException;
/**
* 请求拦截器，在restTemplate请求中自动加入token
*/
public class AuthorizationHeaderInterceptor implements ClientHttpRequestInterceptor {
private final String token;
public AuthorizationHeaderInterceptor(String token) {
this.token = token;
}
@Override
public ClientHttpResponse intercept(HttpRequest request, byte[] body, ClientHttpRequestExecution execution) throws IOException {
// 添加Authorization头
request.getHeaders().add("Authorization", "Bearer " + this.token);
// 如果需要，还可以添加其他请求头
// request.getHeaders().add("Another-Header", "HeaderValue");
return execution.execute(request, body);
}
}
4.3 设置请求头
public void setHeaderToken(){
// 创建MultiValueMap来存储表单数据
MultiValueMap<String, String> formData = new LinkedMultiValueMap<>();
formData.add("client_id", CLIENT_ID);
formData.add("client_secret", CLIENT_SECRET);
formData.add("grant_type", GRANT_TYPE);
// 设置请求头，指明内容类型为application/x-www-form-urlencoded
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
// 创建HttpEntity，它包装了表单数据和请求头
HttpEntity<MultiValueMap<String, String>> requestEntity = new HttpEntity<>(formData, headers);
// 发送POST请求
Object response = restTemplate.postForObject(TOKEN_REQUEST_URL, requestEntity, Object.class);
JSONObject jsonObject = JSON.parseObject(JSONObject.toJSONString(response));
String access_token = jsonObject.getString("access_token");
// 创建拦截器
AuthorizationHeaderInterceptor interceptor = new AuthorizationHeaderInterceptor(access_token);
// 将拦截器添加到RestTemplate
restTemplate.getInterceptors().add(interceptor);
}4.4 获取请求结果
public Object getReqRes(String path){
ServiceInstance services= discoveryClient.getInstances("consumer-service").get(0);
String host = services.getHost();
int port = services.getPort();
StringBuffer reqUrl = new StringBuffer();
reqUrl.append("http://");
reqUrl.append(host);
reqUrl.append(":"+port);
String res = restTemplate.getForObject(reqUrl.toString()+path,String.class);
return res;
}
4.5 远程调用的完整代码：
package com.example.mq.controller;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.example.common.interpretor.AuthorizationHeaderInterceptor;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.http.HttpEntity;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.security.access.prepost.PreAuthorize;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;
@RestController
@RequestMapping("/mq")
public class MqController {
@Autowired
private RestTemplate restTemplate;
private final static String CLIENT_ID ="admin";
private final static String CLIENT_SECRET ="123456";
private final static String GRANT_TYPE ="client_credentials";
private final static String TOKEN_REQUEST_URL ="http://localhost:8063/oauth/token";
private final static String URL ="http://localhost:8063";
private Logger logger = LoggerFactory.getLogger(MqController.class);
@Autowired
private DiscoveryClient discoveryClient;
@GetMapping("/qq")
public String mq(){
//设置请求头
setHeaderToken();
//发起请求
Object reqUrl = getReqRes("/consumer");
logger.info("请求结果:{}",JSON.toJSONString(reqUrl));
return "mq";
}
@PreAuthorize("hasAuthority('system:dept:list')")
@GetMapping("/mm")
public String mm(){
return "mm";
}
public void setHeaderToken(){
// 创建MultiValueMap来存储表单数据
MultiValueMap<String, String> formData = new LinkedMultiValueMap<>();
formData.add("client_id", CLIENT_ID);
formData.add("client_secret", CLIENT_SECRET);
formData.add("grant_type", GRANT_TYPE);
// 设置请求头，指明内容类型为application/x-www-form-urlencoded
HttpHeaders headers = new HttpHeaders();
headers.setContentType(MediaType.APPLICATION_FORM_URLENCODED);
// 创建HttpEntity，它包装了表单数据和请求头
HttpEntity<MultiValueMap<String, String>> requestEntity = new HttpEntity<>(formData, headers);
// 发送POST请求
Object response = restTemplate.postForObject(TOKEN_REQUEST_URL, requestEntity, Object.class);
JSONObject jsonObject = JSON.parseObject(JSONObject.toJSONString(response));
String access_token = jsonObject.getString("access_token");
// 创建拦截器
AuthorizationHeaderInterceptor interceptor = new AuthorizationHeaderInterceptor(access_token);
// 将拦截器添加到RestTemplate
restTemplate.getInterceptors().add(interceptor);
}
public Object getReqRes(String path){
ServiceInstance services= discoveryClient.getInstances("consumer-service").get(0);
String host = services.getHost();
int port = services.getPort();
StringBuffer reqUrl = new StringBuffer();
reqUrl.append("http://");
reqUrl.append(host);
reqUrl.append(":"+port);
Object res = restTemplate.getForObject(reqUrl.toString()+path,Object.class);
return res;
}
}
5.实现效果
