Tạo dịch vụ web RESTful sử dụng Spring, JSON, Jackson, và chương trình client

Spring là một trong những framework Java EE được sử dụng phổ biến nhất. Trước đây, chúng ta đã tìm hiểu cách sử dụng Spring MVC để tạo các ứng dụng web Java. Hôm nay, chúng ta sẽ học cách tạo dịch vụ web RESTful sử dụng Spring MVC, sau đó kiểm tra hoạt động của chúng bằng Rest client. Cuối cùng, chúng ta cũng sẽ tìm hiểu cách gọi dịch vụ web RESTful Spring bằng Spring RestTemplate API.

Spring REST

Chúng ta sẽ sử dụng phiên bản Spring 4.0.0.RELEASE và tích hợp Jackson JSON với Spring để gửi response JSON trong các lệnh gọi REST. Bài hướng dẫn này được tạo trên IDE Spring STS để dễ dàng tạo cấu trúc dự án Spring MVC cơ bản, sau đó được mở rộng để triển khai kiến trúc RESTful.

Sau khi tạo một project Spring MVC mới trong STS, project cuối cùng sẽ trông như hình bên dưới. Ta sẽ lần lượt xem xét từng thành phần của nó ở các bước dưới.

Các file cấu hình XML của Spring REST

File pom.xml của chúng ta trông như sau:

	4.0.0
	com.journaldev
	SpringRestExample
	SpringRestExample
	war
	1.0.0-BUILD-SNAPSHOT
	
		1.6
		4.0.0.RELEASE
		1.7.4
		1.7.5
		2.2.3
	
	
		
		
			com.fasterxml.jackson.core
			jackson-databind
			${jackson.databind-version}
		
		
		
			org.springframework
			spring-context
			${org.springframework-version}
			
				
				
					commons-logging
					commons-logging
				
			
		
		
			org.springframework
			spring-webmvc
			${org.springframework-version}
		

		
		
			org.aspectj
			aspectjrt
			${org.aspectj-version}
		

		
		
			org.slf4j
			slf4j-api
			${org.slf4j-version}
		
		
			org.slf4j
			jcl-over-slf4j
			${org.slf4j-version}
			runtime
		
		
			org.slf4j
			slf4j-log4j12
			${org.slf4j-version}
			runtime
		
		
			log4j
			log4j
			1.2.15
			
				
					javax.mail
					mail
				
				
					javax.jms
					jms
				
				
					com.sun.jdmk
					jmxtools
				
				
					com.sun.jmx
					jmxri
				
			
			runtime
		

		
		
			javax.inject
			javax.inject
			1
		

		
		
			javax.servlet
			servlet-api
			2.5
			provided
		
		
			javax.servlet.jsp
			jsp-api
			2.1
			provided
		
		
			javax.servlet
			jstl
			1.2
		

		
		
			junit
			junit
			4.7
			test
		
	
	
		
			
				maven-eclipse-plugin
				2.9
				
					
						org.springframework.ide.eclipse.core.springnature
					
					
						org.springframework.ide.eclipse.core.springbuilder
					
					true
					true
				
			
			
				org.apache.maven.plugins
				maven-compiler-plugin
				2.5.1
				
					1.6
					1.6
					-Xlint:all
					true
					true
				
			
			
				org.codehaus.mojo
				exec-maven-plugin
				1.2.1
				
					org.test.int1.Main
				
			
		
		
	

Công cụ STS tạo file pom.xml một cách tự động. Tuy nhiên, phiên bản Spring Framework, AspectJ, SLF4J, và Jackson đã được cập nhật lên bản mới nhất tại thời điểm viết bài. Hầu hết các nội dung trong file không có gì đặc biệt, điểm quan trọng cần lưu ý là việc thêm thư viện Jackson JSON vào phần dependency vì chúng ta sẽ dùng chúng để chuyển đổi giữa đối tượng Java và JSON.

	
	
		contextConfigLocation
		/WEB-INF/spring/root-context.xml
	
	
	
	
		org.springframework.web.context.ContextLoaderListener
	

	
	
		appServlet
		org.springframework.web.servlet.DispatcherServlet
		
			contextConfigLocation
			/WEB-INF/spring/appServlet/servlet-context.xml
		
		1
	
		
	
		appServlet
		/
	

