Questo documento vuole essere una guida pratica alla costruzione di agenti mobili per SOMA (Secure and Open Mobile Agent programming framework), il sistema ad agenti mobili messo a disposizione dal Dipartimento di Elettronica, Informatica e Sistemistica (DEIS) della Università di Bologna.

Questa guida, che ripercorre il sentiero da me personalmente seguito nell'imparare a scrivere agenti mobili per SOMA, si limita a trattare alcuni temi basilari riguardanti il sistema e gli agenti costruiti per vivere in esso: la creazione di agenti; la migrazione di agenti da un place all'altro; l'interazione degli agenti con il sistema e l'ambiente sottostante da un lato, e con l'utente dall'altro; l'uso dei meccanismi di comunicazione e coordinamento messi a disposizione dal sistema; lo sfruttamento della libreria grafica per dotare gli agenti di una GUI. Esula dagli scopi di questa guida spiegare le tematiche più avanzate di SOMA, quali sicurezza, Quality of Service (QoS), internazionalizzazione delle interfacce, e tutti quei temi che tendono verso il livello applicativo. Lo scopo di questa guida consiste nello spiegare come sfruttare i meccanismi primitivi messi a disposizione da SOMA, ed essa è caratterizzata dall'avvalersi soprattutto del codice di alcuni agenti di esempio per portare a termine il suo compito.

Ad ottobre 2002, infatti, le principali fonti di informazione su SOMA si dividono in due categorie: da un lato, troviamo le tesi di laurea, che spiegano soprattutto i concetti e le astrazioni che hanno trovato concretizzazione ed implementazione in SOMA, senza però soffermarsi troppo su come effettivamente scrivere codice per costruire agenti mobili che vivano nel sistema; dall'altro, troviamo il codice dei progetti per l'esame di Reti di Calcolatori, il codice degli agenti allegati alla distribuzione di SOMA, e il codice di SOMA stesso, fonti ultime per comprendere la realizzazione concreta di entità mobili per il sistema, ma spesso troppo poco commentate, slegate dai concetti, e nelle quali il codice relativo alle applicazioni ad agenti si confonde con il codice relativo alle funzionalità primitive messe a disposizione da SOMA. Questa guida vuole essere un primo timido passo verso l'incontro e la fusione delle due categorie appena illustrate: la speranza è quella di semplificare la vita agli studenti che vogliono utilizzare SOMA nei loro progetti, cercando di rendere almeno inizialmente più dolce la finora ripida curva di apprendimento del sistema, così che più persone possano utilizzare, supportare e contribuire al progetto di ricerca portato avanti dalla nostra Università.

Questa guida presuppone la lettura di alcuni documenti, riportati in bibliografia, atti a spiegare le logiche di progettazione ed i meccanismi messi a disposizione da SOMA. Si suppone inoltre che il lettore sia a conoscenza della teoria riguardante il paradigma ad agenti mobili.

import SOMA.agent.*;

/**
 * Just a try to build an agent and let it say a shakespearian quotation.
 *
 * @author	Giulio Piancastelli
 * @version	1.0 - Sunday 10th February, 2002
 */
public class TryAgent extends Agent {
	
	public void run() {
		
		agentSystem.getOut().println("Lord, what fools these mortals be\n");
	
	}
	
} // end TryAgent

/**
 * @serial
 * Metodo che verra' eseguito alla prossima attivazione dell'agente.
 */
public String start = "run";

public PlaceID getPlaceID()
public Environment getEnvironment();

public InputStream getIn() {
	return getEnvironment().in;
}

public PrintStream getOut() {
	return getEnvironment().out;
}

public PrintStream getErr() {
	return getEnvironment().err;
}


/**
 * Restituisce l'elenco degli identificatori dei place di questo dominio.
 */
public PlaceID[] getPlaces();

