Elasticsearch、XXLJob以及最近的学习记录
前言
在这九月的最后一周，来总结一下最近的学习记录，主要是对于Elasticsearch、XXLjob的初步学习，想着还是多记录点，以便后面去看看，具体的错误认知点在哪，以及找到一些自己的认识点。
后台数据脱敏
一、普通方式
首先该功能是基于Spring Boot项目做的，所以这是一个简单的流程。
具体实现：首先设定一个角色code，比如 “涉密人员” “secret”；
通过登录时获取token中的用户名然后通过用户名去获取他的角色code，同时去动态的获取涉密人员的角色code（即做判断的时候不能写死，从数据库中获取），
然后将他们的code做判断；
import cn.hutool.core.util.StrUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import javax.servlet.http.HttpServletRequest;
import java.util.List;
/**
* <p>
*
* </p>
*
* @author yuyueq
* @since 2021/9/13
*/
@Component
@Slf4j
public class JudgeSecret {
//TODO
@Autowired
private BosuserIdentityService bosuserIdentityService;
@Autowired
private BosRoleService bosRoleService;
public Boolean judgingSecret(HttpServletRequest servletRequest) {
boolean flag = false;
String token = JwtTokenUtil.getToken(servletRequest);
String username = JwtUtil.getUsername(token);
//做角色code获取并进行判断
for (*:*) {
if (role.getId().equals(sRole.getId())) {
flag = true;// 是涉密员
break;
}
}
return flag;
}
public String mobileReplace(String mobile) {
if (StrUtil.isNotBlank(mobile)) {
return mobile.replaceAll("(\\d{3})\\d{4}(\\d{4})", "$1****$2");
} else {
return "-";
}
}
public String nameReplace(String name) {
if (StrUtil.isNotBlank(name)) {
return StringUtils.rightPad(StringUtils.left(name, 1), StringUtils.length(name), "*");
} else {
return "-";
}
}
}
二、Spring AOP实现
只需要给serviceImpl加EncryptMethod注解，以及在需要加密的字段加上EncryptMobileField、EncryptNameField注解
package net.liangyihui.dhbos.aspect;
import cn.hutool.core.util.ReflectUtil;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import lombok.extern.slf4j.Slf4j;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.annotation.Pointcut;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.context.request.RequestAttributes;
import org.springframework.web.context.request.RequestContextHolder;
import javax.servlet.http.HttpServletRequest;
import java.beans.PropertyDescriptor;
import java.lang.reflect.Field;
import java.lang.reflect.Method;
/**
* @ClassName : ServiceAspect
* @Author : yuyueq
* @Date: 2021/9/18 14:23
* @Description :
*/
@Slf4j
@Configuration
@Aspect
public class ServiceAspect {
private final String ExpGetResultDataPoint = "@annotation(位置)";
@Autowired
private JudgeSecret judgeSecret;
@Pointcut(ExpGetResultDataPoint)
public void EncryptMethod() {
}
@Around("EncryptMethod()")
public Object doAroundAdvice(ProceedingJoinPoint proceedingJoinPoint) {
log.info("环绕通知的目标方法名：" + proceedingJoinPoint.getSignature().getName());
processInputArg(proceedingJoinPoint.getArgs());
try {//obj之前可以写目标方法执行前的逻辑
Object obj = proceedingJoinPoint.proceed();
processOutPutObj(obj);
return obj;
} catch (Throwable throwable) {
throwable.printStackTrace();
}
return null;
}
/**
* 处理返回对象
*/
private void processOutPutObj(Object object) {
RequestAttributes requestAttributes = RequestContextHolder.getRequestAttributes();
HttpServletRequest servletRequest = (HttpServletRequest) requestAttributes.resolveReference(RequestAttributes.REFERENCE_REQUEST);
boolean flag = !judgeSecret.judgingSecret(servletRequest);
if (flag) {
if (object instanceof Page) {
//page
Page page = (Page) object;
page.getRecords().forEach(o -> {
try {
Field[] fields = o.getClass().getDeclaredFields();
for (Field field : fields) {
encrypt(field, o);
}
} catch (Exception e) {
log.info("反射错误" + e);
}
});
} else {
try {
Class clazz = object.getClass();
Field[] fields = ReflectUtil.getFieldsDirectly(clazz, true);
for (Field field : fields) {
field.setAccessible(true);
String proType = field.getGenericType().toString();
if (proType.contains("class java.lang")
|| proType.contains("class java.math.")
|| proType.contains("class java.util")) {
encrypt(field, object);
} else if ("byte".equals(proType) || "short".equals(proType) || "int".equals(proType) || "long".equals(proType) || "double".equals(proType) || "float".equals(proType) || "boolean".equals(proType)) {
encrypt(field, object);
} else if (proType.startsWith("java.util")) {
// if (field.getGenericType() instanceof ParameterizedType) {
// Class newClazz = (Class) ((ParameterizedType) field.getGenericType()).getActualTypeArguments()[0];
// Object obj = newClazz.newInstance();
// processOutPutObj(obj);
// }
} else if (field.getType().isArray()) {
//属性是数组类型则遍历
} else {
//class类型的遍历
PropertyDescriptor descriptor = new PropertyDescriptor(field.getName(), clazz);
Method method = descriptor.getReadMethod();
Object obj = method.invoke(object);
if (null != obj) {
processOutPutObj(obj);
}
}
}
} catch (Exception e) {
e.printStackTrace();
log.info("脱敏加密失败" + e);
}
}
}
}
private Field encrypt(Field field, Object obj) {
try {
if (field.isAnnotationPresent(EncryptMobileField.class)) {
field.setAccessible(true);
Object value = field.get(obj);
if (value instanceof Long || value == null) {
field.set(obj, null);
} else {
field.set(obj, judgeSecret.mobileReplace(value.toString()));
}
}
if (field.isAnnotationPresent(EncryptNameField.class)) {
field.setAccessible(true);
Object value = field.get(obj);
if (value != null) {
field.set(obj, judgeSecret.nameReplace(value.toString()));
} else {
field.set(obj, null);
}
}
} catch (IllegalAccessException e) {
}
return field;
}
/**
* 处理输入参数
*
* @param args 入参列表
*/
private void processInputArg(Object[] args) {
// for (Object arg : args) {
// System.out.println("ARG原来为:" + arg);
// }
}
}
以上根据以下文章学习所得
Elasticsearch学习
参考笔记链接
这块的话是简单入了个门，所以我是在B站上找的“狂神说”的视频，至于视频中的笔记，网上也是一搜一大堆
这里的话贴一个比较全面的笔记链接：https://blog.****.net/qq_21197507/article/details/115076913
体会
初次安装运行体验，感觉整体很像数据库，所以比较好上手，然后目前是未感受到它的魅力，毕竟还未在
实际项目中使用，但是感觉这个技术还是挺强的。
RestfulApi:https://restfulapi.cn/
MVP：https://choerodon.io/zh/blog/mvp/
ES仿京东搜索Demo
我的仓库地址：https://gitee.com/yuyueq/esjd
XXLJob学习
这块的话还是分享我所看到的文章，毕竟我也是根据这些文档跟着学的
了解xxljob
再见 Spring Task，这个定时任务框架真香！
正巧还是今天发的
入门xxljob
Spring Job？Quartz？XXL-Job？年轻人才做选择，艿艿全莽~
最近看到的一些文章分享
其实看到官网通知很及时，因为我当时正在看文档，没想到出了事，个人还是很意外吧，毕竟自己才刚开始
打算去学着用，因为是感觉挺方便的，虽然没有vue和elementUI的好，但各有各的好处吧，只不过就是有点遗憾
没有早接触作者这么优秀的技术作品。
Debug调试
最后
基本上也就这些内容了，所以接下来，还要通过一些的实践内容去体会这些技术，不然仅仅只是看过而已。
共勉！
“他乡纵有当头月，不及家乡一盏灯”
贴几张图
