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

This article mainly introduces "the use method of ServerCnxnFactory connection management factory in zk". In daily operation, I believe many people have doubts about the use method of ServerCnxnFactory connection management factory in zk. Xiaobian consulted various materials and sorted out simple and easy to use operation methods. I hope to help you answer the doubts about "the use method of ServerCnxnFactory connection management factory in zk"! Next, please follow the small series to learn together!

Factory abstract class as ServerCnxn

attribute

ZOOKEEPER_SERVER_CNXN_FACTORY

zookeeper.serverCnxnFactory

secure

Is SSL enabled in ServerCnxnFactory

sessionMap

Information in session management configuration (sessionId,ServerCnxn)

zkServer

ZooKeeperServer

Methods (there are many abstract methods)

addSession(long sessionId, ServerCnxn cnxn)

Add session

removeCnxnFromSessionMap(ServerCnxn cnxn)

Remove Cnxn from Factory

closeSession(long sessionId, ServerCnxn.DisconnectReason reason)

close the session

getLocalPort

getConnections

acquire a connection

getNumAliveConnections

Get surviving connections

getZooKeeperServer

Get zkServer

configure

configured

getMaxClientCnxnsPerHost

Maximum connections on a single port

startup

start the service

createFactory()

unregisterConnection(ServerCnxn serverCnxn)

Go Register Connection

registerConnection(ServerCnxn serverCnxn)

Register Connection

public abstract void startup(ZooKeeperServer zkServer, boolean startServer) throws IOException, InterruptedException;public static ServerCnxnFactory createFactory() throws IOException { //get key corresponding value String serverCnxnFactoryName = System.getProperty(ZOOKEEPER_SERVER_CNXN_FACTORY); if (serverCnxnFactoryName == null) { //default is NIO serverCnxnFactoryName = NIOServerCnxnFactory.class.getName(); } try { //load instance ServerCnxnFactory serverCnxnFactory = (ServerCnxnFactory) Class.forName(serverCnxnFactoryName) .getDeclaredConstructor() .newInstance(); LOG.info("Using {} as server connection factory", serverCnxnFactoryName); return serverCnxnFactory; } catch (Exception e) { IOException ioe = new IOException("Couldn't instantiate " + serverCnxnFactoryName, e); throw ioe; }} At this point, the study of "how to use ServerCnxnFactory connection management factory in zk" is over, hoping to solve everyone's doubts. Theory and practice can better match to help you learn, go and try it! If you want to continue learning more relevant knowledge, please continue to pay attention to the website, Xiaobian will continue to strive to bring more practical articles for everyone!

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.