/**
 * Restituisce l'elenco degli identificatori dei domini, o
 * un array vuoto se non e' presente un Domain Name Service, perche'
 * non siamo in un default place.
 */
public PlaceID[] getDomains();

/**
 * Restituisce il numero di worker e quindi di agenti del place.
 */
public int agentsNumber()

Figura 1. Un agente di prova al lavoro.

import SOMA.agent.*;
import SOMA.naming.*;
import SOMA.naming.domain.*;

import java.util.*;

/**
 * A try to interact with the Environment and the Domain Name Service.
 *
 * @author	Giulio Piancastelli
 * @version	1.0 - Sunday 10th February, 2002
 */
public class EnvAgent extends Agent {
	
	private Vector placesToVisit = new Vector();
	
	public void run() {
		
		PlaceID home = agentSystem.getPlaceID();
		
		if (home.isDomain()) {
			// Get children domains
			DomainNameService dns = agentSystem.getEnvironment().domainNameService;
			Vector children = dns.getChildrenDNS(); // a Vector of PlaceIDs
			for (int index = children.size() - 1; index >= 0; index--) {
				PlaceID place = (PlaceID) children.get(index);
				placesToVisit.add(place);
			}
			// Get places in this domain
			Vector places = new Vector(Arrays.asList(agentSystem.getPlaces()));
			places.remove(home);
			for (int index = places.size() - 1; index >= 0; index--) {
				PlaceID place = (PlaceID) places.get(index);
				placesToVisit.add(place);
			}
		} else
			placesToVisit.add(home);
		
		// Print results
		for (int index = placesToVisit.size() - 1; index >= 0; index--) {
			PlaceID place = (PlaceID) placesToVisit.get(index);
			agentSystem.getOut().println(place);
		}	
		
	}
	
} // end EnvAgent

public void go(PlaceID destination, String method)

import SOMA.agent.*;
import SOMA.naming.*;
import SOMA.naming.domain.*;

import java.util.*;

/**
 * A try to move an agent around the system.
 *
 * @author	Giulio Piancastelli
 * @version	1.0 - Monday 11th February, 2002
 */
public class RegionTourAgent extends Agent {
	
	// Serializable members
	private Vector placesToVisit = new Vector();
	
	public void run() {
		
		list();
		
		// Move agent on the other domains or places just listed
		if (placesToVisit.size() > 0) {
			PlaceID placeToGo = (PlaceID) placesToVisit.get(0);
			placesToVisit.remove(placeToGo);
			try {
				go(placeToGo, "run");
			} catch (CantGoException e) {
				e.printStackTrace();
			}
		} else
			agentSystem.getOut().println("Tour finished!");
	}
	
	/** Very similar to the run() method in EnvAgent */
	public void list() {
		
		PlaceID home = agentSystem.getPlaceID();
		
		if (home.isDomain()) {
			// Get children domains
			DomainNameService dns = agentSystem.getEnvironment().domainNameService;
			Vector children = dns.getChildrenDNS(); // a Vector of PlaceIDs
			for (int index = children.size() - 1; index >= 0; index--) {
				PlaceID place = (PlaceID) children.get(index);
				placesToVisit.add(place);
			}
			// Get places in this domain
			Vector places = new Vector(Arrays.asList(agentSystem.getPlaces()));
			places.remove(home);
			for (int index = places.size() - 1; index >= 0; index--) {
				PlaceID place = (PlaceID) places.get(index);
				placesToVisit.add(place);
			}
		}
		
		// Print results
		for (int index = placesToVisit.size() - 1; index >= 0; index--) {
			PlaceID place = (PlaceID) placesToVisit.get(index);
			agentSystem.getOut().println(place);
		}
	}

} // end RegionTourAgent

protected PlaceID destination;

public void run() {
	try {
		// save the destination for later checking
		destination = placeToGo;
		go(placeToGo, "startMethod");
	} catch (CantGoException e) {
		// manage the exception
	}
}

