kamalcph/CalcService.java

## CalcService.java
package my.apache.ignite.examples.servicegrid;

import org.apache.ignite.services.Service;

public interface CalcService extends Service {

	int add(int a, int b);
	int sub(int a, int b);
}

## CalcServiceImpl.java
package my.apache.ignite.examples.servicegrid;

import java.util.concurrent.TimeUnit;

import org.apache.ignite.services.ServiceContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class CalcServiceImpl implements CalcService {

	private static final long serialVersionUID = 1L;
	private final Logger logger = LoggerFactory.getLogger(CalcServiceImpl.class);

	public CalcServiceImpl() {
		logger.info("CalcServiceImpl instantiated");
	}

	@Override
	public void cancel(ServiceContext ctx) {
		logger.info("Service : {} cancelled", ctx.name());
	}

	@Override
	public void init(ServiceContext ctx) throws Exception {
		logger.info(">>> Service : initing..", ctx.name());
		Thread.sleep(TimeUnit.MINUTES.toMillis(1));
		logger.info("Service : {} inited", ctx.name());
	}

	@Override
	public void execute(ServiceContext ctx) throws Exception {
		logger.info("Service : {} executed", ctx.name());
	}

	@Override
	public int add(int a, int b) {
		return a+b;
	}

	@Override
	public int sub(int a, int b) {
		return a-b;
	}

}

## ServiceDeployer.java
package my.apache.ignite.examples.servicegrid;

import java.io.IOException;

import org.apache.ignite.Ignite;
import org.apache.ignite.Ignition;

public class ServiceDeployer {

	public static final String calcService = "CalcService";

	public ServiceDeployer() {
	}

	public static void main(String[] args) throws InterruptedException, IOException {

		Ignite ignite = Ignition.start("examples/config/example-ignite.xml");

		CalcService calculator = new CalcServiceImpl();
		ignite.services().deployNodeSingleton(calcService, calculator);

		Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {

			@Override
			public void run() {
				System.out.println(">>> Stopping the node");
				Ignition.stop(true);
			}
		}));
	}

}

## ServiceUser.java
import org.apache.ignite.Ignite;
import org.apache.ignite.Ignition;

public class ServiceUser {

	public ServiceUser() {
	}

	public static void main(String[] args) throws InterruptedException {

		Ignition.setClientMode(true);
		final Ignite ignite = Ignition.start("examples/config/example-ignite.xml");

		CalcService calculator = ignite.services().serviceProxy(ServiceDeployer.calcService, CalcService.class, false);

		int i = 0;
		while (true) {
			System.out.println(i++ + ". 2 + 2 = " + calculator.add(2, 2));
			Thread.sleep(100);
		}
	}
}
	package my.apache.ignite.examples.servicegrid;

	import org.apache.ignite.services.Service;

	public interface CalcService extends Service {

	int add(int a, int b);
	int sub(int a, int b);
	}
	package my.apache.ignite.examples.servicegrid;

	import java.util.concurrent.TimeUnit;

	import org.apache.ignite.services.ServiceContext;
	import org.slf4j.Logger;
	import org.slf4j.LoggerFactory;

	public class CalcServiceImpl implements CalcService {

	private static final long serialVersionUID = 1L;
	private final Logger logger = LoggerFactory.getLogger(CalcServiceImpl.class);

	public CalcServiceImpl() {
	logger.info("CalcServiceImpl instantiated");
	}

	@Override
	public void cancel(ServiceContext ctx) {
	logger.info("Service : {} cancelled", ctx.name());
	}

	@Override
	public void init(ServiceContext ctx) throws Exception {
	logger.info(">>> Service : initing..", ctx.name());
	Thread.sleep(TimeUnit.MINUTES.toMillis(1));
	logger.info("Service : {} inited", ctx.name());
	}

	@Override
	public void execute(ServiceContext ctx) throws Exception {
	logger.info("Service : {} executed", ctx.name());
	}

	@Override
	public int add(int a, int b) {
	return a+b;
	}

	@Override
	public int sub(int a, int b) {
	return a-b;
	}

	}
	package my.apache.ignite.examples.servicegrid;

	import java.io.IOException;

	import org.apache.ignite.Ignite;
	import org.apache.ignite.Ignition;

	public class ServiceDeployer {

	public static final String calcService = "CalcService";

	public ServiceDeployer() {
	}

	public static void main(String[] args) throws InterruptedException, IOException {

	Ignite ignite = Ignition.start("examples/config/example-ignite.xml");

	CalcService calculator = new CalcServiceImpl();
	ignite.services().deployNodeSingleton(calcService, calculator);

	Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {

	@Override
	public void run() {
	System.out.println(">>> Stopping the node");
	Ignition.stop(true);
	}
	}));
	}

	}
	import org.apache.ignite.Ignite;
	import org.apache.ignite.Ignition;

	public class ServiceUser {

	public ServiceUser() {
	}

	public static void main(String[] args) throws InterruptedException {

	Ignition.setClientMode(true);
	final Ignite ignite = Ignition.start("examples/config/example-ignite.xml");

	CalcService calculator = ignite.services().serviceProxy(ServiceDeployer.calcService, CalcService.class, false);

	int i = 0;
	while (true) {
	System.out.println(i++ + ". 2 + 2 = " + calculator.add(2, 2));
	Thread.sleep(100);
	}
	}
	}