serverapp.java

移动Agent编程IBM开发的移动Agent编程工具Aglet 采用纯Java编写可移植性好这是用它写的一些例子用于初级入门

/*
 * @(#)ServerApp.java
 *
 * 03L7246 (c) Copyright IBM Corp. 1996, 1998
 *
 * The program is provided "as is" without any warranty express or
 * implied, including the warranty of non-infringement and the implied
 * warranties of merchantibility and fitness for a particular purpose.
 * IBM will not be liable for any damages suffered by you as a result
 * of using the Program. In no event will IBM be liable for any
 * special, indirect or consequential damages or lost profits even if
 * IBM has been advised of the possibility of their occurrence. IBM
 * will not be liable for any third party claims against you.
 */

import java.awt.Frame;
import java.net.URL;
import java.net.UnknownHostException;
import java.io.File;
import java.util.Properties;

import com.ibm.maf.*;
import com.ibm.aglet.*;
import com.ibm.aglet.system.*;
import com.ibm.aglets.MAFAgentSystem_AgletsImpl;
import com.ibm.aglets.tahiti.Tahiti;

import com.ibm.awb.security.AccessController;
import com.ibm.awb.misc.*;

/**
 * The ServerApp example illustrates how to embed the AgletsServer facility
 * into an application program.
 *
 * @version     1.00    $Date: 1999/10/27 05:16:39 $
 * @author      Mitsuru Oshima
 * @see com.ibm.aglet.system.AgletRuntime
 * @see com.ibm.aglets.Tahiti.Main
 */
public class ServerApp extends ContextAdapter {

    public void agletCreated(ContextEvent ev) {
        System.out.println("Aglet Created : " + ev.getAgletProxy());
    }

    public void agletCloned(ContextEvent ev) {
        System.out.println("Aglet Cloned : " + ev.getAgletProxy());
    }

    public void agletArrived(ContextEvent ev) {
        System.out.println("Aglet Arrived : " + ev.getAgletProxy());
    }

    public void agletActivated(ContextEvent ev) {
        System.out.println("Aglet Activated : " + ev.getAgletProxy());
    }

    public void agletDisposed(ContextEvent ev) {
        System.out.println("Aglet Disposed : " + ev.getAgletProxy());
    }

    public void agletDispatched(ContextEvent ev) {
        System.out.println("Aglet Dispatched : " + ev.getAgletProxy());
    }

    public void agletDeactivated(ContextEvent ev) {
        System.out.println("Aglet Deactivated : " + ev.getAgletProxy());
    }

    public void agletReverted(ContextEvent ev) {
        System.out.println("Aglet Reverted : " + ev.getAgletProxy());
    }

    public void showMessage(ContextEvent ev) {
        System.out.println("message : " + ev.getMessage());
    }

    // additional options
    final static Opt options[] = {
        Opt.Entry("-protocol", "maf.protocol", null),
        Opt.Entry("-username", "username",     null),
        Opt.Entry("-password", "password",     null),
    };

    public static void main(String args[]) throws java.lang.Exception {
        Opt.setopt(options);
        AgletRuntime runtime = AgletRuntime.init(args);

        String DEFAULT_USERNAME = null;
        String username = null;
        String password = null;
        try {
            AccessController.beginPrivileged();
            DEFAULT_USERNAME = System.getProperty("user.name");
            username = System.getProperty("username", DEFAULT_USERNAME);
            password = System.getProperty("password", "");
        } finally {
            AccessController.endPrivileged();
        }

        Object obj = runtime.authenticate(username, password);
        if (obj == null) {
            System.err.println("Cannot authenticate the user \"" + username + "\"");
            throw new Exception("User authentication failed.");
        }

        /*
         * User authentication (optional)
         * If this program requests user identification from dialog box,
         * we need the following call.
         */
        /*
        if (Main.login(runtime) == null) return;
        */

        MAFAgentSystem maf_system = new MAFAgentSystem_AgletsImpl(runtime);
        String protocol = "atp";
        try {
            AccessController.beginPrivileged();
            protocol = System.getProperty("maf.protocol", "atp");
        } finally {
            AccessController.endPrivileged();
        }

        MAFAgentSystem.initMAFAgentSystem(maf_system, protocol);
        Tahiti.initializeGUI();
        Tahiti.installFactories();

        /*
         * Create named contexts. To dispatch to this context, 
         * sender has to secify the destination like,
         * "atp://aglets.trl.ibm.com:434/test"
         * Defining multiple contexts is also possible.
         *
         * Support of multiple context is experimental function.
         * This feature may drop in the future.
         */

        // first context
        AgletContext cxt = runtime.createAgletContext("test");
        cxt.addContextListener(new ServerApp());
        // second context
        AgletContext cxt2 = runtime.createAgletContext("test2");
        cxt2.addContextListener(new ServerApp());

        Tahiti.installSecurity();
        MAFAgentSystem.startMAFAgentSystem(maf_system, protocol);

        // start contexts
        cxt.start();
        cxt2.start();

        /*
         * From this point, you can use contexts.
         * (creating, dispatching an aglet, etc.)
         * 1. Create HelloAglet in cxt,
         * 2. And, dispatches it to cxt2.
         * See the source code for the detail of HelloAglet.
         */
        AgletProxy p = cxt.createAglet(null, "examples.hello.HelloAglet", null);
        
        Message msg = new Message("startTrip",
                                  cxt2.getHostingURL().toString());
        p.sendMessage(msg);
    }
}