public void startMethod() {
	// get the current place
	PlaceID currentPlace = agentSystem.getPlaceID();
	if (currrentPlace.equals(destination)) {
		// I am where I am supposed to be
	} else {
		// I did not reach my destination!
	}
}

transient AgentWorker worker = null;

/**
 * Creazione di un agente.
 * @param agentName Nome dell'agente.
 * @param argument Parametro di inizializzazione, vedi
 * {@link SOMA.agent.Agent#putArgument(Object obj)}.
 * @param isSystemAgent Se a true si forza l'utilizzo del classloader di sistema
 * @param traceable Se a true l'agente è traceable ed ha una mailbox.
 */
public AgentWorker createAgent(String agentName, Object argument, boolean isSystemAgent, boolean traceable) 
{
	AgentWorker worker = null;

	try
	{
		AgentID newID = newAgentID();
		
		ClassLoader classLoader;
		
		if (isSystemAgent)
			// Lo stesso ClassLoader della classe attuale!
			classLoader = getClass().getClassLoader();
		else
			classLoader = new AgentClassLoader(env, agentName, newID);
		
		Agent agent = (Agent) classLoader.loadClass(agentName).newInstance();
		agent.setID(newID);
		agent.putArgument(argument);
		agent.setTraceable(traceable);
		
		worker = createWorker(agent);
	}
	catch( Exception e )
	{
		e.printStackTrace(env.err);
	}
	
	return worker;
}

import SOMA.agent.*;
import SOMA.agent.mobility.*;
import SOMA.naming.*;
import SOMA.naming.domain.*;

import java.util.*;

/**
 * This class represents the base agent, and it creates LurkerTryAgent(s) in order
 * to explore the first-level domains and places. Note that the base agent is fixed
 * (i.e. it does not move itself around the domains).
 *
 * @author	Giulio Piancastelli
 * @version	1.0 - Wednesday 13th February, 2002
 */
public class BaseTryAgent extends Agent {
	
	public void run() {
		
		Vector placesToVisit = new Vector();
		PlaceID home = agentSystem.getPlaceID();
		SOMA.Environment env = agentSystem.getEnvironment();
		
		if (home.isDomain()) {
			// Get children domains
			Vector children = env.domainNameService.getChildrenDNS();
			for (int index = children.size() - 1; index >= 0; index--) {
				PlaceID place = (PlaceID) children.get(index);
				// update the list of places to visit
				placesToVisit.add(place);
			}
			// Get places in this domain
			Vector places = new Vector(Arrays.asList(agentSystem.getPlaces()));
			places.remove(home);
			for (int index = places.size() - 1; index >= 0; index--) {
				PlaceID place = (PlaceID) places.get(index);
				// update the list of places to visit
				placesToVisit.add(place);
			}
		}
		
		for (int index = placesToVisit.size() - 1; index >= 0; index--) {
			PlaceID placeToGo = (PlaceID) placesToVisit.get(index);
			Vector v = new Vector();
			v.add(home);
			v.add(placeToGo);
			AgentWorker lurker = env.agentManager.createAgent("LurkerTryAgent", v,
									false, true);
			if (lurker != null)
				try {
					lurker.start();
				} catch (AgentWorker.AgentWorkerException awe) {
					awe.printStackTrace();
				}
		}
	}
} // end BaseTryAgent

import SOMA.agent.*;
import SOMA.naming.*;
import SOMA.naming.domain.*;

/**
 * Coupled with BaseTryAgent, this agent realizes a first try to create and
 * move new agents from an initial place.
 *
 * @author	Giulio Piancastelli
 * @version	1.0 - Wednesday 13th February, 2002
 */
public class LurkerTryAgent extends Agent {
	
	// Serializable fields
	private PlaceID myHome; // the place where the lurker was created
	private PlaceID myNextPlace; // the place where the lurker was said to go
	
