1. 增加 RPC starter

2. security 组件:feign 调用时,通过 header 透传 LoginUser 信息
This commit is contained in:
YunaiV
2022-06-11 22:24:15 +08:00
parent 0cf1738c0a
commit ca6e7a4528
19 changed files with 159 additions and 34 deletions

View File

@@ -0,0 +1,4 @@
/**
* 占坑 TODO
*/
package cn.iocoder.yudao.framework.rpc.config;

View File

@@ -0,0 +1,4 @@
/**
* 占坑 TODO
*/
package cn.iocoder.yudao.framework.rpc.core;

View File

@@ -0,0 +1,48 @@
package cn.iocoder.yudao.framework.rpc.core.util;
import cn.hutool.core.util.ReflectUtil;
import cn.iocoder.yudao.framework.common.util.json.JsonUtils;
import feign.RequestTemplate;
import feign.template.HeaderTemplate;
import feign.template.Literal;
import feign.template.Template;
import feign.template.TemplateChunk;
import java.util.List;
import java.util.Map;
/**
* {@link feign.Feign} 工具类
*
* @author 芋道源码
*/
public class FeignUtils {
/**
* 添加 JSON 格式的 Header
*
* @param requestTemplate 请求
* @param name header 名
* @param value header 值
*/
@SuppressWarnings("unchecked")
public static void createJsonHeader(RequestTemplate requestTemplate, String name, Object value) {
if (value == null) {
return;
}
// 添加 header
String valueStr = JsonUtils.toJsonString(value);
requestTemplate.header(name, valueStr);
// fix由于 OpenFeign 针对 { 会进行分词,所以需要反射修改
// 具体分析,可见 https://zhuanlan.zhihu.com/p/360501330 文档
Map<String, HeaderTemplate> headers = (Map<String, HeaderTemplate>)
ReflectUtil.getFieldValue(requestTemplate, "headers");
HeaderTemplate template = headers.get(name);
List<Template> templateValues = (List<Template>)
ReflectUtil.getFieldValue(template, "values");
List<TemplateChunk> templateChunks = (List<TemplateChunk>)
ReflectUtil.getFieldValue(templateValues.get(0), "templateChunks");
templateChunks.set(0, Literal.create(valueStr));
}
}

View File

@@ -0,0 +1,7 @@
/**
* OpenFeign提供 RESTful API 的调用
* Dubbo提供 Dubbo RPC 的调用
*
* @author 芋道源码
*/
package cn.iocoder.yudao.framework.rpc;