info.xiancloud.nettyhttpserver.http.bean

类 ReqQueue

java.lang.Object

info.xiancloud.nettyhttpserver.http.bean.ReqQueue

public class ReqQueue
extends java.lang.Object

http长连接请求队列,确保http响应的顺序与收到的请求顺序一致,每个http连接的都持有唯一一个ReqQueue对象

字段概要

字段

限定符和类型	字段和说明
static io.netty.util.AttributeKey<ReqQueue>	REQ_QUEUE
static int	RES_COUNT_THRESHOLD 防内存泄露
static int	TIMEOUT_IN_MILLIS 原超时时间为15*1000ms，现改为无限大，即不超时

构造器概要

构造器

构造器和说明
ReqQueue()

方法概要

限定符和类型	方法和说明
void	offer(Request request)
Request	poll()
java.util.List<Request>	removeTimeout() 删除并返回超时未处理的request列表
void	writeAndFlush(ResponseWrapper... responses) 增加并发安全机制,日后如遇到长连接处理速度极限可以考虑去掉synchronized关键字,但需要仔细验证并发安全问题

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

RES_COUNT_THRESHOLD

public static final int RES_COUNT_THRESHOLD

防内存泄露

另请参阅:

常量字段值

TIMEOUT_IN_MILLIS

public static final int TIMEOUT_IN_MILLIS

原超时时间为15*1000ms，现改为无限大，即不超时

另请参阅:

常量字段值

REQ_QUEUE

public static final io.netty.util.AttributeKey<ReqQueue> REQ_QUEUE

构造器详细资料

ReqQueue

public ReqQueue()

方法详细资料

writeAndFlush

public void writeAndFlush(ResponseWrapper... responses)

增加并发安全机制,日后如遇到长连接处理速度极限可以考虑去掉synchronized关键字,但需要仔细验证并发安全问题

offer

public void offer(Request request)

poll

public Request poll()

removeTimeout

public java.util.List<Request> removeTimeout()

删除并返回超时未处理的request列表