	public void putArgument(Object obj) {
		// the object is a Vector
		java.util.Vector v = (java.util.Vector) obj;
		myHome = (PlaceID) v.get(0);
		myNextPlace = (PlaceID) v.get(1);
	}
	
	public void run() {
		try {
			go(myNextPlace, "greetings");
		} catch (CantGoException cge) {
			cge.printStackTrace();
		}
	}
	
	public void greetings() {
		// get the current place
		PlaceID currentPlace = agentSystem.getPlaceID();
		if (currrentPlace.equals(myNextPlace))
			agentSystem.getOut().println("I come from " + myHome + "- I was said to go to "
					+ myNextPlace + " and I am now in " + currentPlace);
		else
			agentSystem.getOut().println("I did not reach my destination!");
	}
	
} // end LurkerTryAgent

/**
 * Permette di definire lo stato iniziale dell'agente.
 * Questo metodo è vuoto nella classe Agent e deve essere
 * ridefinito dalle sottoclassi che implementano agenti, in
 * maniera analoga a {@link #run()}.
 * @param obj Un oggetto contenente informazioni di inizializzazione.
 * Ovviamente l'oggetto può anche contenere una struttura dati complessa.
 */
public void putArgument(Object obj) {}

public AgentWorker createWorker(Agent agent)
{
	AgentWorker worker = null;
	try
	{
		// Se non c'è il security manager, non effettuo neanche i controlli.
		
		if( System.getSecurityManager() == null ||
		agent.getClass().getProtectionDomain().implies(new PlaceAccessPermission(env.placeID)))
		{
			agent.agentSystem = agentSystem;
			// ...
		}
		// ...
	} 
	catch( Exception e )
	{
		e.printStackTrace(env.err);
	}
	return worker;
}

• una forma di interazione stretta, usata quando si vuole avere una forte collaborazione tra agenti, e realizzata sotto forma di oggetti condivisi o tramite l'invocazione diretta dei metodi di un altro agente. Essendo necessaria una conoscenza statica della interazione, questa forma risulta poco flessibile e limitata.
  
  
• una forma di interazione lasca, in cui non è richiesta una conoscenza esplicita degli agenti che vogliono comunicare. Può essere realizzata tramite message passing, in modo che si debba conoscere solo l'identificatore unico del destinatario, lasciando al sistema sottostante i compiti di ricerca dell'agente ricevente e di spedizione del messaggio. Si può anche pensare a forme di comunicazione anonima utilizzando una blackboard o un tuple space.
  
  

import SOMA.agent.*;
import SOMA.agent.mobility.*;
import SOMA.naming.*;
import SOMA.naming.domain.*;

import java.util.*;

/**
 * An example of a base agent using shared objects to coordinate its work
 * with other lurker agents.
 * Note that the base agent does not die, but waits for the lurker agent(s)
 * to return, and must be terminated manually, since it uses the idle() method
 * to suspend itself.
 *
 * @author	Giulio Piancastelli
 * @version	1.0 - Wednesday 13th February, 2002
 */
public class SObjBaseAgent extends Agent {
	
	public void run() {		
		Vector placesToVisit = new Vector();
		PlaceID home = agentSystem.getPlaceID();
		SOMA.Environment env = agentSystem.getEnvironment();
		
		if (home.isDomain()) {
			// Get children domains
			Vector children = env.domainNameService.getChildrenDNS();
			for (int index = children.size() - 1; index >= 0; index--) {
				PlaceID place = (PlaceID) children.get(index);
				// update the list of places to visit
				placesToVisit.add(place);
			}
			// Get places in this domain
			Vector places = new Vector(Arrays.asList(agentSystem.getPlaces()));
			places.remove(home);
			for (int index = places.size() - 1; index >= 0; index--) {
				PlaceID place = (PlaceID) places.get(index);
				// update the list of places to visit
				placesToVisit.add(place);
			}
		}
		
		// Initialize the shared objects relative to all children domains and places
		for (int index = placesToVisit.size() - 1; index >= 0; index--) {
			PlaceID place = (PlaceID) placesToVisit.get(index);
			agentSystem.sharedObjects.put(index, place);
		}
		
		// Create lurkers which will move on first level domains and places, access shared
		// objects and somehow manipulate them
		for (int index = placesToVisit.size() - 1; index >= 0; index--) {
			Vector v = new Vector();
			v.add(home);
			v.add(new Integer(index));
			AgentWorker lurker = env.agentManager.createAgent("SObjLurkerAgent", v,
									false, true);
			try {
				lurker.start();
			} catch (AgentWorker.AgentWorkerException awe) {
				awe.printStackTrace();
			}
		}
		
		idle("printSharedObjects"); // wait
	}
	
