क्या यूनिट परीक्षणों के लिए कहें, प्रक्रिया में एक ज़ूकीपर सर्वर उदाहरण शुरू करना संभव है?

Question

कॉलिंग org.apache.zookeeper.server.quorum.QuorumPeerMain.main() काम नहीं कर रहा है।

Answer 1

फोन ZooKeeper आप ZooKeeperServerMain वर्ग पर अमल करने के लिए है शुरू करने के लिए।

आप एम्बेडेड मोड में ZooKeeper शुरू करने के लिए निम्न कोड का उपयोग कर सकते हैं।

Properties startupProperties = ... 

QuorumPeerConfig quorumConfiguration = new QuorumPeerConfig(); 
try { 
    quorumConfiguration.parseProperties(startupProperties); 
} catch(Exception e) { 
    throw new RuntimeException(e); 
} 

zooKeeperServer = new ZooKeeperServerMain(); 
final ServerConfig configuration = new ServerConfig(); 
configuration.readFrom(quorumConfiguration); 

new Thread() { 
    public void run() { 
     try { 
      zooKeeperServer.runFromConfig(configuration); 
     } catch (IOException e) { 
      log.error("ZooKeeper Failed", e); 
     } 
    } 
}.start(); 

Answer 2

आप इस तरह कुछ उपयोग कर सकते हैं।

int clientPort = 21818; // none-standard 
int numConnections = 5000; 
int tickTime = 2000; 
String dataDirectory = System.getProperty("java.io.tmpdir"); 

File dir = new File(dataDirectory, "zookeeper").getAbsoluteFile(); 

ZooKeeperServer server = new ZooKeeperServer(dir, dir, tickTime); 
NIOServerCnxn.Factory standaloneServerFactory = new NIOServerCnxn.Factory(new InetSocketAddress(clientPort), numConnections); 

standaloneServerFactory.startup(server); // start the server. 

और यह बंद करने के लिए सिर्फ standaloneServerFactory.shutdown()

Answer 3

ServerConfig config = new ServerConfig(); 
config.parse(new String[] {port, dir}); 
ZooKeeperServerMain zk = new ZooKeeperServerMain(); 
zk.runFromConfig(config); 

Answer 4

एक अल्पकालिक बंदरगाह (zkPort द्वारा दिखाया गया है) के उपयोग को जोड़कर बिल्डिंग 1 के जवाब पर और नवीनतम ZK एपीआई के लिए अद्यतन:

int tickTime = 2000; 
int numConnections = 5000; 
String dataDirectory = System.getProperty("java.io.tmpdir"); 

File dir = new File(dataDirectory, "zookeeper").getAbsoluteFile(); 

ZooKeeperServer server = new ZooKeeperServer(dir, dir, tickTime); 
standaloneServerFactory = ServerCnxnFactory.createFactory(0, numConnections); 
int zkPort = standaloneServerFactory.getLocalPort(); 

standaloneServerFactory.startup(server); 

Answer 5

Netfix Curator एक रूपरेखा opensourced बनाने के लिए जुकीपर का उपयोग और भी सुविधाजनक है। यह परीक्षण सर्वर वर्ग में बनाया गया है। आप Maven का उपयोग करते हैं तो बस अपने प्रोजेक्ट की pom.xml से जोड़ें:

<dependency> 
    <groupId>org.apache.curator</groupId> 
    <artifactId>curator-test</artifactId> 
    <version>2.2.0-incubating</version> 
    <scope>test</scope> 
</dependency> 

और यहाँ परीक्षण अनिवार्य कर रहे हैं।

TestingServer zkTestServer; 

@Before 
public void startZookeeper() throws Exception { 
    zkTestServer = new TestingServer(2181); 
    cli = CuratorFrameworkFactory.newClient(zkTestServer.getConnectString(), new RetryOneTime(2000)); 
} 

@After 
public void stopZookeeper() throws IOException { 
    cli.close(); 
    zkTestServer.stop(); 
} 

cli किसी भी परीक्षण डेटा को बनाना बहुत आसान है।

cli.create().forPath("/a1", "testvalue".getBytes()); 

Answer 6

जेफबॉर्न के उत्तर का एक अद्यतन संस्करण।

int clientPort = 2199; // not standard 
    int numConnections = 5000; 
    int tickTime = 2000; 
    String dataDirectory = System.getProperty("java.io.tmpdir"); 

    File dir = new File(dataDirectory, "zookeeper").getAbsoluteFile(); 

    ZooKeeperServer server = new ZooKeeperServer(dir, dir, tickTime); 
    ServerCnxnFactory factory = new NIOServerCnxnFactory(); 
    factory.configure(new InetSocketAddress(clientPort), numConnections); 

    factory.startup(server); // start the server. 

    // ...shutdown some time later 
    factory.shutdown();