Java Batch Client - Revision history

Padro at 11:05, 21 January 2016

2016-01-21T11:05:55Z

Padro at 11:05, 21 January 2016

2016-01-21T11:05:00Z

Padro at 12:12, 20 January 2016

2016-01-20T12:12:21Z

Padro at 12:12, 20 January 2016

2016-01-20T12:12:14Z

Padro: Created page with " "

2016-01-20T12:11:14Z

Created page with "<syntaxhighlight lang="java" line="1" > </syntaxhighlight>"

New page

@@ Line 73: / Line 73: @@
          // Server response should include a job tokenID, retrieve it
          Pattern pattern = Pattern.compile("<job_token_id>(.*)</job_token_id>");
          Matcher matcher = pattern.matcher(content);

@@ Line 10: / Line 10: @@
 //
 ////////////////////////////////////////////////////////////////////////////
 import org.apache.http.client.HttpClient;
@@ Line 39: / Line 40: @@
          System.out.print("Input ZIP file: ");
          String fname = System.console().readLine();
          System.out.print("Language: ");
          String lang = System.console().readLine();
@@ Line 85: / Line 84: @@
+         }
-         System.out.println("Job submitted. Token ID= "+tokenID);
+         System.out.println("Job submitted. Token ID="+tokenID);
-−
-        // prepare request to poll for completion and retrieve results
-        request = new HttpPost(textServer_URL+"/resultRetrieve");
-        request.setEntity(MultipartEntityBuilder
-                          .create()
-                          .addTextBody("username", user)
-                          .addTextBody("tokenID", tokenID)
-                          .build() );
-−
-        int seconds=20;
-        while (true) {
-−
-            System.out.print("Sleeping "); System.out.print(seconds); System.out.println(" seconds");
-            Thread.sleep(seconds*1000);
-−
-            System.out.println("Polling server for job completion");
-            response = client.execute(request);
-            content = EntityUtils.toString(response.getEntity());
-−
-            // if status is OK, we got response, end waiting loop
-            if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK)
-                break;
-−
-            // we got an error code, lets see which one
-            if (response.getStatusLine().getStatusCode()==HttpStatus.SC_SERVICE_UNAVAILABLE &&
-                content.substring(0,8).equals("[TS-125]") ) {
-                // SC=503 and TS_code=TS-125 mean job is not finished. keep waiting
-                System.out.println("Job not finished yet.");
-                continue;
-−
-            else {
-                // some unexpected error happened
-                System.out.println(content);
-                System.exit(1);
-−
-−
-−
-	// write the received ZIP result to output file
-        System.out.println("Job finished. Saving results to "+outfname);
-−
-        InputStream sin = response.getEntity().getContent();
-        byte data[] = new byte[sin.available()];
-        sin.read(data);
-−
-        FileOutputStream outf = new FileOutputStream(outfname);
-        outf.write(data);
-        outf.close();
+     }
+}
 </syntaxhighlight>

@@ Line 10: / Line 10: @@
 //
 ////////////////////////////////////////////////////////////////////////////
 import org.apache.http.client.HttpClient;

