public class HttpConnProcessThread implements Runnable {

    public boolean isStop = false;

    public boolean readOK = false;

    private HttpURLConnection reqConnection = null;

    public Thread readingThread;

    private int readLen;

    private String msg = null;

    private String reqMethod;

    private byte[] data;

    /**

     * ReadThread constructor comment.

     */

    public HttpConnProcessThread(HttpURLConnection reqConnection, String msg, String reqMethod ) {

        super();

        this.reqConnection = reqConnection;

        this.msg = msg;

        this.reqMethod = reqMethod;

    }

    public void run() {

        InputStream input = null;

        OutputStream output = null;

        try{

            //reqConnection.connect();

            output = reqConnection.getOutputStream();

            if ("post".equalsIgnoreCase(reqMethod) && msg != null && msg.length() >0)

            {

                output.write(msg.getBytes());

                output.close();

                output = null;

            }

            // 处理HTTP响应的返回状态信息

            int responseCode = reqConnection.getResponseCode();// 响应的代码if( responseCode != 200 )

                System.out.println("connect failed! responseCode = " + responseCode + " msg=" + reqConnection.getResponseMessage());

            input = reqConnection.getInputStream();

            int len;

            byte[] buf = new byte[2048];

            readLen = 0;

            ByteArrayOutputStream outStream = new ByteArrayOutputStream();

　　　　　　　// 读取inputStream

            while (!isStop)

            {

                len = input.read(buf);

                if (len <= 0)

                {

                    this.readOK = true;

                    input.close();

                    data=outStream.toByteArray();

                    break;

                }

                outStream.write(buf, 0, len);

                readLen += len;

            }

        }

        catch( IOException ie)

        {}

        catch(Exception e)

        {}

        finally

        {

            try{

                reqConnection.disconnect();

                if( input != null )

                    input.close();

                if( output != null )

                    output.close();

                //唤醒线程，跳出等待

                wakeUp();

            }catch(Exception e)

            {

            }

        }

    }

    public String getMessage(){

        if (!readOK) //超时

        {

            return "";

        }

        if (readLen <= 0) {

            return "";

        }

        return new String(data, 0, readLen);

    }

    public void startUp() {

        this.readingThread = new Thread(this);

        readingThread.start();

    }

    //唤醒线程，不再等待

    private synchronized void wakeUp() {

        notifyAll();

    }

    public synchronized void waitForData(int timeout)

    {

        try {

            //指定超时时间，等待connection响应

            wait(timeout);

        }

        catch (Exception e)

        {

        }

        if (!readOK)

        {

            isStop = true;

            try{

                //中断线程

                if( readingThread.isAlive() )

                    readingThread.interrupt();

            }catch(Exception e)

            {

            }

        }

    }

    public static main(String[] args){

        String msg="";

        URL reqUrl = new URL("http://127.0.0.1:8080/");

        // 建立URLConnection连接

        reqConnection = (HttpURLConnection) reqUrl.openConnection();

        HttpConnProcessThread rec = new HttpConnProcessThread(reqConnection, msg, "post" );

        rec.startUp();
　　     // 如果顺利连接到并读完数据，则跳出等待，否则等待超时

        rec.waitForData(2000);

        String retMessage = rec.getMessage();

    }

}