Добавяне на услугата в контейнера

Приложение 2:

Програмен код на файла Math.wsdl

Програмен код на уеб услугата

import org.globus.wsrf.ResourceProperties;

import org.globus.wsrf.ResourceProperty;

import org.globus.wsrf.ResourcePropertySet;

import org.globus.wsrf.impl.ReflectionResourceProperty;

import org.globus.wsrf.impl.SimpleResourcePropertySet;

import org.globus.examples.stubs.MathService_instance.AddResponse;

import org.globus.examples.stubs.MathService_instance.SubtractResponse;

import org.globus.examples.stubs.MathService_instance.GetValueRP;
public class MathService implements Resource, ResourceProperties {
/* Resource Property set */

private ResourcePropertySet propSet;

private int value;

private String lastOp;
/* Constructor. Initializes RPs */

public MathService() throws RemoteException {

/* Create RP set */

this.propSet = new SimpleResourcePropertySet(

MathQNames.RESOURCE_PROPERTIES);
/* Initialize the RP's */

try {

MathQNames.RP_VALUE, "Value", this);

this.propSet.add(valueRP);

setValue(0);

MathQNames.RP_LASTOP, "LastOp", this);

this.propSet.add(lastOpRP);

setLastOp("NONE");

} catch (Exception e) {

throw new RuntimeException(e.getMessage());

}

}
/* Get/Setters for the RPs */

return value;

}
public void setValue(int value) {

this.value = value;

}
public String getLastOp() {

return lastOp;

}
public void setLastOp(String lastOp) {

this.lastOp = lastOp;

}
/* Remotely-accessible operations */
public AddResponse add(int a) throws RemoteException {

value += a;

lastOp = "ADDITION";
return new AddResponse();

}
public SubtractResponse subtract(int a) throws RemoteException {

value -= a;

lastOp = "SUBTRACTION";

}
public int getValueRP(GetValueRP params) throws RemoteException {

return value;

}
/* Required by interface ResourceProperties */

public ResourcePropertySet getResourcePropertySet() {

return this.propSet;

}

}
Програмен код на файла deploy-server.wsdd

import org.apache.axis.message.addressing.EndpointReferenceType;

import org.globus.examples.stubs.MathService_instance.GetValueRP;

import org.globus.examples.stubs.MathService_instance.service.MathServiceAddressingLocator;
public class Client {
public static void main(String[] args) {

MathServiceAddressingLocator locator = new MathServiceAddressingLocator();

String serviceURI = args[0];

EndpointReferenceType endpoint = new EndpointReferenceType();

endpoint.setAddress(new Address(serviceURI));

MathPortType math = locator.getMathPortTypePort(endpoint);

math = locator.getMathPortTypePort(endpoint);

math.add(10);

math.add(5);

System.out.println("Current value: "

+ math.getValueRP(new GetValueRP()));
// Perform a subtraction

math.subtract(5);

System.out.println("Current value: "

+ math.getValueRP(new GetValueRP()));

} catch (Exception e) {

e.printStackTrace();

}

}

import org.apache.axis.message.addressing.EndpointReferenceType;

import org.globus.examples.stubs.MathService_instance.MathPortType;

import org.globus.examples.stubs.MathService_instance.service.MathServiceAddressingLocator;

import org.globus.wsrf.encoding.ObjectDeserializer;

import org.xml.sax.InputSource;
public class ClientAdd {
public static void main(String[] args) {

MathServiceAddressingLocator instanceLocator = new MathServiceAddressingLocator();

int value = Integer.parseInt(args[1]);

EndpointReferenceType instanceEPR;
if (args[0].startsWith("http")) {

// First argument contains a URI

String serviceURI = args[0];

// Create endpoint reference to service

instanceEPR = new EndpointReferenceType();

instanceEPR.setAddress(new Address(serviceURI));

} else {

// First argument contains an EPR file name

String eprFile = args[0];

// Get endpoint reference of WS-Resource from file

FileInputStream fis = new FileInputStream(eprFile);

instanceEPR = (EndpointReferenceType) ObjectDeserializer

.deserialize(new InputSource(fis),

EndpointReferenceType.class);

fis.close();

}
// Get PortType

MathPortType math = instanceLocator

.getMathPortTypePort(instanceEPR);

math.add(value);

System.out

.println("Current value:" + math.getValueRP(new GetValueRP()));

} catch (Exception e) {

e.printStackTrace();

}

}

Програмен код на файла ClientSubtract.java

import org.apache.axis.message.addressing.EndpointReferenceType;

import org.globus.examples.stubs.MathService_instance.MathPortType;

import org.globus.examples.stubs.MathService_instance.service.MathServiceAddressingLocator;

import org.globus.wsrf.encoding.ObjectDeserializer;

import org.xml.sax.InputSource;
public class ClientSubtract {
public static void main(String[] args) {

MathServiceAddressingLocator instanceLocator = new MathServiceAddressingLocator();

try {

int value = Integer.parseInt(args[1]);

// First argument contains a URI

String serviceURI = args[0];

// Create endpoint reference to service

instanceEPR = new EndpointReferenceType();

instanceEPR.setAddress(new Address(serviceURI));

} else {

// First argument contains an EPR file name

String eprFile = args[0];

// Get endpoint reference of WS-Resource from file

FileInputStream fis = new FileInputStream(eprFile);

instanceEPR = (EndpointReferenceType) ObjectDeserializer

.deserialize(new InputSource(fis),

EndpointReferenceType.class);

fis.close();

}
// Get PortType

MathPortType math = instanceLocator

.getMathPortTypePort(instanceEPR);

math.subtract(value);

System.out.println("Current value:" + math.getValueRP(new GetValueRP()));

} catch (Exception e) {

e.printStackTrace();

}

}

Използвана литература:

1. 
   Introduction to Grid Computing - Bart Jacob, Michael Brown, Kentaro Fukui, Nihar Trivedi
   
2. 
   http://www.globus.org/
   
3. 
   http://www.globus.org/toolkit/
   
4. 
   Българският Грид Портал - http://www.grid.bas.bg
   
5. 
   Уикипедия - http://www.wikipedia.org/
   
6. 
   Документи от http://www.gridcomputing.com
   

Проектиране и изграждане на експериментална ГРИД среда

Каталог: 123
123 -> Възникване и развитие на телевизионната индустрия. Модели телевизионни организации
123 -> Списание „Прозорец”3/12
123 -> Н а р е д б а за реда за придобиване, управление и разпореждане с общинско имущество
123 -> Програма за действие по околната среда: Към устойчиво развитие Европейска Общностна програма за политиката и действията по отношение на околната среда и устойчивото развитие
123 -> Curriculum vitae
123 -> За произхода на някои български названия на малки предмети Живка Колева-Златева
123 -> Съобщение на комисията до европейския парламент и съвета план за действие за намаляване на инцидентния улов на морски птици в риболовните уреди
123 -> На научната продукция на ДНК маргарита карамихова
123 -> Програма за овм. Концепция за опазване и мониторинг на овм, чрез изграждане на мрежа от сътрудници по места

Изтегляне 0.59 Mb.

Сподели с приятели: