Начнем с того что же такое грид.

www.gridclub.ru/about:

Грид – географически распределенная инфраструктура, объединяющая множество ресурсов разных типов (проц… ессоры, долговременная и оперативная память, хранилища и базы данных, сети), доступ к которым пользователь может получить из любой точки, независимо от места их расположения. Грид предполагает коллективный разделяемый режим доступа к ресурсам и к связанным с ними услугам в рамках глобально распределенных виртуальных организаций, состоящих из предприятий и отдельных специалистов, совместно использующих общие ресурсы. В каждой виртуальной организации имеется своя собственная политика поведения ее участников, которые должны соблюдать установленные правила. Виртуальная организация может образовываться динамически и иметь ограниченное время существования.

Другими словами грид — это технология позволяющая из множества мало мощных компьютеров программным путем сделать много функциональный и мощный сервер или другую желаемую вычислительную систему.

Историческая справка:

Алгоритм шифрования данных (DES) был взломан с помощью огромной сети, состоящей из десятков тысяч компьютеров через 39 дней. Компьютер который подобрал нужный ключ был мощностью 90 мегагерц с 16мб оперативной памяти.

На сегодняшний день грид технологии имеют бурное развитие, так например в Церне (создатели большого адронного коллаидера) используется данная технология для обработки данных с датчиков, с которых скорость поступления данных ~700мб/сек.

На рынке представлено множество решений для написания программ поддерживающий данную концепцию, но хотелось бы остановиться на программном продукте GridGain. Плюсы гридгейна это бесплатность, открытый код, кросплатформеность, Питерская команда разработчиков (хоть и не ориентированна на русских разработчиков, да и как таковой российский рынок IT). Вот как они позиционируют сами себя:

GridGian:

GridGain – это вычислительный грид уровня предприятия, предназначенный для решения проблем организации вычислительных ресурсов, с целью их более полного использования и, как следствие, повышения эффективности всей системы в целом. За этой, на первый взгляд, «мудреной» фразой скрывается простой и дружественный продукт для распараллеливания различных вычислений. Причем продукт, изначально ориентированный для использования в бизнес приложениях с минимальным их изменением.

И так у GridGain не плохая архитектура с помощью которой его конфигурация представляется наиболее просто.

В данной схеме представлены все возможности по кофигурированию. GridGain можно настроить для работы в локальной сети, в определенном диапазоне айпи адресов, в интернете, т.е. фактически для любых нужд. Конфигурация грида выполняется посредством Spring файла. GridGain поставляется в набором готовых конфигурационных файлов которые могут быть найдены в каталоге [GRIDGAIN_HOME]/config.

Итак как же можно выполнить наш код на гриде? GridGain предоставляет три различных способа выполнения нашего кода на риде:
1. Аннотация Gridify.
2. Executor service.
3. Пользовательские задачи и подзадачи.

