[유치수] [ARCUS-127] refactoring sender.

git-svn-id: http://svn.bds.nhncorp.com/pe/hippo-tomcat-profiler/trunk@482 84d0f5b1-2673-498c-a247-62c4ff18d310

src/main/java/com/profiler/sender/DataSender.java

@@ -0,0 +1,95 @@
+package com.profiler.sender;
+
+import java.io.IOException;
+import java.net.DatagramPacket;
+import java.net.DatagramSocket;
+import java.net.InetSocketAddress;
+import java.net.SocketException;
+import java.util.concurrent.LinkedBlockingQueue;
+
+import org.apache.thrift.TBase;
+import org.apache.thrift.TException;
+import org.apache.thrift.TSerializer;
+import org.apache.thrift.protocol.TBinaryProtocol;
+
+import com.profiler.config.TomcatProfilerConfig;
+import com.profiler.dto.JVMInfoThriftDTO;
+import com.profiler.dto.RequestDataListThriftDTO;
+import com.profiler.dto.RequestThriftDTO;
+
+/**
+ * 
+ * @author netspider
+ * 
+ */
+public class DataSender extends Thread {
+
+	private final LinkedBlockingQueue<TBase<?, ?>> addedQueue = new LinkedBlockingQueue<TBase<?, ?>>();
+
+	private final InetSocketAddress requestDataAddr = new InetSocketAddress(TomcatProfilerConfig.SERVER_IP, TomcatProfilerConfig.REQUEST_DATA_LISTEN_PORT);
+	private final InetSocketAddress requestTransactionDataAddr = new InetSocketAddress(TomcatProfilerConfig.SERVER_IP, TomcatProfilerConfig.REQUEST_TRANSACTION_DATA_LISTEN_PORT);
+	private final InetSocketAddress jvmDataAddr = new InetSocketAddress(TomcatProfilerConfig.SERVER_IP, TomcatProfilerConfig.JVM_DATA_LISTEN_PORT);
+
+	private static class SingletonHolder {
+		public static final DataSender INSTANCE = new DataSender();
+	}
+
+	public static DataSender getInstance() {
+		return SingletonHolder.INSTANCE;
+	}
+
+	private DataSender() {
+		setName("Data Sender");
+		setDaemon(true);
+		start();
+	}
+
+	public boolean addDataToSend(TBase<?, ?> data) {
+		return addedQueue.add(data);
+	}
+
+	public void run() {
+		while (true) {
+			DatagramSocket udpSocket = null;
+			try {
+				TBase<?, ?> dto = addedQueue.take();
+
+				TSerializer serializer = new TSerializer(new TBinaryProtocol.Factory());
+				byte[] sendData = serializer.serialize(dto);
+
+				// TODO: 포트 하나로 통일 시켜야 함. 일단 임시로 이렇게..
+				InetSocketAddress address = null;
+				if (dto instanceof RequestDataListThriftDTO) {
+					address = requestDataAddr;
+				} else if (dto instanceof RequestThriftDTO) {
+					address = requestTransactionDataAddr;
+				} else if (dto instanceof JVMInfoThriftDTO) {
+					address = jvmDataAddr;
+				}
+
+				if (address == null) {
+					throw new IllegalArgumentException("Can't resolve receiver address.");
+				}
+
+				DatagramPacket packet = new DatagramPacket(sendData, sendData.length, address);
+
+				udpSocket = new DatagramSocket();
+				udpSocket.send(packet);
+
+				System.out.println("data sent.");
+			} catch (InterruptedException e) {
+				e.printStackTrace();
+			} catch (TException e) {
+				e.printStackTrace();
+			} catch (SocketException e) {
+				e.printStackTrace();
+			} catch (IOException e) {
+				e.printStackTrace();
+			} finally {
+				if (udpSocket != null) {
+					udpSocket.close();
+				}
+			}
+		}
+	}
+}