Apache Ignite Sample Program Put To Cache and Get From Cache

In our previous tutorial, we had setup a multi-node ignite cluster on a windows machine. Let’s extend it with our first program involving apache ignite. In this tutorial, we will create a cache in a single server ignite cluster; add some values and retrieve it back. I’ll demonstrate this tutorial with eclipse IDE. If you are using any other IDE, you can modify some eclipse specific instructions accordingly.

Followings are used as part of this activity:

1. Launch eclipse with any workspace of your choice. In my case, the workspace is “”F:\workspace\java\ignite”.
2. In the project explorer, right click to create New -> Project … From the New Project dialog, select “Maven Project” wizard. Click Next > buton couple of times and go to the window where you need to specify Group Id, Artifact id and Package and click on Finish button. I have set the followings as the value –
   
   Maven Project Settings

   Group Id: com.iteritory.ignite Artifact Id: ignite-tutorial Package: com.iteritory.ignite.ignitetutorial

   1 2 3

   Group Id: com.iteritory.ignite Artifact Id: ignite-tutorial Package: com.iteritory.ignite.ignitetutorial

3. Next, we’ll update the pom.xml with the required dependencies. For me, it’s the exact like below –
   
   pom.xml

   <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.iteritory.ignite</groupId> <artifactId>ignite-tutorial</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging> <name>ignite-tutorial</name> <url>http://maven.apache.org</url> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> </properties> <dependencies> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>3.8.1</version> <scope>test</scope> </dependency> <dependency> <groupId>org.apache.ignite</groupId> <artifactId>ignite-core</artifactId> <version>2.0.0</version> </dependency> <dependency> <groupId>org.apache.ignite</groupId> <artifactId>ignite-spring</artifactId> <version>2.0.0</version> </dependency> </dependencies> </project>

   1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35

   <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion>   <groupId>com.iteritory.ignite</groupId> <artifactId>ignite-tutorial</artifactId> <version>0.0.1-SNAPSHOT</version> <packaging>jar</packaging>   <name>ignite-tutorial</name> <url>http://maven.apache.org</url>   <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> </properties>   <dependencies> <dependency> <groupId>junit</groupId> <artifactId>junit</artifactId> <version>3.8.1</version> <scope>test</scope> </dependency> <dependency> <groupId>org.apache.ignite</groupId> <artifactId>ignite-core</artifactId> <version>2.0.0</version> </dependency> <dependency> <groupId>org.apache.ignite</groupId> <artifactId>ignite-spring</artifactId> <version>2.0.0</version> </dependency> </dependencies> </project>

   
    
