experimental/agents/BasicAgent.java

//---PACKAGE DECLARATION---

//---IMPORTS---
import java.io.ObjectOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.net.UnknownHostException;
import java.util.Iterator;
import java.util.ArrayList;
import java.util.Random;

/**
 * A basic implementation of the Agent abstract class
 *
 * @author  $Author: ajm $
 * @version $Id: BasicAgent.java,v 1.3 2001/05/06 19:01:48 ajm Exp $
 */
class BasicAgent extends Agent {

//---FINAL / FINAL STATIC ATTRIBUTES---

    /**
     * The current CVS revision of this class
     */
    public static final String REVISION = "$Revision: 1.3 $";
    
//---STATIC METHODS---

    /**
     * A bootstrap mechanism for an agent.
     * Essentially used to fire an agent direct into an agent station.
     *
     * @param args command line arguements
     *
     * @throws UnknownHostException if it can't find the agent station
     * @throws IOException if there is a problem firing the agent
     */
    public static void main(String[] args) throws IOException, UnknownHostException {
        System.out.println("Agent Bootstrapping Started.");
        if (args.length != 3) {
            throw new RuntimeException("Must specify an agent name and agent station hostname and port number on the command line!");
        }
        Agent instance = new BasicAgent(args[0]);
        Socket s = new Socket(args[1], Integer.parseInt(args[2]));
        ObjectOutputStream p = new ObjectOutputStream(s.getOutputStream());
        p.writeObject(instance);
        p.flush();
        s.close();
        System.out.println("Agent " + args[0] + " injected into " + args[1] + ":" + args[2]);
    }

//---CONSTRUCTORS---
    
    public BasicAgent(String name) {
        _name = name;
    }

//---PUBLIC METHODS---
    
    // *** AGENT LIFETIME ***
    
    public void run() {
        while(_running) {
            try {
                Thread.sleep(10000);
            } catch (InterruptedException e) {
            }
            ArrayList agents = _station.getAllAgents();
            Iterator i = agents.iterator();
            while(i.hasNext()) {
                Agent agent = (Agent) i.next();
                if (agent != (Agent) this) {
                    say("Saying hi to " + agent.getName());
                    agent.greet(this);
                }
            }
            say("Requesting to move on...");
            ArrayList peers = _station.getAllPeers();
            if (peers.size() > 1) {
                PeerHandler dstPeer = (PeerHandler) peers.get(new Random().nextInt(peers.size() - 1));
                _station.sendAgent(this, dstPeer);
            } else if (peers.size() == 1) {
                PeerHandler dstPeer = (PeerHandler) peers.get(0);
                _station.sendAgent(this, dstPeer);
            }
        }
    }
    
    //*** AGENT SERVICES ***    
    
    public void onArrival(Station station) {
        _transmissionCount++;
        _station = station;
        _running = true;
        say("Just arrived at - " + _station.getName());
    }

    public void greet(Agent agent) {
        say(agent.getName() + " just said hi to me");
    }

    private void say(String text) {
        System.out.println("*** [" + getName() + "] " + text);
    }
    
    public String getName() {
        return _name;
    }
    
    public long getTransmissionCount() {
        return _transmissionCount;
    }

    /**
     * Used to shutdown this thread
     */
    public void shutdown() {
        say("shutting down");
        _station = null;
        _running = false;
    }
    
    //*** OTHER PUBLIC METHODS ***
    
//---PRIVATE/PROTECTED METHODS---

    /**
     * Overridden for debugging purposes
     * to see when an instance of this class
     * is destroyed
     */
    protected void finalize() throws Throwable {
        say("dead - just been gc'd");
    }

//---ACCESSOR/MUTATOR METHODS---

//---ATTRIBUTES---

    /**
     * The name of the agent
     */
    private String _name;

    /**
     * A reference to the current AgentStation this agent is at
     */    
    private Station _station;
    
    /**
     * A "running" used by the main loop in the run() method to determine if
     * it should continue running this thread.
     */
    private boolean _running = true;
    
