Commit cca74a5c authored by 赵啸非's avatar 赵啸非

添加工作人员最后登录时间

parent 1d5e3be2
......@@ -175,17 +175,14 @@ public class AccessLogFilter implements GlobalFilter, Ordered {
return bodyInserter.insert(outputMessage, new BodyInserterContext())
.then(Mono.defer(() -> {
Flux<DataBuffer> dataBuffers = Flux.from(outputMessage.getBody());
return outputMessage.writeWith(dataBuffers.map(d -> {
byte[] bytes = new byte[d.readableByteCount()];
d.read(bytes);
DataBufferUtils.release(d);
return bytes;
}).map(bytes -> {
DataBuffer buffer = outputMessage.bufferFactory().wrap(bytes);
return buffer;
}).doOnError(error -> {
//DataBufferUtils.release(dataBuffers);
}));
return DataBufferUtils.join(dataBuffers)
.doOnNext(buffer -> {
outputMessage.bufferFactory().wrap(buffer.asByteBuffer());
})
.doOnError(error -> {
// DataBufferUtils.release(dataBuffers);
})
.flatMap(buffer -> outputMessage.writeWith(Mono.just(buffer)));
}));
// return bodyInserter.insert(outputMessage, new BodyInserterContext())
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment