26        String encodingStyleURI = args.length == 3
27                                  ? args[0].substring(1)
28                                  : Constants.NS_URI_SOAP_ENC;
29        URL url = new URL (args[1 - offset]);
30        String symbol = args[2 - offset];
31    
32        // Build the call.
33        Call call = new Call ();
34        call.setTargetObjectURI ("urn:xmltoday-delayed-quotes");
35        call.setMethodName ("getQuote");
36        call.setEncodingStyleURI(encodingStyleURI);
37        Vector params = new Vector ();
38        params.addElement (new Parameter("symbol", String.class, symbol, null));
39        call.setParams (params);
40    
41        // make the call: note that the action URI is empty because the 
42        // XML-SOAP rpc router does not need this. This may change in the
43        // future.
44        Response resp = call.invoke (/* router URL */ url, /* actionURI */ "" );
45    
46        // Check the response.
47        if (resp.generatedFault ()) {
48          Fault fault = resp.getFault ();
49          System.out.println ("Ouch, the call failed: ");
50          System.out.println ("  Fault Code   = " + fault.getFaultCode ());  
51          System.out.println ("  Fault String = " + fault.getFaultString ());
52        } else {
53          Parameter result = resp.getReturnValue ();
54          System.out.println (result.getValue ());
55        }
56      }
57    }
例程10-7
001    //org.apache.soap.server.SMTP2HTTPBridge.Java
002    package org.apache.soap.server;
003    
004    import Java.io.*;
005    import Java.net.*;
006    import Java.util.*;
007    
008    import com.ibm.network.mail.base.*;
009    import com.ibm.network.mail.smtp.event.*;
010    import org.apache.soap.util.net.*;
011    import org.apache.soap.util.*;
012    import org.apache.soap.rpc.SOAPContext;
013    import org.apache.soap.Constants;
014    import org.apache.soap.transport.*;
015    import org.apache.soap.transport.smtp.*;
016    import Javax.mail.MessagingException;
017    
018    /**
019     * This class can be used as a bridge to relay SOAP messages received via
020     * email to an HTTP SOAP listener. This is basically a polling POP3 client
021     * that keeps looking for new messages to work on. When it gets one,
022     * it forwards it to a SOAP HTTP listener and forwards the response via
023     * SMTP to the original requestor (to either the ReplyTo: or From: address).
024     *
025     * @author Sanjiva Weerawarana (sanjiva@watson.ibm.com)
026     */
027    public class SMTP2HTTPBridge implements Runnable {
028      Object waitObject = new Object ();
029      long pollDelayMillis;
030      com.ibm.network.mail.pop3.protocol.CoreProtocolBean pop3 =
031        new com.ibm.network.mail.pop3.protocol.CoreProtocolBean ();
032      com.ibm.network.mail.smtp.protocol.CoreProtocolBean smtp =
033        new com.ibm.network.mail.smtp.protocol.CoreProtocolBean ();
034      URL httpURL;
035    
036      /**
037       * Constructor: creates a bridge. Call run() to start polling using
038       * the current thread. (If you want to use a separate thread then
039       * do new Thread (new SMT2HTTPBridge (...)).start ();
040       *
041       * @param pollDelayMillis number of milli-seconds to sleep b'ween polls
042       * @param popServer hostname of POP3 server
043       * @param popLoginName login ID
044       * @param password password for login
045       * @param smtpServer hostname of SMTP server
046       */
047      public SMTP2HTTPBridge (/* POP3 params */
048                              long pollDelayMillis,
049                              String popServer, String popLoginName,
050                              String password,
051                              /* HTTP params */
052                              URL httpURL,
053                              /* SMTP params */
054                              String smtpServer) {
055        /* set up the pop3 side */
056        this.pollDelayMillis = pollDelayMillis;
057        pop3.setPOP3ServerHost (popServer);
058        pop3.setUserOptions(/* popLoginName */ popLoginName,
059          /* password */ password,
060          /* leaveMessagesOnServer */ false,
061          /* rememberPassword */ false);
062        pop3.addMessageListener (
063          new com.ibm.network.mail.pop3.event.MessageListener () {
064            public void messageReceived (
065                com.ibm.network.mail.pop3.event.MessageEvent me) {
066              receiveMessage (me.getMessage ());
067            }
068          }
069        );
070        pop3.addStatusListener (new POP3StatusListener ());
071    
072        /* set up the http side */
073        this.httpURL = httpURL;
074    
075        /* set up the smtp side */
076        smtp.setSmtpServerHost (smtpServer);
077        smtp.addStatusListener (new StatusListener () {
078          public void operationComplete (StatusEvent e) {
079            System.err.println ("DONE: " + e.getStatusString ());
080            synchronized (waitObject) {
081              waitObject.notify ();
082            }
083          }
084    
085          public void processStatus (StatusEvent e) {
086            System.err.println ("Status update: " + e.getStatusString ());
087          }
088        });
089      }
090    
091      /**
092       * Poll for messages forever.
093       */
094      public void run () {
095        while (true) {
096          if (pop3.isReady ()) {
097            System.err.println ("SMTP2HTTPBridge: Polling for messages ..");
098            pop3.receiveMessage ();
099          }
100          try {
101            Thread.sleep (pollDelayMillis);
102          } catch (Exception e) {
103            e.printStackTrace ();
104          }
105        }
106      }
107    
108      /**
109       * This is called by the POP3 message listener after receiving a 
110       * message from the pop server.
111       * 
112       * @param msg the message that was received
113       */
114      void receiveMessage (MimeMessage msg) {
115        /* extract the stuff from the SMTP message received */
116       String subject = msg.getHeader (SMTPConstants.SMTP_HEADER_SUBJECT);
117        String actionURI = msg.getHeader (Constants.HEADER_SOAP_ACTION);
118        String toAddr = msg.getHeader (SMTPConstants.SMTP_HEADER_TO);
119       String fromAddr = msg.getHeader (SMTPConstants.SMTP_HEADER_FROM);
120        MimeBodyPart mbp = (MimeBodyPart) msg.getContent ();
121        byte[] ba = (byte[]) mbp.getContent ();
122    
123        /* forward the content to the HTTP listener as an HTTP POST */
124        Hashtable headers = new Hashtable ();
125        headers.put (Constants.HEADER_SOAP_ACTION, actionURI);
126        TransportMessage response;
127        // This is the reponse SOAPContext. Sending it as a reply not supported yet.
128        SOAPContext ctx;
129        try
130        {
131            // Note: no support for multipart MIME request yet here...
132            TransportMessage tmsg = new TransportMessage(new String (ba),
133                                                      new SOAPContext(),
134                                                         headers);
135            tmsg.save();
136    
137            response = HTTPUtils.post (httpURL, tmsg,
138                                       30000, null, 0);
139            ctx = response.getSOAPContext();
140        } catch (Exception e) {
141            e.printStackTrace();
142    	return;
143        }
144        System.err.println ("HTTP RESPONSE IS: ");
145        String payload = null;
146        try {
147          // read the stream
148            payload = IOUtils.getStringFromReader (response.getEnvelopeReader());
149        } catch (Exception e) {
150          e.printStackTrace ();
151        }
152        System.err.println ("'" + payload + "'");
153    
154        /* forward the response via SMTP to the original sender */
155        MimeBodyPart mbpResponse = new MimeBodyPart ();
156        mbpResponse.setContent (new String (payload), response.getContentType());
157        mbpResponse.setEncoding (MimePart.SEVENBIT);
158        mbpResponse.setDisposition (MimePart.INLINE);
159    
160        MimeMessage msgResponse = new MimeMessage();
161        msgResponse.setContent (mbpResponse, "");
162        msgResponse.addHeader (SMTPConstants.SMTP_HEADER_SUBJECT,
163                               "Re: " + subject);
164        msgResponse.addHeader (Constants.HEADER_SOAP_ACTION, actionURI);
165        msgResponse.addHeader (SMTPConstants.SMTP_HEADER_FROM, 
166                            SMTPUtils.getAddressFromAddressHeader (toAddr));
167        String sendTo = SMTPUtils.getAddressFromAddressHeader (fromAddr);
168        msgResponse.addRecipients (MimeMessage.TO, 
169                                   new InternetAddress[] { 
170                                     new InternetAddress (sendTo)
171                                   });
172        smtp.sendMessage (msgResponse);
173      }
174    
175      public static void main (String[] args) throws Exception {
176        if (args.length != 6) {
177          System.err.println ("Usage: Java " + SMTP2HTTPBridge.class.getName () +
178                              " polldelay \\");
179          System.err.println ("\t\t pop3host pop3login pop3passwd httpurl " +
180                              "smtphostname");
181          System.err.println ("  where:");
182          System.err.println ("    polldelay    number of millisec to " +
183                              "sleep between polls");
184          System.err.println ("    pop3host     hostname of the POP3 server");
185          System.err.println ("    pop3login    login ID of POP3 account");
186          System.err.println ("    pop3passwd   POP3 account password");
187          System.err.println ("    routerURL    http URL of SOAP router to " +
188                              "bridge to");
189          System.err.println ("    smtphostname SMTP server host name");
190          System.exit (1);
191        }
192        SMTP2HTTPBridge sb = new SMTP2HTTPBridge (/* POP3 params */
193                                                  Integer.parseInt (args[0]),
194                                                  args[1],
195                                                  args[2],
196                                                  args[3],
197                                                  /* HTTP params */
198                                                  new URL (args[4]),
199                                                  /* SMTP params */
200                                                  args[5]);
201        new Thread (sb).start ();
202      }
203    }
例程10-8
01     //samples.stockquote.GetQuoteSMTP.Java
02     package samples.stockquote;
03     
04     import Java.io.*;
05     import Java.net.*;
06     import Java.util.*;
07     import org.apache.soap.*;
08     import org.apache.soap.transport.*;
09     import org.apache.soap.transport.smtp.*;
10     import org.apache.soap.rpc.*;
11     
12     /**
13      * This shows how to get invoke the stockquote service using
14      * SOAP over SMTP. I gave up on command line args for this and
15      * decided to prompt for the info .. just too much stuff to 
16      * set up. 
17      *
18      * @author Sanjiva Weerawarana (sanjiva@watson.ibm.com)
19      */
20     public class GetQuoteSMTP {
21       public static void main (String[] args) throws Exception {
22         if (args.length != 7
23             && (args.length != 8 || !args[0].startsWith ("-"))) {
24           System.err.println ("Usage: Java " + GetQuoteSMTP.class.getName () +
25                               " [-encodingStyleURI] routerURL smtpserver" +
26     			  " replyaddr popserver poplogin poppasswd symbol");
27           System.err.println ("  where:");
28           System.err.println ("    routerURL   mailto: URL of SOAP router");
29           System.err.println ("    smtpserver  SMTP server host name");
30           System.err.println ("    replyaddr   email addr that response should " +
31     			  "be sent to (my address)");
32           System.err.println ("    popserver   POP server host name");
33           System.err.println ("    poplogin    login ID to get response email");
34           System.err.println ("    poppasswd   password for above");
35           System.err.println ("    symbol      stock symbol");
36           System.exit (1);
37         }
38     
39         // Process the arguments.
40         int offset = 8 - args.length;
41         String encodingStyleURI = args.length == 8
42                                   ? args[0].substring(1)
43                                   : Constants.NS_URI_SOAP_ENC;
44         URL url = new URL (args[1 - offset]);
45         String smtpserver = args[2 - offset];
46         String replyaddr = args[3 - offset];
47         String popserver = args[4 - offset];
48         String poplogin = args[5 - offset];
49         String poppasswd = args[6 - offset];
50         String symbol = args[7 - offset];
51     
52         // Build the call.
53        SOAPTransport ss = new SOAPSMTPConnection (/* from address */ replyaddr, 
54     					       /* subject */ "SOAP Request",
55     					       /* smtpServer */ smtpserver,
56     					       /* popPollDelay */ 20000,
57     					       /* popServer */ popserver,
58     					       /* popLogin */ poplogin,
59     					       /* popPassword */ poppasswd);
60         Call call = new Call ();
61         call.setSOAPTransport (ss);
62         call.setTargetObjectURI ("urn:xmltoday-delayed-quotes");
63         call.setMethodName ("getQuote");
64         call.setEncodingStyleURI(encodingStyleURI);
65         Vector params = new Vector ();
66         params.addElement (new Parameter ("symbol", String.class, symbol, null));
67         call.setParams (params);
68     
69         // make the call: note that the action URI is empty because the 
70         // XML-SOAP rpc router does not need this. This may change in the
71         // future.
72         Response resp = call.invoke (/* router URL */ url, /* actionURI */ "" );
73     
74         // Check the response.
75         if (resp.generatedFault ()) {
76           Fault fault = resp.getFault ();
77           System.out.println ("Ouch, the call failed: ");
78           System.out.println ("  Fault Code   = " + fault.getFaultCode ());  
79           System.out.println ("  Fault String = " + fault.getFaultString ());
80         } else {
81           Parameter result = resp.getReturnValue ();
82           System.out.println (result.getValue ());
83         }
84       }
85     }
例程10-9
01    //samples.messaging.POProcessor.Java