    /**
     * The number of times this agent has been transmitted between stations
     */
    private long _transmissionCount = 0;

//---STATIC ATTRIBUTES---

}
1	//---PACKAGE DECLARATION---
2
3	//---IMPORTS---
4	import java.io.ObjectOutputStream;
5	import java.io.IOException;
6	import java.net.Socket;
7	import java.net.UnknownHostException;
8	import java.util.Iterator;
9	import java.util.ArrayList;
10	import java.util.Random;
11
12	/**
13	* A basic implementation of the Agent abstract class
14	*
15	* @author $Author: ajm $
16	* @version $Id: BasicAgent.java,v 1.3 2001/05/06 19:01:48 ajm Exp $
17	*/
18	class BasicAgent extends Agent {
19
20	//---FINAL / FINAL STATIC ATTRIBUTES---
21
22	/**
23	* The current CVS revision of this class
24	*/
25	public static final String REVISION = "$Revision: 1.3 $";
26
27	//---STATIC METHODS---
28
29	/**
30	* A bootstrap mechanism for an agent.
31	* Essentially used to fire an agent direct into an agent station.
32	*
33	* @param args command line arguements
34	*
35	* @throws UnknownHostException if it can't find the agent station
36	* @throws IOException if there is a problem firing the agent
37	*/
38	public static void main(String[] args) throws IOException, UnknownHostException {
39	System.out.println("Agent Bootstrapping Started.");
40	if (args.length != 3) {
41	throw new RuntimeException("Must specify an agent name and agent station hostname and port number on the command line!");
42	}
43	Agent instance = new BasicAgent(args[0]);
44	Socket s = new Socket(args[1], Integer.parseInt(args[2]));
45	ObjectOutputStream p = new ObjectOutputStream(s.getOutputStream());
46	p.writeObject(instance);
47	p.flush();
48	s.close();
49	System.out.println("Agent " + args[0] + " injected into " + args[1] + ":" + args[2]);
50	}
51
52	//---CONSTRUCTORS---
53
54	public BasicAgent(String name) {
55	_name = name;
56	}
57
58	//---PUBLIC METHODS---
59
60	// * AGENT LIFETIME *
61
62	public void run() {
63	while(_running) {
64	try {
65	Thread.sleep(10000);
66	} catch (InterruptedException e) {
67	}
68	ArrayList agents = _station.getAllAgents();
69	Iterator i = agents.iterator();
70	while(i.hasNext()) {
71	Agent agent = (Agent) i.next();
72	if (agent != (Agent) this) {
73	say("Saying hi to " + agent.getName());
74	agent.greet(this);
75	}
76	}
77	say("Requesting to move on...");
78	ArrayList peers = _station.getAllPeers();
79	if (peers.size() > 1) {
80	PeerHandler dstPeer = (PeerHandler) peers.get(new Random().nextInt(peers.size() - 1));
81	_station.sendAgent(this, dstPeer);
82	} else if (peers.size() == 1) {
83	PeerHandler dstPeer = (PeerHandler) peers.get(0);
84	_station.sendAgent(this, dstPeer);
85	}
86	}
87	}
88
89	//* AGENT SERVICES *
90
91	public void onArrival(Station station) {
92	_transmissionCount++;
93	_station = station;
94	_running = true;
95	say("Just arrived at - " + _station.getName());
96	}
97
98	public void greet(Agent agent) {
99	say(agent.getName() + " just said hi to me");
100	}
101
102	private void say(String text) {
103	System.out.println("*** [" + getName() + "] " + text);
104	}
105
106	public String getName() {
107	return _name;
108	}
109
110	public long getTransmissionCount() {
111	return _transmissionCount;
112	}
113
114	/**
115	* Used to shutdown this thread
116	*/
117	public void shutdown() {
118	say("shutting down");
119	_station = null;
120	_running = false;
121	}
122
123	//* OTHER PUBLIC METHODS *
124
125	//---PRIVATE/PROTECTED METHODS---
126
127	/**
128	* Overridden for debugging purposes
129	* to see when an instance of this class
130	* is destroyed
131	*/
132	protected void finalize() throws Throwable {
133	say("dead - just been gc'd");
134	}
135
136	//---ACCESSOR/MUTATOR METHODS---
137
138	//---ATTRIBUTES---
139
140	/**
141	* The name of the agent
142	*/
143	private String _name;
144
145	/**
146	* A reference to the current AgentStation this agent is at
147	*/
148	private Station _station;
149
150	/**
151	* A "running" used by the main loop in the run() method to determine if
152	* it should continue running this thread.
153	*/
154	private boolean _running = true;
155
156	/**
157	* The number of times this agent has been transmitted between stations
158	*/
159	private long _transmissionCount = 0;
160
161	//---STATIC ATTRIBUTES---
162
163	}