Jersey Rest 异常统一处理机制

标签：

前言：

        异常分为运行时异常和非运行时异常，所谓的运行时异常是指那些不需要异常捕获的异常，总是交由虚拟机接管，如：ArrayIndexOutOfBoundsException，我们在写程序时，并没有使用try..catch来捕获它。

    以前，我们进行项目开发时，习惯性的喜欢使用大量的try...catch...finally方法来进行异常处理，并且，只是将异常信息保存到log日志中即可，并没有将一些异常信息以可读性的方式返回给前端用户。而在一些比较大的项目中，进行异常统一处理是架构师或项目经理必须考虑的问题之一。

    Jersey 提供了统一异常处理机制，使得在发生运行时异常时，自动跳转到相应的异常处理资源中，并将处理结果返回给前端用户。对于程序开发人员而言，不需要编写太多的try...catch块，只需要使用throw关键字将自定义的异常抛出即可。

一、Jersey异常处理统一机制

1、演示项目结构及技术

（2）演示案例构建采用Maven

（3）案例结构如下：

（4）案例异常处理结构图

2、业务场景说明

3、代码片段说明

A、messages_zh_CN.properties异常配置内容

11110=\u67E5\u8BE2\u8BF7\u6C42\u8D77\u59CB\u9875 {0} \u662F\u8D1F\u6570

其中，{0}，表示需要传递一个参数值来为其赋值，“11110”为key，等于号后面的unicode码为返回给前端用户显示的中文异常提示信息

B、ExceptionKeys异常key常量定义内容

package com.spring.jersy.jpa.hibernate.constants;

public class ExceptionKeys {

	// 所有的异常key字符串开头都加了E标识，在后面的解析过程中会截取掉E字符，取E字符后面的编号
	// 如下：“E11110”，变成“11110”，才能与messages_zh_CN.properties中的key一一对应
	public final static String page_number_greater_zero = "E11110";
}

C、MessageUtil异常信息解析工具类

package com.spring.jersy.jpa.hibernate.util;

import java.text.MessageFormat;
import java.util.PropertyResourceBundle;
import java.util.ResourceBundle;

import com.spring.jersy.jpa.hibernate.exception.BaseException;

public final class MessageUtil {

	private static MessageUtil instance = new MessageUtil();

	// 用于读取资源属性文件（properties）
	private ResourceBundle resourceBoudle = null;

	public static MessageUtil getInstance() {
		return instance;
	}

	/**
	 * 根据异常key获取对应的异常信息
	 * 
	 * @param exceptionId
	 * @return
	 */
	public String getMessage(String exceptionId) {
		String message = resourceBoudle.getString(getErrorID(exceptionId));
		return message;
	}

	/**
	 * 根据异常获取对应的中文异常
	 * 
	 * @param e
	 * @return
	 */
	public String getMessage(BaseException e) {
		String message = resourceBoudle.getString(getErrorID(e.getMessage()));
		Object[] arguments = e.getValues();
		if (arguments != null) {
			message = MessageFormat.format(message, arguments);
		}
		return message;
	}

	private MessageUtil() {
		init();
	}

	/**
	 * 读取、加载存放key/value形式，并被Unicode编码的properties配置信息
	 */
	private void init() {
		try {
			resourceBoudle = new PropertyResourceBundle(
					getClass()
							.getClassLoader()
							.getResourceAsStream(
									"com/spring/jersy/jpa/hibernate/message/messages_zh_CN.properties"));
		} catch (Exception ex) {
			// LOGGER.error("Error loading messages properties", ex);
		}
	}

	/**
	 * 根据抛出的异常编号截取与配置文件对应的异常编号 编号E11110——>变成11110
	 * 
	 * @param exceptionID
	 *            :example 编号E11110
	 * @return:变成11110
	 */
	private String getErrorID(String exceptionID) {
		exceptionID = exceptionID.substring(1);
		return exceptionID;
	}
}

        其中，使用java.util.ResourceBundle类来读取、解析properties文件，使用java.text.MessageFormat类来格式化消息，即将配置文件中的{0}参数自动替换为传递过来的值。

D、BaseException异常基类，继承RuntimeException

package com.spring.jersy.jpa.hibernate.exception;

public class BaseException extends RuntimeException {

	/**
	 * 
	 */
	private static final long serialVersionUID = 1L;
	private Object[] values;

	private int code = 500;

	public BaseException() {

	}

	public BaseException(String msg) {
		super(msg);
	}

	public BaseException(String msg, String... params) {
		super(msg);
		if (null != params) {
			values = new Object[params.length];
			for (int i = 0; i < params.length; i++) {
				values[i] = params[i];
			}
		}
	}

	public BaseException(String msg, int code, String... params) {
		this(msg, params);
		this.code = code;
	}

