使用MPJ express发送对象

Question

我是并行编程的新手，我想用java来做。我想知道是否有可能通过MPI发送和接收更复杂的对象。我用的是MPJ express。然而，每当我想发送一个对象时，我就会得到一个ClassCastException。

MPI.Init(args);
myrank = MPI.COMM_WORLD.Rank();
numprocs = MPI.COMM_WORLD.Size();
Vector<CustomClass> chr = new Vector<CustomClass>();
if (myrank == 0 ) { //am I the master?
    for (int i = 1; i < numprocs; i++) {
      MPI.COMM_WORLD.Send(chr, 0, chr.size(), MPI.OBJECT, i, 99); //Here's where the 
                                                                  exception occurs
    }
}
else {             
    Vector<BasicRegion> chr_received = new Vector<BasicRegion>();
    MPI.COMM_WORLD.Recv(chr_received, 0, 1, MPI.OBJECT, 0, 99 );
}

异常:

mpi。MPIException: mpi。MPIException: java.lang.ClassCastException: java.util.Vector不能强制转换为[Ljava.lang.Object;

]

我的问题是:MPJ Express能发送/接收更复杂的对象吗?-如果是这样:我做错了什么?

Answer 1

我对MPJ表达也是陌生的，但似乎封闭对象需要是原始类型-数组的东西。(就像你在OpenMPI中使用C/c++实现一样)。

这种代码对我来说很有效:

    Node t[] = new Node[4];
        ...
        count[0] = t.length;
        MPI.COMM_WORLD.Send(count, 0, 1, MPI.INT, 1, 98);
        MPI.COMM_WORLD.Send(t, 0, t.length, MPI.OBJECT, 1, 99);
    } else if( myRank == 1 ) {
        int count[] = new int[1];
        MPI.COMM_WORLD.Recv( count, 0, 1, MPI.INT, 0, 98);
        Status mps = MPI.COMM_WORLD.Recv( t, 0, count[0], MPI.OBJECT, 0, 99 );
        ...

当然，你必须有实现Serializable接口的自定义类

Answer 2

您希望在发送之前序列化它。

import mpi.*;
import java.io.*;
import java.nio.ByteBuffer;
public class MPITest
{
    public static void main(String[] args)
    {
        MPI.Init(args);
        int me = MPI.COMM_WORLD.Rank();
        int tasks = MPI.COMM_WORLD.Size();
        MPI.COMM_WORLD.Barrier();
        if(me == 0)
        {
            Cat cat = new Cat("Tom", 15);
            cat.Speak();
            ByteBuffer byteBuff = ByteBuffer.allocateDirect(2000 + MPI.SEND_OVERHEAD);
            MPI.Buffer_attach(byteBuff);
            try
            {
                ByteArrayOutputStream bos = new ByteArrayOutputStream();
                ObjectOutput out = null;
                out = new ObjectOutputStream(bos);
                out.writeObject(cat);
                byte[] bytes = bos.toByteArray();
                System.out.println("Serialized to " + bytes.length);
                MPI.COMM_WORLD.Isend(bytes, 0, bytes.length, MPI.BYTE, 1, 0);
            }
            catch(IOException ex)
            {
            }
        }
        else
        {
            byte[] bytes = new byte[2000];
            Cat recv = null;
            MPI.COMM_WORLD.Recv(bytes, 0, 2000, MPI.BYTE, MPI.ANY_SOURCE, 0);
            ByteArrayInputStream bis = new ByteArrayInputStream(bytes);
            ObjectInput in = null;
            try
            {
                in = new ObjectInputStream(bis);
                Object obj = in.readObject();
                recv = (Cat)obj;
                recv.Speak();
            }
            catch(IOException ex)
            {
            }
            catch(ClassNotFoundException cnf)
            {
            }
        }
        MPI.COMM_WORLD.Barrier();
        MPI.Finalize();
    }
} 

这可以工作，但是你可能想使用Externalization并手动执行，以避免序列化例程将发送的一些额外的垃圾。

HTH布莱恩

Answer 3

import mpi.*;
/**
 * Compile: javac -cp $MPJ_HOME/lib/mpj.jar:. ObjSend.java 
 * Execute: mpjrun.sh -np 2 -dport 11000 ObjSend
 */
public class ObjSend {
    public static void main(String[] args) throws Exception {
        int peer ; 
        MPI.Init(args);
        int rank = MPI.COMM_WORLD.Rank() ;
        int size = MPI.COMM_WORLD.Size() ; 
        int tag = 100 ; 
        if(rank == 0) {
            String [] smsg = new String[1] ; 
            smsg[0] = "Hi from proc 0" ; 
            peer = 1 ; 
            MPI.COMM_WORLD.Send(smsg, 0, smsg.length, MPI.OBJECT, 
                                                        peer, tag);
            System.out.println("proc <"+rank+"> sent a msg to "+
                               "proc <"+peer+">") ; 
        } else if(rank == 1) {
            String[] rmsg = new String[1] ; 
            peer = 0 ; 
            MPI.COMM_WORLD.Recv(rmsg, 0, rmsg.length , MPI.OBJECT, 
                                                         peer, tag);
            System.out.println("proc <"+rank+"> received a msg from "+
                               "proc <"+peer+">") ; 
            System.out.println("proc <"+rank+"> received the following "+
                               "message: ""+rmsg[0]+""") ; 
        } 
        MPI.Finalize();
    }   
}