import org.apache.axis.SimpleTargetedChain; //导入依赖的package包/类
public static void main(String args[]) {

        Call.addTransportPackage("samples.transport");
        Call.setTransportForProtocol("tcp", TCPTransport.class);

        // Deploy the transport on top of the default client configuration.
        EngineConfiguration defaultConfig = 
            (new DefaultEngineConfigurationFactory()).
            getClientEngineConfig();
        SimpleProvider config = new SimpleProvider(defaultConfig);
        SimpleTargetedChain c = new SimpleTargetedChain(new TCPSender());
        config.deployTransport("tcp", c);

        AdminClient.setDefaultConfiguration(config);

        try {
            org.apache.axis.client.AdminClient client =
                new org.apache.axis.client.AdminClient(true);

            System.out.println(client.process(args));
        }
        catch( Exception e ) {
            System.err.println( e );
            e.printStackTrace( System.err );
        }
    }
 

import org.apache.axis.SimpleTargetedChain; //导入依赖的package包/类
/**
 * Initialize a Handler for the transport defined in the Axis server config.
 * This includes optionally filling in query string handlers.
 */

public void initQueryStringHandlers() {
		this.transport = new SimpleTargetedChain();
		this.transport.setOption("qs.list","org.apache.axis.transport.http.QSListHandler");
		this.transport.setOption("qs.method","org.apache.axis.transport.http.QSMethodHandler");
		this.transport.setOption("qs.wsdl","org.apache.axis.transport.http.QSWSDLHandler");
		
}
 

import org.apache.axis.SimpleTargetedChain; //导入依赖的package包/类
/**
 * Initialize a Handler for the transport defined in the Axis server config.
 * This includes optionally filling in query string handlers.
 */

public void initQueryStringHandlers() {
        this.transport = new SimpleTargetedChain();
        this.transport.setOption("qs.list","org.apache.axis.transport.http.QSListHandler");
        this.transport.setOption("qs.method","org.apache.axis.transport.http.QSMethodHandler");
        this.transport.setOption("qs.wsdl","org.apache.axis.transport.http.QSWSDLHandler");
        
}
 

import org.apache.axis.SimpleTargetedChain; //导入依赖的package包/类
/**
 * Initialize transport for axis (add httpg)
 * 
 * @throws SRMException
 */
private void initTransport() throws SRMException
{
    //logger.log(Level.INFO,"--->>> Init SRM v11 Transport <<< ---");
    
    srmServiceLocator = new SRMServerV1Locator();

    // Register new protocol HTTPG
    SimpleProvider provider = new SimpleProvider();

    // Uses Globus Proxy !
    GSIHTTPSender gsisender = new GSIHTTPSender();

    SimpleTargetedChain chain = new SimpleTargetedChain(gsisender);
    provider.deployTransport("httpg", chain);

    Util.registerTransport();
    // ===========================================
    // ===========================================
    
    // connectiont time out ?
    srmServiceLocator.setEngine(new AxisClient(provider));

    try
    {
        this._srmService = srmServiceLocator.getISRM(srmUri.toURL());

        // Set Axis socket connection timeout
        ((Stub) this._srmService).setTimeout(connectionTimeout);
    }
    catch (Exception e)
    {
        throw SRMException.createConnectionException("SRM Connection Error. Connection failed to:" + srmUri, e);
    }

}
 

import org.apache.axis.SimpleTargetedChain; //导入依赖的package包/类
public ServiceImpl(Map portToImplementationMap, Map seiClassNameToFactoryMap) {
    this.portToImplementationMap = portToImplementationMap;
    this.seiClassNameToFactoryMap = seiClassNameToFactoryMap;

    TypeMappingRegistryImpl typeMappingRegistry = new TypeMappingRegistryImpl();
    typeMappingRegistry.doRegisterFromVersion("1.3");

    SimpleProvider engineConfiguration = new SimpleProvider(typeMappingRegistry);
    engineConfiguration.deployTransport("http", new SimpleTargetedChain(new HTTPSender()));

    AxisClientImpl engine = new AxisClientImpl(engineConfiguration, this.portToImplementationMap);

    delegate = new Service(engineConfiguration, engine);
}
 

