> Hello World !!!

     

@syaku

소셜네트워크 다음 요즘 API 개발 #3 Open API , Daum YOZM API , SNS

 

written by Seok Kyun. Choi. 최석균

"다음 요즘 API 개발"

[연결 포스팅]
2012/04/09 - [개발노트/JAVA] - 오픈API 시작하며 #1 OpenAPI , JSON , XML , HTTP , OAuth
2012/04/09 - [개발노트/JAVA] - 소셜네트워크 트위터 API 개발 #2 Open API , Twitter API , SNS , OAuth

[필독]
1) 연결되는 포스팅입니다. 꼭 이전 포스팅을 참고하세요.
2) OAuth 와 SNS API 대해 기본적인 지식이 필요합니다.
3) 포함된 소스는 참고용이며, 그대로 사용할 경우 오류가 발생합니다. 직접 필요한 부분을 개발하세요.
- 직접 개발해야 할 부분은 임의적으로 주석처리 하였습니다.
4) 시간이 없어 급정리해서 올리는 글입니다. 부족한 부분이 많습니다. 이점 참고하세요.
5) 원문 그대로 사용하는 것을 방지하기 위해 소스파일은 제공하기 않습니다. 꼭 소스를 분석후 직접 개발하세요.

다음 요즘 API 사이트
http://dna.daum.net/apis/yozm

소셜네트워크 대명사 다음 요즘에서 제공되는 API를 이용하여 특화된 다음 요즘을 개발해보자.
우선 다음 요즘 API는 OAuth 2.0 인증방식을 사용한다.

> 이미 앞 장에서 설명했던 내용은 생략함.

1. 다음 요즘에서 어플리케이션을 생성하자.
http://dna.daum.net/apis/oauth

2
. Http Classes (생략)

3. OAuth Classes (생략)

 4. 다음 요즘 API Classes

