lxy/redkale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

http优化

Browse Source
This commit is contained in:
redkale
2023-03-16 22:09:58 +08:00
parent 523c101e25
commit 9e7e4cc177
2 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/org/redkale/net/http/HttpDispatcherServlet.java
View File

@@ -400,7 +400,7 @@ public class HttpDispatcherServlet extends DispatcherServlet<String, HttpContext
} }
} }
} }
if (this.lazyHeaders && (!Rest.isSimpleRestDyn(servlet) || servlet instanceof WebSocketServlet)) { if (this.lazyHeaders && !Rest.isSimpleRestDyn(servlet)) {
this.lazyHeaders = false; this.lazyHeaders = false;
if (context != null) { if (context != null) {
context.lazyHeaders = this.lazyHeaders; //启动后运行过程中执行addServlet context.lazyHeaders = this.lazyHeaders; //启动后运行过程中执行addServlet

14
src/main/java/org/redkale/net/http/Rest.java
View File

@@ -10,10 +10,10 @@ import static java.lang.annotation.ElementType.TYPE;
import static java.lang.annotation.RetentionPolicy.RUNTIME; import static java.lang.annotation.RetentionPolicy.RUNTIME;
import java.lang.annotation.*; import java.lang.annotation.*;
import java.lang.reflect.*; import java.lang.reflect.*;
import java.net.InetSocketAddress; import java.net.*;
import java.nio.channels.CompletionHandler; import java.nio.channels.*;
import java.util.*; import java.util.*;
import java.util.concurrent.CompletionStage; import java.util.concurrent.*;
import org.redkale.annotation.Comment; import org.redkale.annotation.Comment;
import org.redkale.annotation.*; import org.redkale.annotation.*;
import static org.redkale.asm.ClassWriter.COMPUTE_FRAMES; import static org.redkale.asm.ClassWriter.COMPUTE_FRAMES;
@@ -24,9 +24,9 @@ import org.redkale.convert.*;
import org.redkale.convert.json.*; import org.redkale.convert.json.*;
import org.redkale.mq.*; import org.redkale.mq.*;
import org.redkale.net.*; import org.redkale.net.*;
import org.redkale.net.sncp.Sncp; import org.redkale.net.sncp.*;
import org.redkale.service.*; import org.redkale.service.*;
import org.redkale.source.Flipper; import org.redkale.source.*;
import org.redkale.util.*; import org.redkale.util.*;
/** /**
@@ -497,7 +497,7 @@ public final class Rest {
cw.visit(V11, ACC_PUBLIC + ACC_FINAL + ACC_SUPER, newDynName, null, supDynName, null); cw.visit(V11, ACC_PUBLIC + ACC_FINAL + ACC_SUPER, newDynName, null, supDynName, null);
{ //RestDyn { //RestDyn
av0 = cw.visitAnnotation(Type.getDescriptor(RestDyn.class), true); av0 = cw.visitAnnotation(Type.getDescriptor(RestDyn.class), true);
av0.visit("simple", false); av0.visit("simple", false); //WebSocketServlet必须要解析http-header
{ {
AnnotationVisitor av1 = av0.visitArray("types"); AnnotationVisitor av1 = av0.visitArray("types");
av1.visit(null, Type.getType("L" + newDynConsumerFullName.replace('.', '/') + ";")); av1.visit(null, Type.getType("L" + newDynConsumerFullName.replace('.', '/') + ";"));
@@ -1558,7 +1558,7 @@ public final class Rest {
av0.visit("value", Type.getType(Type.getDescriptor(serviceType))); av0.visit("value", Type.getType(Type.getDescriptor(serviceType)));
av0.visitEnd(); av0.visitEnd();
} }
boolean dynsimple = baseServletType != HttpServlet.class; //有自定义的BaseServlet会存在读取header的操作 boolean dynsimple = baseServletType == HttpServlet.class; //有自定义的BaseServlet会存在读取header的操作
//获取所有可以转换成HttpMapping的方法 //获取所有可以转换成HttpMapping的方法
int methodidex = 0; int methodidex = 0;
final MessageMultiConsumer mmc = serviceType.getAnnotation(MessageMultiConsumer.class); final MessageMultiConsumer mmc = serviceType.getAnnotation(MessageMultiConsumer.class);