通过配置的容器过滤

=========================================通过配置的容器过滤？？？？？？？？？？？？？？？？？？？？？？？？？？？？？？？？？？？？
  //过滤器的seevlet形式，
  <servlet>
<servlet-name>RESTEntrance</servlet-name>
<servlet-class>org.glassfish.jersey.servlet.ServletContainer</servlet-class>
<init-param>
<param-name>javax.ws.rs.Application</param-name>
<param-value>com.certusnet.nfv.mano.vim.RestApplication</param-value>//在第三容器中，注入过滤器监听（监听注册类），即可实现代码加强，用这个注册类注册的类来加强目标方法1，注册所有rest接口，2，注册接口调用时，同时调用的加强代码（实现ContainerResponseFilter才可）
</init-param>
<load-on-startup>1</load-on-startup>
</servlet>

<servlet-mapping>
<servlet-name>RESTEntrance</servlet-name>


private static final String SUBSYS_NFVO = "nfvo";
private static final String SUBSYS_VIM = "vim";
private static final String SUBSYS_VNFM = "vnfm";
<url-pattern>/rest/*</url-pattern>
</servlet-mapping>


//加强代码

package com.certusnet.nfv.mano.rest;

import java.io.IOException;
import java.net.URI;
import java.util.Arrays;
import java.util.Date;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;
import javax.ws.rs.container.ContainerRequestContext;
import javax.ws.rs.container.ContainerResponseContext;
import javax.ws.rs.container.ContainerResponseFilter;
import javax.ws.rs.core.Context;
import javax.ws.rs.core.Response.Status;
import javax.ws.rs.ext.Provider;

import net.sf.json.JSONArray;
import net.sf.json.JSONObject;

import org.apache.commons.lang.StringUtils;
import org.apache.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;

import com.certusnet.nfv.mano.ManoThreadLocal;
import com.certusnet.nfv.mano.common.logicapi.IOperationLogLS;
import com.certusnet.nfv.mano.common.model.EventNameId;
import com.certusnet.nfv.mano.common.model.OperationLog;
import com.certusnet.nfv.mano.util.DateUtil;

/**
*
*
* @author Biwei
*
*/
@Provider
public class RestResponseFilter implements ContainerResponseFilter {
Logger logger = Logger.getLogger(RestResponseFilter.class);

@Autowired(required = true)
private IOperationLogLS operationLogLS;

@Context
HttpServletRequest request;

private static final String SUBSYS_NFVO = "nfvo";
private static final String SUBSYS_VIM = "vim";
private static final String SUBSYS_VNFM = "vnfm";

@Override
public void filter(ContainerRequestContext requestContext,
ContainerResponseContext responseContext) throws IOException {

//
capsuitResult(responseContext);

//
printLog(requestContext);

//
recordOperLog(requestContext, responseContext);
}

private void capsuitResult(ContainerResponseContext responseContext) {
if (responseContext.getStatus() >= 200
&& responseContext.getStatus() < 300) {
//
responseContext.setStatus(Status.OK.getStatusCode());
RestResponsePO rpo = new RestResponsePO();
rpo.setResult(responseContext.getEntity());
responseContext.setEntity(rpo);

} else if (responseContext.getStatus() == ManoExceptionMapper.MANOEXCEPTION_STATUS) {
//
responseContext.setStatus(Status.OK.getStatusCode());
}
}

/**
*
*
* @param requestContext
*/
private void printLog(ContainerRequestContext requestContext) {
URI uri = requestContext.getUriInfo().getAbsolutePath();
String url = uri.getHost() + ":" + uri.getPort() + uri.getPath();
logger.debug(url + " send response to UI.");
}

/**
*
*
* @param requestContext
* @param responseContext
*/
private void recordOperLog(ContainerRequestContext requestContext,
ContainerResponseContext responseContext) {
String userId = requestContext.getHeaderString("User-Id");
String eventId = requestContext.getHeaderString("Event-Id");
String operType = requestContext.getHeaderString("Operate-Type");
String subsystem = retrieveSubsys(requestContext);


if (StringUtils.isEmpty(operType)) {
return;
}

//
String requestContent = getRequestContent();

//
RestResponsePO rpo = (RestResponsePO) responseContext.getEntity();
String responseStatus = rpo.getRetCode();
String responseContent = "ok".equals(responseStatus) ? getJsonStr(rpo
.getResult()) : rpo.getMsg();

try {
OperationLog operLog = new OperationLog();
operLog.setEventId(eventId);
operLog.setOperateType(operType);
operLog.setRequestContent(requestContent);
operLog.setResponseContent(responseContent);
operLog.setResponseStatus(responseStatus);
operLog.setSubsystem(subsystem);
operLog.setUserId(userId);

operationLogLS.insertOne(operLog);
} catch (Exception ex) {
logger.error(ex.getMessage(), ex);
}
}

private String retrieveSubsys(ContainerRequestContext requestContext) {
URI uri = requestContext.getUriInfo().getAbsolutePath();
String path = uri.getPath();
if (path.contains(SUBSYS_NFVO)) {
return SUBSYS_NFVO;
} else if (path.contains(SUBSYS_VNFM)) {
return SUBSYS_VNFM;
} else {
return SUBSYS_VIM;
}
}

private String getRequestContent() {

Object param = ManoThreadLocal.getRequestParam();
if(param != null)
{
return getJsonStr(param);
}
else
{
return "request params are not collected.";
}
}

private String getJsonStr(Object obj) {
//
if (obj instanceof Arrays || obj instanceof List) {
JSONArray jsonObj = JSONArray.fromObject(obj);
return jsonObj.toString();
} else {
JSONObject jsonObj = JSONObject.fromObject(obj);
return jsonObj.toString();
}
}
}


