이번 포스팅은 Spring MVC 와 HttpClient 라이브러리를 연동하여 API 웹서버 예를 들어보도록 하겠습니다.

HttpClient는 주로 api호출을 하여 서버로부터 받은 데이터(JSON 또는 XML)를 

클라이언트(웹 또는 안드로이드)에서 응답받아서 화면에 파싱작업을 진행을 할때 주로 사용합니다.

GET/POST/Multipart(파일처리) 이 3가지에 대하여 알아보도록 하겠습니다.

응답데이터는 JSON 규격으로 클라이언트로 보내는걸로 진행 하겠습니다.

API 서버코드 (GET/POST/MultipartFile)

//GET 방식
@RequestMapping(value="/getServer", method=RequestMethod.GET)
public @ResponseBody Map<String, Object> getServer(HttpServletRequest request, HttpServletResponse response) {
	System.out.println("GET Server Response");
	Map<String, Object> map = new HashMap<String, Object>();
	//클라이언트 페이지로 부터 Httpclient로 받은 parameter값
	map.put("param1", request.getParameter("param1"));
	map.put("param2", request.getParameter("param2"));
	map.put("flag", "get");
	map.put("success", true);
	return map;
}

//POST 방식
@RequestMapping(value="/postServer", method=RequestMethod.POST)
public @ResponseBody Map<String, Object> postServer(HttpServletRequest request, HttpServletResponse response) {
	System.out.println("POST Server Response");
	Map<String, Object> map = new HashMap<String, Object>();
	//클라이언트 페이지로 부터 Httpclient로 받은 parameter값
	map.put("param1", request.getParameter("param1"));
	map.put("param2", request.getParameter("param2"));
	map.put("flag", "post");
	map.put("success", true);
	return map;
}

//MultipartFile 방식
@RequestMapping(value="/multipartServer", method=RequestMethod.POST)
public @ResponseBody Map<String, Object> multipartServer(Vo vo,HttpServletRequest request) {
	System.out.println("Multipart Server Response");
	Map<String, Object> map = new HashMap<String, Object>();
	//클라이언트 페이지로 부터 Httpclient로 받은 parameter값
	map.put("txt", request.getParameter("txt"));
	//클라이언트 페이지로 부터 Httpclient로 받은 multipart parameter값
	map.put("filename", vo.getFileupload().getOriginalFilename());
	map.put("filesize", vo.getFileupload().getSize());
	map.put("flag", "multipart");
	map.put("success", true);
	return map;
}

MultipartFile을 받기위한 Vo 클래스

public class Vo {
	private MultipartFile fileupload;

	public MultipartFile getFileupload() {
		return fileupload;
	}

	public void setFileupload(MultipartFile fileupload) {
		this.fileupload = fileupload;
	}
}

다음은 클라이언트 페이지에서 HttpClient를 이용하여 

API 서버를 호출하는 라이브러리 추가 및 샘플코드를 다음과 같이 작성해보도록 합니다.

HttpClient 관련 라이브러리 Pom.xml 추가

<!-- HttpClient 라이브러리 설정 -->
<dependency>
  <groupId>org.apache.httpcomponents</groupId>
  <artifactId>httpclient</artifactId>
  <version>4.3.6</version>
</dependency>
<!-- HttpClient - Multipart를 위한 라이브러리 설정 -->
<dependency>
	<groupId>org.apache.httpcomponents</groupId>
	<artifactId>httpmime</artifactId>
	<version>4.3.6</version>
</dependency>

사용자페이지 샘플 컨트롤러

//Get방식 호출을 위한 샘플폼화면
@RequestMapping(value="/getForm")
public String getForm(HttpServletRequest request, HttpServletResponse response) {
	return "getForm";
}
	
//Post방식 호출을 위한 샘플폼화면
@RequestMapping(value="/postForm")
public String postForm(HttpServletRequest request, HttpServletResponse response) {
	return "postForm";
}

//Multipart방식 호출을 위한 샘플폼화면
@RequestMapping(value="/multipartForm")
public String multipartForm(HttpServletRequest request, HttpServletResponse response) {
	return "multipartForm";
}

getForm.jsp샘플코드

	<form action="/getSubmit" method="get">
		<input type="text" name="param1" /><br/>
		<input type="text" name="param2" /><br/>
		<input type="submit" value="GET전송"/>
	</form>

postForm.jsp샘플코드

	<form action="/postSubmit" method="post">
		<input type="text" name="param1" /><br/>
		<input type="text" name="param2" /><br/>
		<input type="submit" value="POST전송"/>
	</form>

