使用 WebSphere ILOG JRules 开发保险应用系统【四】——新建HelloWorldRule、请求客户端

- 日理万妓 2022-05-25 05:16 80阅读 0赞

【新建规则项目HelloWorldRule】——>点击【下一步】  
![这里写图片描述][70]

【规则项目引用】——>点击【完成】  
![这里写图片描述][70 1]

【新建主流、hello规则】  
![这里写图片描述][70 2]

![这里写图片描述][70 3]

【请求客户端结构】  
![这里写图片描述][70 4]  
ClientMultiThreadedExecution.java:

package httpclient;
    import java.io.IOException;
    import java.net.URISyntaxException;
    import java.net.URL;
    import org.apache.http4.HttpEntity;
    import org.apache.http4.HttpResponse;
    import org.apache.http4.client.methods.HttpPost;
    import org.apache.http4.client.utils.URIBuilder;
    import org.apache.http4.entity.StringEntity;
    import org.apache.http4.util.EntityUtils;
    
    
    public class ClientMultiThreadedExecution { 
        /** * send http post request * * @param url:http url * @param params:String数组 格式为{"param1=value1","param2=value2"} * @param content:发送内容为String不限制长度 * @return com.firsttech.underwriting.dto.UnderwriteResultDTO序列化后的XML * @exception */
        public static String sendHttpPost(String url,String[] params,String content) throws Exception{
            URIBuilder builder = new URIBuilder();
            try {
                URL u = new URL(url);
                builder.setScheme(u.getProtocol()).setHost(u.getHost()).setPort(u.getPort()).setPath(u.getPath());
                for(String param:params){
                    String[] p = param.split("=");
                    builder.setParameter(p[0],p[1]);
                }
            } catch (RuntimeException e) {
                throw new IllegalArgumentException("URL格式错误",e);
            }
            return sendHttpPost(builder,content);
        }
        public static String sendHttpPost(URIBuilder builder,String content) throws URISyntaxException, IOException{
    
            HttpPost httppost = new HttpPost(builder.build());
            if(content!=null){
                 StringEntity entity = new StringEntity(content,"UTF-8");
                 httppost.setEntity(entity);
            }
    
            try {
                  HttpResponse response = HttpConnectionManager.getHttpClient().execute(httppost);
                  HttpEntity result = response.getEntity();
                  return EntityUtils.toString(result);
            } catch (Exception ex) {
                ex.printStackTrace();
                httppost.abort();
                return null;
            }
        }
    
    
    }

ObjectXmlUtils.java：

package utils;
    
    import java.io.ByteArrayInputStream;
    import java.io.ByteArrayOutputStream;
    import java.io.IOException;
    import java.io.InputStream;
    import java.io.OutputStream;
    
    import org.xml.sax.SAXException;
    
    import com.wutka.jox.JOXBeanInputStream;
    import com.wutka.jox.JOXBeanOutputStream;
    
    public class ObjectXmlUtils {
        public static String javaBean2Xml(Object o){
            OutputStream xmlData = null;
    
                xmlData = new ByteArrayOutputStream();
    
                JOXBeanOutputStream joxOut = new JOXBeanOutputStream(xmlData,"GBK");
                try {
                    joxOut.writeObject(o.getClass().getName(), o);
                } catch (IOException e) {
                    System.out.println(e.getMessage());
                    System.out.println(e.getStackTrace());
                    e.printStackTrace();
                }
    
             return xmlData.toString();
        }
        @SuppressWarnings("rawtypes")
        public static Object xml2javaBean(String xml,Class className){
            try {
                InputStream in = new ByteArrayInputStream(xml.getBytes());
    
                JOXBeanInputStream joxIn = new JOXBeanInputStream(in);
                Object o = (Object) joxIn.readObject(className);
                return o;
            } catch (Exception e) {
                e.printStackTrace();
                return null;
            }
        }
    }

FileLoader.java:

package com.test.utils;
    
    import java.io.BufferedReader;
    import java.io.FileInputStream;
    import java.io.IOException;
    import java.io.InputStreamReader;
    import java.io.UnsupportedEncodingException;
    
    public class FileLoader { 
    
        /** * 读取文件到字符串 * * @throws UnsupportedEncodingException */
        public static String readFile(String fileName)
                throws UnsupportedEncodingException {
            String fileContent = "";
            StringBuffer filebuff = new StringBuffer();
            BufferedReader reader = null;
            try {
                reader = new BufferedReader(new InputStreamReader(
                        new FileInputStream(fileName), "GBK"));
                String tempString = null;
                while ((tempString = reader.readLine()) != null) {
                    filebuff.append(tempString + "\n");
                }
                fileContent = filebuff.toString();
                reader.close();
            } catch (IOException e) {
                e.printStackTrace();
            } finally {
                if (reader != null) {
                    try {
                        reader.close();
                    } catch (IOException e) {
                    }
                }
            }
    
            return fileContent;
    
        }
    }

helloWorld.xml:

<?xml version="1.0" encoding="GBK"?>
    <HelloWorldRequestBOM java-class="com.hello.bom.HelloWorldRequestBOM">
        <age java-class="java.lang.Integer">17</age>
        <name>小明</name>
        <requestType>110</requestType>
        <result>结果</result>
    </HelloWorldRequestBOM>

TestHelloWorldService.java:

package com.test.client;
    
    import httpclient.ClientMultiThreadedExecution;
    
    import com.test.utils.FileLoader;
    
    public class TestHelloWorldService {
    
        private final static String url = "http://192.168.17.1:8080/HelloWorldWLS/helloWorldService.do";
    
        public static void main(String[] args) throws Exception {
            String[] params = { "method=helloWorldRule" };
            String content = FileLoader.readFile("resources/helloWorld.xml");
            String resultXML = ClientMultiThreadedExecution.sendHttpPost(url,params, content);
    
            System.out.println("请求：");
            System.out.println(content);
            System.out.println();
            System.out.println("响应:");
            System.out.println(resultXML);
        }
    }

[70]: /images/20220525/be68d27140c542d3b66637b19432aaf5.png
[70 1]: /images/20220525/ae28f3428baa42bf87d1299f247bcafb.png
[70 2]: /images/20220525/c1624034d3cd42c2b72c930c60cb48d6.png
[70 3]: /images/20220525/f82dd6ad378e4db5b0354201ae9522fa.png
[70 4]: /images/20220525/7058d58ca4f34f4a849bdae52cb29381.png