java - JADE 平台通讯

Question

基本上我正在尝试与这里询问的相同的事情:Passing ACL messages between jade remote platforms

我有两个程序分别创建两个主容器和一个代理。我在不同的机器上运行这两个程序，并希望将一条消息从一个代理发送到另一个代理。上面链接的问题中建议的答案对我不起作用。接收方总是抛出 java.lang.OutOfMemoryError 并且发送方显示:

jade.mtp.MTPException: Description: ResponseMessage is not OK

如果两个代理在不同机器上的不同代理容器中运行但在同一个主容器中运行，则发送消息是可行的，但这不是我试图实现的。希望你能帮助我。

代码

发件人:

public class Main {

public static void main(String[] args) {

    Runtime runtime = Runtime.instance();

    Profile p = new ProfileImpl();
    p.setParameter(Profile.MAIN_HOST, "172.16.200.100");
    p.setParameter(Profile.MAIN_PORT, "1337");
    p.setParameter(Profile.CONTAINER_NAME,"Reality");

    AgentContainer agentContainer = runtime.createMainContainer(p);

    try {
        AgentController ac = agentContainer.createNewAgent("hitman",Agent47.class.getName(),null);
        ac.start();
        } catch (StaleProxyException e) {e.printStackTrace();}
    }
}

public class Agent47 extends Agent {

    private static final long serialVersionUID = 1L;

    @Override
    protected void setup() {

        ACLMessage msg = new ACLMessage(ACLMessage.INFORM); 
        AID dest = new AID("AgentSmith@Matrix",AID.ISGUID);
        dest.addAddresses("http://172.16.200.1:4242/acc");
        msg.addReceiver(dest);
        msg.setContent("Hello!");
        send(msg);
    }
}

接收方:

public class Main {

    public static void main(String[] args) {
        Runtime runtime = Runtime.instance();

        Profile p = new ProfileImpl();              
        p.setParameter(Profile.MAIN_HOST, "172.16.200.1");
        p.setParameter(Profile.MAIN_PORT, "4242");
        p.setParameter(Profile.CONTAINER_NAME,"Matrix"); 

        AgentContainer agentContainer = runtime.createMainContainer(p);

        try {
            AgentController ac = agentContainer.createNewAgent("AgentSmith",AgentSmith.class.getName(),null);
            ac.start();
        } catch (StaleProxyException e) {e.printStackTrace();}
    }
}

public class AgentSmith extends Agent {

    private static final long serialVersionUID = 1L;

    @Override
    protected void setup() {

        addBehaviour(new CyclicBehaviour(this){

            private static final long serialVersionUID = 1L;

            public void action() {
                 ACLMessage  msg = myAgent.receive();
                    if(msg != null){

                            String content = msg.getContent();
                            if (content != null) {
                                System.out.println("Received Request from "+msg.getSender().getLocalName());
                                System.out.println("Received Message : "+content);
                            }

                        }  
             }
        });

        System.out.println("Setup done!");
    }

}

Answer 1

解决了一些问题。如果其他人有同样的问题，这里是我的解决方案:我必须设置平台 IP 以及 MTP 主机的 IP。

String host = "172.16.200.100"; // Platform IP
int port = 1099; // default-port 1099

String MTP_hostIP = "172.16.200.100"; 
String MTP_Port = "7778";

Runtime runtime = Runtime.instance();

Profile profile = new ProfileImpl(host, port, null, true);  
profile.setParameter(Profile.MTPS, "jade.mtp.http.MessageTransportProtocol(http://"+MTP_hostIP+":"+MTP_Port+"/acc)");

// create container
AgentContainer container = runtime.createMainContainer(profile);

try {
    AgentController ac = container.createNewAgent("AgentSmith",AgentSmith.class.getName(),null);
    ac.start();
} catch (StaleProxyException e) {
    e.printStackTrace();
}

事实证明，如果我使用 localhost 作为主机 IP 和网络 IP 作为 MTP 主机，通信将无法在我的 B 类中正常工作网络。将两个变量设置为相同的 IP 解决了这个问题。