4. Next, time to write a very simple JAVA program that will join a pre-existing single node ignite server cluster as a client; it’ll create a cache, put some values and retrieve the same from cache.
5. Right click on the package “com.iteritory.ignite.ignitetutorial” in package explorer and create a new JAVA class called “FirstProgram.java”. My program looks as below –
   
   FirstProgram.java

   Java

   package com.iteritory.ignite.ignitetutorial; import org.apache.ignite.Ignite; import org.apache.ignite.IgniteCache; import org.apache.ignite.Ignition; public class FirstProgram { public static void main(String[] args) { // Set the node start mode as client; so, this node will join the apache // cluster as client Ignition.setClientMode(true); // Here, we provide the cache configuration file Ignite objIgnite = Ignition.start("F:\\apache-ignite-fabric-2.0.0-bin\\config\\itc-poc-config.xml"); // create cache if not already existing IgniteCache<Integer, String> objIgniteCache = objIgnite.getOrCreateCache("myFirstIgniteCache"); // Populating the cache with few values objIgniteCache.put(1, "salman"); objIgniteCache.put(2, "Abhishek"); objIgniteCache.put(3, "Siddharth"); objIgniteCache.put(4, "Dev"); // Get these items from cache System.out.println(objIgniteCache.get(1)); System.out.println(objIgniteCache.get(2)); System.out.println(objIgniteCache.get(3)); System.out.println(objIgniteCache.get(4)); } }

   1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32

   package com.iteritory.ignite.ignitetutorial;   import org.apache.ignite.Ignite; import org.apache.ignite.IgniteCache; import org.apache.ignite.Ignition;   public class FirstProgram { public static void main(String[] args) {   // Set the node start mode as client; so, this node will join the apache // cluster as client Ignition.setClientMode(true);   // Here, we provide the cache configuration file Ignite objIgnite = Ignition.start("F:\\apache-ignite-fabric-2.0.0-bin\\config\\itc-poc-config.xml");   // create cache if not already existing IgniteCache<Integer, String> objIgniteCache = objIgnite.getOrCreateCache("myFirstIgniteCache");   // Populating the cache with few values objIgniteCache.put(1, "salman"); objIgniteCache.put(2, "Abhishek"); objIgniteCache.put(3, "Siddharth"); objIgniteCache.put(4, "Dev");   // Get these items from cache System.out.println(objIgniteCache.get(1)); System.out.println(objIgniteCache.get(2)); System.out.println(objIgniteCache.get(3)); System.out.println(objIgniteCache.get(4)); } }

   
    
6. The package structure looks like below –
7. Next we’ll create itc-poc-config.xml; the content is as below –
   
   itc-poc-config.xml

   <?xml version="1.0" encoding="UTF-8"?> <!-- Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to You under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License. --> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd"> <bean class="org.apache.ignite.configuration.IgniteConfiguration"> <!-- Configure TCP discovery SPI to provide list of initial nodes. --> <property name="discoverySpi"> <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi"> <property name="ipFinder"> <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder"> <property name="addresses"> <list> <value>127.0.0.1:47500..47509</value> </list> </property> </bean> </property> </bean> </property> </bean> </beans>

   1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41

   <?xml version="1.0" encoding="UTF-8"?>   <!--   Licensed to the Apache Software Foundation (ASF) under one or more   contributor license agreements.  See the NOTICE file distributed with   this work for additional information regarding copyright ownership.   The ASF licenses this file to You under the Apache License, Version 2.0   (the "License"); you may not use this file except in compliance with   the License.  You may obtain a copy of the License at          http://www.apache.org/licenses/LICENSE-2.0     Unless required by applicable law or agreed to in writing, software   distributed under the License is distributed on an "AS IS" BASIS,   WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.   See the License for the specific language governing permissions and   limitations under the License. -->   <beans xmlns="http://www.springframework.org/schema/beans"        xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"        xsi:schemaLocation="        http://www.springframework.org/schema/beans        http://www.springframework.org/schema/beans/spring-beans.xsd">     <bean class="org.apache.ignite.configuration.IgniteConfiguration">         <!-- Configure TCP discovery SPI to provide list of initial nodes. -->         <property name="discoverySpi">             <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">                 <property name="ipFinder">                     <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">                         <property name="addresses">                             <list>                                 <value>127.0.0.1:47500..47509</value>                             </list>                         </property>                     </bean>                 </property>             </bean>         </property>     </bean> </beans>

   
    
8. Next, launch command prompt and change directory to %IGNITE_HOME%/bin
9. Run command –> ignite.bat F:\apache-ignite-fabric-2.0.0-bin\config\itc-poc-config.xml
10. After the server starts, we’ll see last few lines are something similar to following – 
11. Now, that server is running, we will run above JAVA program as an application from eclipse. In a while, you will see something like following – 
12.  If you analyze the result above, the JAVA program we wrote, joined the cluster as a node; hence, the client became 0 to 1. You can see the same from the server log as well. If you open the command window where we ran the ignite.bat file, you will see a new line; let’s have a look into following screenshot from the server logs –
13. The other part of the result in step 11, outputs the 4 names, we inserted into the cache from the program itself.
14. So, to conclude, this tutorial gives a basic overview of apache ignite client and server node; how a client node joins the server, how to create a simple cache in apache ignite, how to put data in apache ignite cache and how to retrieve data from cache.