Java中使用多线程、curl及代理IP模拟post提交和get訪问

Java中使用多线程、curl及代理IP模拟post提交和get訪问

菜鸟，多线程好玩就写着玩。大神能够路过不吝赐教。小弟在这受教。谢谢！

很多其它分享请关注微信公众号：lvxing1788

~~~~~~ 切割线扭起来 ~~~~~~

/** 
 * @组件名：javaDemo
 * @包名：javaDemo
 * @文件名称：Jenny.java
 * @创建时间： 2014年8月1日 下午5:53:48
 * @版权信息：Copyright © 2014 eelly Co.Ltd,小姨子版权全部。
 */

package javaDemo;

import java.io.BufferedReader;
import java.io.File;
import java.io.FileWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.io.Writer;
import java.net.URL;
import java.net.URLConnection;
import java.util.List;
import java.util.Map;
import java.util.Random;

/**
 * 用于异常的抛出而定义，由于Exception不能抛出。仅仅有子类才干
 */
class MyException extends Exception {

    private static final long serialVersionUID = -1485825968429580934L;

    public MyException() {
        super();
    }

    public MyException(String msg) {
        super(msg);
    }

    public MyException(String msg, Throwable cause) {
        super(msg, cause);
    }

    public MyException(Throwable cause) {
        super(cause);
    }
}

/**
 * 一个小姨子须要的线程类
 */
class ShiMengRen implements Runnable {

    /**
     * 浏览量的链接
     */
    private String url = "http://www.*******.com/article/yj/views.jhtml";

    /**
     * 点赞的链接
     */
    private String urlZan = "http://www.********.com/article/yj/ups.jhtml";

    /**
     * 游记的ID
     */
    private String param = "article_id=10844";

    /**
     * 多线程共享的全局变量
     */
    // private volatile boolean flag = true;

    /**
     * 同一时候进入post提交的线程数
     */
    private static final int MAX_THREAD_COUNT = 25;

    /**
     * 同一时候进入post提交的线程数的计数器
     */
    private volatile static int threadNum = 0;

    /**
     * 计数
     */
    private static int num = 0;

    /**
     * 浏览次数
     */
    private static int view = 0;

    /**
     * 代理IP
     */
    private String[] proxyArray = { "127.0.0.1:8787", "115.239.210.199:80", "149.255.255.242:80",
            "124.172.242.175:80", "117.59.217.243:80", "183.234.59.89:18186", "117.59.217.236:80",
            "183.224.1.56:80", "120.202.249.230:80", "125.46.100.198:9999", "112.65.19.122:8080",
            "202.96.172.234:808", "183.224.1.114:80", "183.224.1.113:80", "222.66.115.229:80" };

    // public void setFlag(boolean flag) {
    // this.flag = flag;
    // }
    //
    // public boolean getFlag() {
    // return this.flag;
    // }
    //
    // public void stop() {
    // this.setFlag(false);
    // }
    //
    // public void start() {
    // this.setFlag(true);
    // }

    public void setNum(int num) {
        ShiMengRen.num = num;
    }

    public int getNum() {
        return ShiMengRen.num;
    }

    public void setThreadNum(int threadNum) {
        ShiMengRen.threadNum = threadNum;
    }

    public int getThreadNum() {
        return ShiMengRen.threadNum;
    }

    public int getView() {
        return ShiMengRen.view;
    }

    /**
     * @方法名：getProxy
     * @描写叙述：随机获代替理IP
     * @创建人：<a href=mailto: 529901956@qq.com>小姨子的姐夫</a>
     * @改动人：
     * @改动时间：2014年8月18日 上午9:23:36
     * @return
     * @返回值：String[]
     * @异常说明：
     */
    public String[] getProxy() {
        String[] strlist = null;
        int len = proxyArray.length - 1;
        int num = 0;
        if (0 < len) {
            num = new Random().nextInt(len);
        }
        String proxy = this.proxyArray[num];
        if (proxy != "") {
            strlist = proxy.split(":");
        }

        return strlist;
    }

