基于IBM Bluemix的数据缓存应用实例

迷南。 2021-09-10 19:14 271阅读 0赞

林炳文Evankaka原创作品。转载请注明出处[http://blog.csdn.net/evankaka][http_blog.csdn.net_evankaka]

摘要：IBM® Data Cache for Bluemix 是高速缓存服务，支持 Web 和移动应用程序的分布式高速缓存场景。高速缓存服务使用数据网格 技术，您可以在其中存储键值对象。Data Cache 提供了一个业务就绪的内存数据网格 (IMDG)，其将数据放在接近逻辑的位置并随着业务扩展仍将其保留在此。很容易使用并扩展现有应用程序的性能和可伸缩性。它可以帮助将冗余事务降到最低、提高响应时间并增加现有应用程序基础结构（支持重要应用程序）中的效率。对于增加的冗余，Data Cache 提供高速缓存中存储的数据副本。因此，万一掉线或停运，客户机应用程序仍可访问高速缓存中的数据。

本文实例访问：[http://datacachetest.eu-gb.mybluemix.net/][http_datacachetest.eu-gb.mybluemix.net]

**BluxMix账号注册：**[https://apps.admin.ibmcloud.com/manage/trial/bluemix.html?cm\_mmc=CMDeveloperGCG-\_-Bluemix-\_-CSDN-\_-onlineeventQ2][https_apps.admin.ibmcloud.com_manage_trial_bluemix.html_cm_mmc_CMDeveloperGCG-_-Bluemix-_-CSDN-_-onlineeventQ2]

# 一、创建工程并添加Data Cache服务 #

1、Bluemix个人中心创建工程web工程

如何创建工程可看[基于IBM Bluemix部署Java Web项目实战演练][IBM Bluemix_Java Web]，这时创建后的工程

![20160204131650784][]

2、添加Data Cache 服务

Data Cache 服务在远程利用数据网格的高速缓存功能并使您可以执行创建、检索、更新和删除操作。

可以进入到项目中，然后点击添加服务或API，然后搜索data,找到Data Cache即可。

![20160204131828717][]

选择基本的套餐：

![20160204131828717][]

# 二、创建本地Java web工程 #

最后整个工程目录如下：

![20160204132104999][]

1、创建一个Dynamic web Project

2、添加jar包

WebContent/WEB-INF/lib 文件夹添加ogclient.jar 、json-org.jar

这两个jar包下载地址，ftp://public.dhe.ibm.com/cloud/bluemix/datacache/

3、创建连接Data cache的代码

要使用 Data Cache 服务实例，可在 VCAP\_SERVICES 环境变量中找到应用程序与服务实例进行通信所需的任何数据。您的应用程序需要包含所需的变量，以与 Data Cache 服务进行通信。您能通过包括以下代码片段，以编程方式从 VCAP\_SERVICES 环境变量获取变量 gridName、username 和 password，并放入代码。此代码片段将读取 VCAP\_SERVICES 环境变量：

下面的代码放在本地eclipse是无法运行的，它得上传到Bluemix工程中才可以运行

public void jspInit() {
     		Map<String, String> env = System.getenv();//取得bluemix的当前工程
     		String vcap=env.get("VCAP_SERVICES");//取得环境变量 
     		
     		String username=null;
     		String password=null;
     		String endpoint=null;
     		String gridName=null;
     			
            boolean foundService=false;
            if(vcap==null) {
            	System.out.println("No VCAP_SERVICES found");
            } else {
                try {
                	JSONObject obj = new JSONObject(vcap);
                    String[] names=JSONObject.getNames(obj);
                    if (names!=null) {
    					for (String name:names) {
                        	if (name.startsWith("DataCache")) { //取得缓存API
                 				JSONArray val = obj.getJSONArray(name);
                 				JSONObject serviceAttr = val.getJSONObject(0);
                 				JSONObject credentials = serviceAttr.getJSONObject("credentials");
                 				username = credentials.getString("username");
                 				password = credentials.getString("password");             							  
                 				endpoint=credentials.getString("catalogEndPoint");
                 				gridName= credentials.getString("gridName");
                 				System.out.println("Found configured username: " + username);
                 				System.out.println("Found configured password: " + password);
                 				System.out.println("Found configured endpoint: " + endpoint);
                 				System.out.println("Found configured gridname: " + gridName);		
                 				foundService = true;
                 				break;
                 			}                                	                                 	                                 	                                         
                        }
    				}
    			} catch(Exception e) {}
     		}
            
     		if(!foundService) {
       			System.out.println("Did not find WXS service, using defaults");
     		}
     		
     		try {
     			
    			ObjectGridManager ogm = ObjectGridManagerFactory.getObjectGridManager();
    			ClientSecurityConfiguration csc=null;
    			csc=ClientSecurityConfigurationFactory.getClientSecurityConfiguration();
    			csc.setCredentialGenerator(new UserPasswordCredentialGenerator(username,password));
    			csc.setSecurityEnabled(true);
    			
    			ClientClusterContext ccc = ogm.connect(endpoint, csc, null);
    	
    			ObjectGrid clientGrid = ogm.getObjectGrid(ccc, gridName);
    			ogSession = clientGrid.getSession();
    			
     		} catch(Exception e) {
     			System.out.println("Failed to connect to grid!");
     			e.printStackTrace();
     		}
    }

其实取得的环境变量在界面上如下

![20160204132605859][]

4、创建增、取、删除缓存的代码

ObjectMap map=ogSession.getMap("mymap.NONE.P");
    map.upsert("key1", "value1");
    Object value = map.get("key1");
    map.remove("key1");

5、合并代码

因为这里我们要实现的是从前台缓存数据，取数据等。所以后台就要实现将前台传过来的数据缓存。为此，可以将上面的代码合并使用。新建一个.jsp文件如下：

**dataCache.jsp**

<%@ page pageEncoding="UTF-8"%>
    <%@ page import="java.util.Map" %>
    <%@ page import="org.json.JSONArray" %>
    <%@ page import="org.json.JSONException" %>
    <%@ page import="org.json.JSONObject" %>
    <%@ page import="com.ibm.websphere.objectgrid.*" %>
    <%@ page import="com.ibm.websphere.objectgrid.security.config.*" %>
    <%@ page import="com.ibm.websphere.objectgrid.security.plugins.builtins.*" %>
    <%!
    Session ogSession;
    
    public void jspInit() {
     		Map<String, String> env = System.getenv();//取得bluemix的当前工程
     		String vcap=env.get("VCAP_SERVICES");//取得环境变量 
     		
     		String username=null;
     		String password=null;
     		String endpoint=null;
     		String gridName=null;
     			
            boolean foundService=false;
            if(vcap==null) {
            	System.out.println("No VCAP_SERVICES found");
            } else {
                try {
                	JSONObject obj = new JSONObject(vcap);
                    String[] names=JSONObject.getNames(obj);
                    if (names!=null) {
    					for (String name:names) {
                        	if (name.startsWith("DataCache")) { //取得缓存API
                 				JSONArray val = obj.getJSONArray(name);
                 				JSONObject serviceAttr = val.getJSONObject(0);
                 				JSONObject credentials = serviceAttr.getJSONObject("credentials");
                 				username = credentials.getString("username");
                 				password = credentials.getString("password");             							  
                 				endpoint=credentials.getString("catalogEndPoint");
                 				gridName= credentials.getString("gridName");
                 				System.out.println("Found configured username: " + username);
                 				System.out.println("Found configured password: " + password);
                 				System.out.println("Found configured endpoint: " + endpoint);
                 				System.out.println("Found configured gridname: " + gridName);		
                 				foundService = true;
                 				break;
                 			}                                	                                 	                                 	                                         
                        }
    				}
    			} catch(Exception e) {}
     		}
            
     		if(!foundService) {
       			System.out.println("Did not find WXS service, using defaults");
     		}
     		
     		try {
     			
    			ObjectGridManager ogm = ObjectGridManagerFactory.getObjectGridManager();
    			ClientSecurityConfiguration csc=null;
    			csc=ClientSecurityConfigurationFactory.getClientSecurityConfiguration();
    			csc.setCredentialGenerator(new UserPasswordCredentialGenerator(username,password));
    			csc.setSecurityEnabled(true);
    			
    			ClientClusterContext ccc = ogm.connect(endpoint, csc, null);
    	
    			ObjectGrid clientGrid = ogm.getObjectGrid(ccc, gridName);
    			ogSession = clientGrid.getSession();
    			
     		} catch(Exception e) {
     			System.out.println("Failed to connect to grid!");
     			e.printStackTrace();
     		}
    }
    %>
    
    <%
    		try {
    			request.setCharacterEncoding("UTF-8");
    			response.setContentType("text/plain");
    			response.setCharacterEncoding("UTF-8");
    				
    		   ///ObjectMap用来存储缓存内容 
    			ObjectMap map=ogSession.getMap("sample.NONE.P");
    			
    		    String key = request.getParameter("key");			
    			String operation=request.getParameter("operation");
    			Object retrievedValue;
    			if("get".equals(operation)) { 	//取得缓存内容
    			  retrievedValue=map.get(key);
    			  response.getWriter().write(retrievedValue==null?"null":retrievedValue.toString());
    			 
    			} else if("put".equals(operation)) { //存储缓存内容
    			  String newValue = request.getParameter("value");
    			  map.upsert(key,newValue);//可以对map实现update or insert  
    			  response.getWriter().write("[PUT]");
    			  
    			} else if("delete".equals(operation)) { //删除缓存 
    			  map.remove(key);			  
    			  response.getWriter().write("[DELETED]");			  
    			}
    			
    		} catch(Exception e) {
    			System.out.println("Failed to perform operation on map");
    			e.printStackTrace();
    		}
     %>

6、编写前台页面代码

这里前台使用ajax请求（不懂ajax可看这里[Ajax实例讲解与技术原理][Ajax]）到dataCache.jsp文件去缓存数据、取数据、删除数据。整个代码如下：

**index.html**

<!DOCTYPE html PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN" "http://www.w3.org/TR/html4/loose.dtd">
    <html>
    <head>
    <meta http-equiv="Content-Type" content="text/html; charset=UTF-8">
    <title>IBM Bluemix缓存实例</title>
    <body  οnlοad="load()">
    <script language="javascript" type="text/javascript">
    function load(){	
      document.getElementById('get').addEventListener("click", getClicked, false);
      document.getElementById('put').addEventListener("click", putClicked, false);
      document.getElementById('delete').addEventListener("click", deleteClicked, false);
    }
    //发送请求
    function sendRequest(operation) {
    	var ajaxRequest;  
    	var key = encodeURIComponent(document.getElementById('key').value);
    	var value = encodeURIComponent(document.getElementById('value').value);
    	
    	ajaxRequest = new XMLHttpRequest();
    	ajaxRequest.onreadystatechange = function(){
    		if(ajaxRequest.readyState == 4){
    			var result = ajaxRequest.responseText;
    			document.getElementById('value').value=result;
            }
    	}
    	//发送ajax的get请求 
    	ajaxRequest.open("GET", "dataCache.jsp?operation="+operation+"&key="+key+"&value="+value, true);
    	ajaxRequest.send(null); 
    }
    //取得缓存
    function getClicked() {
      sendRequest('get');
    }
    //存储缓存
    function putClicked() {
      sendRequest('put');
    }
    //删除缓存
    function deleteClicked() {  
      sendRequest('delete');
    }
    </script>
        <h3>IBM Bluemix缓存实例:</h3> 
    	Key:   <input id="key" type='text' name='key' /> <br>
    	Value:  <input id='value' type="text" name='value' /><br><br>
    	<button id='get'>根据KEY取缓存内容</button>
    	<button id='put'>存储缓存内容</button>
    	<button id='delete'>根据KEY删除缓存内容</button><br>
    	
    </body>
    </html>

7、本地启动tomcat运行一下

![20160204133613732][]

确认页面显示没问题

这里你如何输入数据，点击肯定会出问题，因为还没有部署到Bluxmix:

如下错误：

![20160204133927314][]

# 三、打包与发布到Bluemix #

1、打包本地war包。

直接在Eclipse中使用

![20160204134146566][]

然后选择目录：

![20160204134225395][]

看看最后的结果：

![20160204134306289][]

**注意：也可使用控制台下进行项目目录，然后输入**

// 将当前目录打包成war包
    jar cvf DataCacheTest.war */ .

**不过，这个方法最后打包的war包笔者上传后启动失败了。所以不建议使用这个方法。**

2、上传war包到个人Bluemix中心

(1）、登陆

cf login
    输入用户名、密码、选择工作空间
    或者 直接cf login-u ling20081005@126.com -o ling20081005@126.com -s 工作空间名

邮箱记得换成您自己的。  
  
(2)、上传war包

cf push DataCacheTest-p D:\DataCacheTest.war -m 512M 
    记得要指定空间大小512M

![20160204134800557][]

最后如果显示如下：

![20160204134842057][]

说明上传成功且运行成功

# 四、验证效果 #

输入网址： [http://datacachetest.eu-gb.mybluemix.net/][http_datacachetest.eu-gb.mybluemix.net]

输入内容，点击存储缓存内容

![20160204135314668][]

**注意，最后显示如下才表示缓存存储成功，要稍稍等下（服务器毕竟在美国，速度返回会比较慢），显示put了才表示成功！**

![20160204135459551][]

当然，你也可以看日志：

比如上面的存储缓存的

![20160204135609888][]

日志在这里来看：

![20160204135556747][]

还有就是取缓存的：

页面上输入key，然后点击取缓存的按钮

![20160204135723310][]

删除缓存：

页面上输入key，然后点击删除缓存的按钮

![20160204135738992][]

# 五、监视 IBM Data Cache for Bluemix #

下面是bluxmix提供的用于监视Data Cache的工具

![20160204140011886][]

在将应用程序连接到 Data Cache 之后，您可以监视 Web 应用程序的高速缓存使用情况。单击 IBM Bluemix 仪表板的服务实例，以为您的应用程序显示图表。注意，得绑定服务，并启动程序后才会显示此内容！  
  
已用空间  
此图表包含基于 IBM 的服务计划的高速缓存容量总计的视图。显示的容量总计包括数据网格中存储的数据的 1 个副本。您可以通过为您应用程序购买更多容量，一直增加限制。

吞吐量  
此图表是 5 分钟内吞吐量的快照视图。您可以将此图表展开为更大的视图，显示 1 小时的吞吐量。

事务时间  
此图表是 5 分钟内事务时间的快照视图，其以每毫秒的事务度量。您可以将此图表展开为更大的视图，显示 1 小时的事务时间。

命中率  
此图表是高速缓存命中率的快照视图。您可以将此图表展开为更大的视图，显示 1 小时的命中率。

# 六、遇到的问题 #

遇到的问题：

工程第一次上传部署上去的时候。尝试访问部署的应用程序时，打开网址，笔者出现了以下消息：

**404 Not Found:Requested route ('guesstheword.mybluemix.net') does not exist.**  
这似乎不对劲。显然某处存在问题，而且这个问题似乎与在 Bluemix 上运行的应用程序相关，因为该应用程序能够在本地正常运行。

解决方法：

删除bluxmix上的工程，重新添加服务。然后重新打包本地war包（最好通过eclipse 的expot方法)。最后再重新上传即可！

本文实例访问： [http://datacachetest.eu-gb.mybluemix.net/][http_datacachetest.eu-gb.mybluemix.net]

[http_blog.csdn.net_evankaka]: http://blog.csdn.net/evankaka
[http_datacachetest.eu-gb.mybluemix.net]: http://datacachetest.eu-gb.mybluemix.net/
[https_apps.admin.ibmcloud.com_manage_trial_bluemix.html_cm_mmc_CMDeveloperGCG-_-Bluemix-_-CSDN-_-onlineeventQ2]: https://apps.admin.ibmcloud.com/manage/trial/bluemix.html?cm_mmc=CMDeveloperGCG-_-Bluemix-_-CSDN-_-onlineeventQ2
[IBM Bluemix_Java Web]: http://blog.csdn.net/evankaka/article/details/49836551
[20160204131650784]: /images/20210811/420559f3023c44f08c7b731fb6fff95d.png
[20160204131828717]: /images/20210811/d840ab17bdbc4bfb9ad21a456dc7b0d9.png
[20160204132104999]: /images/20210811/597c1c52787f4b19826b706c9e69fcae.png
[20160204132605859]: /images/20210811/bee5e278018540e0bfdb699067af6bdd.png
[Ajax]: http://blog.csdn.net/evankaka/article/details/46896943
[20160204133613732]: /images/20210811/685d94bfbde94b168311eaa710805638.png
[20160204133927314]: /images/20210811/3b28ac058a774f9e987e57b6aa56a8cb.png
[20160204134146566]: /images/20210811/95d60cb3d25f43c6b7e9e5eb7b5b18f5.png
[20160204134225395]: /images/20210811/b881bf81b3454580af5177fb7419705b.png
[20160204134306289]: /images/20210811/82456935afec45c2bd45576e76b98c5d.png
[20160204134800557]: /images/20210811/cb96617f8afe4ac69192dea9329d5506.png
[20160204134842057]: /images/20210811/707b7246e5dd4e18b57d248c5040e490.png
[20160204135314668]: /images/20210811/b8711da3321344068a2314f5f966748b.png
[20160204135459551]: /images/20210811/af00d501f4654c92a1397eefe00e7e11.png
[20160204135609888]: /images/20210811/b612d3e7248d4e219563a2a6a8fae838.png
[20160204135556747]: /images/20210811/9aed9608b9414d7a9cf0777e5005d345.png
[20160204135723310]: /images/20210811/5533c4e3bc8d482fa71c4fe2fa88732f.png
[20160204135738992]: /images/20210811/2716dd814aa1439f88dd531e1b1bf480.png
[20160204140011886]: /images/20210811/88b00a48e446451aab40ba40514b0763.png