=========================================通过配置的容器过滤????????????????????????????????????
//过滤器的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);
}
}
通过配置的容器过滤
猜你喜欢
转载自yuhuiblog6338999322098842.iteye.com/blog/2212142
今日推荐
周排行