Пример кода с @Gridify:
public final class GridifyHelloWorldBasicExample {<br /> @Gridify<br /> private static int sayIt(String phrase) {<br /> System.out.println(«Hello World.»);<br /> return null;<br /> }<br /> public static void main(String[] args) throws GridException {<br /> GridFactory.start();<br /> try {<br /> // This method will be executed on a remote grid node.<br /> sayIt(«Hello World»);<br /> }<br /> finally {<br /> GridFactory.stop(true);<br /> }<br /> }<br />}

Но для обработки этой аннотации необходимо использовать какой либо framework,
поддерживающий аспектное программирование. И GridGain поддерживает и поставляет
конфигурацию для AspectJ, Jboss и Spring.
Например для использования AspectJ вам необходимо включить в пути классов каталог
[GRIDGAIN_HOME]/config/aop/aspectj
и добавить в строку запуска AOP агента:
-javaagent:[GRIDGAIN_HOME]/libs/aspectjweaver-1.5.3.jar

Пример кода с GridGain executor service:
public final class GridSpringBeanHelloWorldExample {<br /> public static void main(String[] args) throws Exception {<br /> AbstractApplicationContext ctx = new ClassPathXmlApplicationContext(<br /> «org/gridgain/examples/helloworld/spring/spring.xml»);<br /> // Get Grid from Spring.<br /> Grid grid = (Grid)ctx.getBean(«mySpringBean»);<br /> ExecutorService exec = grid.newGridExecutorService();<br /> Future<string> res = exec.submit(new GridHelloWorldCallable());<br /> // Wait for callable completion.<br /> res.get();<br /> ctx.destroy();<br /> }<br /> private static final class GridHelloWorldCallable<br /> implements Callable<string>, Serializable {<br /> public String call() {<br /> System.out.println(«Hello world.»);<br /> return null;<br /> }<br /> }<br />}</string></string>

Как видно из примера GridGain нода была получена из Spring файла и у нее спользован
executor service.
Вот сам Spring file:
<?xml version="1.0" encoding="UTF-8"?><br /> <beans><br /> <description>Main Spring file for grid configuration.</description><br /> <bean class="org.gridgain.grid.GridSpringBean" id="mySpringBean" scope="singleton"></bean><br /> </beans>
В данном случае нода использует конфигурацию по умолчанию.

Наиболее интересный и гибкий способ это «Пользовательские задачи и подзадачи». Суть данного способа это разбиение всей задачи на два класса GridTask и GridJob, в GridTask задача разбивается на нужное множество подзадач, которые будут распределены на найдены ноды, а в GridJob описывается сама задача которую нужно выполнить.
Пример с GridTask и GridJob решает задачу нахождения числа Pi с помощью метода Монте-Карло.

MainMonteGrid.java
<br />import org.gridgain.grid.Grid;<br />import org.gridgain.grid.GridException;<br />import org.gridgain.grid.GridTaskFuture;</p> <p>public class MainMonteGrid {<br /> public static void main(String[] args) throws GridException {</p> <p> if (args.length == 0) { <br /> GridFactory.start();<br /> }<br /> else {<br /> GridFactory.start(args[0]);<br /> }</p> <p> try {<br /> Grid grid = GridFactory.getGrid();</p> <p> long time = System.currentTimeMillis();</p> <p> GridTaskFuture<double> future = grid.execute(GridMonteTask.class, 1000000000);</p> <p> // Wait for task completion.<br /> double Pi = future.get();</p> <p> time = System.currentTimeMillis() — time;</p> <p> System.out.println(«>>>»);<br /> System.out.println(«>>> Finished executing Grid Pi = » + Pi + «; time = » + time + «;»);<br /> System.out.println(«>>>»);</p> <p> }<br /> finally {<br /> GridFactory.stop(true);<br /> }</p> <p> } <br />}</double>

GridMonteTask.java
mport org.gridgain.grid.*;<br />import org.gridgain.grid.logger.GridLogger;<br />import org.gridgain.grid.resources.GridLoggerResource;</p> <p>import java.util.*;</p> <p>public class GridMonteTask extends GridTaskSplitAdapter<integer, double=""> {<br /> /** Auto-injected grid logger. */<br /> @GridLoggerResource<br /> private GridLogger log = null;<br /> private int gridSize;<br /> private long iteration;</p> <p> @Override<br /> public Collection<? extends GridJob> split(int gridSize, Integer iteration) throws GridException { </p> <p> this.gridSize = gridSize;<br /> this.iteration = iteration;<br /> List<gridjob> jobs = new ArrayList<gridjob>(); <br /> for(int i = 1; i <= gridSize; i++) {<br /> jobs.add(new GridMontedJob(this.iteration)); <br /> }<br /> return jobs;<br /> }</p> <p> /**<br /> * @param results Job results.<br /> * @return Pi passed into <br /> * <tt>split(gridSize, iteration)</tt> method above.<br /> * @throws GridException If reduce failed.<br /> */<br /> public Double reduce(List<gridjobresult> results) throws GridException {<br /> double total = 0; <br /> int circle = 0;</p> <p> for (GridJobResult res : results) {<br /> circle = circle + (Integer)res.getData();<br /> } </p> <p> total = (circle / (double)this.gridSize);<br /> total = (total / (double)this.iteration) * 4;</p> <p> return total;<br /> }<br />}</gridjobresult></gridjob></gridjob></integer,>

GridMontedJob.java
import java.io.Serializable;<br />import java.util.Random;</p> <p>import org.gridgain.grid.GridException;<br />import org.gridgain.grid.GridJob;</p> <p>public class GridMontedJob implements GridJob {</p> <p> private long iteration; </p> <p> public GridMontedJob(long iteration) { <br /> this.iteration = iteration;<br /> }</p> <p> public void cancel() {<br /> // TODO Автоматически созданная заглушка метода</p> <p> }</p> <p> public Serializable execute() throws GridException {<br /> Random ran = new Random();<br /> int circle = 0;</p> <p> for(long i = 0; i < iteration; i++)<br /> {<br /> double tmpx = ran.nextDouble();<br /> double tmpy = ran.nextDouble();<br /> if((tmpx*tmpx + tmpy*tmpy) <= 1)<br /> {<br /> circle++;<br /> }<br /> } <br /> return circle; <br /> }</p> <p>}

На моей Ubuntu OS с jdk 1.6.0_07 была замечена бага с работай функции System.getProperties(), которая не хотела возвращать переменные ОС в следствии чего не возможно было запускать программу, пришлось переписовать класс GridFactory и указывать в нем в явном виде домашнюю директорию с GridGain.

Источники.
GridGain
Число пи
Грид концепция

программирование
грид
java
grid