博客

调用BIEE提供的web service

  • Post author:
  • Post category:其他

文章来源：http://jianchen.iteye.com/blog/1264227

门户项目中准备用web service获取现有的制作好的报表进行展示。遂去研究了下，研究的过程也是满纠结的，总算根据多方资料，将demo跑通了。

本文参考了网上的一些资料，做一下总结而已。讲解下如何配置，成功的获取到相关报表。

 

biee的web service的介绍我就不说了了，官方文档如下：
http://download.oracle.com/docs/cd/E21764_01/bi.1111/e16364/soa_overview.htm

提供的服务如下：
http://download.oracle.com/docs/cd/E12096_01/books/AnyWebServ/AnyWebServTOC.html

使用axis生成WEB service的客户端代码：
步骤参考：
http://gerardnico.com/wiki/ide/eclipse/eclipse_how_to_consume_a_webservice_with_wtp
需要指定包名为：com.siebel.analytics.web.soap.v5

客户端代码生成后，在eclipse下由于下载了插件依赖包都是有的，所以可以直接写一个java程序去测试下是否调用web service成功。
如果用maven生成工程，或者最终发布的话，需要在pom。xml中增加如下的依赖配置：

Xml代码
复制代码 
收藏代码
  1. <dependency>  
  2.     <groupId>org.apache.axis</groupId>  
  3.     <artifactId>axis</artifactId>  
  4.     <version>1.4</version>  
  5. </dependency>  
  6. <dependency>  
  7.     <groupId>javax.xml</groupId>  
  8.     <artifactId>jaxrpc</artifactId>  
  9.     <version>1.1</version>  
  10. </dependency>  
  11. <dependency>  
  12.     <groupId>commons-discovery</groupId>  
  13.     <artifactId>commons-discovery</artifactId>  
  14.     <version>0.2</version>  
  15. </dependency>  
  16. <dependency>  
  17.     <groupId>wsdl4j</groupId>  
  18.     <artifactId>wsdl4j</artifactId>  
  19.     <version>1.6.2</version>  
  20. </dependency>  
  21. <dependency>  
  22.     <groupId>org.apache.httpcomponents</groupId>  
  23.     <artifactId>httpclient</artifactId>  
  24.     <version>4.1-beta1</version>  
  25. </dependency>  

 

测试代码如下：

Java代码
复制代码 
收藏代码
  1. public class TestReadCatalog {   
  2.     public static void main(String[] args) {   
  3.         String sessionID = “”;   
  4.         SAWSessionServiceSoapProxy myPort = new SAWSessionServiceSoapProxy();   
  5.         try {   
  6.             sessionID = myPort.logon(“jianchen”, “jianchen”);   
  7.         } catch (RemoteException e) {   
  8.             // TODO Auto-generated catch block   
  9.             e.printStackTrace();   
  10.         }   
  11.         //测试获取目录结构   
  12.         WebCatalogServiceSoapProxy catalogService = new WebCatalogServiceSoapProxy();   
  13.         try {   
  14.             CatalogObject catalogItems = catalogService.readObject(“/shared”, false, sessionID);   
  15.             System.out.println(catalogItems.getItemInfo().getPath());   
  16.             ItemInfo[] items = catalogService.getSubItems(“/shared”, “*”, false, null, sessionID);   
  17.             for (ItemInfo item : items) {   
  18.                 System.out.println(item.getCaption());   
  19.             }   
  20.         } catch (RemoteException e) {   
  21.             // TODO Auto-generated catch block   
  22.             e.printStackTrace();   
  23.         }   
  24.     }   
  25. }  
