update

pom.xml

@@ -220,6 +220,19 @@
 			<version>2.9.0</version>
 		</dependency>
 		
+		<!-- https://mvnrepository.com/artifact/com.rabbitmq/amqp-client -->
+		<dependency>
+		    <groupId>com.rabbitmq</groupId>
+		    <artifactId>amqp-client</artifactId>
+		    <version>5.7.3</version>
+		</dependency>
+
+		<dependency>
+			<groupId>org.elasticsearch</groupId>
+			<artifactId>elasticsearch</artifactId>
+			<version>1.7.6</version>
+		</dependency>
+	
 	</dependencies>
 	
 	<build>

src/main/java/kr/co/swh/lecture/opensource/elasticsearch/App.java

@@ -0,0 +1,49 @@
+package kr.co.swh.lecture.opensource.elasticsearch;
+
+import java.io.IOException;
+import java.util.Date;
+
+import org.elasticsearch.ElasticsearchException;
+import org.elasticsearch.action.delete.DeleteResponse;
+import org.elasticsearch.action.get.GetResponse;
+import org.elasticsearch.action.index.IndexResponse;
+import org.elasticsearch.client.Client;
+import org.elasticsearch.client.transport.TransportClient;
+import org.elasticsearch.common.settings.ImmutableSettings;
+import org.elasticsearch.common.settings.Settings;
+import org.elasticsearch.common.transport.InetSocketTransportAddress;
+import org.elasticsearch.node.Node;
+import org.elasticsearch.node.NodeBuilder;
+
+import static org.elasticsearch.node.NodeBuilder.*;
+import static org.elasticsearch.common.xcontent.XContentFactory.*;
+
+public class App {
+
+	public static void main(String[] args) {
+		Settings settings = ImmutableSettings.settingsBuilder()
+				.put("cluster.name", "elasticsearch")
+				.build();
+		TransportClient client = new TransportClient(settings)
+		.addTransportAddress(new InetSocketTransportAddress("dev-swh.ga", 9300));
+
+		IndexResponse index_response = null;
+		try {
+			index_response = client.prepareIndex("twitter", "tweet", "1")
+			        .setSource(jsonBuilder()
+			                    .startObject()
+			                        .field("user", "kimchy")
+			                        .field("postDate", new Date())
+			                        .field("message", "trying out Elasticsearch")
+			                    .endObject()
+			                  )
+			        .execute()
+			        .actionGet();
+		} catch (ElasticsearchException e) {
+			e.printStackTrace();
+		} catch (IOException e) {
+			e.printStackTrace();
+		}
+		client.close();;
+	}
+}

src/main/java/kr/co/swh/lecture/opensource/jsoup/news/NaverNewsCrawlSource.java

@@ -75,8 +75,8 @@ public class NaverNewsCrawlSource
 	public void init() {
 		domain = "naver";
 		category = new String[]{"politics"};
-		startDate = "20191019";
-		endDate = "20191020";
+		startDate = "20191117";
+		endDate = "20191117";
 		fastMode = false;
 		service = new NaverCrawlManager(domain, startDate, endDate, category, fastMode);
 		
@@ -91,7 +91,7 @@ public class NaverNewsCrawlSource
 	public static void main(String[] args) {
 		
 		NaverNewsCrawlSource source = new NaverNewsCrawlSource();
-//		source.init();
+		source.init();
 		System.out.println(NaverCrawlManager.totalDayFromCalendar(2019,10,20));
 		System.out.println(NaverCrawlManager.endDayFromTotalDay(2019,10));
 //		System.out.println(StringUtils.leftPad(String.valueOf(1), 2, "0"));

src/main/java/kr/co/swh/lecture/opensource/rabbitmq/Publisher.java

@@ -0,0 +1,28 @@
+package kr.co.swh.lecture.opensource.rabbitmq;
+
+import java.io.IOException;
+import java.util.concurrent.TimeoutException;
+
+import com.rabbitmq.client.Channel;
+import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.ConnectionFactory;
+
+public class Publisher {
+
+	private final static String QUEUE_NAME = "hello";
+
+	public static void main(String[] args) throws IOException, TimeoutException {
+		ConnectionFactory factory = new ConnectionFactory();
+		factory.setHost("dev-swh.ga");
+		Connection connection = factory.newConnection();
+		Channel channel = connection.createChannel();
+
+		channel.queueDeclare(QUEUE_NAME, false, false, false, null);
+		String message = "Hello World!";
+		channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
+		System.out.println(" [x] Sent '" + message + "'");
+
+		channel.close();
+		connection.close();
+	}
+}

src/main/java/kr/co/swh/lecture/opensource/rabbitmq/Receiver.java

@@ -0,0 +1,31 @@
+package kr.co.swh.lecture.opensource.rabbitmq;
+
+import java.io.IOException;
+import java.util.concurrent.TimeoutException;
+import com.rabbitmq.client.AMQP;
+import com.rabbitmq.client.Channel;
+import com.rabbitmq.client.Connection;
+import com.rabbitmq.client.ConnectionFactory;
+import com.rabbitmq.client.Consumer;
+import com.rabbitmq.client.DefaultConsumer;
+import com.rabbitmq.client.Envelope;
+public class Receiver {
+	private final static String QUEUE_NAME = "hello";
+	public static void main(String[] argv) throws IOException, TimeoutException {
+		ConnectionFactory factory = new ConnectionFactory();
+		factory.setHost("dev-swh.ga");
+		Connection connection = factory.newConnection();
+		Channel channel = connection.createChannel();
+		channel.queueDeclare(QUEUE_NAME, false, false, false, null);
+		System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
+		Consumer consumer = new DefaultConsumer(channel) {
+			@Override
+			public void handleDelivery(String consumerTag, Envelope envelope,
+					AMQP.BasicProperties properties, byte[] body) throws IOException {
+				String message = new String(body, "UTF-8");
+				System.out.println(" [x] Received '" + message + "'");
+			}
+		};
+		channel.basicConsume(QUEUE_NAME, true, consumer);
+	}
+}