ignite中的消息使用实例

package test.ignite.broadcast;

import java.util.UUID;

import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteMessaging;
import org.apache.ignite.Ignition;
import org.apache.ignite.lang.IgniteBiPredicate;

public class Receiver {
    public static void main(String[] args) {
        System.out.println("======================================================");
        Ignite ignite = Ignition.start("ignite.xml");
        IgniteMessaging msg = ignite.message();
        msg.localListen("aaa", new IgniteBiPredicate<UUID, Integer>() {
            @Override
            public boolean apply(UUID nodeId, Integer funId) {
                System.out.println(funId);
                return true; 
            }
        });
        
    }

}

package test.ignite.broadcast;

import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.Lock;

import org.apache.ignite.Ignite;
import org.apache.ignite.IgniteCache;
import org.apache.ignite.IgniteMessaging;
import org.apache.ignite.Ignition;
import org.apache.ignite.configuration.CacheConfiguration;
import org.apache.ignite.transactions.Transaction;

public class Sender {
    public static void main(String[] args) {
        Ignition.setClientMode(true);
        Ignite ignite = Ignition.start("ignite.xml");
        IgniteMessaging msg = ignite.message();
        msg.sendOrdered("aaa", 100,0);
    }

}