Skip to content

Commit cfb952f

Browse files
abirkhan04pivovarit
abirkhan04
authored and
pivovarit
committedSep 30, 2017
Atomix Intro Project (eugenp#2675)
* This is whole project * BeanInjectionTest.java class is added for Junit Test. * Atomix Intro Project * Update pom.xml : Module name changed to Atomix * Intro to Atomix: 1. Module name is changed. 2. Module name is updated in pom.xml. * maven-compiler-plugin version number is updated.
1 parent 77aa65b commit cfb952f

File tree

6 files changed

+215
-0
lines changed

6 files changed

+215
-0
lines changed
 

‎atomix/.gitignore

+1
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
/target

‎atomix/pom.xml

+41
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,41 @@
1+
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
2+
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
3+
<modelVersion>4.0.0</modelVersion>
4+
<groupId>com.atomix.io</groupId>
5+
<artifactId>atomix</artifactId>
6+
<version>0.0.1-SNAPSHOT</version>
7+
8+
<dependencies>
9+
<dependency>
10+
<groupId>io.atomix</groupId>
11+
<artifactId>atomix-all</artifactId>
12+
<version>1.0.0-rc9</version>
13+
</dependency>
14+
<dependency>
15+
<groupId>junit</groupId>
16+
<artifactId>junit</artifactId>
17+
<version>4.9</version>
18+
<scope>test</scope>
19+
</dependency>
20+
<dependency>
21+
<groupId>log4j</groupId>
22+
<artifactId>log4j</artifactId>
23+
<version>1.2.17</version>
24+
</dependency>
25+
</dependencies>
26+
<build>
27+
<sourceDirectory>src</sourceDirectory>
28+
<plugins>
29+
<plugin>
30+
<artifactId>maven-compiler-plugin</artifactId>
31+
<version>3.7.0</version>
32+
<configuration>
33+
<source>1.8</source>
34+
<target>1.8</target>
35+
</configuration>
36+
</plugin>
37+
</plugins>
38+
</build>
39+
40+
41+
</project>

‎atomix/src/main/java/com/atomix/example/BootstrapingCluster.java

+30
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,30 @@
1+
package com.atomix.example;
2+
3+
import java.io.File;
4+
import java.util.concurrent.CompletableFuture;
5+
6+
import io.atomix.AtomixReplica;
7+
import io.atomix.catalyst.transport.Address;
8+
import io.atomix.catalyst.transport.netty.NettyTransport;
9+
import io.atomix.copycat.server.storage.Storage;
10+
import io.atomix.copycat.server.storage.StorageLevel;
11+
12+
public class BootstrapingCluster {
13+
14+
public static void main(String[] args) {
15+
// TODO Auto-generated method stub
16+
17+
Storage storage = Storage.builder()
18+
.withDirectory(new File("log"))
19+
.withStorageLevel(StorageLevel.DISK)
20+
.build();
21+
AtomixReplica replica = AtomixReplica.builder(new Address("localhost", 8700))
22+
.withStorage(storage)
23+
.withTransport(new NettyTransport())
24+
.build();
25+
26+
CompletableFuture<AtomixReplica> completableFuture = replica.bootstrap();
27+
completableFuture.join();
28+
29+
}
30+
}

‎atomix/src/main/java/com/atomix/example/ClientExample.java

+32
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,32 @@
1+
package com.atomix.example;
2+
3+
import java.util.Arrays;
4+
import java.util.List;
5+
6+
import io.atomix.AtomixClient;
7+
import io.atomix.catalyst.transport.Address;
8+
import io.atomix.catalyst.transport.netty.NettyTransport;
9+
import io.atomix.collections.DistributedMap;
10+
11+
public class ClientExample {
12+
13+
public static void main(String args[]) throws InterruptedException {
14+
AtomixClient client = AtomixClient.builder()
15+
.withTransport(new NettyTransport())
16+
.build();
17+
18+
List<Address> cluster = Arrays.asList(new Address("localhost", 8700), new Address("localhsot", 8701));
19+
client.connect(cluster)
20+
.thenRun(() -> System.out.println("Client Connected"));
21+
22+
Thread.sleep(5000);
23+
24+
DistributedMap<Object, Object> map = client.getMap("map")
25+
.join();
26+
27+
String value = (String) map.get("bar")
28+
.join();
29+
System.out.println("Value: " + value);
30+
31+
}
32+
}

‎atomix/src/main/java/com/atomix/example/OtherNodes.java

+73
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,73 @@
1+
package com.atomix.example;
2+
3+
import java.io.File;
4+
5+
import java.util.Arrays;
6+
import java.util.List;
7+
8+
import io.atomix.AtomixReplica;
9+
import io.atomix.catalyst.transport.Address;
10+
import io.atomix.catalyst.transport.netty.NettyTransport;
11+
import io.atomix.collections.DistributedMap;
12+
import io.atomix.concurrent.DistributedLock;
13+
import io.atomix.copycat.server.storage.Storage;
14+
import io.atomix.copycat.server.storage.StorageLevel;
15+
16+
public class OtherNodes {
17+
18+
public static void main(String[] args) throws InterruptedException {
19+
// TODO Auto-generated method stub
20+
21+
List<Address> cluster = Arrays.asList(new Address("localhost", 8700), new Address("localhost", 8701), new Address("localhost", 8702));
22+
23+
Storage storage = Storage.builder()
24+
.withDirectory(new File("log"))
25+
.withStorageLevel(StorageLevel.DISK)
26+
.build();
27+
28+
AtomixReplica replica2 = AtomixReplica.builder(new Address("localhost", 8701))
29+
.withStorage(storage)
30+
.withTransport(new NettyTransport())
31+
.build();
32+
33+
WorkerThread WT1 = new WorkerThread(replica2, cluster);
34+
WT1.run();
35+
36+
AtomixReplica replica3 = AtomixReplica.builder(new Address("localhost", 8702))
37+
.withStorage(storage)
38+
.withTransport(new NettyTransport())
39+
.build();
40+
41+
WorkerThread WT2 = new WorkerThread(replica3, cluster);
42+
WT2.run();
43+
44+
Thread.sleep(6000);
45+
46+
DistributedLock lock = replica2.getLock("my-lock")
47+
.join();
48+
lock.lock()
49+
.thenRun(() -> System.out.println("Acquired a lock"));
50+
51+
DistributedMap<Object, Object> map = replica2.getMap("map")
52+
.join();
53+
54+
// Put a value in the map and call the completion callback on response
55+
map.put("bar", "Hello world!")
56+
.thenRun(() -> System.out.println("Value is set in Distributed Map"));
57+
}
58+
59+
private static class WorkerThread extends Thread {
60+
AtomixReplica replica;
61+
List<Address> cluster;
62+
63+
public WorkerThread(AtomixReplica replica, List<Address> cluster) {
64+
this.replica = replica;
65+
this.cluster = cluster;
66+
}
67+
68+
public void run() {
69+
replica.join(cluster)
70+
.join();
71+
}
72+
}
73+
}

‎atomix/src/test/java/com/atomix/exampletest/ClientExampleTest.java

+38
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,38 @@
1+
package com.atomix.exampletest;
2+
3+
import static org.junit.Assert.assertEquals;
4+
import static org.junit.Assert.assertSame;
5+
import io.atomix.AtomixClient;
6+
import io.atomix.catalyst.transport.Address;
7+
import io.atomix.catalyst.transport.netty.NettyTransport;
8+
import io.atomix.collections.DistributedMap;
9+
10+
import java.util.Arrays;
11+
import java.util.List;
12+
13+
import org.junit.Test;
14+
15+
public class ClientExampleTest {
16+
17+
@Test
18+
public void ExampleTest() throws InterruptedException {
19+
AtomixClient client = AtomixClient.builder()
20+
.withTransport(new NettyTransport())
21+
.build();
22+
23+
List<Address> cluster = Arrays.asList(new Address("localhost", 8700), new Address("localhsot", 8701));
24+
client.connect(cluster)
25+
.thenRun(() -> System.out.println("Client Connected"));
26+
27+
Thread.sleep(5000);
28+
29+
DistributedMap<Object, Object> map = client.getMap("map")
30+
.join();
31+
32+
String value = (String) map.get("bar")
33+
.join();
34+
35+
assertEquals("Hello world!", value);
36+
}
37+
38+
}

0 commit comments

Comments
 (0)
Please sign in to comment.