======================================================

《深入浅出JAX-WS 2.0》

http://blog.csdn.net/nanjingjiangbiao/archive/2010/02/11/5306034.aspx

《SOA技术研究之 图解JAX-WS技术》

http://blog.csdn.net/nanjingjiangbiao/archive/2010/02/10/5305049.aspx

《手把手教你在Interstage上部署WebService》

http://blog.csdn.net/nanjingjiangbiao/archive/2010/02/22/5317356.aspx

======================================================

.

@javax.jws.WebService

public class StockQuoteProvider {

public StockQuoteProvider () {

}

public float getLastTradePrice (String tickerSymbol) {

return “abc”.equals(tickerSymbol)? 1234.0f : 0.0f;

}

}

import stock.server.*;

import javax.xml.ws.Service;

public class StockQuoteClient {

public static void main(String[] args) throws Exception {

StockQuoteProviderService service = new StockQuoteProviderService();

StockQuoteProvider port = service.getStockQuoteProviderPort();

System.out.println(port.getLastTradePrice(args[0]));

}

}

http://blog.csdn.net/nanjingjiangbiao/archive/2010/01/28/5264913.aspx

http://blog.csdn.net/nanjingjiangbiao/archive/2010/02/10/5305049.aspx

StockQuoteProviderService();

super(STOCKQUOTEPROVIDERSERVICE_WSDL_LOCATION, new QName(“http://server.stock/”, “StockQuoteProviderService”));

}

public ServiceDelegate createServiceDelegate( URL wsdlDocumentLocation, QName serviceName, Class serviceClass) {

return new WSServiceDelegate(wsdlDocumentLocation, serviceName, serviceClass);

}

* @param serviceClass

*      Either {@link Service}.class or other generated service-derived classes.

*/

public WSServiceDelegate(@Nullable Source wsdl, @NotNull QName serviceName, @NotNull final Class<? extends Service> serviceClass) {

～省略～

}

if (wsdl != null) {

try {

URL url = wsdl.getSystemId()==null ? null : new URL(wsdl.getSystemId());

WSDLModelImpl model = parseWSDL(url, wsdl);

service = model.getService(this.serviceName);

if (service == null)

throw new WebServiceException(

ClientMessages.INVALID_SERVICE_NAME(this.serviceName,

buildNameList(model.getServices().keySet())));

// fill in statically known ports

for (WSDLPortImpl port : service.getPorts())

ports.put(port.getName(), new PortInfo(this, port));

} catch (MalformedURLException e) {

throw new WebServiceException(ClientMessages.INVALID_WSDL_URL(wsdl.getSystemId()), e);

}

}

this.wsdlService = service;

WebServiceFeature… features) {

SEIPortInfo spi = addSEI(portName, portInterface, features);

return createEndpointIFBaseProxy(wsepr,portName,portInterface,features, spi);

}

* Creates a new pipeline for the given port name.

*/

private Tube createPipeline(PortInfo portInfo, WSBinding binding) {

//Check all required WSDL extensions are understood

checkAllWSDLExtensionsUnderstood(portInfo,binding);

SEIModel seiModel = null;

if(portInfo instanceof SEIPortInfo) {

seiModel = ((SEIPortInfo)portInfo).model;

}

BindingID bindingId = portInfo.bindingId;

TubelineAssembler assembler = TubelineAssemblerFactory.create(

Thread.currentThread().getContextClassLoader(), bindingId);

if (assembler == null)

throw new WebServiceException(“Unable to process bindingID=” + bindingId);    // TODO: i18n

return assembler.createClient(

new ClientTubeAssemblerContext(

portInfo.targetEndpoint,

portInfo.portModel,

this, binding, container,((BindingImpl)binding).createCodec(),seiModel));

}

public Tube createClient(ClientTubeAssemblerContext context) {

Tube head = context.createTransportTube();

head = context.createSecurityTube(head);

if (dump) {

// for debugging inject a dump pipe. this is left in the production code,

// as it would be very handy for a trouble-shooting at the production site.

head = context.createDumpTube(“client”, System.out, head);

}

head = context.createWsaTube(head);

head = context.createClientMUTube(head);

head = context.createValidationTube(head);

return context.createHandlerTube(head);

}

MethodHandler handler = methodHandlers.get(method);

if (handler != null) {

return handler.invoke(proxy, args);

} else {

// we handle the other method invocations by ourselves

try {

return method.invoke(this, args);

} catch (IllegalAccessException e) {

// impossible

throw new AssertionError(e);

} catch (IllegalArgumentException e) {

throw new AssertionError(e);

} catch (InvocationTargetException e) {

throw e.getCause();

}

}

}

* Passes a message to a pipe for processing.

* <p>

* Unlike {@link Tube} instances,