File này được tạo tự động và chưa thay đổi gì. Tuy nhiên, nếu bạn muốn thay đổi các file cấu hình context và địa chỉ của chúng, bạn có thể thực hiện trong file web.xml.

File này chứa các tài nguyên dùng chung mà tất cả các web component đều có thể thấy. Chúng ta sẽ tạo một service REST đơn giản, vì vậy chưa thay đổi gì ở đây.

Hầu hết nội dung được tạo tự động và chứa các cấu hình mẫu. Tuy nhiên, cần lưu ý phần để hỗ trợ cấu hình dựa trên annotation và việc thêm MappingJackson2HttpMessageConverter vào messageConverters của RequestMappingHandlerAdapter.

Điều này cho phép Jackson API hoạt động để chuyển đổi giữa JSON và Java Bean. Với cấu hình này, chúng ta sẽ sử dụng JSON trong phần thân request và nhận dữ liệu JSON trong response.

Các lớp model trong Spring REST

Chúng ta hãy viết một lớp POJO đơn giản đóng vai trò là dữ liệu đầu vào và đầu ra cho các method của web service RESTful.

package com.journaldev.spring.model;

import java.io.Serializable;
import java.util.Date;

import com.fasterxml.jackson.databind.annotation.JsonSerialize;
import com.fasterxml.jackson.databind.ser.std.DateSerializer;

public class Employee implements Serializable{

	private static final long serialVersionUID = -7788619177798333712L;
	
	private int id;
	private String name;
	private Date createdDate;
	
	public int getId() {
		return id;
	}
	public void setId(int id) {
		this.id = id;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	
	@JsonSerialize(using=DateSerializer.class)
	public Date getCreatedDate() {
		return createdDate;
	}
	public void setCreatedDate(Date createdDate) {
		this.createdDate = createdDate;
	}
	
	
}

Điểm quan trọng nhất cần lưu ý là việc sử dụng annotation @JsonSerialize để dùng lớp DateSerializer cho việc chuyển đổi kiểu Date của Java sang định dạng JSON và ngược lại.

Các end point của dịch vụ web RESTful Spring

Chúng ta sẽ có các endpoint của web service REST như sau.

Chúng ta có một lớp định nghĩa tất cả các URI này dưới dạng hằng số String.

package com.journaldev.spring.controller;

public class EmpRestURIConstants {

	public static final String DUMMY_EMP = "/rest/emp/dummy";
	public static final String GET_EMP = "/rest/emp/{id}";
	public static final String GET_ALL_EMP = "/rest/emps";
	public static final String CREATE_EMP = "/rest/emp/create";
	public static final String DELETE_EMP = "/rest/emp/delete/{id}";
}

Lớp Controller của dịch vụ web RESTful sử dụng Spring

Lớp EmployeeController của chúng ta sẽ cung cấp tất cả các endpoint đã đề cập ở trên. Hãy xem qua code của nó trước, sau đó chúng ta sẽ tìm hiểu kĩ hơn về từng phương thức.

package com.journaldev.spring.controller;

import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;

import com.journaldev.spring.model.Employee;

/**
 * Handles requests for the Employee service.
 */
@Controller
public class EmployeeController {
	
	private static final Logger logger = LoggerFactory.getLogger(EmployeeController.class);
	
	//Map to store employees, ideally we should use database
	Map empData = new HashMap();
	
	@RequestMapping(value = EmpRestURIConstants.DUMMY_EMP, method = RequestMethod.GET)
	public @ResponseBody Employee getDummyEmployee() {
		logger.info("Start getDummyEmployee");
		Employee emp = new Employee();
		emp.setId(9999);
		emp.setName("Dummy");
		emp.setCreatedDate(new Date());
		empData.put(9999, emp);
		return emp;
	}
	
