Spring集成CXF獲取HttpServletRequest,HttpServletResponse

 

最近的項目中，在Spring繼承CXF中要用到request來獲取IP，所以先要獲取到HttpServletRequest對象，具體方法如下：

 

1、配置文件：

   <jaxrs:server id="aslRest" address="/">
       <jaxrs:inInterceptors>
             <bean class="org.apache.cxf.interceptor.LoggingInInterceptor" />
         </jaxrs:inInterceptors> 
         
       <jaxrs:serviceBeans>
           <ref bean="umpgServiceInf"/>
       </jaxrs:serviceBeans>
       
       <jaxrs:providers>
           <bean class="com.fasterxml.jackson.jaxrs.json.JacksonJsonProvider"/>  
       </jaxrs:providers>
       
   </jaxrs:server> 

 

2、代碼實現：

package com.zat.asl.output.service.impl;

import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.parser.Feature;
import com.zat.asl.output.service.inf.UmpgServiceInf;
import com.zat.asl.output.service.inf.UmpgServiceProxyInf;
import com.zat.asl.service.AbstractService;
import com.zat.asl.util.AslUtils;
import org.apache.cxf.message.Message;
import org.apache.cxf.phase.PhaseInterceptorChain;
import org.apache.cxf.transport.http.AbstractHTTPDestination;
import org.apache.log4j.Logger;
import org.springframework.stereotype.Service;
import org.springframework.util.StringUtils;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.ws.rs.core.Response;

@Service("umpgServiceInf")
public class UmpgServiceImpl extends AbstractService implements UmpgServiceInf {

    Logger logger = Logger.getLogger(UmpgServiceImpl.class);
    @Resource(name="umpgServiceProxyInf")
    private UmpgServiceProxyInf umpgServiceProxyInf;

    @Override
    public Response gateway(String request) {
        String resp = null;
        try{
31             Message message = PhaseInterceptorChain.getCurrentMessage();
32             HttpServletRequest httpServletRequest = (HttpServletRequest) message.get(AbstractHTTPDestination.HTTP_REQUEST);
33             String realIp = httpServletRequest.getHeader("X-Real-IP");
35             logger.info("客戶端真實IP>>>realIp=" + realIp + "，forwardedFor=" + forwardedFor);

            String requestWithIp = request;
            if (!StringUtils.isEmpty(realIp)) {
                JSONObject reqJson = JSONObject.parseObject(request, Feature.OrderedField);
                reqJson.put("clientRealIp", realIp);
                requestWithIp = JSONObject.toJSONString(reqJson);
                logger.info("原始的request=" + request);
                logger.info("注入IP的request=" + requestWithIp);
            }
            resp = umpgServiceProxyInf.gateway(requestWithIp);
        }catch(Exception e){
            logger.error(e.getMessage(),e);
            return getErrorResponse(AslUtils.ASL_RESP_DATA_TYPE_JSON, AslUtils.ASL_RESPCODE_9999);
        }
        return getSuccessResponse(resp);
    }
}