Контейнеры для нефритовых агентов - PullRequest
Новая
       40

Контейнеры для нефритовых агентов

4 голосов
/ 03 февраля 2009

Может кто-нибудь сказать мне, как найти доступные контейнеры агента через код Java? Я использую среду агента JADE и выяснил, как создавать новые контейнеры, но не могу найти существующие контейнеры (чтобы в них можно было развертывать агенты).

1 Ответ

5 голосов
/ 10 декабря 2009

Есть два способа сделать это, в зависимости от того, хотите ли вы получать информацию через текущую службу или текущий снимок в сообщении.

Чтобы получить моментальный снимок идентификаторов доступных на данный момент контейнеров агентов, отправьте сообщение-запрос в Службу управления агентами (AMS) и дождитесь его ответа. Используя онтологию JADE Management и термин QueryPlatformLocationsAction , методы отправки и получения будут следующими: 

private void queryAMS() throws CodecException, OntologyException {
    QueryPlatformLocationsAction query = new QueryPlatformLocationsAction();
    Action action = new Action(myAgent.getAID(), query);

    ACLMessage message = new ACLMessage(ACLMessage.REQUEST);
    message.addReceiver(myAgent.getAMS());
    message.setLanguage(FIPANames.ContentLanguage.FIPA_SL);
    message.setOntology(JADEManagementOntology.getInstance().getName());
    myAgent.getContentManager().fillContent(message, action);
    myAgent.send(message);
}
private void listenForAMSReply() throws UngroundedException, CodecException, 
OntologyException {
    ACLMessage receivedMessage = myAgent.blockingReceive(MessageTemplate
            .MatchSender(myAgent.getAMS()));
    ContentElement content = myAgent.getContentManager().extractContent(
        receivedMessage);

    // received message is a Result object, whose Value field is a List of
    // ContainerIDs
    Result result = (Result) content;
    List listOfPlatforms = (List) result.getValue();

    // use it
    Iterator iter = listOfPlatforms.iterator();
    while (iter.hasNext()) {
        ContainerID next = (ContainerID) iter.next();
        System.out.println(next.getID());
    }
}

Чтобы получить эту информацию в качестве текущей службы и получить ContainerID каждого контейнера при регистрации в AMS, создайте поведение, расширяющее AMSSubscriber. Зарегистрируйте обработчик для события AddedContainer, и вы сможете получить доступ к ContainerID нового доступного контейнера: 

public class AMSListenerBehaviour extends AMSSubscriber {
@Override
public void installHandlers(Map handlersTable) {
    handlersTable.put(AddedContainer.NAME, addedContainerHandler);
}

public final class AddedContainerHandler implements EventHandler {
@Override
public void handle(Event ev) {
    AddedContainer event = (AddedContainer) ev;
    ContainerID addedContainer = event.getContainer();
    System.out.println(addedContainer.getID());
}

Надеюсь, это поможет,

Russ

...