package testJava;import java.io.DataOutputStream;
import java.net.ConnectException;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;public class CallableTest {final int ThreadPoolSize = 30;ExecutorService executorService;　　// 在外面只要调用sendRequest()这个方法就可以了public boolean sendRequest() {boolean result =false;try {executorService = Executors.newFixedThreadPool(ThreadPoolSize);　　　　　　　// 这里就是调用Callable的使用方法, 用get得到返回的结果 Future tvFuture = executorService.submit(new TestCallable("192.168.0.11", 80));result = (boolean) tvFuture.get();        } catch (Exception e) {System.out.println(e.getMessage());}return result;}class TestCallable implements Callable {private String ip;private int port;public TestCallable(String ip, int port){this.ip = ip;this.port = port;}@Overridepublic Object call() throws Exception {// TODO Auto-generated method stubreturn testCall(ip, port);}        }private boolean testCall(String ip, int port) {boolean result = false;try {URL url = new URL("http://" + ip + ":" + port + "/WIXP");String data = "testData";HttpURLConnection connection = (HttpURLConnection) url.openConnection();connection.setRequestMethod("POST");connection.setConnectTimeout(20*1000);connection.setRequestProperty("Content-Type","application/x-www-form-urlencoded");connection.setRequestProperty("Content-Length", ""+ Integer.toString(data.getBytes().length));connection.setRequestProperty("Content-Language", "en-US");connection.setUseCaches(false);connection.setDoInput(true);connection.setDoOutput(true);try (DataOutputStream wr = new DataOutputStream(connection.getOutputStream());) {wr.writeBytes(data);wr.flush();} catch (ConnectException e) {System.out.println(e.getMessage());} catch (Exception e) {System.out.println(e.getMessage());}if (connection.getResponseCode() == 200) { result = true;}} catch (Exception e) {System.out.println(e.getMessage());}return result;}}