	public void printSharedObjects() {
		for (int index = agentSystem.sharedObjects.size() - 1; index >= 0; index--)
			agentSystem.getOut().println(agentSystem.sharedObjects.get(index).toString());
	}
	
} // end SObjBaseAgent

Figura 2. Premendo il pulsante Start, l'agente selezionato esce dallo stato Idle e si riattiva.

import SOMA.agent.*;
import SOMA.naming.*;
import SOMA.naming.domain.*;

import java.util.*;

/**
 * An example of a lurker agent coordinating with a base agent thanks to
 * the use of shared objects.
 *
 * @author	Giulio Piancastelli
 * @version	1.0 - Wednesday 13th February, 2002
 */
public class SObjLurkerAgent extends Agent {
	
	private PlaceID myHome; // the PlaceID the agent come from
	
	// myIndex really indicates the particular shared object property of the lurker agent,
	// i.e. the one and only object a single lurker agent will modify
	private int myIndex;
	private String manipulation = "";
	
	public void putArgument(Object obj) {
		Vector v = (Vector) obj;
		myHome = (PlaceID) v.get(0);
		Integer temp = (Integer) v.get(1);
		// the agent destination place's index in the shared objects table
		myIndex = temp.intValue();
	}
	
	public void run() {
		try {
			go((PlaceID) agentSystem.sharedObjects.get(myIndex), "buildString");
		} catch (CantGoException cge) {
			cge.printStackTrace();
		}
	}
	
	/**
	 * Builds the String which will substitute the destination PlaceID entry in the
	 * shared objects table.
	 */
	public void buildString() {
		// Get children domains
		if (agentSystem.getPlaceID().isDomain()) {
			SOMA.Environment env = agentSystem.getEnvironment();		
			Vector children = env.domainNameService.getChildrenDNS();
			for (int index = children.size() - 1; index >= 0; index--) {
				PlaceID place = (PlaceID) children.get(index);
				manipulation += place.toString();
			}
		}
		// Get places in this domain
		Vector places = new Vector(Arrays.asList(agentSystem.getPlaces()));
		places.remove(agentSystem.getPlaceID());
		for (int index = places.size() - 1; index >= 0; index--) {
			PlaceID place = (PlaceID) places.get(index);
			manipulation += " " + place.toString();
		}
		
		try {
			go(myHome, "manipulate");
		} catch (CantGoException cge) {
			cge.printStackTrace();
		}
	}
	
	public void manipulate() {
		// Substitute the old object (a PlaceID) with the String previously built
		agentSystem.sharedObjects.remove(myIndex);
		agentSystem.sharedObjects.put(myIndex, manipulation);
		// Print all the shared objects except the one just modified
		agentSystem.getOut().println("---" + getID() + "---" + myIndex + "---\n");
		for (int index = agentSystem.sharedObjects.size() - 1; index >= 0; index--)
			if (index != myIndex)
				agentSystem.getOut().println(
					agentSystem.sharedObjects.get(index).toString());
	}
	
} // end SObjLurkerAgent

public synchronized void storeMessage(Message message)
public syncrhonized Message getMessage()
public synchronized boolean isMessage()