← Older revision		Revision as of 12:12, 20 January 2016
Line 1:		Line 1:
	<syntaxhighlight lang="java" line="1" >		<syntaxhighlight lang="java" line="1" >
		+	////////////////////////////////////////////////////////////////////////////
		+	//
		+	// Example client to submit a batch request to TextServer
		+	// SERVICENAME service, and wait for the job to be finished.
		+	//
		+	// Input must be a ZIP file containing one or more text files to analyze
		+	// Output will be a ZIP file containing results for each input file in
		+	// the requested format (XML, json, conll)
		+	//
		+	////////////////////////////////////////////////////////////////////////////
		+
		+
		+	import org.apache.http.client.HttpClient;
		+	import org.apache.http.HttpResponse;
		+	import org.apache.http.HttpStatus;
		+	import org.apache.http.entity.mime.content.FileBody;
		+
		+	import org.apache.http.client.methods.HttpPost;
		+	import org.apache.http.entity.mime.MultipartEntityBuilder;
		+	import org.apache.http.impl.client.HttpClientBuilder;
		+	import org.apache.http.util.EntityUtils;
		+
		+	import java.io.File;
		+	import java.io.InputStream;
		+	import java.io.FileOutputStream;
		+
		+	import java.util.regex.Matcher;
		+	import java.util.regex.Pattern;
		+
		+	public class SERVICENAMEClientBatch {
		+
		+	// service base URL
		+	static final String textServer_URL = "http://frodo.lsi.upc.edu:8080/TextWS/textservlet/ws";
		+	static final String service = "SERVICENAME";
		+
		+	public static void main(String[] args) throws Exception {
		+
		+	// Get request parameters
		+	System.out.print("Input ZIP file: ");
		+	String fname = System.console().readLine();
		+	System.out.print("Output ZIP file: ");
		+	String outfname = System.console().readLine();
		+	System.out.print("Language: ");
		+	String lang = System.console().readLine();
		+	System.out.print("Output format (xml,json,conll,naf): ");
		+	String out = System.console().readLine();
		+	System.out.print("TextServer Username: ");
		+	String user = System.console().readLine();
		+	System.out.print("TextServer Password: ");
		+	String pwd = System.console().readLine();
		+
		+	// Create request, fill query parameters
		+	HttpPost request = new HttpPost(textServer_URL+"/processQuery/"+service);
		+	request.setEntity(MultipartEntityBuilder
		+	.create()
		+	.addTextBody("username", user)
		+	.addTextBody("password", pwd)
		+	.addPart("file", new FileBody(new File(fname)))
		+	.addTextBody("language", lang)
		+	.addTextBody("output", out)
		+	.addTextBody("interactive", "0")
		+	.build() );
		+
		+	// create client, send request, get response
		+	HttpClient client = HttpClientBuilder.create().build();
		+	HttpResponse response = client.execute(request);
		+	String content = EntityUtils.toString(response.getEntity());
		+
		+	// check for communication errors
		+	if (response.getStatusLine().getStatusCode() != HttpStatus.SC_OK) {
		+	System.out.println(response.getStatusLine() + " - " + content);
		+	System.exit(1);
		+	}
		+
		+	// Server response should include a job tokenID, retrieve it
		+	Pattern pattern = Pattern.compile("<job_token_id>(.*)</job_token_id>");
		+	Matcher matcher = pattern.matcher(content);
		+	String tokenID="";
		+	if (matcher.find())
		+	tokenID = matcher.group(1);
		+	else {
		+	// unexpected response
		+	System.out.println(content);
		+	System.exit(1);
		+	}
		+
		+	System.out.println("Job submitted. Token ID= "+tokenID);
		+
		+	// prepare request to poll for completion and retrieve results
		+	request = new HttpPost(textServer_URL+"/resultRetrieve");
		+	request.setEntity(MultipartEntityBuilder
		+	.create()
		+	.addTextBody("username", user)
		+	.addTextBody("tokenID", tokenID)
		+	.build() );
		+
		+	int seconds=20;
		+	while (true) {
		+
		+	System.out.print("Sleeping "); System.out.print(seconds); System.out.println(" seconds");
		+	Thread.sleep(seconds*1000);
		+
		+	System.out.println("Polling server for job completion");
		+	response = client.execute(request);
		+	content = EntityUtils.toString(response.getEntity());
		+
		+	// if status is OK, we got response, end waiting loop
		+	if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK)
		+	break;
		+
		+	// we got an error code, lets see which one
		+	if (response.getStatusLine().getStatusCode()==HttpStatus.SC_SERVICE_UNAVAILABLE &&
		+	content.substring(0,8).equals("[TS-125]") ) {
		+	// SC=503 and TS_code=TS-125 mean job is not finished. keep waiting
		+	System.out.println("Job not finished yet.");
		+	continue;
		+	}
		+	else {
		+	// some unexpected error happened
		+	System.out.println(content);
		+	System.exit(1);
		+	}
		+	}
		+
		+	// write the received ZIP result to output file
		+	System.out.println("Job finished. Saving results to "+outfname);
		+
		+	InputStream sin = response.getEntity().getContent();
		+	byte data[] = new byte[sin.available()];
		+	sin.read(data);
		+
		+	FileOutputStream outf = new FileOutputStream(outfname);
		+	outf.write(data);
		+	outf.close();
		+	}
		+	}
	</syntaxhighlight>		</syntaxhighlight>