Java

[Java] 105. 공공 데이터 포탈 사용하기

Song hyun 2024. 6. 4. 15:22
728x90
반응형

[Java] 105. 공공 데이터 포탈 사용하기

1. 공공데이터포털 사용해보기

2. 공공데이터포털 API 활용하여 HTTP 서버 생성하기

 


1. 공공데이터포털 사용해보기

 

공공데이터포털을 사용하면 많은 Open API 자료들을 사용할 수 있다. 아래의 주소에서 회원가입을 한 뒤, 공공데이터 포털 사이트를 활용해보자.


(공공 데이터 포털 사이트 : https://www.data.go.kr/tcs/opd/ndm/view.do)

 

공공데이터 포털

국가에서 보유하고 있는 다양한 데이터를『공공데이터의 제공 및 이용 활성화에 관한 법률(제11956호)』에 따라 개방하여 국민들이 보다 쉽고 용이하게 공유•활용할 수 있도록 공공데이터(Datase

www.data.go.kr

 

가입을 마쳤다면 Open API를 사용할 수 있는 권한을 신청할 수 있다. 공공데이터포털 사이트에서 [데이터찾기]-[데이터목록]으로 들어가면 아래와 같이 사용할 수 있는 open API 목록이 나타난다. (하지만 데이터와 발행처에 따라 신청 방식이 조금씩 다를 수도 있다.)

 

*API(Application Programming Interface): 인터페이스(약속)을 지켜 값을 주면, 정해진 과정에 따라 답을 도출하는(=응답하는) 프로그램.

 

활용승인 절차 개발단계는 우리가 신청한 활용승인이 어떻게 승인되는지를 보여준다. '자동승인'의 경우, 기존에 입력된 시스템에 따라 자동적으로 승인되는 방식이다. 

 

요청변수(Request Parameter)와 출력결과(Response Elements)역시 볼 수 있다. 요청 변수는 우리가 입력하는 값이며, 출력결과는 요청변수에 따라 Open API가 도출해내는 값들이다.

 

사이트 하단에서는 각 언어에 맞는 샘플코드들을 살펴볼 수 있다.

/* Java 1.8 샘플 코드 */


import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.io.BufferedReader;
import java.io.IOException;

public class ApiExplorer {
    public static void main(String[] args) throws IOException {
        StringBuilder urlBuilder = new StringBuilder("http://apis.data.go.kr/B552584/UlfptcaAlarmInqireSvc/getUlfptcaAlarmInfo"); /*URL*/
        urlBuilder.append("?" + URLEncoder.encode("serviceKey","UTF-8") + "=서비스키"); /*Service Key*/
        urlBuilder.append("&" + URLEncoder.encode("returnType","UTF-8") + "=" + URLEncoder.encode("xml", "UTF-8")); /*xml 또는 json*/
        urlBuilder.append("&" + URLEncoder.encode("numOfRows","UTF-8") + "=" + URLEncoder.encode("100", "UTF-8")); /*한 페이지 결과 수*/
        urlBuilder.append("&" + URLEncoder.encode("pageNo","UTF-8") + "=" + URLEncoder.encode("1", "UTF-8")); /*페이지번호*/
        urlBuilder.append("&" + URLEncoder.encode("year","UTF-8") + "=" + URLEncoder.encode("2020", "UTF-8")); /*측정 연도*/
        urlBuilder.append("&" + URLEncoder.encode("itemCode","UTF-8") + "=" + URLEncoder.encode("PM10", "UTF-8")); /*미세먼지 항목 구분(PM10, PM25), PM10/PM25 모두 조회할 경우 파라미터 생략*/
        URL url = new URL(urlBuilder.toString());
        HttpURLConnection conn = (HttpURLConnection) url.openConnection();
        conn.setRequestMethod("GET");
        conn.setRequestProperty("Content-type", "application/json");
        System.out.println("Response code: " + conn.getResponseCode());
        BufferedReader rd;
        if(conn.getResponseCode() >= 200 && conn.getResponseCode() <= 300) {
            rd = new BufferedReader(new InputStreamReader(conn.getInputStream()));
        } else {
            rd = new BufferedReader(new InputStreamReader(conn.getErrorStream()));
        }
        StringBuilder sb = new StringBuilder();
        String line;
        while ((line = rd.readLine()) != null) {
            sb.append(line);
        }
        rd.close();
        conn.disconnect();
        System.out.println(sb.toString());
    }
}

이번에는 직업 Open API 사용 신청을 해보자. 먼저 아래의 링크로 접속하자.

https://www.data.go.kr/data/15073885/openapi.do#tab_layer_prcuse_exam

 

한국환경공단_에어코리아_미세먼지 경보 발령 현황

미세먼지(PM10, PM2.5)에 대한 주의보, 경보 발령을 조회하기 위한 서비스 ※ 운영계정으로 사용하고자 할 경우 "한국환경공단 에어코리아 OpenAPI 기술문서" 내 신청 가이드 참고

www.data.go.kr

 

링크로 들어가 우측 상단의 [활용 신청] 버튼을 클릭하고, 신청 이유와 동의란을 작성한 뒤 신청한다.

위 사이트의 Open API는 자동승인 형식이기 때문에, 신청 직후 바로 데이터를 사용할 수 있다.

 

데이터 사용이 승인되면 아래와 같은 화면이 나타난다. 그리고 인증키, End Point등 해당 API의 기능들을 사용할 수 있게 된다.

package ch01;

import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;

public class API_Explorer {
	
	public static void main(String[] args) throws UnsupportedEncodingException {
		
		// 순수 자바 코드로 (클라이언트 측 코딩)
		// 준비물이 필요하다.
		// 1. 서버측 주소가 필요하다.(=경로)
		// http://localhost:8080/test?name=홍길동&age=20 <-쿼리스트링 방식
		// http://localhost:8080/test?name=%ED%99%8D%EA%B8%B8%EB%8F%99&age=20
		StringBuilder urlBuilder=new StringBuilder("http://apis.data.go.kr/B552584/UlfptcaAlarmInqireSvc/getUlfptcaAlarmInfo");
		urlBuilder.append("?" + URLEncoder.encode("serviceKey","UTF-8") + "=서비스키"); /*Service Key*/
		// Builder와 Buffer의 차이점
		// 빌더는 단일 스레드에서, 버퍼는 멀티 스레드에서 안정적으로 사용할 수 있다.
		
	} // end of main

} // end of class
package ch01;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;

public class APIExplorer {

	public static void main(String[] args) throws IOException {

		// 순수 자바코드로 (클라이언트 측 코딩)
		// 준비물
		// 1. 서버측 주소 - 경로
		// http://localhost:8080/test?name=홍길동&age=20
		// http://localhost:8080/test?name=%ED%99%8D%EA%B8%B8%EB%8F%99&age=20
		StringBuilder urlBuilder = new StringBuilder(
				"http://apis.data.go.kr/B552584/UlfptcaAlarmInqireSvc/getUlfptcaAlarmInfo");
		urlBuilder.append("?" + URLEncoder.encode("serviceKey", "UTF-8")
				+ "=9fDgSkBB3xRvTRgGb3n8kZmTa2fnUnZDizBdWcQNF97fCnbgnu2essFxPqXYRlu%2BZ4tQGQauyjmZOBgdmZCK2g%3D%3D"); /*
																														 */
		urlBuilder.append("&" + URLEncoder.encode("returnType", "UTF-8") + "=" + URLEncoder.encode("json", "UTF-8"));
		urlBuilder.append("&" + URLEncoder.encode("numOfRows", "UTF-8") + "=" + URLEncoder.encode("100", "UTF-8"));
		urlBuilder.append("&" + URLEncoder.encode("pageNo", "UTF-8") + "=" + URLEncoder.encode("1", "UTF-8"));
		urlBuilder.append("&" + URLEncoder.encode("year", "UTF-8") + "=" + URLEncoder.encode("2024", "UTF-8"));
		urlBuilder.append("&" + URLEncoder.encode("itemCode", "UTF-8") + "=" + URLEncoder.encode("PM10", "UTF-8"));

		// URL 객체에서 문자열 경로 넣어서 객체 생성
		// url.openConnection() 데이터 요청 보내기 - 설정하고

		URL url = new URL(urlBuilder.toString());

		HttpURLConnection conn = (HttpURLConnection) url.openConnection();

		conn.setRequestMethod("GET"); // 서버에게 자원 요청
		conn.setRequestProperty("Content-type", "application/json");
		// 200, 실패 404, 405 
		System.out.println("Response code: " + conn.getResponseCode());
		
		// 100 ~ 500 의미 (약속) 
		BufferedReader rd;
		if (conn.getResponseCode() >= 200 && conn.getResponseCode() <= 300) {
			rd = new BufferedReader(new InputStreamReader(conn.getInputStream()));
		} else {
			rd = new BufferedReader(new InputStreamReader(conn.getErrorStream()));
		}
		
		StringBuilder sb = new StringBuilder();
		String line;
		while ((line = rd.readLine()) != null) {
			sb.append(line);
		}
		rd.close();
		conn.disconnect();
		System.out.println(sb.toString());

	} // end of main

} // end of class
728x90
반응형