Java_SDK.tar.gz_etl程序

package com.bw.javasdk; import java.util.concurrent.BlockingQueue; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.LinkedBlockingDeque; import com.bw.javasdk.utils.HttpRequestUtil; /** * * @Title: SendMonitor.java * @Package com.bw.javasdk * @Description: 负责发送url到nginx服务器 * @author: sgx * @date: 2018年6月26日 上午10:30:34 * @version V1.0 */ //这个Monitor实际上监控的是一个线程安全url队列 //为了和唯一队列匹配 节约资源 这个Monitor应该是单例 public class SendMonitor { //定义一个线程安全的队列 用于存放url private static BlockingQueue<String> url_queue = new LinkedBlockingDeque<String>(); //定一个唯一的一个可用实例 private static SendMonitor sendMonitor; //定义一个私有的构造方法 private SendMonitor(){} //定义一个对外可以访问的提供实例的方法 public static SendMonitor getInstance(){ if (sendMonitor==null) { //因为方法是静态方法 它是属于类的不是属于对象的 //所以在这里直接选用字节码对象做同步锁 //处理多线程安全性的方法: //1:synchronized 同步锁 //2:ThreadLocal 本地线程 //3:volatile 线程间变量共享 synchronized (SendMonitor.class) { //如果是null 则需要创建一个唯一实例 sendMonitor = new SendMonitor(); //开始监控url队列 //需要使用多线程 把监控队列中是否有待发送的url //和发送url 要作为线程的执行任务 //1:先要使用一个线程服务 (只需要一个线程即可) //常用的线程池?池化? //a:newCachedThreadPool 内存/缓存线程池 //b:newFixedThreadPool(int nThreads) 固定线程池 //c:newSingleThreadExecutor() 单一线程池 ExecutorService es = Executors.newSingleThreadExecutor(); //2:使用线程服务执行业务方法 es.execute(new Runnable() { @Override public void run() { //这个线程需要执行的业务方法 sendURL(); } }); } } return sendMonitor; } //此监控器需要执行的发送url的业务方法 private static void sendURL(){ String url = null; //1:从队列取出一个url try { url = url_queue.take(); if (url!=null) { //2:发送这个url HttpRequestUtil.sendGet(url); } } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } } /** * * @Title: addURL * @Description: 往队列中加入url * @param: String 待发送的url * @return: null * @throws: null */ public static void addURL(String url){ getInstance().url_queue.add(url); } }