public class TestReadCatalog {
    public static void main(String[] args) {
        String sessionID = "";
        SAWSessionServiceSoapProxy myPort = new SAWSessionServiceSoapProxy();
        try {
            sessionID = myPort.logon("jianchen", "jianchen");
        } catch (RemoteException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        //测试获取目录结构
        WebCatalogServiceSoapProxy catalogService = new WebCatalogServiceSoapProxy();
        try {
            CatalogObject catalogItems = catalogService.readObject("/shared", false, sessionID);
            System.out.println(catalogItems.getItemInfo().getPath());
            ItemInfo[] items = catalogService.getSubItems("/shared", "*", false, null, sessionID);
            for (ItemInfo item : items) {
                System.out.println(item.getCaption());
            }
        } catch (RemoteException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

 

这里我用的登录账号是：rpd的账号。登录成功后会返回一个sessionID。跟服务器的交互必须要有sessionID作为参数。
执行后，的确能够获取到返回的catalog目录，输出目录名称。

最关键的来了，就是如何把biee中做好的报表展示到web页面上呢。biee提供了HtmlViewService，支持对biee report进行访问。
测试代码如下：

Java代码
复制代码 
收藏代码
  1. public class TestReadReport {   
  2.   
  3.     /**  
  4.      * @param args  
  5.      */  
  6.     public static void main(String[] args) {   
  7.         String sessionID = “”;   
  8.         SAWSessionParameters sessionparams = new SAWSessionParameters();   
  9.         SAWSessionServiceSoapProxy myPort = new SAWSessionServiceSoapProxy();   
  10.         try {   
  11.             sessionID = myPort.logon(“jianchen”, “jianchen”);   
  12.         } catch (RemoteException e) {   
  13.             // TODO Auto-generated catch block   
  14.             e.printStackTrace();   
  15.         }   
  16.   
  17.         HtmlViewServiceSoapProxy viewService = new HtmlViewServiceSoapProxy();   
  18.         ReportRef reportRef = new ReportRef();   
  19.         reportRef.setReportPath(“/shared/”);   
  20.   
  21.         StartPageParams startPageParams = new StartPageParams();   
  22.         startPageParams.setIdsPrefix(“beijixing”+Math.round(Math.random()*1000000));   
  23.         startPageParams.setDontUseHttpCookies(false);   
  24.         try {   
  25.             String pageID = viewService.startPage(startPageParams, sessionID);   
  26.   
  27.             viewService.addReportToPage(pageID, “beijixing”, reportRef, null, null, null, sessionID);   
  28.   
  29.             StringBuffer reportHTML = new StringBuffer();   
  30.            /* reportHTML.append(viewService.getHeadersHtml(pageID, sessionID));  
  31.             reportHTML.append(viewService.getHtmlForReport(pageID, “beijixing”, sessionID));*/  
  32.             reportHTML.append(viewService.getHtmlForPageWithOneReport(“beijixing”, reportRef, null, null, null, null, sessionID));   
  33.             System.out.println(reportHTML.toString());   
  34.         } catch (RemoteException e) {   
  35.             // TODO Auto-generated catch block   
  36.             e.printStackTrace();   
  37.         }   
  38.     }   
  39. }  
public class TestReadReport {

    /**
     * @param args
     */
    public static void main(String[] args) {
        String sessionID = "";
        SAWSessionParameters sessionparams = new SAWSessionParameters();
        SAWSessionServiceSoapProxy myPort = new SAWSessionServiceSoapProxy();
        try {
            sessionID = myPort.logon("jianchen", "jianchen");
        } catch (RemoteException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

        HtmlViewServiceSoapProxy viewService = new HtmlViewServiceSoapProxy();
        ReportRef reportRef = new ReportRef();
        reportRef.setReportPath("/shared/");

        StartPageParams startPageParams = new StartPageParams();
        startPageParams.setIdsPrefix("beijixing"+Math.round(Math.random()*1000000));
        startPageParams.setDontUseHttpCookies(false);
        try {
            String pageID = viewService.startPage(startPageParams, sessionID);

            viewService.addReportToPage(pageID, "beijixing", reportRef, null, null, null, sessionID);

            StringBuffer reportHTML = new StringBuffer();
           /* reportHTML.append(viewService.getHeadersHtml(pageID, sessionID));
            reportHTML.append(viewService.getHtmlForReport(pageID, "beijixing", sessionID));*/
            reportHTML.append(viewService.getHtmlForPageWithOneReport("beijixing", reportRef, null, null, null, null, sessionID));
            System.out.println(reportHTML.toString());
        } catch (RemoteException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

 测试是能够获取到html代码的。但是在页面上展示这段代码时，只会出现一个“等待”，而没有真正的获取报表内容。
分析页面源代码：发现页面里的js以及css等资源的路径都是：“missing_xxx.css”之类的。说明获取的那些资源没有加载到。
还有一个很关键的点，在某篇老外的博客上提到：

写道
SAWLocale and SAWSessionParameters are quite important for the OBIEE report to be displayed. Many have tried and have seen only the rotating clock instead of the report. We too went through the same problem and realized that the OBIEE report javascript file paths are dependent on the Locale and the User-Agent.

 所以在登录服务器前，需要有如下代码段：

Java代码
复制代码 
收藏代码
  1. SAWLocale sawlocale = new SAWLocale();   
  2. sawlocale.setLanguage(request.getLocale().getLanguage());   
  3. sawlocale.setCountry(request.getLocale().getCountry());   
  4.   
  5. SAWSessionParameters sessionparams = new SAWSessionParameters();   
  6. sessionparams.setUserAgent(request.getHeader(“User-Agent”));   
  7. sessionparams.setLocale(sawlocale);   
  8. sessionparams.setAsyncLogon(false);  
    SAWLocale sawlocale = new SAWLocale();
    sawlocale.setLanguage(request.getLocale().getLanguage());
    sawlocale.setCountry(request.getLocale().getCountry());

    SAWSessionParameters sessionparams = new SAWSessionParameters();
    sessionparams.setUserAgent(request.getHeader("User-Agent"));
    sessionparams.setLocale(sawlocale);
    sessionparams.setAsyncLogon(false);

 后仔细阅读文档，内容如下：

写道
To embed a report with active drilldown links, the HtmlViewService service allows the Web browser to issue callback requests from embedded reports to the Oracle BI Web Services server. Although it is possible to route requests directly to the Oracle BI Web Services server, in many cases it is preferable to route requests through the Presentation Services that originally serviced the third-party page. Also, in situations where Oracle BI Web Services and the third-party Web server do not belong to the same Domain Name Service (DNS) domain, users may get JavaScript errors related to browser security constraints for cross-domain scripting.

To avoid these issues, use the setBridge() method to modify callback URLs to point to the third-party Web server. Be aware that a Web component executed by the third-party Web server to re-route requests to Oracle BI Web Services is not provided. This function would need to be fulfilled by the third-party application. For more information about the setBridge() method, read setBridge() Method.

 就是说这些静态资源需要用桥接的方式向真正的服务器发起请求，返回给浏览器。

 桥接的实现，可以利用servlet，该servlet里要干的事情如下：

 
Read the RedirectURL argument of the request which will contain the absolute path to the OBIEE resources.

Make a URLConnection to the URL and read the content.

Write to the output stream.

当时为了立即看到效果，该bridge的代码我是借用了别人的(代码有点bug，比如连接未关闭，不能复用的bug)，等正式开发用的时候可以考虑重新改写下，优化下性能。还是贴出来吧，方便下大众。

 

Java代码
复制代码 
收藏代码
  1. public class MyBridge extends HttpServlet {   
  2.     private static final long serialVersionUID = 1L;   
  3.     /**  
  4.      * Default constructor.  
  5.      */  
  6.     public MyBridge() {   
  7.         // TODO Auto-generated constructor stub   
  8.     }   
  9.     /**  
  10.      * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse  
  11.      *      response)  
  12.      */  
  13.     @SuppressWarnings(“unchecked”)   
  14.     protected void doGet(HttpServletRequest request,   
  15.             HttpServletResponse response) throws ServletException, IOException {   
  16.         String relatedtUrl = request.getParameter(“RedirectURL”);   
  17.         relatedtUrl = relatedtUrl.replaceAll(“NoAuthGo”, “Go”);   
  18.         StringBuffer url = new StringBuffer(“”).append(relatedtUrl);   
  19.         System.out.println(“relatedtUrl>>>>>*****>>>>>>>>>>” + relatedtUrl);   
  20.   
  21.         List<NameValuePair> nvps = new ArrayList<NameValuePair>();   
  22.         Map parameterMap = request.getParameterMap();   
  23.         for (Iterator iterator = parameterMap.keySet().iterator(); iterator   
  24.                 .hasNext();) {   
  25.             String parameterName = (String) iterator.next();   
  26.             String[] parameterValues = (String[]) parameterMap   
  27.                     .get(parameterName);   
  28.             if (parameterValues != null && parameterValues.length > 0) {   
  29.                 if (parameterName.equals(“RedirectURL”)) {   
  30.                     continue;   
  31.                 }   
  32.   
  33.                 for (int i = 0; i < parameterValues.length; i++) {   
  34.                     NameValuePair pair = new BasicNameValuePair(parameterName,   
  35.                             parameterValues[i]);   
  36.                     nvps.add(pair);   
  37.                 }   
  38.             }   
  39.         }   
  40.         HttpClient client = new DefaultHttpClient();   
  41.         if (!url.toString().endsWith(“.js”) && !url.toString().endsWith(“.css”)   
  42.                 && !url.toString().endsWith(“.png”) && !url.toString().endsWith(“.gif”)) {   
  43.             List<NameValuePair> tmp = new ArrayList<NameValuePair>();   
  44.             NameValuePair pair = new BasicNameValuePair(“NQUser”, “jianchen”);   
  45.             NameValuePair pair1 = new BasicNameValuePair(“NQPassword”, “jianchen”);   
  46.             tmp.add(pair);   
  47.             tmp.add(pair1);   
  48.             HttpPost lpost = new HttpPost(url.toString());   
  49.             lpost.setEntity(new UrlEncodedFormEntity(tmp, “GBK”));   
  50.             HttpResponse lresp = client.execute(lpost);   
  51.             System.out.println(“登陆结果:”+lresp.getStatusLine().getStatusCode());   
  52.             lpost.abort();   
  53.         }   
  54.         if(url.toString().indexOf(“?Go”)<0 || url.toString().indexOf(“?DocPart”)>0){   
  55.             HttpPost post = new HttpPost(url.toString());   
  56.             post.setEntity(new UrlEncodedFormEntity(nvps,“GBK”));   
  57.             post.addHeader(“Content-Type”, “binary/data”);   
  58.             post.addHeader(“User-Agent”, request.getHeader(“USER-AGENT”));   
  59.             HttpResponse resp = client.execute(post);   
  60.             HttpEntity entity = resp.getEntity();   
  61.             InputStream in = entity.getContent();   
  62.             if(url.toString().indexOf(“?DocPart”)>0){   
  63.                 FileOutputStream fout=new FileOutputStream(“e:\\aaa.jpg”);   
  64.                 byte buffer1[] = new byte[1024 * 128];   
  65.                 int k = 0;   
  66.                 while ((k = in.read(buffer1)) != –1) {   
  67.                     fout.write(buffer1, 0, k);   
  68.                 }   
  69.                 fout.flush();   
  70.                 fout.close();   
  71.             }   
  72.             ServletOutputStream out = response.getOutputStream();   
  73.             byte buffer1[] = new byte[1024 * 128];   
  74.             int k = 0;   
  75.             while ((k = in.read(buffer1)) != –1) {   
  76.                 out.write(buffer1, 0, k);   
  77.             }   
  78.             in.close();   
  79.             out.close();   
  80.         } else {   
  81.             HttpPost post = new HttpPost(url.toString());   
  82.             post.setEntity(new UrlEncodedFormEntity(nvps,“GBK”));   
  83.             post.addHeader(“Content-Type”, “binary/data”);   
  84.             post.addHeader(“User-Agent”, request.getHeader(“USER-AGENT”));   
  85.             HttpResponse resp = client.execute(post);   
  86.             HttpEntity entity = resp.getEntity();   
  87.             InputStream in = entity.getContent();   
  88.             InputStreamReader isr = new InputStreamReader(in);   
  89.             BufferedReader br = new BufferedReader(isr);   
  90.             StringBuffer sb = new StringBuffer();   
  91.             String r = br.readLine();   
  92.             sb.append(r);   
  93.             while (r != null) {   
  94.                 r = br.readLine();   
  95.                 sb.append(r);   
  96.             }   
  97.             String html = sb.toString();//TODO 本地   
  98.             InputStream sin = new ByteArrayInputStream(html.getBytes());   
  99.             ServletOutputStream out = response.getOutputStream();   
  100.             byte buffer1[] = new byte[1024 * 128];   
  101.             int k = 0;   
  102.             while ((k = sin.read(buffer1)) != –1) {   
  103.                 out.write(buffer1, 0, k);   
  104.             }   
  105.             sin.close();   
  106.             out.close();   
  107.             post.abort();   
  108.         }   
  109.   
  110.           
  111.     }   
  112.   
  113.     /**  
  114.      * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse  
  115.      *      response)  
  116.      */  
  117.     protected void doPost(HttpServletRequest request,   
  118.             HttpServletResponse response) throws ServletException, IOException {   
  119.         doGet(request, response);   
  120.     }   
  121.   
  122. }  
public class MyBridge extends HttpServlet {
	private static final long serialVersionUID = 1L;
	/**
	 * Default constructor.
	 */
	public MyBridge() {
		// TODO Auto-generated constructor stub
	}
	/**
	 * @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse
	 *      response)
	 */
	@SuppressWarnings("unchecked")
	protected void doGet(HttpServletRequest request,
			HttpServletResponse response) throws ServletException, IOException {
		String relatedtUrl = request.getParameter("RedirectURL");
		relatedtUrl = relatedtUrl.replaceAll("NoAuthGo", "Go");
		StringBuffer url = new StringBuffer("").append(relatedtUrl);
		System.out.println("relatedtUrl>>>>>*****>>>>>>>>>>" + relatedtUrl);

		List<NameValuePair> nvps = new ArrayList<NameValuePair>();
		Map parameterMap = request.getParameterMap();
		for (Iterator iterator = parameterMap.keySet().iterator(); iterator
				.hasNext();) {
			String parameterName = (String) iterator.next();
			String[] parameterValues = (String[]) parameterMap
					.get(parameterName);
			if (parameterValues != null && parameterValues.length > 0) {
				if (parameterName.equals("RedirectURL")) {
					continue;
				}

				for (int i = 0; i < parameterValues.length; i++) {
					NameValuePair pair = new BasicNameValuePair(parameterName,
							parameterValues[i]);
					nvps.add(pair);
				}
			}
		}
		HttpClient client = new DefaultHttpClient();
		if (!url.toString().endsWith(".js") && !url.toString().endsWith(".css")
				&& !url.toString().endsWith(".png") && !url.toString().endsWith(".gif")) {
			List<NameValuePair> tmp = new ArrayList<NameValuePair>();
			NameValuePair pair = new BasicNameValuePair("NQUser", "jianchen");
			NameValuePair pair1 = new BasicNameValuePair("NQPassword", "jianchen");
			tmp.add(pair);
			tmp.add(pair1);
			HttpPost lpost = new HttpPost(url.toString());
			lpost.setEntity(new UrlEncodedFormEntity(tmp, "GBK"));
			HttpResponse lresp = client.execute(lpost);
			System.out.println("登陆结果:"+lresp.getStatusLine().getStatusCode());
            lpost.abort();
		}
		if(url.toString().indexOf("?Go")<0 || url.toString().indexOf("?DocPart")>0){
			HttpPost post = new HttpPost(url.toString());
			post.setEntity(new UrlEncodedFormEntity(nvps,"GBK"));
			post.addHeader("Content-Type", "binary/data");
			post.addHeader("User-Agent", request.getHeader("USER-AGENT"));
			HttpResponse resp = client.execute(post);
			HttpEntity entity = resp.getEntity();
			InputStream in = entity.getContent();
			if(url.toString().indexOf("?DocPart")>0){
				FileOutputStream fout=new FileOutputStream("e:\\aaa.jpg");
				byte buffer1[] = new byte[1024 * 128];
				int k = 0;
				while ((k = in.read(buffer1)) != -1) {
					fout.write(buffer1, 0, k);
				}
				fout.flush();
				fout.close();
			}
			ServletOutputStream out = response.getOutputStream();
			byte buffer1[] = new byte[1024 * 128];
			int k = 0;
			while ((k = in.read(buffer1)) != -1) {
				out.write(buffer1, 0, k);
			}
			in.close();
			out.close();
		} else {
			HttpPost post = new HttpPost(url.toString());
			post.setEntity(new UrlEncodedFormEntity(nvps,"GBK"));
			post.addHeader("Content-Type", "binary/data");
			post.addHeader("User-Agent", request.getHeader("USER-AGENT"));
			HttpResponse resp = client.execute(post);
			HttpEntity entity = resp.getEntity();
			InputStream in = entity.getContent();
			InputStreamReader isr = new InputStreamReader(in);
			BufferedReader br = new BufferedReader(isr);
			StringBuffer sb = new StringBuffer();
			String r = br.readLine();
			sb.append(r);
			while (r != null) {
				r = br.readLine();
				sb.append(r);
			}
			String html = sb.toString();//TODO 本地
			InputStream sin = new ByteArrayInputStream(html.getBytes());
			ServletOutputStream out = response.getOutputStream();
			byte buffer1[] = new byte[1024 * 128];
			int k = 0;
			while ((k = sin.read(buffer1)) != -1) {
				out.write(buffer1, 0, k);
			}
			sin.close();
			out.close();
            post.abort();
		}

       
	}

	/**
	 * @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse
	 *      response)
	 */
	protected void doPost(HttpServletRequest request,
			HttpServletResponse response) throws ServletException, IOException {
		doGet(request, response);
	}

}

 

 

web.xml中配置servlet如下：

Xml代码
复制代码 
收藏代码
  1.         <servlet>  
  2.     <description>  
  3.     </description>  
  4.     <display-name>MyBridge</display-name>  
  5.     <servlet-name>MyBridge</servlet-name>  
  6.     <servlet-class>com.taobao.service.kunshuo.webservice.MyBridge</servlet-class>  
  7. </servlet>  
  8. <servlet>  
  9.     <display-name>Apache-Axis Servlet</display-name>  
  10.     <servlet-name>AxisServlet</servlet-name>  
  11.     <servlet-class>org.apache.axis.transport.http.AxisServlet</servlet-class>  
  12. </servlet>  
  13. <servlet>  
  14.     <display-name>Axis Admin Servlet</display-name>  
  15.     <servlet-name>AdminServlet</servlet-name>  
  16.     <servlet-class>org.apache.axis.transport.http.AdminServlet</servlet-class>  
  17.     <load-on-startup>100</load-on-startup>  
  18. </servlet>  
  19.   
  20.    <servlet-mapping>  
  21.     <servlet-name>MyBridge</servlet-name>  
  22.     <url-pattern>/MyBridge</url-pattern>  
  23. </servlet-mapping>  
  24. <servlet-mapping>  
  25.     <servlet-name>AxisServlet</servlet-name>  
  26.     <url-pattern>/servlet/AxisServlet</url-pattern>  
  27. </servlet-mapping>  
  28. <servlet-mapping>  
  29.     <servlet-name>AxisServlet</servlet-name>  
  30.     <url-pattern>*.jws</url-pattern>  
  31. </servlet-mapping>  
  32. <servlet-mapping>  
  33.     <servlet-name>AxisServlet</servlet-name>  
  34.     <url-pattern>/services/*</url-pattern>  
  35. </servlet-mapping>  
  36. <servlet-mapping>  
  37.     <servlet-name>AdminServlet</servlet-name>  
  38.     <url-pattern>/servlet/AdminServlet</url-pattern>  
  39. </servlet-mapping>  

 

至此，将获取到的报表html增加到要展示的页面里，比如jsp，就可以直接展示报表了。