public Message(Object message, AgentID from, AgentID to)

/**
 * Restituisce il primo messaggio in mailbox. La chiamata è sospensiva
 * ma esiste la possibilità di verificare se la Mailbox è piena.
 */
public synchronized Message getMessage()
{
	try
	{
		while (messages.size() == 0)
			wait();
	}
	catch (Exception e)
	{
		e.printStackTrace();
	}
	return (Message) messages.removeFirst();
}

import SOMA.agent.*;
import SOMA.agent.mobility.*;
import SOMA.naming.*;
import SOMA.naming.domain.*;

import java.util.*;

/**
 * An example of a base agent using its mailbox to coordinate its work
 * with other lurker agents.
 *
 * @author	Giulio Piancastelli
 * @version	1.0 - Wednesday 13th February, 2002
 */
public class MailboxBaseAgent extends Agent {
	
	private int numAgents = 0;
	private int numMessage = 0;
	
	public void run() {
		Vector placesToVisit = new Vector();
		PlaceID home = agentSystem.getPlaceID();
		SOMA.Environment env = agentSystem.getEnvironment();
		
		if (home.isDomain()) {
			// Get children domains
			Vector children = env.domainNameService.getChildrenDNS();
			for (int index = children.size() - 1; index >= 0; index--) {
				PlaceID place = (PlaceID) children.get(index);
				// update the list of places to visit
				placesToVisit.add(place);
			}
			// Get places in this domain
			Vector places = new Vector(Arrays.asList(agentSystem.getPlaces()));
			places.remove(home);
			for (int index = places.size() - 1; index >= 0; index--) {
				PlaceID place = (PlaceID) places.get(index);
				// update the list of places to visit
				placesToVisit.add(place);
			}
		}
		
		// Initialize the shared objects relative to all children domains and places
		for (int index = placesToVisit.size() - 1; index >= 0; index--) {
			PlaceID place = (PlaceID) placesToVisit.get(index);
			agentSystem.sharedObjects.put(index, place);
		}
		
		// Create lurkers which will move on first level domains and places, access shared
		// objects and somehow manipulate them
		for (int index = placesToVisit.size() - 1; index >= 0; index--) {
			Vector v = new Vector();
			v.add(home);
			v.add(new Integer(index));
			v.add(getID()); // the base agent ID
			AgentWorker lurker = env.agentManager.createAgent("MailboxLurkerAgent", v,
									false, true);
			try {
				lurker.start();
			} catch (AgentWorker.AgentWorkerException awe) {
				awe.printStackTrace();
			}
			numAgents++;
		}
		
		// if the agent is not traceable, there is no mailbox
		if (mailbox != null)
			mailbox.mailListener = new Mailbox.MailListener() {
				
				public void run() {
					Message mex = mailbox.getMessage();
					agentSystem.getOut().println(
						"Message received by " + mex.from);
					if (mex.message.toString().equals("lurker_agent_done"))
						numMessage++;
					agentSystem.getOut().println(
						"" + numMessage + " message(s) arrived");
				}
				
			};
		agentSystem.getOut().println("" + getID() + ": I'm going idle...");
		idle("idleCycle"); // wait
	}
	
	public void idleCycle() {
		if (numMessage != numAgents)
			idle("idleCycle");
		else
			printSharedObjects();
	}
	
	public void printSharedObjects() {
		for (int index = agentSystem.sharedObjects.size() - 1; index >= 0; index--)
			agentSystem.getOut().println(agentSystem.sharedObjects.get(index).toString());
	}
	
} // end MailboxBaseAgent

