有 Java 编程相关的问题?

你可以在下面搜索框中键入要查询的问题!

java如何在CXF请求拦截器中从SoapMessage获取WSDL操作名

我试图获取wsdl操作名(SOAPAction),但它给了我空值。我已经在camel blueprint中编写了一个请求拦截器。
要执行的任务:目标是拦截Web服务请求,检索用户名&;来自Header&;检查用户是否有权使用请求的SOAPAction/OperationName。我怎样才能做到这一点。?有没有其他方法可以做到这一点

public class Interceptor extends AbstractSoapInterceptor {

    Logger _log = Logger.getLogger(Interceptor.class);

    public Interceptor() {
        super(Phase.PRE_LOGICAL);
    }

    @Override
    public void handleMessage(SoapMessage message) {
        _log.info(".... IM HERE INTERCEPTOR");

        Map<String, List<String>> headers = CastUtils.cast((Map) message.get(Message.PROTOCOL_HEADERS));
        _log.info(".... IM HERE INTERCEPTOR:::: " + headers.size());

        for (Entry<String, List<String>> entry : headers.entrySet()) {
            _log.info(entry.getKey() + " /// " + entry.getValue().get(0));
        }
    }
}

我的代码日志如下:

.... IM HERE INTERCEPTOR
.... IM HERE INTERCEPTOR:::: 9
accept-encoding /// gzip,deflate
connection /// keep-alive
Content-Length /// 351
content-type /// text/xml;charset=UTF-8
Host /// localhost:8181
password /// herman
SOAPAction /// ""
User-Agent /// Apache-HttpClient/4.1.1 (java 1.5)
username /// herman

下面是蓝图

<?xml version="1.0" encoding="UTF-8"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
    xmlns:camel="http://camel.apache.org/schema/blueprint"
    xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.1.0"
    xmlns:cxf="http://camel.apache.org/schema/blueprint/cxf"
    xmlns:cxfcore="http://cxf.apache.org/blueprint/core"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="              http://www.osgi.org/xmlns/blueprint/v1.0.0 http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd              http://camel.apache.org/schema/blueprint/cxf http://camel.apache.org/schema/blueprint/cxf/camel-cxf.xsd              http://camel.apache.org/schema/blueprint http://camel.apache.org/schema/blueprint/camel-blueprint.xsd              http://cxf.apache.org/schemas/blueprint/core http://cxf.apache.org/schemas/blueprint/core.xsd              http://cxf.apache.org/blueprint/jaxws http://cxf.apache.org/blueprint/jaxws.xsd">
    <bean class="pk.com.herman.log.query.QueryProcessor" id="QueryProcessor"/>
    <bean class="pk.com.herman.get.query.QueryGetProcessor" id="QueryGetProcessor"/>
    <bean class="pk.com.herman.interceptors.Interceptor" id="requestInterceptor"/>
    <cxfcore:bus bus="cxf">
        <cxfcore:inInterceptors>
            <ref component-id="requestInterceptor"/>
        </cxfcore:inInterceptors>
    </cxfcore:bus>
    <cxf:cxfEndpoint address="/query/" id="queryEndpoint" serviceClass="pk.com.herman.log.query.QueryService"/>
    <camelContext id="camelContext-282c3eaf-a6ba-4f22-bee7-9ad3fd7ae3ca" xmlns="http://camel.apache.org/schema/blueprint">
        <route id="cxf">
            <!-- route starts from the cxf webservice in POJO mode -->
            <from id="_from1" uri="cxf:bean:queryEndpoint"/>
            <recipientList id="_recipientList1">
                <simple>direct:${header.operationName}</simple>
            </recipientList>
        </route>
        <route id="query">
            <from id="_from2" uri="direct:reportQuery"/>
            <log id="_log1" message="Query Call"/>
            <process id="_process1" ref="QueryProcessor"/>
            <to id="_to1" uri="log:output"/>
        </route>
    </camelContext>
</blueprint>

共 (0) 个答案