JBoss ESB学习笔记7——第六个ESB应用Http Gateway
续上篇介绍了第五个ESB应用,本文介绍第六个ESB应用——Http Gateway。
说明:本文及后续文章虽非百分百的原创,但毕竟包含本人的努力和付出,所以希望大家转载时务请注明出处:http://yarafa.iteye.com,谢谢合作。
1概述
该实例主要演示了如何通过http通道将客户端发来的http请求传给ESB服务。
2 新建ESB工程
操作过程略。
3 ESB配置
3.1 定义Action类
下面将定义两个action类以及一个自定义的exception类。
3.1.1 HttpGatewayAction
当客户端向ESB服务器发出http请求后,由ESB服务器将请求封装成ESB消息,该action的主要作用是通过ESB消息解析出http请求的相关信息,并打印出来。代码如下:
/***********************************************************************
* <p>Project Name: httpgateway</p>
* <p>File Name: com.thu.afa.esb.jbossesb.action.HttpGatewayAction.java</p>
* <p>Copyright: Copyright (c) 2010</p>
* <p>Company: <a href="http://afa.thu.com">http://afa.thu.com</a></p>
***********************************************************************/
package com.thu.afa.esb.jbossesb.action;
import org.jboss.soa.esb.Service;
import org.jboss.soa.esb.actions.AbstractActionLifecycle;
import org.jboss.soa.esb.helpers.ConfigTree;
import org.jboss.soa.esb.http.HttpRequest;
import org.jboss.soa.esb.listeners.ListenerTagNames;
import org.jboss.soa.esb.message.Message;
import com.thoughtworks.xstream.XStream;
/**
* <p>Class Name: HttpGatewayAction</p>
* <p>Description: </p>
* @author Afa
* @date 2010-9-12
* @version 1.0
*/
public class HttpGatewayAction extends AbstractActionLifecycle
{
protected ConfigTree configTree;
protected Service service;
public HttpGatewayAction(ConfigTree configTree)
{
this.configTree = configTree;
service = new Service(configTree.getParent()
.getAttribute(ListenerTagNames.SERVICE_CATEGORY_NAME_TAG),
configTree.getParent().getAttribute(ListenerTagNames.SERVICE_NAME_TAG));
}
public Message process(Message message) throws Exception
{
System.out.println("&&&&&&&&&&&&&&&& MyAction &&&&&&&&&&&&&&&&&&&&&");
System.out.println("");
System.out.println("Service: " + service);
System.out.println("");
System.out.println("------------Http Request Info (XStream Encoded)-------------------");
HttpRequest request = HttpRequest.getRequest(message);
String requestXml = "";
XStream xstream = new XStream();
requestXml = xstream.toXML(request);
System.out.println(requestXml);
System.out.println("------------Http Request body -------------------");
System.out.println(message.getBody().get());
System.out.println("&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&");
StringBuffer response = new StringBuffer();
response.append("Service: " + service + "\n\n");
response.append("------------Http Request Info (XStream Encoded)-------------------\n");
response.append(requestXml);
message.getBody().add(response.toString());
return message;
}
}
3.1.2 HttpGatewayException
这是自定义的异常类。
/***********************************************************************
* <p>Project Name: httpgateway</p>
* <p>File Name: com.thu.afa.esb.jbossesb.action.HttpGatewayException.java</p>
* <p>Copyright: Copyright (c) 2010</p>
* <p>Company: <a href="http://afa.thu.com">http://afa.thu.com</a></p>
***********************************************************************/
package com.thu.afa.esb.jbossesb.action;
import org.jboss.soa.esb.actions.ActionProcessingException;
/**
* <p>Class Name: HttpGatewayException</p>
* <p>Description: </p>
* @author Afa
* @date 2010-9-12
* @version 1.0
*/
public class HttpGatewayException extends ActionProcessingException
{
private static final long serialVersionUID = 1L;
public HttpGatewayException(String message)
{
super(message);
}
}
3.1.3 HttpGatewayExceptionAction
这是自定义的异常处理类,该action类主要用来产生一个自定义异常。
/***********************************************************************
* <p>Project Name: httpgateway</p>
* <p>File Name: com.thu.afa.esb.jbossesb.action.HttpGatewayExceptionAction.java</p>
* <p>Copyright: Copyright (c) 2010</p>
* <p>Company: <a href="http://afa.thu.com">http://afa.thu.com</a></p>
***********************************************************************/
package com.thu.afa.esb.jbossesb.action;
import org.jboss.soa.esb.actions.AbstractActionLifecycle;
import org.jboss.soa.esb.helpers.ConfigTree;
import org.jboss.soa.esb.message.Message;
/**
* <p>Class Name: HttpGatewayExceptionAction</p>
* <p>Description: </p>
* @author Afa
* @date 2010-9-12
* @version 1.0
*/
public class HttpGatewayExceptionAction extends AbstractActionLifecycle
{
protected ConfigTree configTree;
public HttpGatewayExceptionAction(ConfigTree configTree)
{
this.configTree = configTree;
}
public Message process(Message message) throws Exception
{
throw new HttpGatewayException("HttpGatewayException...");
}
}
3.2 属性定义
在src目录下创建属性文件http-exception-mappings.properties,并添加以下两个属性:
org.jboss.soa.esb.services.security.SecurityServiceException=401 com.thu.afa.esb.jbossesb.action.HttpGatewayException=502
3.3 配置安全域
<globals> <war-security domain="JBossWS" method="BASIC" /> </globals>
这里是对jboss-esb.xml中的所有http-provider和EBWS的安全配置,用到了java:/jaas/JBossWS安全域,该安全域配置由JBoss ESB服务器提供,客户端提交http请求时需要使用具有该安全域的账号信息。比如,用户名:kermit,密码:thefrog。
3.4定义Provider
<http-provider name="http"> <http-bus busid="secureFriends"> <protected-methods> <method name="GET" /> <method name="POST" /> </protected-methods> <allowed-roles> <role name="friend" /> </allowed-roles> </http-bus> <exception mappingsFile="/http-exception-mappings.properties" /> </http-provider>
这里定义了只有具有friend角色的用户才能向secureFriends通道提交请求。
3.5 定义第一个服务
<service category="HttpGateway" description="Http Gateway" invmScope="GLOBAL" name="SalesList"> <listeners> <http-gateway busidref="secureFriends" name="sales" urlPattern="sales/*" /> </listeners> <actions mep="RequestResponse"> <action class="com.thu.afa.esb.jbossesb.action.HttpGatewayAction" name="printAction" process="process" /> </actions> </service>
说明:该服务的配置表明,当客户端请求的url具有 urlPattern 属性指定的格式时,将触发对应的操作,即由 com.thu.afa.esb.jbossesb.action.HttpGatewayAction 类中的process方法执行处理操作。
3.6 第一个服务请求
通过浏览器请求以下地址:http://localhost:8080/httpgateway/http/sales/a/b/c 即可向第一个服务提交请求,并且可以在浏览器和ESB服务器控制台看到如下输出信息,需要注意的是,在提交请求之前,浏览器会自动提示输入用户名和密码,输入以下信息即可:kermit/thefrog。
从以上两图中可以看到http请求的详细信息。
3.7 定义第二个服务
<service category="HttpGateway" description="Soap List" invmScope="GLOBAL" name="SoapList"> <listeners> <http-gateway busidref="secureFriends" name="soap" urlPattern="soap/*"> <exception> <mapping class="org.jboss.soa.esb.services.security.SecurityServiceException" status="401" /> </exception> </http-gateway> </listeners> <actions> <action class="com.thu.afa.esb.jbossesb.action.HttpGatewayAction" name="printAction" process="process" /> </actions> </service>
说明:该服务配置与第一个服务类似,这里不再重复说明。
3.8 第二个服务请求
在浏览器中请求以下地址:http://localhost:8080/httpgateway/http/soap即可在浏览器和ESB服务器控制台看到如下输出信息:
与第一个服务类似,从以上两图中可以看到http请求的详细信息。
3.9 定义第三个服务
<service category="HttpGateway" description="Http Gateway Exception1" invmScope="GLOBAL" name="Exception1"> <listeners> <http-gateway name="exception1" /> </listeners> <actions mep="RequestResponse"> <action class="com.thu.afa.esb.jbossesb.action.HttpGatewayExceptionAction" name="printAction" process="process" /> </actions> </service>
说明:这里用到了自定义的异常处理类。
3.10 第三个服务请求
在浏览器中请求以下地址:http://localhost:8080/httpgateway/http/HttpGateway/Exception1即可在浏览中看到以下输出结果:
说明:从上图可以看到,在浏览器中打印了异常信息。实际应用中,一般不会像这样打印异常信息,此时,可以通过修改HttpGatewayExceptionAction的处理逻辑来执行异常处理。
3.11 定义第四个服务
<service category="HttpGateway" description="Http Gateway Exception2" invmScope="GLOBAL" name="Exception2"> <listeners> <http-gateway busidref="secureFriends" name="exception2"> <exception> <mapping class="com.thu.afa.esb.jbossesb.action.HttpGatewayException" status="503" /> </exception> </http-gateway> </listeners> <actions mep="RequestResponse"> <action class="com.thu.afa.esb.jbossesb.action.HttpGatewayExceptionAction" name="printAction" process="process" /> </actions> </service>
3.12 第四个服务请求
在浏览器中请求以下地址:http://localhost:8080/httpgateway/http/HttpGateway/Exception2即可在浏览中看到以下输出结果:
与第三个服务类似,这里同样是打印输出异常信息。
上述便是ESB第六个应用实例。如有问题,欢迎指正。
-----------------------------------------------------
Stay Hungry, Stay Foolish!
http://yarafa.iteye.com
Afa
Feb 26th, 2011
-----------------------------------------------------