/* * YozmAPI.java 2011.10.31 * * Copyright (c) 2010, MEI By Seok Kyun. Choi. (최석균) * http://syaku.tistory.com * * GNU Lesser General Public License * http://www.gnu.org/licenses/lgpl.html */ package com.syaku.modules.snsauth; import java.util.*; import org.apache.log4j.Logger; import org.apache.commons.lang.*; import org.apache.commons.collections.*; import oauth.signpost.*; import oauth.signpost.basic.*; import oauth.signpost.exception.*; import org.apache.http.NameValuePair; import org.apache.http.message.BasicNameValuePair; import org.apache.http.client.entity.UrlEncodedFormEntity; import net.sf.json.*; /* import org.apache.commons.codec.binary.Base64; import org.apache.commons.codec.digest.DigestUtils; import javax.servlet.*; import javax.servlet.http.*; import com.opensymphony.xwork2.*; import org.apache.struts2.ServletActionContext; import com.ibatis.sqlmap.client.SqlMapClient; import org.apache.commons.configuration.Configuration; import com.syaku.config.*; import com.syaku.common.*; import com.syaku.core.*; import com.syaku.util.*; */ public class YozmAPI extends SnsOAuthAPI { //private Logger log = Logger.getLogger(YozmAPI.class); //public SqlMapClient sqlMap = SqlMapConfig.getSqlMapInstance(); //public final Configuration MODULE_CONFIG = SyakuConfig.getInstance("com/syaku/modules/snsauth/info.properties"); public HttpServletRequest request = ServletActionContext.getRequest(); public HttpServletResponse response = ServletActionContext.getResponse(); public HttpSession session = request.getSession(); //private SnsAuthObject mSnsAuthObject = new SnsAuthObject(); //private SnsAuthStored mSnsAuthStored = new SnsAuthStored(); private SnsAuthHttp mSnsAuthHttp = new SnsAuthHttp(); private String uid,user_id,nickname,profile_cover,post_send; public String getUid() { return this.uid; } // url_name  String  Daum ID public String getUser_id() { return this.user_id; } // url_name String Daum ID public String getNickname() { return this.nickname; } // nickname  String  yozm 닉네임 public String getProfile_cover() { return this.profile_cover; } // profile_img_url  String  글 작성시 좌측에 달리는 이미지 public void setPost_send(String post_send) { this.post_send = post_send; } public String getPost_send() { return this.post_send; } // 글 전송여부 final String API_URL = "https://apis.daum.net/yozm/v1_0"; final String SNS_NAME = "YOZM"; final int TEXT_LENGTH = 150; // 글 내용 길이 public YozmAPI() { // 클래스를 호출할때 아래의 값들을 변수로 받는것이 유동성에 좋음. this.setRequest_token_url( "Request token URL" ); this.setAuthorize_url( "Authorize URL" ); this.setAccess_token_url( "Access token URL" ); this.setConsumer_key( "Consumer key" ); this.setConsumer_secret( "Consumer secret" ); this.setCallback( "Callback URL" ); } // 싱크 처리 public void getSignIn() throws Exception { try { String token = "쿠키에 저장된 access_token 을 읽어옴"; if (StringUtils.isNotEmpty(token)) { if (mSnsAuthStored.getAuthSessValid(this.SNS_NAME) == false) { // 세션이 없다면 디비에서 정보 조회 (아래의 소스는 직접 구현하기) //Map mapSch = new HashMap(); //mapSch.put("name",this.SNS_NAME); //mapSch.put("token",token); //SnsAuthBean objSns = (SnsAuthBean) mSnsAuthObject.getSnsAuthView(mapSch); if (objSns != null) { String access_token = objSns.getAccess_token(); String access_token_secret = objSns.getAccess_token_secret(); this.getInstance(); getAuthSync(access_token,access_token_secret); } } if (mSnsAuthStored.getAuthSessValid(this.SNS_NAME) == true) { Map<String,String> mapUser = this.getUserInfo(); // 계정 정보 //mSnsAuthStored.setUserInfo(this.SNS_NAME,mapUser); // 세션 저장 } //mSnsAuthStored.setAuthCookie(token); // 쿠키 갱신 } else { //mSnsAuthStored.getSessRemove(this.SNS_NAME); //세션 삭제 } } catch (Exception e) { //log.error(e.toString()); //mSnsAuthStored.getSessRemove(this.SNS_NAME); // 세션 삭제 } } public String getAccess(ParameterUtils param) throws Exception{ String auth_url = null; String oauth_token = param.value("oauth_token"); String oauth_verifier = param.value("oauth_verifier"); //String token = mSnsAuthStored.getAuthCookie(); // 저장된 쿠키 호출 String access_token = null; String access_token_secret = null; Map mapSch = new HashMap(); if (StringUtils.isEmpty(oauth_token)) { if (StringUtils.isNotEmpty(token)) { // 디비에 저장된 트위터 정보 조회 //mapSch.clear(); //mapSch.put("name",this.SNS_NAME); //mapSch.put("token",token); //SnsAuthBean objSns = (SnsAuthBean) mSnsAuthObject.getSnsAuthView(mapSch); if (objSns != null) { access_token = objSns.getAccess_token(); access_token_secret = objSns.getAccess_token_secret(); } //mSnsAuthStored.setAuthCookie(token); // 쿠키 갱신 } this.getInstance(); if (access_token != null && access_token_secret != null) { // access token 을 이용하여 재인증 처리 getAuthSync(access_token,access_token_secret); auth_url = "SUCCESS"; } else { //mSnsAuthStored.getSessRemove(this.SNS_NAME); // 세션 삭제 auth_url = getRequestToken(); // 인증 url 요청 //mSnsAuthStored.setSessCreate(this.SNS_NAME,this.consumer,this.provider); // oauth_token 세션에 인증 consumer , provider 필수로 저장 } } else { try { //sqlMap.startTransaction(); if (StringUtils.isEmpty(token)) { // 임의의 토큰 생성 및 토큰 디비저장 //token = DigestUtils.sha256Hex(DigestUtils.sha256("syaku" + DateUtils.date("yyyyMMddHHmmss") + "me")); } // access token 얻기 getSuccess(oauth_token,oauth_verifier); access_token = consumer.getToken(); access_token_secret = consumer.getTokenSecret(); // 싱크처리 getAuthSync(access_token,access_token_secret); Map<String,String> mapUser = this.getUserInfo(); // 계정 정보 /* 디비에 저장할 정보를 기록 String uid = this.uid; String ip = request.getRemoteAddr(); String user_agent = request.getHeader("User-Agent"); mSnsAuthObject.getSnsAuthMainResetUpdate(token); SnsAuthBean snsauthbean = new SnsAuthBean(); snsauthbean.setToken(token); snsauthbean.setName(this.SNS_NAME); snsauthbean.setAccess_token(access_token); snsauthbean.setAccess_token_secret(access_token_secret); snsauthbean.setMain("Y"); snsauthbean.setPost_send("Y"); snsauthbean.setUid(uid); snsauthbean.setReg_date(DateUtils.date("yyyyMMddHHmmss")); snsauthbean.setIp(ip); snsauthbean.setUser_agent(user_agent); mSnsAuthObject.getSnsAuthInsert(snsauthbean); mSnsAuthStored.setAuthCookie(token); // 갱신 mSnsAuthStored.setUserInfo(this.SNS_NAME,mapUser); mSnsAuthStored.setSessClean(oauth_token); */ auth_url = "SUCCESS"; //sqlMap.commitTransaction(); } catch (Exception e) { //mSnsAuthStored.getSessRemove(this.SNS_NAME); // 세션 삭제 //log.error(e.toString()); // 로그 출력 } finally { //sqlMap.endTransaction(); } } return auth_url; } // 인증 완료 public void getSuccess(String oauth_token,String oauth_verifier) throws Exception{ // getAccess에서 생성된 세션 this.consumer = (OAuthConsumer) session.getAttribute("_MEI_" + oauth_token + "_CR"); this.provider = (OAuthProvider) session.getAttribute("_MEI_" + oauth_token + "_PR"); String request_token = (String) session.getAttribute("_MEI_" + oauth_token + "_REQT"); String request_tokensecret = (String) session.getAttribute("_MEI_" + oauth_token + "_REQTS"); if (StringUtils.isNotEmpty(request_token) && StringUtils.isNotEmpty(request_token)) { getAccessToken(oauth_verifier); } } // 인증 싱크 (재인증) public void getAuthSync(String access_token,String access_tokensecret) throws Exception{ if (access_token != null && access_tokensecret != null) { getAcceptToken(access_token,access_tokensecret); //mSnsAuthStored.setAuthSess(this.SNS_NAME,this.consumer); //consumer 세션에 저장 : 인증완료 후 consumer 는 트위터 요청에서 자주 필요하므로 세션에 저장한다. } } // 계정 정보 public Map<String,String> getUserInfo() throws Exception { this.uid = null; this.user_id = null; this.nickname = null; this.profile_cover = null; //OAuthConsumer sess_consumer = (OAuthConsumer) mSnsAuthStored.getAuthSess(this.SNS_NAME); // 세션에 저장된 consumer //Map<String,String> mapSS = (Map<String,String>) mSnsAuthStored.getUserInfo(this.SNS_NAME); // 이전에 세션에 저장된 계정정보 Map<String,String> mapRet = new HashMap(); if (MapUtils.isNotEmpty(mapSS)) { this.uid = mapSS.get("uid"); this.user_id = mapSS.get("user_id"); this.nickname = mapSS.get("nickname"); this.profile_cover = mapSS.get("profile_cover"); } else { // 계정 정보 호출 String result = mSnsAuthHttp.getHttpGet(API_URL + "/user/show.json",sess_consumer); try { JSONObject objJson = JSONObject.fromObject(result); JSONObject objUser = objJson.getJSONObject("user"); String user_id = objUser.getString("url_name"); String nickname = objUser.getString("nickname"); String profile_cover = objUser.getString("profile_img_url"); String uid = user_id; // 정보 기록 this.uid = uid; this.user_id = user_id; this.nickname = nickname; this.profile_cover = profile_cover; } catch (Exception e) { //mSnsAuthStored.getSessRemove(this.SNS_NAME); // 세션 삭제 getException(result); } } if (this.user_id != null || this.nickname != null || this.profile_cover != null) { mapRet.put("uid",this.uid); mapRet.put("user_id",this.user_id); mapRet.put("nickname",this.nickname); mapRet.put("profile_cover",this.profile_cover); } return mapRet; } // 글 쓰기 // getPost 메소드를 호출 후 msg_id 받아 글 내용과 같이 디비에 저장하자. msg_id 는 글을 나중에 삭제할때 필요하다. // http://dna.daum.net/apis/yozm/AddMessage 참고하여 필요한 정보를 구현하세요. public String getPost(Map map) throws Exception { //OAuthConsumer sess_consumer = (OAuthConsumer) mSnsAuthStored.getAuthSess(this.SNS_NAME); String msg_id = null; String message = (String) map.get("message"); String parent_msg_id = (String) map.get("parent_msg_id"); String url = (String) map.get("url"); //message = FnUtils.getCutString(message,TEXT_LENGTH-6,""); // 글자길이 자르기 List<NameValuePair> formparams = new ArrayList<NameValuePair>(); if (StringUtils.isNotEmpty(url)) { message = "[syaku]##_LINK|" + message + "|" + url + "_##"; } else { message = "[syaku]" + message; } formparams.add(new BasicNameValuePair("message", message)); // 부모글과 연결할때 if (StringUtils.isNotEmpty(parent_msg_id)) { // 부모글 msg_id formparams.add(new BasicNameValuePair("parent_msg_id", parent_msg_id)); } UrlEncodedFormEntity formentity = new UrlEncodedFormEntity(formparams, "UTF-8"); String result = mSnsAuthHttp.getHttpPost(API_URL + "/message/add.json",formentity,sess_consumer); log.debug("[MEI YOZM getHttpPost]" + result); try { JSONObject objJson = JSONObject.fromObject(result); JSONObject objMsg = objJson.getJSONObject("message"); msg_id = objMsg.getString("msg_id"); } catch (Exception e) { getException(result); } log.debug("[MEI YOZM POST ID]" + msg_id); return msg_id; } // 글 삭제 public void getDelete(String msg_id) throws Exception { OAuthConsumer sess_consumer = (OAuthConsumer) mSnsAuthStored.getAuthSess(this.SNS_NAME); String result = mSnsAuthHttp.getHttpGet(API_URL + "/message/delete.json?msg_id=" + msg_id,sess_consumer); JSONObject objJson = JSONObject.fromObject(result); getException(result); } // result json 익셉션 출력 public void getException(String json) throws Exception { JSONObject objJson = JSONObject.fromObject(json); String msg_text = objJson.getString("result_msg"); String status = objJson.getString("status"); if (!StringUtils.equals(status,"200")) { log.debug("DAUM YOZM : " + msg_text + "(" + status + ")"); //throw new Exception("DAUM YOZM : " + msg_text + "(" + status + ")"); } } }


 5. 다음 요즘 프로그램

아래의 내용에서 SNS라는 대상은 다음 요즘 말합니다.

SNS 뷰(JSP)단의 필요한 UI 항목은 아래와 같다. JSP와 자바스크립트를 적절하게 혼합하여 구현하면 된다.

- SNS 에 등록된 글 목록
- 글을 삭제하는 삭제 버튼
- 글을 등록하는 쓰기 폼
- SNS 에 로그인 하거나 로그아웃하는 버튼

1단계. 세션이나 쿠키 존재를 파악하여 계정을 연결한다.

// 객체생성
YozmAPI yozm = new YozmAPI();
String token = ID 쿠키가져오기;

if token 존재할 경우 {
  yozm.getSignIn(); // SNS 연결
  yozm.getUid(); // 고유 아이디 (숫자)
  yozm.getUser_id(); // 유동 아이디 (영문)
  yozm.getNickname(); // 별명
  yozm.getProfile_cover(); // 절대경로의 프로필 사진
}

2단계. SNS 글 목록

SNS에 연결하여 글을 가져오는 것이 아니라, 글을 쓸때마다 자신의 디비에 저장한다. 꼭 글 id도 함께 저장하여야 한다.
[참고] 프로필 사진는 id를 이용해 img 태그로 가져오면 된다.

3단계. SNS 로그인 , 로그아웃

1단계 SNS 계정이 연결되지 않을 경우 UI 상에서 로그인 버튼을 노출시켜 로그인을 유도한다.
로그인 버튼을 누를면 새 창이 뜬다. 이부분에 추가적인 UI 화면(JSP)이 필요하다.
이 화면에서 URL 이 SNS 애플리케이션(OAuth settings)의 콜백 URL이 되어야한다.
그래서 SNS 서버에 거친 후 다시 돌아오게 되고, oauth_token 파라미터 값을 얻을 수 있다.

YozmAPI yozm = new YozmAPI();
// 연결이 되지 않을 경우 (즉 토큰이나 세션이 없을 경우) auth_url 를 리턴받는 다.
auth_url = yozm.getAccess(request);

if (auth_url 값이 있을 경우) {
  auth_url 페이지로 이동하게 함
} else {
  자바스크립트를 이용하여 현재 창(팝업:새창)을 닫고 부모 페이지를 새로고침
}

로그아웃은 쿠키와 세션에 존재하는 해당 SNS 정보를 삭제하면 된다.


4단계. 글 쓰기 , 글삭제

YozmAPI yozm = new YozmAPI();
Map map = new HashMap();
map.put("message","글 내용");

이 외 필요한 기능은 해당 SNS DOCS 참고하여 추가하자.

String msg_id = yozm.getPost(map);
SNS에 정상적으로 등록되면 msg_id 와 message 를 서버 디비에 저장한다.

// 글 삭제
yozm.getDelete(msg_id);



http://syaku.tistory.com