perspectiveserverconnector.java

《Java网络程序设计.rar》包括三个网络程序的源代码。

package org.impact.stars.appclient.perspective;

import java.util.*;
import java.io.*;
import java.net.*;
import java.sql.Date;


import org.impact.stars.appclient.util.ClientUtil;
import org.impact.stars.appclient.common.StarsServerConnector;
import org.impact.stars.appclient.common.StarsConsole;

import org.impact.stars.perspectivemd.perspective.model.*;
import org.impact.stars.control.event.PerspectiveEvent;
import org.impact.stars.control.event.StarsEventSupport;

/**
 * Insert the type's description here.
 * Creation date: (1/14/02 2:32:56 PM)
 * Modified 10/8/2001
 * @author: Jian Cai
 * serialVersion
 */


public class PerspectiveServerConnector extends StarsServerConnector {
        
    private java.awt.List perspectiveList = null;
    
    private String webServerControlStr = null;
    
    private String webServerReadStr = null;
    
    private String hostName;
    private int port = 8080;
    
    private String servletreadPath = "/stars/ReadPerspectiveList";
    private String servletcontrolPath = "/stars/control/perspective";
        
    private String perspectiveID = null;
    private String lastID = "0";
    
    private URLConnection responseCon;
    boolean reload = true;
    
    public PerspectiveServerConnector(StarsConsole pdlg, javax.swing.JTextArea tarea) {
        setStatusTextArea(tarea);
        init(pdlg);
    }
    
        public PerspectiveServerConnector(StarsConsole pdlg) {
        init(pdlg);
    }

    public void setReadPath(String readp)
    {
        servletreadPath = readp;
    }
    
        public void setControlPath(String controlp)
    {
        servletcontrolPath = controlp;
    }

    
    public String getWebServerControlStr()
    {
        return webServerControlStr;
    }
    
        public String getWebServerReadStr()
    {
        return webServerReadStr;
    }
    
    public Date getCurrentDate()
    {
       java.sql.Date cdate= new java.sql.Date(((new GregorianCalendar()).getTime()).getTime());
       return cdate;
    }
    
    protected String getPerspectiveID() {
        return perspectiveID;
    }
    
    public void sendEvent(StarsEventSupport theEvent)
    {
                URLConnection theCon = getObjectConnectiontoServer(getWebServerControlStr());
                responseCon = theCon;
                sendEventToServlet(theCon, theEvent);        
    }
    
        public String readResponse()
    {
        if (responseCon!=null)
        {
        return readServletResponse(responseCon);
        }
        else
        {
            return "NO CONNECTION";
        }
    }

        
        protected void setPerspectiveID(String cstrid) {
            perspectiveID = cstrid;
        }

        protected Vector getPerspectiveList(String condition) {
            
            ObjectInputStream inputFromServlet = null;
            Vector perspectiveVector = null;
            
            try {
                // connect to the servlet
                inputFromServlet = new ObjectInputStream(getNormalConnectiontoServer(webServerReadStr+condition).getInputStream());
                
                perspectiveVector = readPerspectiveVector(inputFromServlet);
                
            }
            catch (Exception e) {
                log(e.toString());
            }
            
            return perspectiveVector;
            
        }

    public void init(StarsConsole pdlg) {
        try {
            
            URL hostURL = pdlg.getRootApplet().getCodeBase();
            hostName = hostURL.getHost();
            port = hostURL.getPort();
            
            if (port == -1) {
                port = 80;
            }
            
            webServerControlStr = "http://" + hostName + ":" + port + servletcontrolPath;
            
            webServerReadStr = "http://" + hostName + ":" + port + servletreadPath;
                        
            log("Web Server host name: " + hostName);            
            
            //webServerStr = "http://" + hostName + servletPath;
            log("Web String Control full = " + webServerControlStr);
            
            
        } catch (java.lang.Throwable ivjExc) {
            // user code begin {2}
            // user code end
            super.handleException(ivjExc);
        }
        
        
    }
    /**
     * Read the input from the servlet.  <b>
     *
     * The servlet will return a serialized vector containing
     * perspective entries.
     *
     */
    protected Vector readPerspectiveVector(ObjectInputStream theInputFromServlet) {
        Vector theperspectiveVector = null;
        try {
            // read the serialized vector of perspectives objects from
            // the servlet
            //
            log("Reading data...");
            theperspectiveVector = (Vector) theInputFromServlet.readObject();
            log("Finished reading data.  " + theperspectiveVector.size() + " perspectives returned");
            
            theInputFromServlet.close();
        }
        catch (IOException e) {
            log(e.toString());
        }
        catch (ClassNotFoundException e) {
            log(e.toString());
        }
        catch (Exception e) {
            System.out.println(e);
        }
        
        return theperspectiveVector;
    }

    // this class is the centrol communication point toward the server
}