类org.apache.zookeeper.server.ZooKeeperServerMain源码实例Demo

下面列出了怎么用org.apache.zookeeper.server.ZooKeeperServerMain的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: spring-boot-tutorial   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
            + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码2 项目: xian   文件: TestingZooKeeperMain.java
@Override
public void kill()
{
    try
    {
        Field cnxnFactoryField = ZooKeeperServerMain.class.getDeclaredField("cnxnFactory");
        cnxnFactoryField.setAccessible(true);
        ServerCnxnFactory cnxnFactory = (ServerCnxnFactory)cnxnFactoryField.get(this);
        cnxnFactory.closeAll();

        Field ssField = cnxnFactory.getClass().getDeclaredField("ss");
        ssField.setAccessible(true);
        ServerSocketChannel ss = (ServerSocketChannel)ssField.get(cnxnFactory);
        ss.close();

        close();
    }
    catch ( Exception e )
    {
        e.printStackTrace();    // just ignore - this class is only for testing
    }
}
 
源代码3 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码4 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码5 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码6 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码7 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码8 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码9 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码10 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码11 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码12 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码13 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码14 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码15 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码16 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码17 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码18 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码19 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码20 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码21 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码22 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码23 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码24 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码25 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码26 项目: dubbo-samples   文件: EmbeddedZooKeeper.java
@Override
public void run() {
    try {
        Properties properties = new Properties();
        File file = new File(System.getProperty("java.io.tmpdir")
                + File.separator + UUID.randomUUID());
        file.deleteOnExit();
        properties.setProperty("dataDir", file.getAbsolutePath());
        properties.setProperty("clientPort", String.valueOf(clientPort));

        QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
        quorumPeerConfig.parseProperties(properties);

        zkServer = new ZooKeeperServerMain();
        ServerConfig configuration = new ServerConfig();
        configuration.readFrom(quorumPeerConfig);

        zkServer.runFromConfig(configuration);
    } catch (Exception e) {
        if (errorHandler != null) {
            errorHandler.handleError(e);
        } else {
            logger.error("Exception running embedded ZooKeeper", e);
        }
    }
}
 
源代码27 项目: iotplatform   文件: KafkaDemoClient.java
private static void startZkLocal() throws Exception {
    final File zkTmpDir = File.createTempFile("zookeeper", "test");
    if (zkTmpDir.delete() && zkTmpDir.mkdir()) {
        Properties zkProperties = new Properties();
        zkProperties.setProperty("dataDir", zkTmpDir.getAbsolutePath());
        zkProperties.setProperty("clientPort", String.valueOf(ZK_PORT));

        ServerConfig configuration = new ServerConfig();
        QuorumPeerConfig quorumConfiguration = new QuorumPeerConfig();
        quorumConfiguration.parseProperties(zkProperties);
        configuration.readFrom(quorumConfiguration);

        new Thread() {
            public void run() {
                try {
                    new ZooKeeperServerMain().runFromConfig(configuration);
                } catch (IOException e) {
                    System.out.println("Start of Local ZooKeeper Failed");
                    e.printStackTrace(System.err);
                }
            }
        }.start();
    } else {
        System.out.println("Failed to delete or create data dir for Zookeeper");
    }
}
 
源代码28 项目: Flink-CEPplus   文件: FlinkZooKeeperQuorumPeer.java
/**
 * Runs a ZooKeeper {@link QuorumPeer} if further peers are configured or a single
 * {@link ZooKeeperServer} if no further peers are configured.
 *
 * @param zkConfigFile ZooKeeper config file 'zoo.cfg'
 * @param peerId       ID for the 'myid' file
 */
public static void runFlinkZkQuorumPeer(String zkConfigFile, int peerId) throws Exception {

	Properties zkProps = new Properties();

	try (InputStream inStream = new FileInputStream(new File(zkConfigFile))) {
		zkProps.load(inStream);
	}

	LOG.info("Configuration: " + zkProps);

	// Set defaults for required properties
	setRequiredProperties(zkProps);

	// Write peer id to myid file
	writeMyIdToDataDir(zkProps, peerId);

	// The myid file needs to be written before creating the instance. Otherwise, this
	// will fail.
	QuorumPeerConfig conf = new QuorumPeerConfig();
	conf.parseProperties(zkProps);

	if (conf.isDistributed()) {
		// Run quorum peer
		LOG.info("Running distributed ZooKeeper quorum peer (total peers: {}).",
				conf.getServers().size());

		QuorumPeerMain qp = new QuorumPeerMain();
		qp.runFromConfig(conf);
	}
	else {
		// Run standalone
		LOG.info("Running standalone ZooKeeper quorum peer.");

		ZooKeeperServerMain zk = new ZooKeeperServerMain();
		ServerConfig sc = new ServerConfig();
		sc.readFrom(conf);
		zk.runFromConfig(sc);
	}
}
 
源代码29 项目: flink   文件: FlinkZooKeeperQuorumPeer.java
/**
 * Runs a ZooKeeper {@link QuorumPeer} if further peers are configured or a single
 * {@link ZooKeeperServer} if no further peers are configured.
 *
 * @param zkConfigFile ZooKeeper config file 'zoo.cfg'
 * @param peerId       ID for the 'myid' file
 */
public static void runFlinkZkQuorumPeer(String zkConfigFile, int peerId) throws Exception {

	Properties zkProps = new Properties();

	try (InputStream inStream = new FileInputStream(new File(zkConfigFile))) {
		zkProps.load(inStream);
	}

	LOG.info("Configuration: " + zkProps);

	// Set defaults for required properties
	setRequiredProperties(zkProps);

	// Write peer id to myid file
	writeMyIdToDataDir(zkProps, peerId);

	// The myid file needs to be written before creating the instance. Otherwise, this
	// will fail.
	QuorumPeerConfig conf = new QuorumPeerConfig();
	conf.parseProperties(zkProps);

	if (conf.isDistributed()) {
		// Run quorum peer
		LOG.info("Running distributed ZooKeeper quorum peer (total peers: {}).",
				conf.getServers().size());

		QuorumPeerMain qp = new QuorumPeerMain();
		qp.runFromConfig(conf);
	}
	else {
		// Run standalone
		LOG.info("Running standalone ZooKeeper quorum peer.");

		ZooKeeperServerMain zk = new ZooKeeperServerMain();
		ServerConfig sc = new ServerConfig();
		sc.readFrom(conf);
		zk.runFromConfig(sc);
	}
}
 
源代码30 项目: dubbo-arthas-demo   文件: EmbeddedZooKeeper.java
@Override
public void run() {
	try {
		Properties properties = new Properties();
		File file = new File(System.getProperty("java.io.tmpdir")
				+ File.separator + UUID.randomUUID());
		file.deleteOnExit();
		properties.setProperty("dataDir", file.getAbsolutePath());
		properties.setProperty("clientPort", String.valueOf(clientPort));

		QuorumPeerConfig quorumPeerConfig = new QuorumPeerConfig();
		quorumPeerConfig.parseProperties(properties);

		zkServer = new ZooKeeperServerMain();
		ServerConfig configuration = new ServerConfig();
		configuration.readFrom(quorumPeerConfig);

		zkServer.runFromConfig(configuration);
	}
	catch (Exception e) {
		if (errorHandler != null) {
			errorHandler.handleError(e);
		}
		else {
			logger.error("Exception running embedded ZooKeeper", e);
		}
	}
}
 
 类所在包
 类方法
 同包方法