	@RequestMapping(value = EmpRestURIConstants.GET_EMP, method = RequestMethod.GET)
	public @ResponseBody Employee getEmployee(@PathVariable("id") int empId) {
		logger.info("Start getEmployee. ID="+empId);
		
		return empData.get(empId);
	}
	
	@RequestMapping(value = EmpRestURIConstants.GET_ALL_EMP, method = RequestMethod.GET)
	public @ResponseBody List getAllEmployees() {
		logger.info("Start getAllEmployees.");
		List emps = new ArrayList();
		Set empIdKeys = empData.keySet();
		for(Integer i : empIdKeys){
			emps.add(empData.get(i));
		}
		return emps;
	}
	
	@RequestMapping(value = EmpRestURIConstants.CREATE_EMP, method = RequestMethod.POST)
	public @ResponseBody Employee createEmployee(@RequestBody Employee emp) {
		logger.info("Start createEmployee.");
		emp.setCreatedDate(new Date());
		empData.put(emp.getId(), emp);
		return emp;
	}
	
	@RequestMapping(value = EmpRestURIConstants.DELETE_EMP, method = RequestMethod.PUT)
	public @ResponseBody Employee deleteEmployee(@PathVariable("id") int empId) {
		logger.info("Start deleteEmployee.");
		Employee emp = empData.get(empId);
		empData.remove(empId);
		return emp;
	}
	
}

Để đơn giản, ta lưu trữ tất cả dữ liệu employee trong HashMap empData. Annotation @RequestMapping được dùng để map URI của request tới phương thức xử lý (handler method).

Chúng ta cũng có thể chỉ định phương thức HTTP mà client cần sử dụng để gọi phương thức REST. Annotation @ResponseBody được dùng để đưa đối tượng trả về vào phần thân của response. Khi đối tượng response được trả về bởi phương thức xử lý, MappingJackson2HttpMessageConverter sẽ hoạt động để chuyển đổi nó thành response JSON.

Annotation @PathVariable là cách dễ dàng để trích xuất dữ liệu từ URI của REST và map vào tham số của phương thức. Annotation @RequestBody được dùng để map dữ liệu JSON từ request body vào đối tượng Employee, việc này cũng được thực hiện bởi MappingJackson2HttpMessageConverter.

Phần code còn lại khá đơn giản và dễ hiểu. Ứng dụng của chúng ta đã sẵn sàng để kiểm thử và triển khai. Chỉ cần export ra file WAR và sao chép vào thư mục web app của servlet container. Nếu bạn đã cấu hình server trong STS, bạn chỉ cần chạy ứng dụng trên server đó để triển khai.

Ở đây ta sử dụng WizTools RestClient để thực hiện các lệnh gọi REST, nhưng bạn cũng có thể dùng extension Postman trên Chrome. Các ảnh chụp màn hình bên dưới minh họa các lệnh gọi khác nhau đến REST API do ứng dụng của chúng ta cung cấp và kết quả trả về.

Kiểm tra Health Check – Lệnh gọi REST lấy Employee mẫu

Lệnh gọi REST POST tạo Employee: Đảm bảo Content-Type của request được đặt là “application/json”, nếu không bạn sẽ gặp lỗi HTTP 415.

Lệnh gọi REST lấy Employee

Lệnh gọi REST xóa Employee

Lệnh gọi REST lấy tất cả Employee

Chương trình Spring Rest Client

Các Rest client rất hữu ích để kiểm thử web service REST. Nhưng trong đa số trường hợp, chúng ta cần gọi các service REST từ chính chương trình của mình.

Chúng ta có thể sử dụng RestTemplate của Spring để dễ dàng gọi các phương thức này. Dưới đây là một chương trình đơn giản gọi các phương thức REST của ứng dụng bằng RestTemplate API.

package com.journaldev.spring;

import java.util.LinkedHashMap;
import java.util.List;

import org.springframework.web.client.RestTemplate;

import com.journaldev.spring.controller.EmpRestURIConstants;
import com.journaldev.spring.model.Employee;

public class TestSpringRestExample {

