简单需求:
针对在webservice中一些商业数据的机密性采用加密等验证的方式实现,这里主要说明soap使用UsernameToken的验证方式.
mule-config.xml配置:
<mule xmlns:core="http://www.mulesoft.org/schema/mule/core" xmlns="http://www.mulesoft.org/schema/mule/core"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:spring="http://www.springframework.org/schema/beans"
xmlns:cxf="http://www.mulesoft.org/schema/mule/cxf"
xmlns:doc="http://www.mulesoft.org/schema/mule/documentation"
xmlns:http="http://www.mulesoft.org/schema/mule/http"
xsi:schemaLocation="
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd
http://www.mulesoft.org/schema/mule/cxf http://www.mulesoft.org/schema/mule/cxf/current/mule-cxf.xsd
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd " version="EE-3.3.0">
<flow name="UnsecureServiceFlow" doc:name="UnsecureServiceFlow">
<http:inbound-endpoint address="http://localhost:63082/services/unsecure" exchange-pattern="request-response" doc:name="HTTP Inbound Endpoint"/>
<cxf:jaxws-service serviceClass="com.mulesoft.mule.soap.security.Greeter" doc:name="Unsecure service"/>
<component class="com.mulesoft.mule.soap.security.GreeterService" doc:name="Greeter Service" />
</flow>
<flow name="UsernameTokenServiceFlow" doc:name="UsernameTokenServiceFlow">
<http:inbound-endpoint address="http://localhost:63082/services/username" exchange-pattern="request-response" doc:name="HTTP Inbound Endpoint"/>
<cxf:jaxws-service serviceClass="com.mulesoft.mule.soap.security.Greeter" doc:name="Secure UsernameToken service">
<cxf:ws-security>
<cxf:ws-config>
<cxf:property key="action" value="UsernameToken Timestamp"/>
<cxf:property key="passwordCallbackClass" value="com.mulesoft.mule.soap.security.PasswordCallback"/>
</cxf:ws-config>
</cxf:ws-security>
</cxf:jaxws-service>
<component class="com.mulesoft.mule.soap.security.GreeterService" doc:name="Greeter Service"/>
</flow>
</mule>
package com.mulesoft.mule.soap.security;
import javax.jws.WebParam;
import javax.jws.WebResult;
import javax.jws.WebService;
@WebService
public interface Greeter
{
@WebResult(name="name")
public String greet(@WebParam(name="name") String name);
}
package com.mulesoft.mule.soap.security;
public class GreeterService implements Greeter
{
public String greet(String name)
{
return "Hello " + name;
}
}
回调类:
package com.mulesoft.mule.soap.security;
import java.io.IOException;
import javax.security.auth.callback.Callback;
import javax.security.auth.callback.CallbackHandler;
import javax.security.auth.callback.UnsupportedCallbackException;
import org.apache.ws.security.WSPasswordCallback;
/**
*
* <p>功能描述,该部分必须以中文句号结尾。<p>
*
* 创建日期 2013-8-27<br>
* @author $Author$<br>
* @version $Revision$ $Date$
* @since 3.0.0
*/
public class PasswordCallback implements CallbackHandler
{
public void handle(Callback[] callbacks) throws IOException, UnsupportedCallbackException
{
WSPasswordCallback pc = (WSPasswordCallback) callbacks[0];
if (pc.getIdentifier().equals("joe"))
{
pc.setPassword("secret");
}
else if (pc.getIdentifier().equals("stan"))
{
pc.setPassword("elephant");
}
}
}
服务端测试
public class MuleServerApp {
public static void main(String[] args) throws MuleException {
String configFile = "mule-config.xml";
System.setProperty("mule.verbose.exceptions","true");
String[] configFileArr = new String[] {configFile };
MuleContextFactory muleContextFactory = new DefaultMuleContextFactory();
MuleContext muleContext = muleContextFactory
.createMuleContext(new SpringXmlConfigurationBuilder(configFileArr));
muleContext.start();
}
}
客户端测试
package com.mulesoft.mule.soap.test;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.HashMap;
import java.util.Map;
import javax.xml.namespace.QName;
import javax.xml.ws.Service;
import org.apache.cxf.endpoint.Client;
import org.apache.cxf.frontend.ClientProxy;
import org.apache.cxf.ws.security.wss4j.WSS4JOutInterceptor;
import com.mulesoft.mule.soap.security.Greeter;
import com.mulesoft.mule.soap.security.PasswordCallback;
/**
*
* <p>功能描述,该部分必须以中文句号结尾。<p>
*
* 创建日期 2013-8-27<br>
* @author $Author$<br>
* @version $Revision$ $Date$
* @since 3.0.0
*/
public class MuleSecureClient
{
public static void main(String[] args) throws Exception
{
Greeter service1 = createService("http://localhost:63082/services/unsecure?wsdl", null);
System.out.println(service1.greet("Mule"));
Greeter service2 = createService("http://localhost:63082/services/username?wsdl",
getUsernameTokenProps("UsernameToken Timestamp"));
System.out.println(service2.greet("Mule"));
}
protected static Map<String, Object> getUsernameTokenProps(String action)
{
Map<String, Object> wss4jProps = new HashMap<String, Object>();
//设置请求时候的参数信息
wss4jProps.put("action", action);
wss4jProps.put("user", "joe");
//回调类
wss4jProps.put("passwordCallbackClass", PasswordCallback.class.getName());
return wss4jProps;
}
public static Greeter createService(String url, Map<String, Object> wss4jProps)
{
URL wsdlDocumentLocation;
try
{
wsdlDocumentLocation = new URL(url);
}
catch (MalformedURLException e)
{
throw new RuntimeException("Invalid test definition", e);
}
QName serviceName = new QName("http://security.soap.mule.mulesoft.com/", "GreeterService");
Service dynService = Service.create(wsdlDocumentLocation, serviceName);
Greeter service = dynService.getPort(Greeter.class);
Client client = ClientProxy.getClient(service);
if (wss4jProps != null)
{
client.getOutInterceptors().add(new WSS4JOutInterceptor(wss4jProps));
}
return service;
}
}
相关推荐
### ESB原理及Mule ESB实践 #### ESB（Enterprise Service Bus）原理概述 **ESB**（企业服务总线）是SOA（面向服务架构）架构中的关键组件之一，用于实现服务间的智能集成与管理。其核心作用在于简化不同系统间的...
根据提供的文件内容，以下是关于Mule ESB手册-中文版的知识点： 1. Mule ESB简介 ...通过这些知识点的学习，可以加深对Mule ESB的使用方法的理解，并通过实例加深对ESB概念的理解，对新手来说非常有帮助。
在本篇“Mule ESB 学习笔记（13）CSV数据文件到数据库”中，我们将探讨如何使用Mule ESB（Enterprise Service Bus，企业服务总线）处理CSV（Comma Separated Values，逗号分隔值）数据，并将其有效地导入到数据库中...
《深入解析Mule ESB源码》 Mule ESB（Enterprise Service Bus，企业服务总线）是一款开源的集成平台，旨在简化企业级应用之间的数据交互。本文将围绕Mule ESB的源码进行深入探讨，揭示其核心设计理念与工作原理。 ...
MULE ESB（Mule Enterprise Service Bus）是Anypoint Platform的核心组件，它是一个强大的、全面集成的企业服务总线（ESB），专为构建、部署和管理API和集成解决方案而设计。MULE ESB-4.1是MuleSoft公司推出的企业版...
Mule ESB 是一个基于 Java 的轻量级企业服务总线和集成平台，允许开发人员快速便利地连接多个应用，并支持应用间的数据交换。Mule ESB 支持集成现有系统而无论其底层采用何种技术，如 JMS、Web Services、JDBC、...
Mule ESB 是一个轻量级的基于java的企业服务总线和集成平台， 使得开发人员可以快速，简单的连接多个应用， 使得它们可以交换数据。 Mule ESB 容易集成现有异构系统，包括：JMS, Web Services, JDBC, HTTP, 等. ESB...
1. **事件驱动架构**：Mule ESB基于事件驱动模型，能够实时响应系统中的变化，实现快速的数据传输和处理。 2. **无代码/低代码开发**：通过图形化的工作流设计工具Anypoint Studio，开发者可以直观地构建和部署集成...
- **与JBI容器的整合**：虽然Mule ESB不是基于JBI构建的，但它提供了JBI适配器，以便更好地与JBI容器协同工作。 #### 三、Mule ESB 3.0的关键特性 - **云连接(Cloud Connect)**：Mule 3引入了一种全新的特性——云...
2. **Mule ESB架构**：Mule ESB基于事件驱动的架构，允许它快速响应系统中的变化。它由消息代理、连接器、数据转换器、流量控制和安全组件等组成。 3. **Mule Studio**：MuleSoft提供的集成开发环境（IDE），支持...
4. **Web服务支持**：Mule ESB能够处理基于Axis或Glue的Web服务，支持SOAP和其他Web服务标准，允许服务间的互操作性。 5. **灵活的部署结构**：Mule ESB提供了多种部署拓扑，包括Client/Server、P2P（对等）、ESB...
5. **事件驱动架构**：Mule ESB基于事件模型，能够响应并处理来自不同系统的事件。 6. **云集成**：支持与云平台如AWS、Azure、Google Cloud的集成。 《Mule ESB Cookbook随书源码》中的样本项目可能涵盖了以下主题...
MuleESB是一个基于Java的轻量级企业服务总线和集成平台，允许开发人员快速便利地连接多个应用，并支持应用间的数据交换。MuleESB支持集成现有系统而无论其底层采用何种技术，如JMS、WebServices、JDBC、HTTP以及其他...
Mule ESB支持各种安全机制，如SSL/TLS加密、身份验证、授权等，以保护数据传输的安全。同时，通过合理的配置和设计，可以优化Mule应用的性能，如使用缓存、负载均衡、异步处理等策略。 总之，Mule ESB提供了一个...
《Mule ESB 开发手册》是一份详尽的指南，专为希望深入了解并掌握 Mule ESB（Enterprise Service Bus）技术的...通过深入学习和实践，开发者可以充分利用 Mule ESB 的强大功能，实现高效、可靠的企业级集成解决方案。
Anypoint Studio 是 Mule ESB 的官方开发工具，它是基于 Eclipse 的一个强大IDE，专为构建基于Mule的应用而设计。Anypoint Studio 提供了图形化的工作流设计界面，使得开发者可以通过拖拽组件来创建和配置Mule应用...
标题：《Mule ESB 3用户指南》 描述：本手册旨在为用户提供对Mule ESB 3的基础使用指导，强调了Mule ESB作为一个社区成熟且文档丰富的开源企业服务总线（ESB）的使用方法。 知识点说明： 1. Mule ESB概述： Mule ...