Class HttpExchange

ZezeJava/ZezeJava/src/main/java/Zeze/Netty/HttpExchange.java:77–980

import org.thymeleaf.context.Context;

public class HttpExchange {
	protected static final int CLOSE_FINISH = 0; // 正常结束HttpExchange,不关闭连接
	protected static final int CLOSE_ON_FLUSH = 1; // 结束HttpExchange,发送完时关闭连接
	protected static final int CLOSE_FORCE = 2; // 结束HttpExchange,不等发送完强制关闭连接
	protected static final int CLOSE_TIMEOUT = 3; // 同上,只是因idle超时而关闭
	protected static final int CLOSE_PASSIVE = 4; // 同上,只是因远程主动关闭而关闭

	protected static final @NotNull Pattern rangePattern = Pattern.compile("[ =\\-/]");
	protected static final OpenOption[] readOnlyOpenOptions = new OpenOption[]{StandardOpenOption.READ};
	protected static final @NotNull VarHandle detachedHandle;
	protected static final HttpDataFactory httpDataFactory = new DefaultHttpDataFactory(false);
	protected static final HttpHeadersFactory headersFactory = DefaultHttpHeadersFactory.headersFactory().withValidation(false);
	protected static final HttpHeadersFactory trailersFactory = DefaultHttpHeadersFactory.trailersFactory().withValidation(false);

	static {
		try {
			detachedHandle = MethodHandles.lookup().findVarHandle(HttpExchange.class, "detached", int.class);
		} catch (ReflectiveOperationException e) {
			throw new ExceptionInInitializerError(e);
		}
	}

	protected final @NotNull HttpServer server; // 所属的HttpServer对象,每个对象管理监听端口的所有连接
	protected final @NotNull ChannelHandlerContext context; // netty的连接上下文,每个连接可能会依次绑定到多个HttpExchange对象
	protected @Nullable HttpRequest request; // 收到完整HTTP header部分会赋值
	protected @Nullable HttpHandler handler; // 收到完整HTTP header部分会查找对应handler并赋值
	protected @NotNull ByteBuf content = Unpooled.EMPTY_BUFFER; // 当前收集的HTTP body部分, 只用于非流模式
	protected @Nullable Object userState;
	protected @Nullable ArrayList<Object> resHeaders; // key,value,key,value,...
	protected @Nullable List<Cookie> cookies;
	protected @Nullable HttpSession.CookieSession cookieSession;
	protected @Nullable String path;
	protected volatile @SuppressWarnings("unused") int detached; // 0:not detached; 1:detached; 2:detached and closed
	protected boolean willCloseConnection; // true表示close时会关闭连接
	protected boolean inStreamMode; // 是否在流/WebSocket模式过程中
	protected boolean isWebSocketTextContent;

	public HttpExchange(@NotNull HttpServer server, @NotNull ChannelHandlerContext context) {
		this.server = server;
		this.context = context;
	}

	public HttpServer getHttpServer() {
		return server;
	}

	public @Nullable Object getUserState() {
		return userState;
	}

	public void setUserState(@Nullable Object userState) {
		this.userState = userState;
	}

	public @Nullable HttpSession.CookieSession getCookieSession() {
		return cookieSession;
	}