JADE提供了in-process接口来提供给外部应用程序对Agent的调用。在JADE提供的Runtime类中， 我们可以通过jade.core.Runtime.instance()来获得JADE运行时的一个单独的实例。Runtime类提供了两种方法来创建容器：
- createMainContainer(Profile p) 在当前JVM中创建一个新的主容器，以提供通过代理对象的访问。
- createAgentContainer(Profile p) 在当前JVM中创建一个新的代理容器，以提供通过代理对象的访问。
两个方法都需要一个Profile文件对象作为参数，用于配置运行时所需要的参数包括主机和端口， 返回 AgentContainer类型。
简单示例
先创建一个需要调用的CustomAgent
package cn.bcrab.agent;
import jade.core.Agent;
import jade.core.behaviours.SimpleBehaviour;
public class CustomAgent extends Agent{
@Override
protected void setup() {
SimpleBehaviour sb = new SimpleBehaviour() {
boolean done = false;
@Override
public void action() {
System.out.println("CustomAgent : hello world!");
System.out.println("----- INFO-----");
System.out.println("My local name: " + getLocalName());
System.out.println("My unique name :" + getName());
System.out.println("My AID is :"+getAID());
done = true;
}
@Override
public boolean done() {
return done;
}
};
this.addBehaviour(sb);
}
}
再建立外部调用类：
package cn.bcrab;
/**
* Hello world!
*
*/
import jade.core.Profile;
import jade.core.ProfileImpl;
import jade.core.Runtime;
import jade.wrapper.AgentContainer;
import jade.wrapper.AgentController;
import jade.wrapper.StaleProxyException;
public class App
{
public static void main( String[] args )
{
try {
System.out.println( "Hello World!" );
Runtime rt = Runtime.instance();
rt.setCloseVM(true);
Profile profileMain = new ProfileImpl(null, 8888, null);
System.out.println("System is launching a whole in-process platform... " + profileMain);
AgentContainer ac = rt.createMainContainer(profileMain);
Profile profileContainer = new ProfileImpl(null, 8888, null);
System.out.println("System is launching a whole in-process platform... " + profileContainer);
AgentController custom = ac.createNewAgent("custom", "cn.bcrab.agent.CustomAgent", null);
custom.start();
} catch (StaleProxyException e) {
e.printStackTrace();
}
}
}
然后直接用Java Application方式运行这个 App.java。
运行效果如下：
System is launching a whole in-process platform... {port=8888, main=true}
CustomAgent : hello world!
----- INFO-----
My local name: custom
My unique name :custom@192.168.0.107:8888/JADE
My AID is :( agent-identifier :name custom@192.168.0.107:8888/JADE :addresses)
由此可以见，外部调用 CustomAgent是成功的。
再看一个例子，由一个Agent去启动另一个Agent。
大致步骤如下：
- 由于是通过Agent去启动，不需要新建一个容器
- 直接通过 getContainerController() 获取容器
- 通过createNewAgent()方法创建一个AgentController类并且将其启动
- 调用另一个类
package cn.bcrab.agent;
import jade.core.AID;
import jade.core.Agent;
import jade.core.behaviours.SimpleBehaviour;
import jade.lang.acl.ACLMessage;
import jade.wrapper.AgentContainer;
import jade.wrapper.AgentController;
import jade.wrapper.StaleProxyException;
public class BuildAgent extends Agent {
@Override
protected void setup() {
try {
AgentContainer container = getContainerController();
AgentController ac = container.createNewAgent("custom","cn.bcrab.agent.CustomAgent",null);
ac.start();
System.out.println("Build the custom agent from cn.bcrab.agent.CustomAgent");
} catch (StaleProxyException e) {
e.printStackTrace();
}
}
}
运行结果：
Build the custom agent from cn.bcrab.agent.CustomAgent
CustomAgent : hello world!
----- INFO-----
My local name: custom
My unique name :custom@Platform
My AID is :( agent-identifier :name custom@Platform :addresses )
Agent的O2A通信机制
我们往往会将Agent实例封装起来，提供给外部去调用，这样可以提高程序的安全性和可靠性。但许多情况下，外部程序除了启动Agent以外，还需要与Agent进行交互，以通知他们完成一些任务。如，图书管系统中，我们需要将图书的信息通过外部调用的方式传给Agent，从而让借阅者进行下一步的动作。这就需要用到Object-to-Object(O2A)通讯机制，它允许外部应用程序和Agent之间进行交互。
这种机制本质是一个同步的FIFO队列，每个Agent都有一个O2A对了，外部应用程序可以将Agent中抽象的Java对象放到这个队列中。
封装Agent的AgentController对象提供了putO2AObject()方法，外部程序调用该方法将Java对象插入O2A队列。Agent中首先通过调用setEnabledO2ACommunication()方法声明允许O2A通讯机制，再通过getO2AObject()方法接收对象。
我们再通过最简单的例子来看看。
首先定义一个Book类
package cn.bcrab;
public class Book {
public String name;
public double price;
public String getName() {
return name;
}
public double getPrice() {
return price;
}
}
创建一个 O2OAgent
package cn.bcrab.agent;
import cn.bcrab.Book;
import jade.core.Agent;
import jade.core.behaviours.Behaviour;
public class O2OAgent extends Agent {
@Override
protected void setup() {
setEnabledO2ACommunication(true,5);
addBehaviour(new Behaviour() {
@Override
public void action() {
Book book = (Book) myAgent.getO2AObject();
if(book != null){
System.out.println("-------------------O2OAgent----------------------------");
System.out.println("Book name: "+ book.getName() + " Price: " + book.getPrice());
System.out.println("-------------------O2OAgent----------------------------");
myAgent.doDelete();
}
}
@Override
public boolean done() {
return false;
}
});
}
}
外部调用程序：
package cn.bcrab.agent;
import jade.core.Profile;
import jade.core.ProfileImpl;
import jade.core.Runtime;
import jade.wrapper.AgentContainer;
import jade.wrapper.AgentController;
import jade.wrapper.StaleProxyException;
import cn.bcrab.Book;
public class O2ODemo {
public static void main(String[] args) {
Runtime rt = Runtime.instance();
Profile p = new ProfileImpl(null, 8889, null);
System.out.println(p);
AgentContainer ac = rt.createMainContainer(p);
try {
AgentController controller = ac.createNewAgent("O2OAgent","cn.bcrab.agent.O2OAgent",null);
controller.start();
Book book = new Book("程序员的自我修养", 108.88);
controller.putO2AObject(book,true);
} catch (StaleProxyException e) {
e.printStackTrace();
}
}
}
运行结果：
-------------------O2OAgent----------------------------
Book name: 程序员的自我修养 Price: 108.88
-------------------O2OAgent----------------------------
网友评论