	public BaseException(String msg, int code) {
		super(msg);
		this.code = code;
	}

	public BaseException(String message, Throwable cause, String... params) {
		super(message, cause);
		if (null != params) {
			values = new Object[params.length];
			for (int i = 0; i < params.length; i++) {
				values[i] = params[i];
			}
		}
	}

	public BaseException(int code, String message, Throwable cause,
			String... params) {
		this(message, cause, params);
		this.code = code;
	}

	public Object[] getValues() {
		return values;
	}

	public void setValues(Object[] values) {
		this.values = values;
	}

	public int getCode() {
		return code;
	}

	public void setCode(int code) {
		this.code = code;
	}
}

E、用户异常处理类UserException

package com.spring.jersy.jpa.hibernate.exception;

import com.spring.jersy.jpa.hibernate.constants.ExceptionKeys;

public class UserException extends BaseException{

	/**
	 * 
	 */
	private static final long serialVersionUID = 1L;

	public UserException(){
		
	}
	
	public UserException(String... params){
		super(ExceptionKeys.page_number_greater_zero,params);
	}
}

F、异常统一处理类ExceptionMappingResource

package com.spring.jersy.jpa.hibernate.resource;

import javax.ws.rs.core.Response;
import javax.ws.rs.core.Response.ResponseBuilder;
import javax.ws.rs.ext.ExceptionMapper;
import javax.ws.rs.ext.Provider;

import com.spring.jersy.jpa.hibernate.bean.ExceptionResponse;
import com.spring.jersy.jpa.hibernate.exception.BaseException;
import com.spring.jersy.jpa.hibernate.util.MessageUtil;

/**
 * 必须添加该注解使得在程序的任何地方发生运行时异常时，自动的进行异常统一处理
 * 同时该类要能够被Jersey扫描到
 */
@Provider
public class ExceptionMappingResource implements ExceptionMapper<Exception> {

	@Override
	public Response toResponse(Exception exception) {
		ResponseBuilder responseBuilder = null;

		// 用户自定义的运行时异常处理
		if (exception instanceof BaseException) {
			
			//获取用户抛出的异常信息
			String code = exception.getMessage();
			
			//根据异常key获取对应的中文异常信息
			String message = MessageUtil.getInstance().getMessage(
					(BaseException) exception);
			Throwable cause = exception.getCause();
			if (cause != null) {
				String realReason = cause.getMessage();
				message += " 可能的原因是：" + realReason + "";
			}

			//自定义异常返回实体bean类
			ExceptionResponse error = new ExceptionResponse();
			error.setCode(code);
			error.setMessage(message);
			error.setStatus("error");

			responseBuilder = Response.ok(error).status(
					((BaseException) exception).getCode());
		}
		// 其他异常
		else {
			ExceptionResponse error = new ExceptionResponse();
			error.setCode("E000000");
			error.setMessage(exception.getMessage());
			error.setStatus("error ");
			responseBuilder = Response.ok(error).status(
					Response.Status.INTERNAL_SERVER_ERROR);
		}
		return responseBuilder.build();
	}
}

        注意：该类必须被@Provider注解，且要实现JAX-RS提供的ExceptionMapper才能时刻跟踪处理项目中抛出的运行时异常，同时，该类需要被放在能够被JPA扫描器扫描到的包中。
G、用户资源类UserResource中的分页查询测试方法

	// 分页查询
	@GET
	@Path("/findByPage")
	@Produces(MediaType.APPLICATION_JSON)
	@Consumes(MediaType.APPLICATION_JSON)
	public Response findByPage(
			@DefaultValue("0") @QueryParam(value = "page") Integer page,
			@DefaultValue("10") @QueryParam(value = "pageSize") Integer pageSize) {

		if (page >= 0) {
			List<User> listUser = userSpringDataJpaService.findUserByPage(page,
					pageSize);
			ResponseBuilder rb = null;
			if (listUser == null) {
				rb = Response.serverError().status(500);
			} else {
				rb = Response.ok(listUser).status(200);
			}
			return rb.build();
		} else {
			//如果page为负数，则抛出该异常
			throw new UserException(page.toString());
		}
	}

        其中，“page.toString”参数值是用来为messages_zh_CN.properties中的{0}参数赋值的，提示该值是负数。

二、PostMan测试

postman是一个很好的模拟前端发送请求，测试后端代码正确性的测试工具，可以通过chrome浏览器安装插件，界面如下：

接下来，我们准备测试Jersey rest统一异常处理机制是否搭建成功，发送如下请求连接：

附：

           测试源码：Spring Data JPA+Jersey+TestNG用户CRUD操作案例

Jersey Rest 异常统一处理机制

标签：

原文地址：http://blog.csdn.net/niityzu/article/details/51112878