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
-----------------------------------------------------

 

 

评论

9 楼 apollo211 2012-11-23  

可能是访问路径不对 http://localhost:8080/httpgateway/http/sales/a/b/c 中的httpgateway改成自己定义的工程名 就可以解决404问题

8 楼 hesihua 2011-08-14  

yarafa 写道

404是错误的服务请求，你的服务部署是否成功了

服务端没有提示错误:
15:12:47,796 INFO  [JBoss4ESBDeployer] create esb service, sixesb.esb
15:12:47,806 INFO  [TomcatDeployer] deploy, ctxPath=/sixesb, warUrl=.../tmp/deploy/tmp50689sixesb-exp.war/

7 楼 hesihua 2011-08-11  

yarafa 写道

404是错误的服务请求，你的服务部署是否成功了

嗯 服务器上没有提示错误呀~

6 楼 yarafa 2011-08-10  

404是错误的服务请求，你的服务部署是否成功了

5 楼 hesihua 2011-08-09  

测试第一个服务时我得不到正确的结果,我在firefox中进行测试时是提示404错误:
The requested resource (/httpgateway/http/sales/a/b/c) is not available.

4 楼 yarafa 2011-05-02  

1. deployment.xml中不需要任何依赖信息
2. ie显示不出来，可能是安全设置的问题，好久没用ie了，你自己上网查吧，就好像ie可以直接显示xml文件，但chrome不能一样

3 楼 crabboy 2011-05-02  

crabboy 写道

goole浏览器看不到信息，console上也打印不出来信息。ie上没有问题

抱歉，写反了。
goole浏览器上显示完整，ie上打印不完整。也不知怎么调试ie设置？

2 楼 crabboy 2011-05-02  

goole浏览器看不到信息，console上也打印不出来信息。ie上没有问题

1 楼 crabboy 2011-05-02  

这个例子无需deployment.xml?