public synchronized void sendMessage(Message message, int attemptsCount)
{
	AgentWorker destinationWorker =
		env.agentManager.agentWorkerStore.getWorker(message.to);
	
	if (destinationWorker != null &&
	destinationWorker.getStatus() != AgentWorker.GONE) // Ho già trovato l'agente!
	{
		destinationWorker.agent.mailbox.storeMessage(message);
		
		// ATTENZIONE: Agenti in idle ==> riavviati.
		if (destinationWorker.getStatus() == AgentWorker.OFF ||
		destinationWorker.getStatus() == AgentWorker.IDLE ||
		destinationWorker.getStatus() == AgentWorker.STOPPED)
		{
			env.out.println("Waking up agent " + message.to);
			try
			{
				destinationWorker.start();
			}
			catch (AgentWorker.AgentWorkerException e)
			{
				e.printStackTrace();
			}
		}
	}
	// ...
}

import SOMA.agent.*;
import SOMA.naming.*;
import SOMA.naming.domain.*;

import java.util.*;

/**
 * An example of a lurker agent coordinating with a base agent thanks to
 * the use of a mailbox.
 *
 * @author	Giulio Piancastelli
 * @version	1.0 - Wednesday 13th February, 2002
 */
public class MailboxLurkerAgent extends Agent {
	
	private PlaceID myHome; // the PlaceID the agent come from
	
	// myIndex really indicates the particular shared object property of the lurker agent,
	// i.e. the one and only object a single lurker agent will modify
	private int myIndex;
	private AgentID parent;
	private String manipulation = "";
	
	public void putArgument(Object obj) {
		
		Vector v = (Vector) obj;
		myHome = (PlaceID) v.get(0);
		Integer temp = (Integer) v.get(1);
		// the agent destination place's index in the shared objects table
		myIndex = temp.intValue();
		parent = (AgentID) v.get(2);
		
	}
	
	public void run() {
		try {
			go((PlaceID) agentSystem.sharedObjects.get(myIndex), "buildString");
		} catch (CantGoException cge) {
			cge.printStackTrace();
		}
	}
	
	/**
	 * Builds the String which will substitute the destination PlaceID entry in the
	 * shared objects table.
	 */
	public void buildString() {
		// Get children domains
		if (agentSystem.getPlaceID().isDomain()) {
			SOMA.Environment env = agentSystem.getEnvironment();
			Vector children = env.domainNameService.getChildrenDNS();
			for (int index = children.size() - 1; index >= 0; index--) {
				PlaceID place = (PlaceID) children.get(index);
				manipulation += place.toString();
			}
		}
		// Get places in this domain
		Vector places = new Vector(Arrays.asList(agentSystem.getPlaces()));
		places.remove(agentSystem.getPlaceID());
		for (int index = places.size() - 1; index >= 0; index--) {
			PlaceID place = (PlaceID) places.get(index);
			manipulation += " " + place.toString();
		}
		
		// Build a huge vector - make them being late!
		Vector v = new Vector();
		for (int i = 0; i < 10000; i++)
			v.add(new Integer(i));
		
		try {
			go(myHome, "manipulate");
		} catch (CantGoException cge) {
			cge.printStackTrace();
		}
	}
	
	public void manipulate() {
		// Substitute the old object (a PlaceID) with the String previously built
		agentSystem.sharedObjects.remove(myIndex);
		agentSystem.sharedObjects.put(myIndex, manipulation);
		// the agent has done, and notifies it to its parent
		Message mex = new Message("lurker_agent_done", getID(), parent);
		agentSystem.sendMessage(mex);
	}
	
} // end MailboxLurkerAgent

Figura 3. Un minimale agente dotato di GUI.

import SOMA.agent.*;
import SOMA.gui.*;
import SOMA.utility.*;

import java.awt.*;
import javax.swing.*;

/**
 * The minimal windowed agent - a mobile agent controlled by a window
 * built up using the SOMA GUI facilities.
 *
 * @author	Giulio Piancastelli
 * @version	1.0 - Monday 18th February, 2002
 */
public class WinSkeletonAgent extends Agent {
	
	/* Transient members */
	
