【实例简介】
1、首先保证计算机上已经成功安装SQL Server 。
2、将数据库文件附加到数据库中。
3、如果当前计算机装有多个SQL Server 实例,请在BookManageSystem目录下打开app.config程序文件，将程序数据库连接字符串localhost改为localhost\你的数据库实例名。如果仅有一个实例，就不用修改了。
4、编译运行即可。
管理员账户和密码：admin admin
读者账户和密码：user user
文件：/f/25127180-488083780-127562（访问密码：551685）
【实例截图】
以下内容无关：
-------------------------------------------分割线---------------------------------------------
方法日志打印
最近开发遇到的一个问题是关于日志打印。日志非常重要，通过查看日志，我们可以快速排查问题。
我们项目的整个系统内网关处做了拦截，能够看到前端传过来的日志，但是内部服务间调用，服务间的入参与出参看不到；还有，一些重要的方法如果要看到入参和出参，只能一个个去写log方法。
这种重复的工作非常适合使用切面来写一些小工具。下面是我写的小工具，下面方法几乎是搬运一位老哥写的博客，老哥的博客找不见了，sorry。
定义注释类
/**
@Description 打印参数
@Author lkb
@CreateDate: /3/25
/
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
@Inherited
public @interface MethodLog {
}
AOP 打印输入输出参数
/*
@Description
@Author lkb
@CreateDate: /3/25
*/
@Aspect
@Component
@Slf4j
public class MethodLogAspect {
@Pointcut("@annotation(com…annotion.MethodLog)")
public void pointCut(){}
@Around(value = “pointCut()”)
public Object around(ProceedingJoinPoint joinPoint) throws Throwable{
try{
MethodSignature signature = (MethodSignature) joinPoint.getSignature();
Method method = signature.getMethod();
MethodLog annotation = method.getAnnotation(MethodLog.class);
if (Objects.isNull(annotation)){
try {
return joinPoint.proceed();
} catch (Throwable throwable) {
log.error(“method proceed fail. e = {}”, throwable.getMessage(), throwable);
throw throwable;
}
}else{
String methodName = method.getDeclaringClass().getSimpleName() + “.” + method.getName();
log.info("methodName: "+methodName);
Object[] args = joinPoint.getArgs();
log.info("param: " + JsonUtil.toJSON(args));
Instant start = Instant.now();log.info("method start. methodName = {}", methodName);Object result = null;try {// 这里的result记得returnresult = joinPoint.proceed();} catch (Throwable throwable) {log.error("method proceed fail. e = {}", throwable.getMessage(), throwable);throw throwable;}log.info("method end. methodName = {}, cost = {}", methodName, ChronoUnit.MILLIS.between(start, Instant.now()));return result;}}catch (Exception e){log.error("MethodLogAspect around fail. e= {}", e.getMessage(), e);throw e;}
}
}
任务切片
遇到的第二个问题是，
在一个调用中，需要多次调用外部系统的服务，本来应该使用MQ去解耦，但是因为多方面原因只能维持现状（我们服务多次调用外部系统的服务）。这样导致整个请求特别慢，上线多台设备的时候可能需要十几二十秒。
与其他两个系统的交互互不影响，相互独立。因此，我想到使用任务切片的方式来加快执行速度。
下面是我写的任务切片小工具。
DTO
/**
@Description
@Author lkb
@CreateDate: /3/26
*/
@Data
public class AsynTaskDTO<T, R> {
public T param;
public Function<T, R> function;
public R resultData;
public Boolean result;
public String key;
public AsynTaskDTO(Function<T,R> function, T param){
this.function = function;
this.param = param;
this.result = false;
this.key = String.valueOf(param.hashCode());
}
}
任务切片实现类
/**
@Description
@Author lkb
@CreateDate: /3/26
*/
@Slf4j
@Getter
public class AsynTaskUtil {
private static final ForkJoinPool ASYNC_IO_POOL = new ForkJoinPool((Runtime.getRuntime().availableProcessors() << 1) + 1);
private List taskDTOS;
public AsynTaskUtil(List taskDTOS){
this.taskDTOS = taskDTOS;
}
public boolean doTask(){
CompletableFuture[] futures = taskDTOS.stream().map(task -> CompletableFuture.runAsync(() -> {
try{
task.setResultData(task.getFunction().apply(task.getParam()));
task.setResult(true);
}catch (Exception e){
log.error(“AsynTaskUtil doTask fail. e = {}” + e.getMessage(), e);
task.setResult(false);
}
}, ASYNC_IO_POOL)).toArray(CompletableFuture[]::new);
CompletableFuture.allOf(futures).join();boolean f = taskDTOS.stream().anyMatch(t -> Objects.equals(false, t.getResult()));return !f;
}
}
