溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

zk中ServerCnxnFactory連接管理工廠的使用方法

發(fā)布時(shí)間:2021-06-28 16:52:02 來(lái)源:億速云 閱讀:187 作者:chen 欄目:大數(shù)據(jù)

這篇文章主要介紹“zk中ServerCnxnFactory連接管理工廠的使用方法”,在日常操作中,相信很多人在zk中ServerCnxnFactory連接管理工廠的使用方法問(wèn)題上存在疑惑,小編查閱了各式資料,整理出簡(jiǎn)單好用的操作方法,希望對(duì)大家解答”zk中ServerCnxnFactory連接管理工廠的使用方法”的疑惑有所幫助!接下來(lái),請(qǐng)跟著小編一起來(lái)學(xué)習(xí)吧!

作為ServerCnxn的工廠抽象類

屬性

ZOOKEEPER_SERVER_CNXN_FACTORY

zookeeper.serverCnxnFactory

secure

在ServerCnxnFactory中SSL是否啟用

sessionMap

session管理配置中信息(sessionId,ServerCnxn)

zkServer

ZooKeeperServer

方法 (存在很多抽象方法)

addSession(long sessionId, ServerCnxn cnxn)

添加session

removeCnxnFromSessionMap(ServerCnxn cnxn)

從工廠中移除Cnxn

closeSession(long sessionId, ServerCnxn.DisconnectReason reason)

關(guān)閉session

getLocalPort

 

getConnections

獲取連接

getNumAliveConnections

獲取存活的連接

getZooKeeperServer

獲取zkServer

configure

配置

getMaxClientCnxnsPerHost

單個(gè)端口上最大連接

startup

啟動(dòng)服務(wù)

createFactory()

 

unregisterConnection(ServerCnxn serverCnxn)

去注冊(cè)連接

registerConnection(ServerCnxn serverCnxn)

注冊(cè)連接

public abstract void startup(ZooKeeperServer zkServer, boolean startServer) throws IOException, InterruptedException;


public static ServerCnxnFactory createFactory() throws IOException {
    //獲取key對(duì)應(yīng)值
    String serverCnxnFactoryName = System.getProperty(ZOOKEEPER_SERVER_CNXN_FACTORY);
    if (serverCnxnFactoryName == null) {
        //默認(rèn)是NIO
        serverCnxnFactoryName = NIOServerCnxnFactory.class.getName();
    }
    try {
        //加載實(shí)例
        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;
    }
}

到此,關(guān)于“zk中ServerCnxnFactory連接管理工廠的使用方法”的學(xué)習(xí)就結(jié)束了,希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí),快去試試吧!若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí),請(qǐng)繼續(xù)關(guān)注億速云網(wǎng)站,小編會(huì)繼續(xù)努力為大家?guī)?lái)更多實(shí)用的文章!

向AI問(wèn)一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

zk
AI