	// The agent's output window
	private transient OutputFrame2 window;
	// Wait on the semaphore before exiting - to synchronize the main thread (waiting) with
	// actions from the menu and buttons
	private transient WaitAndTimeout exitSemaphore;
	
	public void run() {
		agentSystem.getOut().println("Agent [" + getID() + "] running...");
		buildWindow(); // create the agent's window
		
		exitSemaphore = new WaitAndTimeout(0, "<EXIT>", window.out);
		startMethod();
	}
	
	public void startMethod() {
		agentSystem.getOut().println("Agent [" + getID() + "] executing startMethod...");
		
		exitSemaphore.Wait(); // waiting here...
		// restarting with Exit, Go or Idle commands
		window.dispose();
		agentSystem.getOut().println("Agent [" + getID() + "] exiting from main thread...");
	}
	
	private void buildWindow() {
		window = new OutputFrame2("Agent [" + getID() + "]", WinSkeletonAgent.class.getName());
		
		// what to do on exit
		window.onExitCommand = new OutputFrame2.Listener() {
			
			public void run() {		
				// show this message in the agent window when exiting
				window.out.println("Agent [" + getID() + "] exiting...");
				exitSemaphore.Done();
			}
			
		};
		window.pack();
		window.setVisible(true);
	}
	
} // end WinAgent

/**
 * Pannello vuoto, inserito prima del pannello coi bottoni di default.
 * Utile per inserirvi i propri bottoni.
 * Questo pannello viene CREATO E INSERITO NEL FRAME DA QUESTA CLASSE.
 * Dopo la costruzione lo si può riempire con ciò che si vuole, ma bisogna
 * farlo sempre PRIMA di chiamare il metodo setVisible() sulla finestra!
 */
public JPanel prePanBottoni;

Figura 4. Un agente dotato di GUI con una serie di pulsanti ed un menu.

public transient PrintStream out;
public Listener onExitCommand;

Il primo è lo stream di output collegato alla area di testo della finestra, su cui si scrivono informazioni come sulla area di testo della finestra di Place: nei nostri esempi, nel primo caso si è usato window.out.println(), nel secondo caso si è usato agentSystem.getOut().println(). Il secondo è un listener al cui metodo run() deve essere assegnato il lavoro da fare prima di chiudere la finestra e di lasciare quindi che l'agente muoia.

Nel codice del nostro esempio va sottolineato l'uso dell'oggetto di sincronizzazione SOMA.utility.WaitAndTimeout. Esso serve in generale per l'attesa di un evento coadiuvata da un timeout, e nel presente caso di costruzione di una GUI per un agente, funziona da semaforo su cui attendere prima di uscire, in modo da sincronizzare il thread principale in attesa con le azioni dei bottoni o del menu.

Non per tutti gli agenti ha senso l'uso di una GUI: nell'esempio del capitolo precedente, infatti, l'agente base potrebbe aver bisogno di una interfaccia grafica in modo che l'utente possa decidere quando far partire i lurker, oppure per un tipo di presentazione dei dati più raffinato rispetto alle possibilità offerte dalle finestre dei Place. Può avere meno senso l'idea di fornire una GUI anche ai lurker, che somigliano piuttosto ad elementi di pura computazione e comunicazione, senza che vi sia da parte loro un interesse per la parte di presentazione necessaria in una qualsiasi applicazione.

Infine, si noti che un vantaggio indiretto nell'uso di una GUI, per quegli agenti che ne possono essere ragionevolmente dotati, consiste nel non doversi più preoccupare del rischio che un agente muoia prima di potersi coordinare efficacemente con altri agenti, magari da lui stesso creati, come nelle combinazioni tra base e lurker viste finora. Infatti, riprendendo l'esempio visto nell'uso di mailbox o Shared Objects, nel caso l'agente base sia dotato di GUI, le chiamate al metodo idle() non sono più necessarie per il corretto funzionamento della applicazione.