	public static final String SERVER_URI = "https://localhost:9090/SpringRestExample";
	
	public static void main(String args[]){
		
		testGetDummyEmployee();
		System.out.println("*****");
		testCreateEmployee();
		System.out.println("*****");
		testGetEmployee();
		System.out.println("*****");
		testGetAllEmployee();
	}

	private static void testGetAllEmployee() {
		RestTemplate restTemplate = new RestTemplate();
		//we can't get List because JSON convertor doesn't know the type of
		//object in the list and hence convert it to default JSON object type LinkedHashMap
		List emps = restTemplate.getForObject(SERVER_URI+EmpRestURIConstants.GET_ALL_EMP, List.class);
		System.out.println(emps.size());
		for(LinkedHashMap map : emps){
			System.out.println("ID="+map.get("id")+",Name="+map.get("name")+",CreatedDate="+map.get("createdDate"));;
		}
	}

	private static void testCreateEmployee() {
		RestTemplate restTemplate = new RestTemplate();
		Employee emp = new Employee();
		emp.setId(1);emp.setName("Pankaj Kumar");
		Employee response = restTemplate.postForObject(SERVER_URI+EmpRestURIConstants.CREATE_EMP, emp, Employee.class);
		printEmpData(response);
	}

	private static void testGetEmployee() {
		RestTemplate restTemplate = new RestTemplate();
		Employee emp = restTemplate.getForObject(SERVER_URI+"/rest/emp/1", Employee.class);
		printEmpData(emp);
	}

	private static void testGetDummyEmployee() {
		RestTemplate restTemplate = new RestTemplate();
		Employee emp = restTemplate.getForObject(SERVER_URI+EmpRestURIConstants.DUMMY_EMP, Employee.class);
		printEmpData(emp);
	}
	
	public static void printEmpData(Employee emp){
		System.out.println("ID="+emp.getId()+",Name="+emp.getName()+",CreatedDate="+emp.getCreatedDate());
	}
}

Phần lớn code ở trên đều dễ hiểu. Tuy nhiên, khi gọi phương thức REST để trả về một Collection, chúng ta cần sử dụng LinkedHashMap. Lý do là vì quá trình chuyển đổi JSON sang đối tượng ở trên không biết trước kiểu Employee object cụ thể, nên nó sẽ chuyển đổi thành một Collection chứa các LinkedHashMap.

Chúng ta có thể viết một phương thức để chuyển đổi từ LinkedHashMap sang đối tượng Java Bean mong muốn. Khi chạy chương trình trên, chúng ta sẽ nhận được kết quả sau trong console:

ID=9999,Name=Dummy,CreatedDate=Tue Mar 04 21:02:41 PST 2014
*****
ID=1,Name=Pankaj Kumar,CreatedDate=Tue Mar 04 21:02:41 PST 2014
*****
ID=1,Name=Pankaj Kumar,CreatedDate=Tue Mar 04 21:02:41 PST 2014
*****
2
ID=1,Name=Pankaj Kumar,CreatedDate=1393995761654
ID=9999,Name=Dummy,CreatedDate=1393995761381

Một điểm khác cần lưu ý là các phương thức PUT của RestTemplate thường không có tùy chọn để nhận đối tượng response. Lý do là phương thức PUT được dùng để lưu trữ dữ liệu trên server, và thường chỉ cần trả về mã trạng thái HTTP 200 là đủ.

Tổng kết

Tải project dịch vụ web RESTful với Spring ở trên bằng link này.

Do có nhiều yêu cầu cung cấp ví dụ tương tự hỗ trợ cả XML và JSON, chúng tôi đã mở rộng ứng dụng này từ bài viết Spring REST XML JSON để hỗ trợ cả request và response dạng XML lẫn JSON. Bạn nên đọc qua bài đó để thấy được sự linh hoạt của Spring framework và cách đạt được điều đó dễ như thế nào.

Bạn có thể tải về project hoàn chỉnh từ repo GitHub này.