import org.apache.axis.SimpleTargetedChain; //导入依赖的package包/类
/**
 * Process the given message, treating it as raw XML.
 */
public void proxyService(SOAPEnvelope env1, SOAPEnvelope env2)
    throws AxisFault
{
    try {
        // Get the current Message Context
        MessageContext msgContext = MessageContext.getCurrentContext();
        
        // Look in the message context for our service
        Handler self = msgContext.getService();
        
        // what is our target URL?
        String dest = (String)self.getOption("URL");
        
        // use the server's client engine in case anything has 
        // been deployed to it
        Service service = new Service();
        service.setEngine( msgContext.getAxisEngine().getClientEngine() );
        Call    call = (Call) service.createCall();

        SimpleTargetedChain c = new SimpleTargetedChain(new TCPSender());
        // !!! FIXME
        //service.getEngine().deployTransport("tcp", c);

        // add TCP for proxy testing
        call.addTransportPackage("samples.transport");
        call.setTransportForProtocol("tcp", TCPTransport.class);
        
        // NOW set the client's URL (since now the tcp handler exists)
        call.setTargetEndpointAddress(new java.net.URL(dest));

        call.setRequestMessage(msgContext.getRequestMessage());
        
        call.invoke();
        
        Message msg = call.getResponseMessage();

        msgContext.setResponseMessage(msg);
    }
    catch( Exception exp ) {
        throw AxisFault.makeFault( exp );
    }
}
 

import org.apache.axis.SimpleTargetedChain; //导入依赖的package包/类
public float getQuote (String args[]) throws Exception {
    Call.addTransportPackage("samples.transport");
    Call.setTransportForProtocol("tcp", TCPTransport.class);
    
    Options opts = new Options( args );
    
    args = opts.getRemainingArgs();
    
    if ( args == null ) {
        System.err.println( "Usage: GetQuote <symbol>" );
        System.exit(1);
    }
    
    String namespace = "urn:xmltoday-delayed-quotes";
    symbol = args[0] ;

    EngineConfiguration defaultConfig =
        (new DefaultEngineConfigurationFactory()).
        getClientEngineConfig();
    SimpleProvider config = new SimpleProvider(defaultConfig);
    SimpleTargetedChain c = new SimpleTargetedChain(new TCPSender());
    config.deployTransport("tcp", c);

    Service service = new Service(config);
    Call call = (Call)service.createCall();
    
    call.setTransport(new TCPTransport());
    
    call.setTargetEndpointAddress( new URL(opts.getURL()) );
    call.setOperationName( new QName("urn:xmltoday-delayed-quotes", "getQuote") );
    call.addParameter( "symbol", XMLType.XSD_STRING, ParameterMode.IN );
    call.setReturnType( XMLType.XSD_FLOAT );
    
    // TESTING HACK BY ROBJ
    if (symbol.equals("XXX_noaction")) {
        symbol = "XXX";
    }
    
    call.setUsername( opts.getUser() );
    call.setPassword( opts.getPassword() );
    
    // useful option for profiling - perhaps we should remove before
    // shipping?
    String countOption = opts.isValueSet('c');
    int count=1;
    if ( countOption != null) {
        count=Integer.valueOf(countOption).intValue();
        System.out.println("Iterating " + count + " times");
    }
    
    Float res = new Float(0.0F);
    for (int i=0; i<count; i++) {
        Object ret = call.invoke(new Object[] {symbol} );
        if (ret instanceof String) {
            System.out.println("Received problem response from server: "+ret);
            throw new AxisFault("", (String)ret, null, null);
        }
        res = (Float) ret;
    }
    
    return res.floatValue();
}