What is the purpose of the zk request processing class PrepRequestProcessor
This article introduces the relevant knowledge of "what is the role of zk request processing class PrepRequestProcessor". In the operation of actual cases, many people will encounter such a dilemma, so let the editor lead you to learn how to deal with these situations. I hope you can read it carefully and be able to achieve something!
As the first request processor in leader, PrepRequestProcessor can identify whether the current client request is a transaction request. If so, it performs a series of preprocessing, creating the request transaction header, transaction body, session detection, ACL check and version detection.
Attribute
Construction method
Method
Submitted request queue
LinkedBlockingQueue submittedRequests = new LinkedBlockingQueue ()
Next processor
Private final RequestProcessor nextProcessor
Zk service
ZooKeeperServer zks
Constructor function
Public PrepRequestProcessor (ZooKeeperServer zks, RequestProcessor nextProcessor) {super ("ProcessThread (sid:" + zks.getServerId () + "cport:" + zks.getClientPort () + "):", zks.getZooKeeperServerListener ()); this.nextProcessor = nextProcessor; this.zks = zks } process request public void run () {try {while (true) {ServerMetrics.getMetrics () .PREP_PROCESSOR_QUEUE_SIZE.add (submittedRequests.size ()); / / take out request information 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, 'playing, 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!");}
The main method is to reprocess the request and establish the transaction request through the request type. Different types of requests have different processing methods.
PRequest (request)
Transaction request: createContainer,create,create2,createTTL,deleteContainer
Delete
Non-transactional request:.
PRequest2TxnCreate (int type, Request request, Record record, boolean deserialize) throws IOException, KeeperException
This is the end of the content of "what is the purpose of the zk request processing class PrepRequestProcessor". Thank you for reading. If you want to know more about the industry, you can follow the website, the editor will output more high-quality practical articles for you!
