基于AnypointStudio IDE开发MuleESB实例
本文部分内容引用https://www.cnblogs.com/enjoyingsoft/p/10132360.html，在此，对原著作者表示感谢。
一、AnypointStudio IDE环境的安装
1.安装jdk1.8以上
2.MuleESB分为社区版和企业版，两者的区别如下：
3.mule esb的开发，主要是在AnypointStudio IDE环境下开发的，所以首先需要下载一个AnypointStudio IDE，本文下载的是6.6.4版本。安装过程和eclipse一样。
由于Anypoint Studio默认只内嵌了Mule ESB企业版运行环境，如果你想使用社区版的话，我们还需要安装Mule ESB社区版运行环境。
安装社区版运行环境，可以使用下列步骤。
点击Help/Install New Software...菜单
在Work with下拉框中选择Mule Runtimes for Anypoint Studio
选中Mule ESB Server Runtime 3.9.0 CE，CE就是Community Edition，社区版的意思。然后点击Next一直到完成。
本例是实现一个cxf的webservice服务封装为http服务。
首先，需要自行开发一个webservice的服务端程序。
<code> <dependencies>
<dependency>
<groupid>org.springframework.boot/<groupid>
<artifactid>spring-boot-starter/<artifactid>
/<dependency>
<dependency>
<groupid>org.springframework.boot/<groupid>
<artifactid>spring-boot-starter-test/<artifactid>
<scope>test/<scope>
<exclusions>
<exclusion>
<groupid>org.junit.vintage/<groupid>
<artifactid>junit-vintage-engine/<artifactid>
/<exclusion>
/<exclusions>
/<dependency>
<dependency>
<groupid>org.springframework.boot/<groupid>
<artifactid>spring-boot-starter-web/<artifactid>
/<dependency>
<dependency>
<groupid>org.springframework.boot/<groupid>
<artifactid>spring-boot-starter-web-services/<artifactid>
<version>2.2.5.RELEASE/<version>
/<dependency>
<dependency>
<groupid>org.apache.cxf/<groupid>
<artifactid>cxf-spring-boot-starter-jaxws/<artifactid>
<version>3.3.5/<version>
/<dependency>
<dependency>
<groupid>commons-io/<groupid>
<artifactid>commons-io/<artifactid>
<version>2.5/<version>
/<dependency>
/<dependencies>/<code>
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
@WebService(name = "helloService",targetNamespace="http://service.cxf.cbi.com/")
public interface HelloService {
@WebMethod
String sayHello(@WebParam(name="param") Person person);
}
@Service
@WebService(targetNamespace="http://service.cxf.cbi.com/",
serviceName = "helloService",
endpointInterface = "com.cbi.cxf.server.service.HelloService")
public class HelloServiceImpl implements HelloService {
@Override
public String sayHello(@WebParam(name="param") Person person) {
System.out.println("receive:"+person.getName()+","+person.getAge());
return "hello,"+person.getName()+","+person.getAge();
}
}
<code>@Configuration
public class WebServiceConfig {
@Autowired
private HelloService helloService;
@Autowired
private SpringBus springBus;
@Bean(name = "helloServiceEndPoint")
public Endpoint endpoint() {
EndpointImpl endpoint=new EndpointImpl(springBus, helloService);//绑定要发布的服务
endpoint.publish("/helloWs"); //显示要发布的名称
return endpoint;
}/<code>
<code>public class Person implements Serializable {
private static final long serialVersionUID = 1L;
private String name;
private String age;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getAge() {
return age;
}
public void setAge(String string) {
this.age = string;
}
}/<code>
服务端程序开发完成之后启动，访问http://localhost:8080/cxf/webServices/helloWs?wsdl，即可得到如下wsdl：
<code><definitions>
<types>
<schema>
<element>
<element>
<complextype>
<sequence>
<element>
/<sequence>
/<complextype>
<complextype>
<sequence>
<element>
<element>
/<sequence>
/<complextype>
<complextype>
<sequence>
<element>
/<sequence>
/<complextype>
/<schema>
/<types>
<message>
<part> /<part>
/<message>
<message>
<part> /<part>
/<message>
<porttype>
<operation>
<output> /<output>
/<operation>
/<porttype>
<binding>
<binding>
<operation>
<operation>
<body>
/<input>
<output>
<body>
/<output>
/<operation>
/<binding>
<service>
<port>
<address>
/<port>
/<service>
/<definitions>/<code>
6.使用AnypointStudio开发mule ESB的服务。
根据实际选择运行环境，一直next下去，完成即可。
工程依赖包：
工程http2webservice创建好之后，按照区域1拖拽出流程，按照区域3编写java代码，区域2是在拖拽流程的过程中，可以搜索需要的组件。
<code>public class Person implements Serializable {
private static final long serialVersionUID = 1L;
private String name;
private String age;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getAge() {
return age;
}
public void setAge(String string) {
this.age = string;
}
}/<code>
<code>public class Trans extends AbstractMessageTransformer{
@Override
public Object transformMessage(MuleMessage message, String outputEncoding) throws TransformerException {
String xml="";
try {
xml=message.getPayloadAsString();
Document doc=DocumentHelper.parseText(xml);
Element root=doc.getRootElement();
Person person=new Person();
person.setName(root.element("name").getText());
person.setAge(root.element("age").getText());
JSONObject node = new JSONObject();
node.put("param", person);
System.out.println("node==================="+node);
Map<string> newMap=TransUtil.parseJSONToMap(node.toString());
System.out.println("newMap==================="+newMap);
xml=TransUtil.parseMapToXML(newMap, "sayHello", "http://service.cxf.cbi.com/");
} catch (Exception e) {
e.printStackTrace();
}
System.out.println("xml==================="+xml);
return xml;
}
}/<string>/<code>
<code>public class ReturnTrans extends AbstractMessageTransformer{
@Override
public Object transformMessage(MuleMessage message, String outputEncoding) throws TransformerException {
Object payload=message.getPayload();
DepthXMLStreamReader xmlreader=(DepthXMLStreamReader) payload;
XMLStreamReader reader=xmlreader.getReader();
String returnxml="";
try {
while(reader.hasNext()) {
int point =reader.next();
if(point==XMLStreamReader.START_ELEMENT) {
String eleName=reader.getName().toString();
if("return".equals(eleName)) {
returnxml=reader.getElementText();
break;
}
}
}
} catch (XMLStreamException e) {
e.printStackTrace();
}
returnxml="<result>"+returnxml+"/<result>";
System.out.println("xml==================="+returnxml);
return returnxml;
}/<code>
<code>public class TransUtil {
public static Map<string> parseJSONToMap(String jsonStr){
Map<string> map = new HashMap<>();
JSONObject json = JSONObject.fromObject(jsonStr);
for (Object k : json.keySet()) {
Object v = json.get(k);
if (v instanceof JSONArray) {
List/<string>/<string>/<code>
按照如上图的配置完成之后，可以启动工程。在工程上右键run as mule application即可。
7.测试
cxf服务客户端测试：
方式一：动态调用
<code>public class TestClient {
public static void main(String[] args) throws InvocationTargetException, IllegalAccessException, NoSuchMethodException, ClassNotFoundException, InstantiationException {
// 创建动态客户端
JaxWsDynamicClientFactory dcf = JaxWsDynamicClientFactory.newInstance();
Client client = dcf.createClient("http://localhost:8080/cxf/webServices/helloWs?wsdl");
// 需要密码的情况需要加上用户名和密码
// client.getOutInterceptors().add(new ClientLoginInterceptor(USER_NAME, PASS_WORD));
Object[] result = null;
//loadClass路径是命名空间+po类名，不是Po的包路径+po类名
Object po = Thread.currentThread().getContextClassLoader().loadClass("com.cbi.cxf.service.Person").newInstance();//加载类为服务端自定义对象命名空间
Method method = po.getClass().getMethod("setName", String.class);//调用set方法设置参数
method.invoke(po, "卓宝贝");
method = po.getClass().getMethod("setAge", String.class);//调用set方法设置参数
method.invoke(po, "6");
Object[] parameters = new Object[]{po};
try {
result = client.invoke("sayHello", parameters);//uploadcs为接口方法
System.out.println(result[0].toString());
} catch (Exception e) {
e.printStackTrace();
}
}/<code>
方式二：静态调用
<code>public class TestClient2 {
public static void main(String[] args) {
JaxWsProxyFactoryBean factory = new JaxWsProxyFactoryBean();
factory.setAddress("http://localhost:8080/cxf/webServices/helloWs?wsdl");
factory.setServiceClass(HelloService.class);//服务端接口类
Person person = new Person();//自定义对象参数
person.setName("卓宝贝");
person.setAge("6");
HelloService service = (HelloService) factory.create();
String results = service.sayHello(person);//sayHello为接口方法
System.out.println(results);
}
}/<code>
两种方式测试原始的webservice接口的结果相同，如下：
hello,卓宝贝,6
使用postman测试封装的http接口：post方式 http://127.0.0.1:8081/http2webservice/hello
返回结果说明：
如果返回结果要和原始的webservice接口保持一致，流程图中的最后一个节点需要去掉。
如果返回结果需要用json表示，则需要在ReturnTrans类中或者在webservice接口返回时，先拼接成xml格式，然后xml to json节点才会正确转换，否则会报错，如下：
最终获得的结果json格式如下：
<code>{
"result": "hello,卓宝贝,6"
}/<code>閱讀更多 滄瀾孤城 的文章
