Post to Website using Jakarta Commons HTTP Client

demo

1. package net.alsee.hotfolder.processors;
   
2. 
   
3. import java.io.File;
   
4. import java.io.FileInputStream;
   
5. import java.io.IOException;
   
6. 
   
7. import net.alsee.hotfolder.core.context.IHotFolderContext;
   
8. import net.alsee.hotfolder.processors.IHotFolderProcessor;
   
9. 
   
10. import org.apache.commons.httpclient.HttpClient;
    
11. import org.apache.commons.httpclient.methods.InputStreamRequestEntity;
    
12. import org.apache.commons.httpclient.methods.PostMethod;
    
13. import org.apache.log4j.Logger;
    
14. 
    
15. /**
    
16. * Processes a HTTP Post Request with the file in the HotFolder Requires:
    
17. * Jakarta Commons HTTP Client (http://jakarta.apache.org/commons/httpclient/)
    
18. *
    
19. * @author R. Albisser
    
20. */
    
21. public class HTTPPostProcessor implements IHotFolderProcessor {
    
22.     private static final String DEFAULT_CONTENT_TYPE = "text/xml; charset=ISO-8859-1";
    
23. 
    
24.     private static final Logger log = Logger.getLogger(HTTPPostProcessor.class);
    
25. 
    
26.     private IHotFolderContext ctx;
    
27. 
    
28.     /**
    
29.      * @see net.alsee.hotfolder.processors.IHotFolderProcessor#fileProcess(java.io.File,
    
30.      *      java.lang.String)
    
31.      */
    
32.     public void fileProcess(File file, String id) {
    
33.         log.info("file: " + file.getName() + " [" + file.getAbsoluteFile()
    
34.                 + "] process!");
    
35.         process(file);
    
36.     }
    
37. 
    
38.     /**
    
39.      * @see net.alsee.hotfolder.processors.IHotFolderProcessor#fileFound(java.io.File,
    
40.      *      java.lang.String)
    
41.      */
    
42.     public void fileFound(File file, String id) {
    
43.         log.debug("file: " + file.getName() + " [" + file.getAbsoluteFile()
    
44.                 + "] found!");
    
45.     }
    
46. 
    
47.     /**
    
48.      * Method process.
    
49.      *
    
50.      * @param file
    
51.      *            File
    
52.      */
    
53.     private void process(File file) {
    
54.         processHTTPPostRequest(file);
    
55.     }
    
56. 
    
57.     private String processHTTPPostRequest(File file) {
    
58.         String url = ctx.getProperty("parameters.url");
    
59.         // url =
    
60.         // "http://vies1nyx.sie.siemens.at:8034/sap/xi/adapter_plain?namespace=http%3A//siemens.com/SIE/SIBT/xi/EUROPE/Quotation&interface=Sender_Quotation_IT&service=BS_QS_BE_QA&QOS=EO&sap-user=XIAPPLUSER1&sap-password=APPXI$1&sap-client=710";
    
61.         if (url == null || url.length() < 1) {
    
62.             log.warn("processHTTPPostRequest: Url invalid (" + url + ")");
    
63.         }
    
64.         String contentType = ctx.getProperty("parameters.contentType");
    
65.         if (contentType == null || contentType.length() < 1) {
    
66.             contentType = DEFAULT_CONTENT_TYPE;
    
67.         }
    
68.         String timeOut = ctx.getProperty("parameters.timeout");
    
69.         String responseCode = "";
    
70.         File postFile = new File(file.getAbsolutePath());
    
71.         PostMethod post = new PostMethod(url);
    
72.         HttpClient httpclient;
    
73.         FileInputStream fis = null;
    
74.         try {
    
75.             fis = new FileInputStream(postFile);
    
76.             post.setRequestEntity(new InputStreamRequestEntity(fis, postFile
    
77.                     .length()));
    
78.             post.setRequestHeader("Content-type", contentType);
    
79.             httpclient = new HttpClient();
    
80.             if (timeOut != null) {
    
81.                 try {
    
82.                     int timeOutInt = Integer.parseInt(timeOut);
    
83.                     if (timeOutInt > 1000) {
    
84.                         log.info("Set Timeout to: " + timeOutInt);
    
85.                         httpclient.setConnectionTimeout(timeOutInt);
    
86.                     }
    
87.                 } catch (Exception ignore) {
    
88.                 }
    
89.             }
    
90.             log.info("Execute HTTPPost: " + url);
    
91.             int result = httpclient.executeMethod(post);
    
92.             log.info("Response status code: " + result);
    
93.             log.debug("Response body: " + post.getResponseBodyAsString());
    
94.             responseCode = Integer.toString(result);
    
95.             // try {
    
96.             // Thread.sleep(20000);
    
97.             // } catch (InterruptedException ignore) {
    
98.             // ignore.printStackTrace();
    
99.             // }
    
100.         } catch (Exception e) {
     
101.             log.warn("Response status code: " + responseCode + " " + e);
     
102.             e.printStackTrace();
     
103.         } finally {
     
104.             try {
     
105.                 if ((responseCode == null) || (!responseCode.equals("200"))) {
     
106.                     String msg = "ResponseCode: " + responseCode + "\nUrl: "
     
107.                             + url + "\nFile: " + file.getAbsolutePath();
     
108.                     log.warn(msg);
     
109.                     ctx.sendNotificationEmail("HTTPPostProcessor Status: "
     
110.                             + responseCode + "", msg);
     
111.                 }
     
112.                 // Release current connection to the connection pool once you
     
113.                 // are
     
114.                 // done
     
115.                 try {
     
116.                     fis.close();
     
117.                 } catch (IOException e) {
     
118.                     // e.printStackTrace();
     
119.                 }
     
120.                 post.releaseConnection();
     
121.                 post = null;
     
122.                 httpclient = null;
     
123.             } catch (Exception ignore) {
     
124.                 // ignore
     
125.             }
     
126.         }
     
127.         return responseCode;
     
128.     }
     
129. 
     
130.     /**
     
131.      * @see net.alsee.hotfolder.processors.IHotFolderProcessor#setProcessorContext(net.alsee.hotfolder.core.context.IHotFolderContext)
     
132.      */
     
133.     public void setProcessorContext(IHotFolderContext procContext) {
     
134.         this.ctx = procContext;
     
135.     }
     
136. }
     

复制代码

This sample is from HotFolder project.