JBossESB学习笔记8——第七个ESB应用HttpsGateway.doc

JBoss ESB学习笔记8第七个ESB应用Https Gateway续上篇介绍了第六个ESB应用，本文介绍第七个ESB应用Https Gateway。1概述该实例主要演示了两点：一是配置一个https的ESB入口，二是在ESB外部端点中配置http路由器实现https传输方式的调用。 2 新建ESB工程操作过程略。3 ESB配置3.1 创建消息队列这里将创建一个消息地理用于接收客户端消息，在esbcontent文件夹下创建文件jbm-queue-service.xml用于配置消息队列，内容如下：Xml代码 1 2 3 5 6 jboss.messaging:service=ServerPeer 7 8 jboss.messaging:service=PostOffice 9 10 3.2 定义Provider这里将创建两个provider，一个提供客户端消息通道，另一个是jbr-provider，下面具体介绍。3.2.1 jms-providerXml代码 11 12 13 15 16 3.2.2 jbr-providerXml代码 17 18 20 21 23 24 25 26 27 关于jbr-provider的配置如上所示，下面对各个属性做简要说明：jbr-KeyStoreURL：密钥库文件的路径，下面会说明如何创建密钥库文件jbr-KeyStorePassword：密钥库文件的密码，在创建密钥库文件时指定jbr-TrustStoreURL：受信任的密钥库文件路径，可与jbr-KeyStoreURL属性值一样jbr-TrustStorePassword：受信任的密钥库文件的密码jbr-ClientAuthMode：客户端验证模式serviceInvokerTimeout：服务调用时限httpsgatewayJBRChanel：JBR端口设置关于各个属性的详细说明，可参考官方文档或者相关API。 3.2.3 keystore制作密钥库文件的制作如下图所示，这里使用的是JDK提供的keytool工具。关于如何使用keytool制作密钥库文件，请自行查找，网上到处都是，这里不再说明。将制作好的keystore文件命名为httpsgateway.keystore，并保存至C:/jbossesb-server-4.7目录下。 3.2.4 配置属性文件在esbcontent/ META-INF目录下新建属性文件HttpRperties，其内容如下：Properties代码 28 configurators=HttpProtocol 29 protocol-socket-factory=mons.httpclient.contrib.ssl.EasySSLProtocolSocketFactory 30 keystore=C:/jbossesb-server-4.7/httpsgateway.keystore 31 keystore-passw=123456 32 truststore=C:/jbossesb-server-4.7/httpsgateway.keystore 33 truststore-passw=123456 34 max-connections-per-host=5 3.3定义Action类3.3.1 Client Action该类用于打印输出客户端响应的具体内容。Java代码 35 package com.thu.afa.esb.jbossesb.action.client; 36 37 import org.jboss.soa.esb.actions.AbstractActionLifecycle; 38 import org.jboss.soa.esb.helpers.ConfigTree; 39 import org.jboss.soa.esb.http.HttpHeader; 40 import org.jboss.soa.esb.http.HttpResponse; 41 import org.jboss.soa.esb.message.Message; 42 43 import java.util.List; 44 45 public class HttpResponsePrinter extends AbstractActionLifecycle 46 47 protected ConfigTree configTree; 48 49 public HttpResponsePrinter(ConfigTree config) 50 this.configTree = config; 51 52 53 54 public Message process(Message message) throws Exception 55 56 HttpResponse httpResponse = (HttpResponse) message.getBody().get(HttpResponse.RESPONSE_KEY); 57 58 System.out.println(= Client Response: =); 59 System.out.println(Message Payload:); 60 System.out.println(t + message.getBody().get() + ); 61 62 System.out.println(); 63 System.out.println(Http Response:); 64 System.out.println(tCode: + httpResponse.getResponseCode(); 65 System.out.println(tLength: + httpResponse.getLength(); 66 System.out.println(tEncoding: + httpResponse.getEncoding(); 67 68 System.out.println(tHeaders:); 69 List headers = httpResponse.getHttpHeaders(); 70 for (HttpHeader header : headers) 71 System.out.println(tt + header.getName() + : + header.getValue(); 72 73 74 System.out.println(=); 75 76 return message; 77 78 3.3.2 Server Action该类用于打印输出服务端请求的具体内容。Java代码 79 package com.thu.afa.esb.jbossesb.action.server; 80 81 import org.jboss.soa.esb.actions.AbstractActionLifecycle; 82 import org.jboss.soa.esb.helpers.ConfigTree; 83 import org.jboss.soa.esb.message.Message; 84 import org.jboss.soa.esb.message.Properties; 85 86 public class HttpRequestPrinter extends AbstractActionLifecycle 87 88 protected ConfigTree configTree; 89 90 public HttpRequestPrinter(ConfigTree config) 91 this.configTree = config; 92 93 94 95 public Message process(Message message) throws Exception 96 Properties properties = message.getProperties(); 97 98 System.out.println(= Server Request: =); 99 System.out.println(Message Payload:); 100 System.out.println(t + message.getBody().get() + ); 101 102 System.out.println(); 103 System.out.println(tHeaders:); 104 System.out.println(tthost: + properties.getProperty(host); 105 System.out.println(ttMethod: + properties.getProperty(MethodType); 106 System.out.println(ttPath: + properties.getProperty(Path); 107 System.out.println(ttuser-agent: + properties.getProperty(user-agent); 108 System.out.println(ttcontent-type: + properties.getProperty(content-type); 109 System.out.println(=); 110 111 message.getBody().add(Http Response Payload!); 112 113 return message; 114 115 3.4 定义第一个ServiceXml代码 116 118 119 121 122 123 124 125 126 128 130 131 132 133 134 135 137 138 配置说明：该服务执行了两次操作，首先将接收到的消息执行了一次http转发，然后由HttpResponsePrinter打印请求的内容。 3.5 定义第二个ServiceXml代码 139 141 142 144 145 146 148 149 配置说明：该服务用语打印输出接收到的消息的内容。 3.6 配置部署文件部署依赖文件deployment.xml内容如下：Xml代码 150 151 jboss.esb.quickstart.destination:service=Queue,name=httpsgateway 152 153 3.7 部署ESB将整个工程导出成一个ESB文件，并保存至JBoss ESB Server的部署目录下，启动JBoss ESB Server即可。4 ESB客户端4.1 新建Java工程这里略去操作过程以及添加所需要的Jar包，具体操作过程可参考第一个ESB实例说明。4.2 发送消息的客户端Java代码 154 /* 155 * Project Name: helloworldclient 156 * File Name: com.thu.afa.esb.jbossesb.client.HttpsGatewayClient.java 157 * Copyright: Copyright (c) 2010 158 * Company: 159 */ 160 package com.thu.afa.esb.jbossesb.client; 161 162 import java.util.Properties; 163 164 import javax.jms.Message; 165 import javax.jms.ObjectMessage; 166 import javax.jms.Queue; 167 import javax.jms.QueueConnection; 168 import javax.jms.QueueConnectionFactory; 169 import javax.jms.QueueReceiver; 170 import javax.jms.QueueSender; 171 import javax.jms.QueueSession; 172 import javax.jms.TextMessage; 173 import javax.naming.Context; 174 import javax.naming.InitialContext; 175 176 /* 177 * Class Name: HttpsGatewayClient 178 * Description: 179 * author Afa 180 * date 2010-9-7 181 * version 1.0 182 */ 183 public class HttpsGatewayClient 184 185 private QueueConnection connection; 186 private QueueSession session; 187 private Queue queue; 188 189 public void setupConnection() throws Exception 190 191 Properties properties = new Properties(); 192 properties.put(Context.INITIAL_CONTEXT_FACTORY, erfaces.NamingContextFactory); 193 properties.put(Context.URL_PKG_PREFIXES, org.jboss.naming:erfaces); 194 properties.put(Context.PROVIDER_URL, jnp:/:1099); 195 InitialContext context = new InitialContext(properties); 196 197 QueueConnectionFactory factory = (QueueConnectionFactory) context.lookup(ConnectionFactory); 198 connection = factory.createQueueConnection(); 199 queue = (Queue) context.lookup(queue/httpsgateway); 200 session = connection.createQueueSession(false, QueueSession.AUTO_ACKNOWLEDGE); 201 connection.start(); 202 203 System.out.println(Connection Started); 204 205 206 public void stop() throws Exception 207 208 if(connection != null) connection.stop(); 209 if(session != null) session.close(); 210 if(connection != null) connection.close(); 211 212 213 public void sendAMessage(String text) throws Exception 214 215 QueueSender sender = session.createSender(queue); 216 ObjectMessage message = session.createObjectMessage(text); 217 sender.send(message); 218 sender.close(); 219 220 221 public void receiveMessage() throws Exception 222 223 QueueReceiver receiver = session.createReceiver(queue); 224 Message message = receiver.receive(); 225 if(