本篇内容介绍了“zk请求处理类PrepRequestProcessor有什么作用”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
PrepRequestProcessor作为leader第一个请求处理器,可以识别当前客户端请求是否是事务请求,如果是,会进行一系列预处理,创建请求事务头,事务体,会话检测,ACL检查和版本检测
属性
构造方法
方法
提交的请求队列
LinkedBlockingQueue<Request> submittedRequests = new LinkedBlockingQueue<Request>();
下一个处理器
private final RequestProcessor nextProcessor;
zk服务
ZooKeeperServer zks;
构造函数
public PrepRequestProcessor(ZooKeeperServer zks, RequestProcessor nextProcessor) {
super(
"ProcessThread(sid:" + zks.getServerId()
+ " cport:" + zks.getClientPort()
+ "):", zks.getZooKeeperServerListener());
this.nextProcessor = nextProcessor;
this.zks = zks;
}
处理请求
public void run() {
try {
while (true) {
ServerMetrics.getMetrics().PREP_PROCESSOR_QUEUE_SIZE.add(submittedRequests.size());
//拿出请求信息
Request request = submittedRequests.take();
ServerMetrics.getMetrics().PREP_PROCESSOR_QUEUE_TIME
.add(Time.currentElapsedTime() - request.prepQueueStartTime);
long traceMask = ZooTrace.CLIENT_REQUEST_TRACE_MASK;
if (request.type == OpCode.ping) {
traceMask = ZooTrace.CLIENT_PING_TRACE_MASK;
}
if (LOG.isTraceEnabled()) {
ZooTrace.logRequest(LOG, traceMask, 'P', request, "");
}
if (Request.requestOfDeath == request) {
break;
}
request.prepStartTime = Time.currentElapsedTime();
pRequest(request);
}
} catch (RequestProcessorException e) {
if (e.getCause() instanceof XidRolloverException) {
LOG.info(e.getCause().getMessage());
}
handleException(this.getName(), e);
} catch (Exception e) {
handleException(this.getName(), e);
}
LOG.info("PrepRequestProcessor exited loop!");
}
主要方法通过请求类型,重新处理请求,建立事务请求,不同类型处理方式不同,
pRequest(request);
事务请求:createContainer,create,create2,createTTL,deleteContainer,
delete
非事务请求:...
pRequest2TxnCreate(int type, Request request, Record record, boolean deserialize) throws IOException, KeeperException;
“zk请求处理类PrepRequestProcessor有什么作用”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注亿速云网站,小编将为大家输出更多高质量的实用文章!
亿速云「云服务器」,即开即用、新一代英特尔至强铂金CPU、三副本存储NVMe SSD云盘,价格低至29元/月。点击查看>>
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。
原文链接:https://my.oschina.net/iioschina/blog/3120315