diff options
author | 2017-08-08 14:02:53 +0800 | |
---|---|---|
committer | 2017-08-08 14:02:53 +0800 | |
commit | c0604184b2aa8cff924ca783ec6b36f1f5988775 (patch) | |
tree | 1c70ffe1ad90c915b3382a37eb2fa80901519c7b /wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/util | |
parent | 706fc9fed496972968fde136c3e4e10f9578a5b3 (diff) |
init code
Change-Id: Icd0948118397b256da70dfbcbbec5520dc5eafd4
Signed-off-by: Zhaoxing <meng.zhaoxing1@zte.com.cn>
Diffstat (limited to 'wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/util')
5 files changed, 0 insertions, 546 deletions
diff --git a/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/util/ClientWsdlLoader.java b/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/util/ClientWsdlLoader.java deleted file mode 100644 index 70a9588..0000000 --- a/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/util/ClientWsdlLoader.java +++ /dev/null @@ -1,82 +0,0 @@ -/** - * Copyright 2016 ZTE Corporation. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.openo.carbon.bpel.util; - -import java.io.ByteArrayInputStream; -import java.io.InputStream; -import java.net.URL; -import org.apache.log4j.Logger; - -import org.apache.commons.httpclient.HttpClient; -import org.apache.commons.httpclient.HttpException; -import org.apache.commons.httpclient.HttpStatus; -import org.apache.commons.httpclient.methods.GetMethod; - -import com.eviware.soapui.impl.wsdl.support.wsdl.WsdlLoader; - -public class ClientWsdlLoader extends WsdlLoader { - private static Logger logger = Logger.getLogger(ClientWsdlLoader.class); - - private boolean isAborted = false; - private HttpClient httpClient; - - public ClientWsdlLoader(String url, HttpClient httpClient) { - super(url); - this.httpClient = httpClient; - } - - public InputStream load(String url) throws Exception { - GetMethod httpGetMethod; - - if (url.startsWith("file")) { - return new URL(url).openStream(); - } - - // Authentication is not being overridden on the method. It needs - // to be present on the supplied HttpClient instance! - httpGetMethod = new GetMethod(url); - httpGetMethod.setDoAuthentication(true); - - try { - int result = httpClient.executeMethod(httpGetMethod); - - if (result != HttpStatus.SC_OK) { - if (result < 200 || result > 299) { - throw new HttpException( - "Received status code '" + result + "' on WSDL HTTP (GET) request: '" + url + "'."); - } else { - logger.warn( - "Received status code '" + result + "' on WSDL HTTP (GET) request: '" + url + "'."); - } - } - - return new ByteArrayInputStream(httpGetMethod.getResponseBody()); - } finally { - httpGetMethod.releaseConnection(); - } - } - - public boolean abort() { - isAborted = true; - return true; - } - - public boolean isAborted() { - return isAborted; - } - - public void close() {} -} diff --git a/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/util/JsonUtil.java b/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/util/JsonUtil.java deleted file mode 100644 index f2a4d97..0000000 --- a/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/util/JsonUtil.java +++ /dev/null @@ -1,61 +0,0 @@ -/** - * Copyright 2016 ZTE Corporation. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.openo.carbon.bpel.util; - -import java.io.IOException; -import java.io.StringWriter; - -import com.fasterxml.jackson.core.JsonFactory; -import com.fasterxml.jackson.core.JsonGenerator; -import com.fasterxml.jackson.core.JsonParseException; -import com.fasterxml.jackson.core.JsonProcessingException; -import com.fasterxml.jackson.databind.JavaType; -import com.fasterxml.jackson.databind.JsonMappingException; -import com.fasterxml.jackson.databind.JsonNode; -import com.fasterxml.jackson.databind.ObjectMapper; - -public class JsonUtil { - - @SuppressWarnings("deprecation") - public static String bean2Json(Object obj) throws IOException { - ObjectMapper mapper = new ObjectMapper(); - StringWriter sw = new StringWriter(); - JsonGenerator gen = new JsonFactory().createJsonGenerator(sw); - mapper.writeValue(gen, obj); - gen.close(); - return sw.toString(); - } - - public static <T> T json2Bean(String jsonStr, Class<T> objClass) - throws JsonParseException, JsonMappingException, IOException { - ObjectMapper mapper = new ObjectMapper(); - return mapper.readValue(jsonStr, objClass); - } - - @SuppressWarnings("deprecation") - public static <T> T readJson(String jsonStr, Class<?> collectionClass, Class<?>... elementClasses) - throws Exception { - ObjectMapper mapper = new ObjectMapper(); - JavaType javaType = - mapper.getTypeFactory().constructParametricType(collectionClass, elementClasses); - return mapper.readValue(jsonStr, javaType); - } - - public static JsonNode getJsonNode(String json) throws JsonProcessingException, IOException { - return new ObjectMapper().readTree(json); - } - -} diff --git a/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/util/LRULinkedHashMap.java b/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/util/LRULinkedHashMap.java deleted file mode 100644 index deb07c6..0000000 --- a/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/util/LRULinkedHashMap.java +++ /dev/null @@ -1,106 +0,0 @@ -/** - * Copyright 2016 ZTE Corporation. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.openo.carbon.bpel.util; - -import java.util.ArrayList; -import java.util.Collection; -import java.util.LinkedHashMap; -import java.util.Map; -import java.util.concurrent.locks.Lock; -import java.util.concurrent.locks.ReentrantLock; - -/** - * - * @author bsli - * - * @param <K> - * @param <V> - */ -@SuppressWarnings("serial") -public class LRULinkedHashMap<K, V> extends LinkedHashMap<K, V> { - private final int maxCapacity; - - private static final float DEFAULT_LOAD_FACTOR = 0.75f; - - private final Lock lock = new ReentrantLock(); - - public LRULinkedHashMap(int maxCapacity) { - super(maxCapacity, DEFAULT_LOAD_FACTOR, true); - this.maxCapacity = maxCapacity; - } - - @Override - protected boolean removeEldestEntry(java.util.Map.Entry<K, V> eldest) { - return size() > maxCapacity; - } - - @Override - public boolean containsKey(Object key) { - try { - lock.lock(); - return super.containsKey(key); - } finally { - lock.unlock(); - } - } - - @Override - public V get(Object key) { - try { - lock.lock(); - return super.get(key); - } finally { - lock.unlock(); - } - } - - @Override - public V put(K key, V value) { - try { - lock.lock(); - return super.put(key, value); - } finally { - lock.unlock(); - } - } - - public int size() { - try { - lock.lock(); - return super.size(); - } finally { - lock.unlock(); - } - } - - public void clear() { - try { - lock.lock(); - super.clear(); - } finally { - lock.unlock(); - } - } - - public Collection<Map.Entry<K, V>> getAll() { - try { - lock.lock(); - return new ArrayList<Map.Entry<K, V>>(super.entrySet()); - } finally { - lock.unlock(); - } - } -} diff --git a/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/util/SoapUtil.java b/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/util/SoapUtil.java deleted file mode 100644 index 6f7bf0d..0000000 --- a/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/util/SoapUtil.java +++ /dev/null @@ -1,156 +0,0 @@ -/** - * Copyright 2016 ZTE Corporation. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.openo.carbon.bpel.util; - -import java.io.IOException; -import java.util.ArrayList; -import java.util.List; -import java.util.Map; -import java.util.Properties; - -import javax.naming.ConfigurationException; -import javax.xml.parsers.DocumentBuilderFactory; - -import org.apache.commons.httpclient.HttpClient; -import org.apache.log4j.Logger; - -import com.eviware.soapui.impl.wsdl.WsdlInterface; -import com.eviware.soapui.impl.wsdl.WsdlProject; -import com.eviware.soapui.impl.wsdl.support.wsdl.WsdlLoader; -import com.eviware.soapui.model.iface.Operation; -import com.eviware.soapui.model.iface.Request; - -public class SoapUtil { - private static final Logger log = Logger.getLogger(SoapUtil.class); - - private DocumentBuilderFactory docBuilderFactory; - private Map<String, WsdlInterface[]> wsdls = new LRULinkedHashMap<String, WsdlInterface[]>(256); - - public SoapUtil() { - docBuilderFactory = DocumentBuilderFactory.newInstance(); - docBuilderFactory.setNamespaceAware(true); - } - - public Request[] getRequestTemplate(String wsdlUrl) - throws UnsupportedOperationException, IOException { - Request[] requests = new Request[0]; - List<Request> requestList = new ArrayList<Request>(); - Operation operationInst = null; - WsdlInterface[] wsdlInterfaces = getWsdlInterfaces(wsdlUrl, null); - for (WsdlInterface wsdlInterface : wsdlInterfaces) { - Operation opr = wsdlInterface.getOperationAt(0); - if (opr != null) { - operationInst = opr; - String requestTemplate = operationInst.getRequestAt(0).getRequestContent(); - requestList.add(operationInst.getRequestAt(0)); - } - } - requests = requestList.toArray(new Request[0]); - return requests; - } - - /** - * - * @param wsdl - * @param operation - * @param httpClientProps - * @return - * @throws IOException - * @throws UnsupportedOperationException - */ - private Operation getOperation(String wsdl, String operation, Properties httpClientProps) - throws IOException, UnsupportedOperationException { - WsdlInterface[] wsdlInterfaces = getWsdlInterfaces(wsdl, httpClientProps); - for (WsdlInterface wsdlInterface : wsdlInterfaces) { - Operation operationInst = wsdlInterface.getOperationByName(operation); - - if (operationInst != null) { - return operationInst; - } - } - wsdls.remove(wsdl); - wsdlInterfaces = getWsdlInterfaces(wsdl, httpClientProps); - for (WsdlInterface wsdlInterface : wsdlInterfaces) { - Operation operationInst = wsdlInterface.getOperationByName(operation); - if (operationInst != null) { - return operationInst; - } - } - - throw new UnsupportedOperationException( - "Operation '" + operation + "' not supported by WSDL '" + wsdl + "'."); - } - - /** - * - * @param wsdl - * @param httpClientProps - * @return - * @throws IOException - */ - private WsdlInterface[] getWsdlInterfaces(String wsdl, Properties httpClientProps) - throws IOException { - try { - WsdlInterface[] wsdlInterfaces = wsdls.get(wsdl); - if (wsdlInterfaces == null) { - WsdlProject wsdlProject = new WsdlProject(); - WsdlLoader wsdlLoader = createWsdlLoader(wsdl, httpClientProps); - - wsdlInterfaces = wsdlProject.importWsdl(wsdl, true, wsdlLoader); - - wsdls.put(wsdl, wsdlInterfaces); - } - return wsdlInterfaces; - } catch (Exception e) { - e.printStackTrace(); - log.error(e.getMessage()); - throw new RuntimeException("Failed to import WSDL '" + wsdl + "'."); - } - } - - /** - * - * @param wsdl - * @param httpClientProps - * @return - * @throws ConfigurationException - */ - private WsdlLoader createWsdlLoader(String wsdl, Properties httpClientProps) - throws ConfigurationException { - HttpClient httpClient = new HttpClient(); - return new ClientWsdlLoader(wsdl, httpClient); - } - - public static void main(String[] args) { - SoapUtil soapUtil = new SoapUtil(); - - try { - String url = "http://10.74.151.36:9763/services/initService?wsdl"; - Request[] requestXMLs = soapUtil.getRequestTemplate(url); - - for (Request requestXML : requestXMLs) { - String requestJson = Xml2JsonUtil.xml2JSON(requestXML.getRequestContent()); - System.out.println("===================================="); - System.out.println(requestJson); - } - - } catch (UnsupportedOperationException e1) { - e1.printStackTrace(); - } catch (IOException e1) { - e1.printStackTrace(); - } - } -} diff --git a/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/util/Xml2JsonUtil.java b/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/util/Xml2JsonUtil.java deleted file mode 100644 index 7f05a84..0000000 --- a/wso2bpel-ext/wso2bpel-core/wso2bpel-mgr/src/main/java/org/openo/carbon/bpel/util/Xml2JsonUtil.java +++ /dev/null @@ -1,141 +0,0 @@ -/** - * Copyright 2016 ZTE Corporation. - * - * Licensed under the Apache License, Version 2.0 (the "License"); - * you may not use this file except in compliance with the License. - * You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.openo.carbon.bpel.util; - -import java.io.ByteArrayInputStream; -import java.io.File; -import java.io.InputStream; -import java.util.HashMap; -import java.util.LinkedList; -import java.util.List; -import java.util.Map; - -import net.sf.json.JSONObject; - -import org.jdom.Document; -import org.jdom.Element; -import org.jdom.input.SAXBuilder; - -public class Xml2JsonUtil { - /** - * transform xml to json - * - * @param xml xml format string - * @return return json string when success; otherwise return null - */ - public static String xml2JSON(String xml) { - JSONObject obj = new JSONObject(); - try { - InputStream is = new ByteArrayInputStream(xml.getBytes("utf-8")); - SAXBuilder sb = new SAXBuilder(); - Document doc = sb.build(is); - Element root = doc.getRootElement(); - obj.put(root.getName(), iterateElement(root)); - return obj.toString(); - } catch (Exception e) { - e.printStackTrace(); - return null; - } - } - - /** - * transform xml file to json string - * - * @param file java.io.File is an effective xml file - * @return return json string when success; otherwise return null - */ - public static String xml2JSON(File file) { - JSONObject obj = new JSONObject(); - try { - SAXBuilder sb = new SAXBuilder(); - Document doc = sb.build(file); - Element root = doc.getRootElement(); - obj.put(root.getName(), iterateElement(root)); - return obj.toString(); - } catch (Exception e) { - e.printStackTrace(); - return null; - } - } - - /** - * an iteration function - * - * @param parentElement : org.jdom.Element - * @return java.util.Map - */ - @SuppressWarnings({"unchecked", "rawtypes"}) - private static Map iterateElement(Element parentElement) { - List node = parentElement.getChildren(); - Element element = null; - Map map = new HashMap(); - List list = null; - for (int i = 0; i < node.size(); i++) { - element = (Element) node.get(i); - if (element.getTextTrim().equals("")) { - if (element.getChildren().size() == 0) - continue; - if (map.containsKey(element.getName())) { - Object obj = map.get(element.getName()); - if (obj instanceof Map) { - list = new LinkedList(); - list.add(obj); - list.add(iterateElement(element)); - map.remove(element.getName()); - map.put(element.getName(), list); - } else if (obj instanceof List) { - list = (List) obj; - list.add(iterateElement(element)); - } - } else { - map.put(element.getName(), iterateElement(element)); - } - } else { - map.put(element.getName(), element.getTextTrim()); - } - } - return map; - } - - public static void main(String[] args) { - System.out.println(Xml2JsonUtil.xml2JSON("<MapSet>" + "<MapGroup id='Sheboygan'>" + "<Map>" - + "<Type>MapGuideddddddd</Type>" + "<SingleTile>true</SingleTile>" + "<Extension>" - + "<ResourceId>ddd</ResourceId>" + "</Extension>" + "</Map>" + "<Map>" + "<Type>ccc</Type>" - + "<SingleTile>ggg</SingleTile>" + "<Extension>" + "<ResourceId>aaa</ResourceId>" - + "</Extension>" + "</Map>" + "<Extension />" + "</MapGroup>" + "<ddd>" + "33333333" - + "</ddd>" + "<ddd>" + "444" + "</ddd>" + "</MapSet>")); - - String xml = - "<body> <p:helloXsl xmlns:p=\"http://ode/bpel/unit-test.wsdl\"> <!--Exactly 1 occurrence--> <TestPart> <!--Exactly 1 occurrence--> <content>fdsafasdfasdf</content> </TestPart> </p:helloXsl></body>"; - - System.out.println(Xml2JsonUtil.xml2JSON(xml)); - - xml = - "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:unit=\"http://ode/bpel/unit-test.wsdl\"> <soapenv:Header/> <soapenv:Body> <unit:helloXsl> <TestPart> <content>?</content> </TestPart> </unit:helloXsl> </soapenv:Body></soapenv:Envelope>"; - - System.out.println(Xml2JsonUtil.xml2JSON(xml)); - - xml = - "<ns:uploadServiceResponse xmlns:ns=\"http://services.deployer.bpel.carbon.wso2.org\"><ns:return xmlns:xsi=\"http://www.w3.org/2001/XMLSchema-instance\" xsi:nil=\"true\"/></ns:uploadServiceResponse>"; - - System.out.println(Xml2JsonUtil.xml2JSON(xml)); - - xml = - "<body> <p:planInput xmlns:p=\"http://www.open-o.org/tosca/nfv/2015/12\"> <!--Exactly 1 occurrence--> <p:sfc_count>2</p:sfc_count> <!--Exactly 1 occurrence--> <p:iaUrl></p:iaUrl> <!--Exactly 1 occurrence--> <p:vnfmId>112</p:vnfmId> <!--Exactly 1 occurrence--> <p:object_context>{\"e\":{\"f\":\"4\"}}</p:object_context> <!--Exactly 1 occurrence--> <p:statusUrl></p:statusUrl> <!--Exactly 1 occurrence--> <p:serviceTemplateId>?</p:serviceTemplateId> <!--Exactly 1 occurrence--> <p:roUrl></p:roUrl> <!--Exactly 1 occurrence--> <p:vl_count>2</p:vl_count> <!--Exactly 1 occurrence--> <p:containerapiUrl>?</p:containerapiUrl> <!--Exactly 1 occurrence--> <p:flavor></p:flavor> <!--Exactly 1 occurrence--> <p:nsInstanceId>223</p:nsInstanceId> <!--Exactly 1 occurrence--> <p:instanceId>334</p:instanceId> <!--Exactly 1 occurrence--> <p:resourceUrl></p:resourceUrl> <!--Exactly 1 occurrence--> <p:vnf_count>2</p:vnf_count> <!--Exactly 1 occurrence--> <p:callbackId></p:callbackId> <!--Exactly 1 occurrence--> <p:object_additionalParamForVnf>[{\"b\":1},{\"c\":{\"d\":\"2\"}}}]</p:object_additionalParamForVnf> <!--Exactly 1 occurrence--> <p:object_additionalParamForNs>[{\"a\":3},{\"e\":{\"f\":\"4\"}}}]</p:object_additionalParamForNs> <!--Exactly 1 occurrence--> <p:flavorParams></p:flavorParams> </p:planInput></body>"; - - System.out.println(Xml2JsonUtil.xml2JSON(xml)); - } -} |