multipartForm.jsp샘플코드

	<form action="/multipartSubmit" method="post" enctype="multipart/form-data">
		<input type="file" name="fileupload" /><br/>
		<input type="text" name="txt" /><br/>
		<input type="submit" value="POST전송"/>
	</form>

HttpClient 호출 GET

	//Get Submit
	@RequestMapping(value="/getSubmit")
	public void getSubmit(HttpServletRequest request) {
		try {
			CloseableHttpClient httpclient = HttpClients.createDefault();
			//GET 방식으로 parameter를 전달
			HttpGet httpGet = new HttpGet("http://localhost:7070/getServer?param1="+request.getParameter("param1")+"¶m2="+request.getParameter("param2"));
			CloseableHttpResponse response = httpclient.execute(httpGet);
			try {
			    System.out.println(response.getStatusLine());
			    //API서버로부터 받은 JSON 문자열 데이터
			    System.out.println(EntityUtils.toString(response.getEntity()));
			    HttpEntity entity = response.getEntity();
			    EntityUtils.consume(entity);
			} finally {
				response.close();
			}	
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

HttpClient 호출 POST

	//Post Submit
	@RequestMapping(value="/postSubmit")
	public void postSubmit(HttpServletRequest request) {
		try {
			CloseableHttpClient httpclient = HttpClients.createDefault();
			HttpPost httpPost = new HttpPost("http://localhost:7070/postServer");
			//전달하고자 하는 PARAMETER를 List객체에 담는다
			List <NameValuePair> nvps = new ArrayList >NameValuePair>();
			nvps.add(new BasicNameValuePair("param1", request.getParameter("param1")));
			nvps.add(new BasicNameValuePair("param2", request.getParameter("param2")));
			//UTF-8은 한글 
			httpPost.setEntity(new UrlEncodedFormEntity(nvps,"UTF-8"));
			CloseableHttpResponse response = httpclient.execute(httpPost);
			try {
			    System.out.println(response.getStatusLine());
			    //API서버로부터 받은 JSON 문자열 데이터
			    System.out.println(EntityUtils.toString(response.getEntity()));
			    HttpEntity entity = response.getEntity();
			    EntityUtils.consume(entity);
			} finally {
				response.close();
			}	
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

HttpClient 호출 Multipart

//파일첨부 MultipartFile Submit 
@RequestMapping(value="/multipartSubmit")
public void multipartSubmit(HttpServletRequest request,  Vo vo) {
	CloseableHttpClient httpclient = HttpClients.createDefault();
        try {
            HttpPost httppost = new HttpPost("http://localhost:7070/multipartServer");
            File convFile = new File(vo.getFileupload().getOriginalFilename());
            vo.getFileupload().transferTo(convFile);
            FileBody multipart = new FileBody(convFile);
            //Charset.forName("UTF-8") : 한글깨짐 방지를위함
            StringBody txt = new StringBody(request.getParameter("txt"), Charset.forName("UTF-8"));
            //API 서버에 전달하고자하는 PARAMETER
            HttpEntity reqEntity = MultipartEntityBuilder.create().addPart("fileupload", multipart).addPart("txt", txt).build();
            httppost.setEntity(reqEntity);
            CloseableHttpResponse response = httpclient.execute(httppost);
            try {
                System.out.println(response.getStatusLine());
                //API서버로부터 받은 JSON 문자열 데이터
		System.out.println(EntityUtils.toString(response.getEntity()));
                HttpEntity resEntity = response.getEntity();
                if (resEntity != null) {
                    System.out.println("Response content length: " + resEntity.getContentLength());
                }
                EntityUtils.consume(resEntity);
            } finally {
                response.close();
            }
        } catch(Exception e){
        	e.printStackTrace();
        }finally {
            try {
		httpclient.close();
	    } catch (IOException e) {}
        }
}

위와같이 코드를 작성하였다면 각 폼컨트롤러 호출을 하여

 실행테스트를 해보도록 하겠습니다.

/getForm 실행결과(화면)

/getForm 실행결과(콘솔)

/postForm 실행결과(화면)

/postForm 실행결과(콘솔)

/multipartForm 실행결과(화면)

/multipartForm 실행결과(콘솔)

위와같이 정상적으로 API서버에 PARAMETER 또는 MultipartFile 전송 후

 응답값을 받아오는 것을 확인 할 수 있었습니다.

안드로이드 API 서버 구축시 또는 외부 API 서버로부터 API 호출할 경우가 생긴다면

해당 샘플을 응용하여 사용하시면 되겠습니다.

by 개발로짜

기존에는 쿼츠 혹은 배치를 이용하여 실시간 스케줄러를 구현하였는데 

"spring-task"를 이용해보니 쿼츠를 사용할 필요도 없이 간편하게 개발이 가능하여 포스팅을 하게 되었습니다.

프로젝트생성부터 DB연동하여 실행하는 부분까지 한번에 진행하도록 하겠습니다.

Spring 프로젝트생성

1.New Spring Project -> Simple Spring Web Maven -> 프로젝트명 : "spring_task"

2.spring_task프로젝트 마우스 우클릭 -> Maven -> Update Project.. -> OK

/src/main/webapp/WEB-INF/mvc-config.xml 환경설정

1. beans 태그에 하단 속성 추가

xmlns:task="http://www.springframework.org/schema/task"

2. xsi:schemaLocation 내에 다음 코드 추가

http://www.springframework.org/schema/task 
http://www.springframework.org/schema/task/spring-task.xsd

3. beans 태그의 자식태그 추가 (Job Scheduler 연동)

<context:component-scan base-package="com.scheduler" />
<task:scheduler id="jobScheduler" pool-size="10" />
<task:annotation-driven scheduler="jobScheduler" />

/src/main/resources/spring/application-config.xml 환경설정

DB설정 부분에 대해서는 하단 링크를 참고해주세요

※ 본인은 MySQL을 이용하여 설명을 진행하겠습니다.

2014/11/14 - [개발에필요한연동법/스프링연동] - Spring3 Maven을 이용하여 pom.xml에 oracle,mysql,mssql jdbc 라이브러리 등록하기

2014/11/14 - [개발에필요한연동법/스프링연동] - Spring3 + MyBatis 기본설정 + 연동테스트 후 쿼리로그 확인해보기

2014/11/14 - [개발에필요한연동법/스프링연동] - Spring3 + Mybatis연동에 추가로 트랜잭션 설정 하여 실패시 Rollback 처리하기

2014/11/16 - [개발에필요한연동법/스프링연동] - Spring3 + Mybatis 여러개 Datasource 연동법(다중 트랜잭션 포함)

트랜잭션 및 다중DB 연동에 대해서는 생략하도록 하겠습니다.

스케줄러를 위한 패키지 생성 및 샘플코드작성

1. com.scheduler.Scheduler.java 코드 작성

@Component
public class Scheduler {

	@Autowired
	private SchedulerDao schedulerDao;
	
	@Scheduled(cron = "0 45 11 * * *")
	public void cronTest1(){
		try {
			String value = schedulerDao.test();
			System.out.println("value:"+value);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}
}

2. com.scheduler.dao.SchedulerDao.java 코드 작성

public interface SchedulerDao {
	public String test() throws SQLException;
}

3. com.scheduler.dao.impl.SchedulerDaoImpl.java 코드 작성

@Repository
public class SchedulerDaoImpl implements SchedulerDao {	
	@Autowired
	private SqlSession query;

	public String test() throws SQLException {
		return query.selectOne("query.test");
	}
}

4. query.xml mybatis XML 쿼리 작성

<select id="test" resultType="String">
	SELECT 'test'
</select>

위처럼 코드 작성이 완료되었다면 Tomcat에 프로젝트 ADD 한다음 실행을 해보도록 하겠습니다.

※ @scheduled 어노테이션을 확인해보면 expression이 존재합니다.

바로 정의한 시간에 해당 메서드를 실행하겠다라는 선언을 해주는것인대

샘플코드를 기준으로 간단하게 설명하겠습니다.

"0 45 11 * * *"

"초 분 시 일 월 요일" 에 대한 설정을 의미하는것인대

"오전 11시 45분 00초"에 해당 메서드 실행을 의미합니다.

"*" 표시는 항상/모두 를 의미하는 expression입니다.

만약 서버를 계속 켜놓는다 가정한다면 

"항상 오전 11시45분00초에 메서드를 실행하라" 

라는 의미가 되는것입니다.

정상적으로 스케쥴러 실행이 완료 되었습니다.

만약 여러개의 스케쥴러를 구축하고 싶으시다면 method 추가 후

 @Scheduled 어노테이션으로 동일하게 정의해주시면 되겠습니다.

by 개발로짜

Mybatis 이전버전인 ibatis + Spring3 에 대한 기본적인 연동법을 소개해보고자 합니다.

Spring 기본 연동법은 하단 포스팅을 참조해 주세요

2014/11/06 - [개발에필요한연동법/스프링연동] - STS 이클립스를 이용하여 UTF-8 인코딩 설정 및 Spring3 MVC 연동해보기

2014/11/06 - [개발에필요한연동법/스프링연동] - Spring3 한글깨짐 방지를 위한 UTF-8 인코딩 설정하기

2014/11/14 - [개발에필요한연동법/스프링연동] - Spring3 Maven을 이용하여 pom.xml에 oracle,mysql,mssql jdbc 라이브러리 등록하기

위 링크 기준으로 이어서 DB 설정에 대하여 포스팅 하도록 하겠습니다.

저는 Mybatis 연동법에 소개드렸듯이 MySQL 기준으로 아이바티스 연동을 하도록 하겠습니다.

2014/11/14 - [개발에필요한연동법/스프링연동] - Spring3 + MyBatis 기본설정 + 연동테스트 후 쿼리로그 확인해보기

/resources/spring/application-config.xml 설정부분을 보도록 하겠습니다.

application-config.xml 설정

<context:component-scan base-package="com.spring"/>
<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
        <property name="driverClassName" value="com.mysql.jdbc.Driver" />
        <property name="url" value="jdbc:mysql://도메인:포트/db명" />
        <property name="username" value="계정" />
        <property name="password" value="비밀번호" />
</bean>
<bean id="sqlMapClient" class="org.springframework.orm.ibatis.SqlMapClientFactoryBean">
	<property name="configLocation" value="classpath:sqlmap-config.xml"/>
	<property name="dataSource" ref="dataSource"/>
</bean>
</beans>

위와같이 설정을 하셨다면 

"/resources/sqlmap-config.xml 파일을 하나 생성하고 다음 코드를 덮어씌워주세요

sqlmap-config.xml 코드

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE sqlMapConfig PUBLIC "-//iBATIS.com//DTD SQL Map Config 2.0//EN" "http://www.ibatis.com/dtd/sql-map-config-2.dtd">
<sqlMapConfig>
	 <settings cacheModelsEnabled="true" enhancementEnabled="true" lazyLoadingEnabled="true" useStatementNamespaces="true" />
	  <sqlMap resource="query/query.xml" />
</sqlMapConfig>

"/resources/query/" 디렉토리 생성 후 query.xml파일을 생성 한 다음 

하단 코드를 덮어씌워보도록 하겠습니다.

query.xml 샘플 쿼리코드

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE sqlMap PUBLIC "-//iBATIS.com//DTD SQL Map 2.0//EN" "http://www.ibatis.com/dtd/sql-map-2.dtd">
<sqlMap namespace="query">
	<select id="ibatisSelect" resultClass="String">
	     SELECT 'TEST'
    </select>
</sqlMap>

이번 포스팅은 간단하게 DB SELECT 테스트를 하기 위함으로써 Service 영역을 제외하고 

Controller -> Dao 로 바로 호출하는 샘플 코드를 작성해보겠습니다.

1. StudyController 클래스 샘플코드

@Autowired
private StudyDao studyDao;
	
@RequestMapping("/ibatisSelect")
public void ibatisSelect(){
	try {
		studyDao.ibatisSelect();	
	} catch (Exception e) {
		e.printStackTrace();
	}
}

2. StudyDao 인터페이스 샘플코드

public void ibatisSelect() throws SQLException;

3. StudyDaoImpl 클래스 샘플코드

@Repository
public class StudyDaoImpl implements StudyDao {

	@Autowired
	private SqlMapClient query;
	 
	public void ibatisSelect() throws SQLException {
		String result= (String)query.queryForObject("query.ibatisSelect");
		System.out.println("결과값:"+result);
	}
}

샘플코드들에 대한 작성이 완료되었다면 한번 실행결과를 확인해보도록 하겠습니다.

쿼리로그는 Mybatis와 다르게 출력되지않지만 결과값이 나왔다는 것은 Spring과 ibatis 와 연동이 되었다는 결과 입니다.

다음장은 logback.xml 파일로 쿼리출력을 하는것이 아닌 

log4j 를 이용하여 쿼리로그 출력하는 포스팅을 하도록 하겠습니다 .

그다음 이어서 스프링 + 아이바티스 기본 연동에 추가로 트랜잭션 관련 포스팅을 다루겠습니다.

by 개발로짜