|
@@ -53,12 +53,11 @@ public class PersonVerificationHandler extends SimpleChannelInboundHandler<Perso
|
|
|
|
|
|
@Override
|
|
|
protected void channelRead0(ChannelHandlerContext ctx, PersonVerification personVerification) throws Exception {
|
|
|
- log.warn("===人员记录 begin===");
|
|
|
- asyncWork(ctx,personVerification);
|
|
|
- log.warn("===人员记录 end===");
|
|
|
+ new Thread(()->{
|
|
|
+ asyncWork(ctx,personVerification);
|
|
|
+ }).start();
|
|
|
}
|
|
|
|
|
|
- @Async
|
|
|
public void asyncWork(ChannelHandlerContext ctx,PersonVerification personVerification) {
|
|
|
log.warn("===人员记录异步处理 begin===");
|
|
|
|