    /**
     * @方法名：sendGet
     * @描写叙述：向指定URL发送GET方法的请求
     * @创建人：<a href=mailto: 529901956@qq.com>小姨子的姐夫</a>
     * @改动人：
     * @改动时间：2014年8月18日 上午9:26:27
     * @param url
     *            发送请求的URL
     * @param param
     *            请求參数，请求參数应该是 name1=value1&name2=value2 的形式。
     * @return URL 所代表远程资源的响应结果
     * @返回值：String
     * @异常说明：
     */
    public String sendGet(String url, String param) {
        String result = "";
        BufferedReader in = null;

        String[] proxyList = this.getProxy();
        if (null != proxyList) {
            System.setProperty("http.proxySet", "true");
            System.setProperty("http.proxyHost", proxyList[0]);
            System.setProperty("http.proxyPort", proxyList[1]);
        }
        try {
            String urlNameString = url + "?
" + param;
            URL realUrl = new URL(urlNameString);
            // 打开和URL之间的连接
            URLConnection connection = realUrl.openConnection();
            // 设置通用的请求属性
            connection.setRequestProperty("accept", "*/*");
            connection.setRequestProperty("connection", "Keep-Alive");
            connection.setRequestProperty("user-agent",
                    "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
            // 建立实际的连接
            connection.connect();
            // 获取全部响应头字段
            Map<String, List<String>> map = connection.getHeaderFields();
            // 遍历全部的响应头字段
            for (String key : map.keySet()) {
                System.out.println(key + "--->" + map.get(key));
            }
            // 定义 BufferedReader输入流来读取URL的响应
            in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
            String line;
            while ((line = in.readLine()) != null) {
                result += line;
            }
        } catch (Exception e) {
            System.out.println("发送GET请求出现异常！" + e);
            e.printStackTrace();
        }
        // 使用finally块来关闭输入流
        finally {
            try {
                if (in != null) {
                    in.close();
                }
            } catch (Exception e2) {
                e2.printStackTrace();
            }
        }

        return result;
    }

    /**
     * @方法名：sendPost
     * @描写叙述：向指定 URL 发送POST方法的请求
     * @创建人：<a href=mailto: 529901956@qq.com>小姨子的姐夫</a>
     * @改动人：
     * @改动时间：2014年8月18日 上午9:29:09
     * @param url
     *            发送请求的 URL
     * @param param
     *            请求參数。请求參数应该是 name1=value1&name2=value2 的形式。

     * @return 所代表远程资源的响应结果
     * @throws Exception
     * @返回值：String
     * @异常说明：
     */
    public String sendPost(String url, String param) throws Exception {
        PrintWriter out = null;
        BufferedReader in = null;
        String result = "";

        String[] proxyList = this.getProxy();
        if (null != proxyList) {
            System.setProperty("http.proxySet", "true");
            System.setProperty("http.proxyHost", proxyList[0]);
            System.setProperty("http.proxyPort", proxyList[1]);
        }
        try {
            URL realUrl = new URL(url);
            // 打开和URL之间的连接
            URLConnection conn = realUrl.openConnection();
            // 设置通用的请求属性
            conn.setRequestProperty("accept", "*/*");
            conn.setRequestProperty("connection", "Keep-Alive");
            conn.setRequestProperty("user-agent",
                    "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
            // 发送POST请求必须设置例如以下两行
            conn.setDoOutput(true);
            conn.setDoInput(true);
            // 获取URLConnection对象相应的输出流
            out = new PrintWriter(conn.getOutputStream());
            // 发送请求參数
            out.print(param);
            // flush输出流的缓冲
            out.flush();
            // 定义BufferedReader输入流来读取URL的响应
            in = new BufferedReader(new InputStreamReader(conn.getInputStream()));
            String line;
            while ((line = in.readLine()) != null) {
                result += line;
            }
        } catch (Exception e) {
            throw new MyException("发送 POST 请求出现异常！" + e);
            // System.out.println("发送 POST 请求出现异常！" + e);
            // e.printStackTrace();
        }
        // 使用finally块来关闭输出流、输入流
        finally {
            try {
                if (out != null) {
                    out.close();
                }
                if (in != null) {
                    in.close();
                }
            } catch (IOException ex) {
                throw new MyException("发送 POST 请求出现异常！
" + ex);
                // ex.printStackTrace();
            }
        }

        return result;
    }

    /**
     * @方法名：plusNum
     * @描写叙述：总线程数的计数
     * @创建人：<a href=mailto: 529901956@qq.com>小姨子的姐夫</a>
     * @改动人：
     * @改动时间：2014年8月18日 上午9:29:53
     * @返回值：void
     * @异常说明：
     */
    public void plusNum() {
        ShiMengRen.num++;
    }

    /**
     * @方法名：reductionNum
     * @描写叙述：总线程数的计数
     * @创建人：<a href=mailto: 529901956@qq.com>小姨子的姐夫</a>
     * @改动人：
     * @改动时间：2014年8月18日 上午9:30:03
     * @返回值：void
     * @异常说明：
     */
    public void reductionNum() {
        ShiMengRen.num--;
        ShiMengRen.num = ShiMengRen.num < 0 ? 0 : ShiMengRen.num;
    }

    /**
     * @方法名：plusThreadNum
     * @描写叙述：并发线程数计数（事实上也不算是并发），使用同步标识符，防止多线程的干扰
     * @创建人：<a href=mailto: 529901956@qq.com>小姨子的姐夫</a>
     * @改动人：
     * @改动时间：2014年8月18日 上午9:30:22
     * @返回值：void
     * @异常说明：
     */
    public synchronized void plusThreadNum() {
        ShiMengRen.threadNum++;
    }

    /**
     * @方法名：reductionThreadNum
     * @描写叙述：并发线程数计数（事实上也不算是并发），使用同步标识符，防止多线程的干扰
     * @创建人：<a href=mailto: 529901956@qq.com>小姨子的姐夫</a>
     * @改动人：
     * @改动时间：2014年8月18日 上午9:30:28
     * @返回值：void
     * @异常说明：
     */
    public synchronized void reductionThreadNum() {
        ShiMengRen.threadNum--;
        ShiMengRen.threadNum = ShiMengRen.threadNum < 0 ? 0 : ShiMengRen.threadNum;
    }

    /**
     * @方法名：plusView
     * @描写叙述：浏览量计数。使用同步标识符。防止多线程的干扰
     * @创建人：<a href=mailto: 529901956@qq.com>小姨子的姐夫</a>
     * @改动人：
     * @改动时间：2014年8月18日 上午9:30:33
     * @返回值：void
     * @异常说明：
     */
    public synchronized void plusView() {
        ShiMengRen.view++;
    }

    /**
     * @方法名：runShiMengRen
     * @描写叙述：调用sendPost的方法，以及各种计数
     * @创建人：<a href=mailto: 529901956@qq.com>小姨子的姐夫</a>
     * @改动人：
     * @改动时间：2014年8月18日 上午9:30:37
     * @throws MyException
     * @throws InterruptedException
     * @返回值：void
     * @异常说明：
     */
    public void runShiMengRen() throws MyException, InterruptedException {
        this.plusNum();
        try {
            Thread.sleep(new Random().nextInt(2000));
            if (ShiMengRen.MAX_THREAD_COUNT > this.getThreadNum()) {
                this.plusThreadNum(); // 计数器自增
                String result = sendPost(this.url, this.param); // 刷浏览数
                sendPost(this.urlZan, this.param); // 刷点赞数
                if (result.equals("1")) {
                    this.plusView();
                    this.jennyLog("浏览次数：" + this.getView() + "
");
                }
            }
        } catch (Exception e) {
            Thread.sleep(2000);
            throw new MyException("站点出现异常，停止全部线程.");
        }

        finally {
            System.out.println("等待运行线程队列：" + this.getNum() + "。当前异步线程数量：" + this.getThreadNum()
                    + "，浏览次数：" + this.getView());
            this.reductionNum();
            this.reductionThreadNum();
        }
    }

    /**
     * @方法名：jennyLog
     * @描写叙述：小姨子的日志记录，仅仅为看浏览量的变化
     * @创建人：<a href=mailto: 529901956@qq.com>小姨子的姐夫</a>
     * @改动人：
     * @改动时间：2014年8月18日 上午9:30:52
     * @param data
     * @throws IOException
     * @返回值：void
     * @异常说明：
     */
    public void jennyLog(String data) throws IOException {
        File file = new File("/home/beyond/tmp/Jenny.log.txt");
        // File file = new File("E:\Jenny.log.txt");
        if (!file.getParentFile().exists()) {
            file.getParentFile().mkdirs();
        }
        Writer out = new FileWriter(file);
        out.write(data);
        out.close();
    }

    /**
     * <p>
     * 主题：run
     * </p>
     * <p>
     * 描写叙述：往死里拼命的Post提交数据
     * </p>
     * 
     * @see java.lang.Runnable#run()
     */
    @Override
    public void run() {
        for (;;) {
            try {
                this.runShiMengRen();
            } catch (Exception e) {
                System.out.println("发送 POST 请求出现异常.");
            }
        }
    }
}

/**
 * @类名：Jenny
 * @描写叙述:小姨子类
 * @创建人：<a href=mailto: 529901956@qq.com>小姨子的姐夫</a>
 * @改动人：
 * @改动时间：2014年8月1日 下午5:53:48
 * @改动说明：<br/>
 * @版本号信息：V1.0.0<br/>
 */
public class JennyThread {

    /**
     * @方法名：main
     * @描写叙述：小姨子的主方法
     * @创建人：<a href=mailto: 529901956@qq.com>小姨子的姐夫</a>
     * @改动人：
     * @改动时间：2014年8月1日 下午5:53:48
     * @param args
     * @throws Exception
     * @返回值：void
     * @异常说明：
     */
    public static void main(String[] args) {
        Runnable t = new ShiMengRen();
        for (int i = 0; i < 60; i++) {
            new Thread(t, "Thread-" + i).start();
        }
    }
}

~~~~~~ 切割线扭起来 ~~~~~~

很多其它分享请关注微信公众号：lvxing1788