//注册织入代码，这个具有注册过滤器功能的类，一方面需要继承ResourceConfig；另一方面需要在他监听的容器内注入

package com.certusnet.nfv.mano.nfvo;

import org.codehaus.jackson.jaxrs.JacksonJsonProvider;
import org.glassfish.jersey.server.ResourceConfig;
import org.springframework.web.filter.RequestContextFilter;

import com.certusnet.nfv.mano.nfvo.log.rest.OperationLogRest;
import com.certusnet.nfv.mano.nfvo.network.rest.NetworkRest;
import com.certusnet.nfv.mano.nfvo.nsd.rest.NsdRest;
import com.certusnet.nfv.mano.nfvo.nsr.rest.NsrRest;
import com.certusnet.nfv.mano.nfvo.pnfd.rest.PnfdRest;
import com.certusnet.nfv.mano.nfvo.vnfd.rest.LifecycleEventRest;
import com.certusnet.nfv.mano.nfvo.vnfd.rest.VduRest;
import com.certusnet.nfv.mano.nfvo.vnfd.rest.VnfcRest;
import com.certusnet.nfv.mano.nfvo.vnfd.rest.VnfdRest;
import com.certusnet.nfv.mano.nfvo.vnfr.rest.VdurRest;
import com.certusnet.nfv.mano.nfvo.vnfr.rest.VnfrRest;
import com.certusnet.nfv.mano.rest.ManoExceptionMapper;
import com.certusnet.nfv.mano.rest.RestRequestFilter;
import com.certusnet.nfv.mano.rest.RestResponseFilter;

public class RestApplication extends ResourceConfig {

    /**
     * Register JAX-RS application components.
     */
    public RestApplication () {
        register(RequestContextFilter.class);
        register(ManoExceptionMapper.class);
        register(RestResponseFilter.class);
        register(RestRequestFilter.class);
        register(JacksonJsonProvider.class);
        register(NsdRest.class);
        register(PnfdRest.class);
        register(VnfdRest.class);
        register(LifecycleEventRest.class);
        register(VduRest.class);
        register(VnfcRest.class);
        register(NsrRest.class);
        register(VnfrRest.class);
        register(VdurRest.class);
        register(NetworkRest.class);
        register(OperationLogRest.class);
    }
}