Shulou(Shulou.com)06/02 Report--

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!

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.