* this method is thread-safe and can be invoked from

* multiple threads concurrently.

*

* @param packet         The message to be sent to the server

* @param requestContext The {@link RequestContext} when this invocation is originally scheduled.

*                       This must be the same object as {@link #requestContext} for synchronous

*                       invocations, but for asynchronous invocations, it needs to be a snapshot

*                       captured at the point of invocation, to correctly satisfy the spec requirement.

* @param receiver       Receives the {@link ResponseContext}. Since the spec requires

*                       that the asynchronous invocations must not update response context,

*                       depending on the mode of invocationthey have to go to different places.

*                       So we take a setter that abstracts that away.

*/

protected final Packet process(Packet packet, RequestContext requestContext, ResponseContextReceiver receiver) {

configureRequestPacket(packet, requestContext);

Pool<Tube> pool = tubes;

if (pool == null)

throw new WebServiceException(“close method has already been invoked”); // TODO: i18n

Fiber fiber = engine.createFiber();

// then send it away!

Tube tube = pool.take();

try {

return fiber.runSync(tube, packet);

} finally {

// this allows us to capture the packet even when the call failed with an exception.

// when the call fails with an exception it’s no longer a ‘reply’ but it may provide some information

// about what went wrong.

// note that Packet can still be updated after

// ResponseContext is created.

Packet reply = (fiber.getPacket() == null) ? packet : fiber.getPacket();

receiver.setResponseContext(new ResponseContext(reply));

pool.recycle(tube);

}

}

* To be invoked from {@link #doRun(Tube)}.

*

* @see #doRun(Tube)

*/

private Tube __doRun(Tube next) {

final Fiber old = CURRENT_FIBER.get();

CURRENT_FIBER.set(this);

// if true, lots of debug messages to show what’s being executed

final boolean traceEnabled = LOGGER.isLoggable(Level.FINER);

try {

while(!isBlocking() && !needsToReenter) {

try {

NextAction na;

Tube last;

if(throwable!=null) {

if(contsSize==0) {

// nothing else to execute. we are done.

return null;

}

last = popCont();

if(traceEnabled)

LOGGER.finer(getName()+’ ‘+last+”.processException(“+throwable+’)’);

na = last.processException(throwable);

} else {

if(next!=null) {

if(traceEnabled)

LOGGER.finer(getName()+’ ‘+next+”.processRequest(“+packet+’)’);

na = next.processRequest(packet);

last = next;

} else {

if(contsSize==0) {

// nothing else to execute. we are done.

return null;

}

last = popCont();

if(traceEnabled)

LOGGER.finer(getName()+’ ‘+last+”.processResponse(“+packet+’)’);

na = last.processResponse(packet);

}

}

～省略～

if (packet.getMessage() != null) {

XMLStreamWriter writer = XMLStreamWriterFactory.create(out);

try {

packet.getMessage().writeTo(writer);

writer.flush();

} catch (XMLStreamException e) {

throw new WebServiceException(e);

}

XMLStreamWriterFactory.recycle(writer);

}

return getContentType(packet.soapAction);

}

HttpServletResponse response)

throws ServletException ,IOException{

/**

* This requirement came from the jbi team. If the WebServiceEndpoint

* is a jbi endpoint which is private throw an error whenever a get

* or a post request is made

*/

Endpoint endpt =

wsEngine_.getEndpoint(request.getServletPath());

～省略～

public void handle(WSHTTPConnection con) throws IOException {

boolean invoke = false;

try {

Packet packet = new Packet();

try {

packet = decodePacket(con, codec);

invoke = true;

} catch(ExceptionHasMessage e) {

LOGGER.log(Level.SEVERE, “JAXWS2015: An ExceptionHasMessage occurred. ” + e.getMessage(), e);

packet.setMessage(e.getFaultMessage());

} catch(UnsupportedMediaException e) {

LOGGER.log(Level.SEVERE, “JAXWS2016: An UnsupportedMediaException occurred. ” + e.getMessage(), e);

con.setStatus(WSHTTPConnection.UNSUPPORTED_MEDIA);

} catch(Exception e) {

LOGGER.log(Level.SEVERE, “JAXWS2017: A ServerRtException occurred. ” + e.getMessage(), e);

con.setStatus(HttpURLConnection.HTTP_INTERNAL_ERROR);

}

if (invoke) {

try {

packet = head.process(packet, con.getWebServiceContextDelegate(),

packet.transportBackChannel);

} catch(Exception e) {

LOGGER.log(Level.SEVERE, “JAXWS2018: An Exception occurred. ” + e.getMessage(), e);

if (!con.isClosed()) {

writeInternalServerError(con);

}

return;

}

}

encodePacket(packet, con, codec);

} finally {

if (!con.isClosed()) {

con.close();

}

}

}

}