Apache Ignite — вычисления в гриде04.02.2018 18:03

//Стартуем клиента
Ignition.setClientMode(true);
try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {

    //Подготовка к вычислениям, создание задач 
    //Проходим через все задания и создаем задачу на выполнение, добавляем в список
    for (final T item: list) {
        calls.add(new IgniteCallable() {
            @Override public String call() throws Exception {
                //Вот этот код будет выполняться на нодах, на разных компьютерах в сети 
                return result;
            }
        });
    }

    // Запускаем список заданий на ноды грида
    Collection res = ignite.compute().call(calls);

    // Получаем результат от каждой ноды 
    for (String hash : res) {
        System.out.println(">>> Check all nodes for output : " + result);
    }
}

                calls.add(new IgniteCallable() {
                    @Override public String call() throws Exception {
                        System.out.println();
                        System.out.println(">>> Id  transaction=#" + transaction.getId() + " on this node from ignite job.");

                        MessageDigest md = MessageDigest.getInstance("MD5");
                        String transactHash;
                         // ищем красивый хеш
                        do {
                            md.update(transaction.getDifficultyContent().getBytes());
                            byte[] digest = md.digest();
                            transactHash = DatatypeConverter.printHexBinary(digest).toUpperCase();
                            // увеличиваем сложность
                            transaction.setDifficulty(transaction.getDifficulty() + 1);
                        } while (!transactHash.contains("AAAAAAA"));

                        return transactHash;
                    }
                });

public class MyComputeCallable {
    // Данные для транзакции 
    public static final String LOREM_IPSUM = "Lorem ipsum dolor sit amet, consetetur sadipscing elitr,# " +
            "sed diam nonumy eirmod tempor invidunt ut labore et dolore magna aliquyam erat, sed diam voluptua.#" +
            "At vero eos et accusam et justo duo dolores et ea rebum.#" +
            "Stet clita kasd gubergren, no sea takimata sanctus est Lorem ipsum dolor sit amet.";

    /**
     * Executes example.
     *
     * @param args Command line arguments, none required.
     * @throws IgniteException If example execution failed.
     */
    public static void main(String[] args) throws IgniteException {
        String[] loremIpsum = LOREM_IPSUM.split("#");
        List transactionList = new ArrayList<>();
        for (int i= 0; i <= 10; i++) {
            transactionList.add(i, new Transaction(i, loremIpsum[i % 4]));
        }

        Ignition.setClientMode(true);

        try (Ignite ignite = Ignition.start("examples/config/example-ignite.xml")) {
            System.out.println();
            System.out.println(">>> Compute callable example started.");

            Collection> calls = new ArrayList<>();

            // Iterate through all words in the sentence and create callable jobs.
            for (final Transaction transaction : transactionList) {
                calls.add(new IgniteCallable() {
                    @Override public String call() throws Exception {
                        System.out.println();
                        System.out.println(">>> Id  transaction=#" + transaction.getId() + " on this node from ignite job.");

                        MessageDigest md = MessageDigest.getInstance("MD5");
                        String transactHash;
                        do {
                            md.update(transaction.getDifficultyContent().getBytes());
                            byte[] digest = md.digest();
                            transactHash = DatatypeConverter.printHexBinary(digest).toUpperCase();
                            // увилмваем сложность
                            transaction.setDifficulty(transaction.getDifficulty() + 1);
                        } while (!transactHash.contains("AAAAAAA"));

                        return transactHash;
                    }
                });
            }

            // Execute collection of callables on the ignite.
            long millis = System.currentTimeMillis();
            Collection res = ignite.compute().call(calls);

            System.out.println();
            // individual received from remote nodes.
            for (String hash : res) {
                System.out.println(">>> Check all nodes for output hash: " + hash);
            }

            System.out.println(">>> Total msec: " + (System.currentTimeMillis() - millis));
        }
    }
}
//----------------------- Transaction   ---------------------------------
public class Transaction {
    private int difficulty;
    private int id;
    private String content;

    public Transaction(int id, String content) {
        this.id = id;
        this.content = content;
    }

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public int getDifficulty() {
        return difficulty;
    }

    public void setDifficulty(int difficulty) {
        this.difficulty = difficulty;
    }

    public String getContent() {
        return content;
    }

    public void setContent(String content) {
        this.content = content;
    }

    public String getDifficultyContent() {
        return "" + difficulty + content;
    }

}