`
y806839048
  • 浏览: 1120867 次
  • 性别: Icon_minigender_1
  • 来自: 上海
文章分类
社区版块
存档分类
最新评论

通过配置的容器过滤

阅读更多
=========================================通过配置的容器过滤????????????????????????????????????
  //过滤器的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);
    }
}


分享到:
评论

相关推荐

    websphere7.0配置容器级sso

    【标题】:WebSphere 7.0 配置容器级单点登录(SSO) 【内容】: 在企业级应用环境中,单点登录(Single Sign-On,SSO)是一种重要的安全机制,它允许用户在一次身份验证后访问多个应用程序,而无需再次输入凭证。...

    SpringBoot之配置嵌入式Servlet容器.pdf

    2. 编写一个实现了EmbeddedServletContainerCustomizer接口的Bean,通过编程方式设置Servlet容器的配置项,如端口号、上下文路径及会话超时时间。 注册Servlet三大组件(Servlet、Filter和Listener)是构建Web应用...

    XML常用配置信息 过滤器 监听器

    ### XML常用配置信息详解:过滤器、监听器与Session会话闲置时间 #### 一、XML配置基础 在Java Web开发中,`web.xml`是一个非常重要的配置文件,它主要用于定义Web应用程序的基本结构和行为。该文件是用XML(可...

    关于Java web的Servlet的配置和过滤器的配置和使用

    过滤器同样可以通过`web.xml`文件或者使用注解的方式进行配置。 - **通过web.xml配置**: ```xml &lt;filter-name&gt;CharsetFilter &lt;filter-class&gt;com.example.CharsetFilter&lt;/filter-class&gt; &lt;filter-name&gt;...

    过滤器(java编写的过滤器)

    通过对给定的过滤器配置进行深入解析,我们可以更好地理解过滤器的工作原理和配置方式,这对于实际项目开发具有重要的指导意义。在设计Web应用时,合理利用过滤器,可以有效提升应用的质量和效率。

    管道过滤器程序,主要用java实现

    4. **Filter生命周期**:在Java中,过滤器通常在Servlet容器(如Tomcat)启动时初始化,并在容器关闭时销毁。生命周期方法如`init()`, `doFilter()`, 和`destroy()`用于管理过滤器的初始化、运行和清理。 5. **过滤...

    容器编排系统中的配置状态治理.pptx

    ### 容器编排系统中的配置状态治理 #### 一、概述 ...通过对容器编排系统中配置状态的有效治理,不仅可以提高系统的稳定性和安全性,还能确保企业的业务活动符合各项法规要求,从而为企业创造更大的价值。

    通过过滤器判断用户权限

    在 `WEB.xml` 文件中,通过 `&lt;filter&gt;` 和 `&lt;filter-mapping&gt;` 元素来配置过滤器。 - `&lt;filter&gt;`:定义过滤器的基本信息,如名称和实现类。 - `&lt;filter-mapping&gt;`:指定哪些 URL 模式会被该过滤器拦截。 #### 2. ...

    Java过滤器及其特性

    过滤器的配置通常在Web应用的部署描述符`web.xml`中完成,通过`&lt;filter&gt;`和`&lt;filter-mapping&gt;`元素定义过滤器及其关联的URL模式。此外,Java EE 6及以上版本引入了注解配置,可以直接在过滤器类上使用`@WebFilter`...

    WAS 6.0.2.9 部署应用使用过滤器问题解决办法

    当在WAS 6.0.2.9环境中遇到过滤器问题时,通过检查配置、代码实现、日志以及容器设置,通常能找出问题并找到有效的解决方案。在测试程序`mytest`中,我们可以通过类似的方法来分析和解决过滤器问题。

    JAVA Web中过滤器

    过滤器是JAVA Servlet API的一部分,通过实现javax.servlet.Filter接口来创建自定义过滤器。下面将详细阐述JAVA Web中过滤器的相关知识点。 1. **过滤器的基本概念** 过滤器是一种动态调用的组件,它可以在请求...

    servlet基础与servlet容器模型

    2. **部署描述符**(web.xml):这是Web应用的配置文件,定义了Servlet、过滤器、监听器等组件的配置信息。 3. **Servlet**:实现了Servlet接口的Java类,处理客户端请求。 4. **Servlet实例**:Servlet容器根据...

    过滤器笔记整理

    - **执行顺序**:容器根据`web.xml`中的配置顺序依次调用各个过滤器的`doFilter()`方法。每个过滤器的处理结果通过`FilterChain`传递给下一个过滤器或目标资源。 #### 七、过滤器执行流程 1. **请求到达**:客户端...

    用过滤器验证

    1. **init(FilterConfig filterConfig)**:初始化方法,由容器调用,在容器启动时调用一次,用于配置过滤器。 2. **doFilter(ServletRequest request, ServletResponse response, FilterChain chain)**:核心方法,...

    简单迅速的web容器 简单迅速的web容器 简单迅速的web容器

    通过查看和运行这些示例,用户可以快速了解如何与Web容器交互,以及如何配置和管理Web应用。 在选择一个简单的Web容器时,开发者通常关注以下几点: - **性能**:轻量级的Web容器往往对硬件资源需求较低,但能快速...

    java敏感词过滤(支持指定字段过滤)

    - 配置类:如果是Spring项目,可能包含配置Bean的代码,用于注册过滤器到Spring容器。 - 示例或测试类:演示如何使用过滤器,可能包含一些测试用例。 通过以上步骤,我们可以有效地在Java项目中实现敏感词过滤,...

    过滤器链的一个小Demo

    在实际开发中,我们可以通过调整过滤器的配置顺序,实现不同的功能组合,例如先进行身份验证,再进行数据校验,最后进行日志记录。同时,过滤器还可以结合Servlet容器的其他特性,如Session管理、URL重写等,实现更...

    过滤器的编写

    在Web应用程序中,过滤器通常作为Servlet容器的一部分,如Tomcat或Jetty,它们在请求到达目标Servlet之前或之后执行。 2. **过滤器的生命周期** - **初始化**:当过滤器被加载时,`init()` 方法会被调用,用于初始...

    JAVAEE过滤器的使用

    在`doFilter()`方法中,如果抛出未捕获的异常,容器会自动调用`destroy()`方法,并跳过剩余的过滤器,直接将异常传递给Servlet容器处理。 8. **Spring MVC中的Filter** 在Spring MVC框架中,可以使用Spring的...

    过滤器.zip

    通过分析和实践"过滤器.zip"中的示例项目,你可以更好地理解过滤器的工作原理,掌握如何创建、配置和使用过滤器,以及它们在实际应用中的价值。每个filter_demo可能都对应着不同的应用场景或过滤器特性,逐一学习和...

Global site tag (gtag.js) - Google Analytics