本文為原創(chuàng)，歡迎轉(zhuǎn)載，轉(zhuǎn)載請(qǐng)注明出處BlogJava。
在上一篇 Hessian構(gòu)建分布式系統(tǒng)應(yīng)用 的基礎(chǔ)上，我們對(duì)程序進(jìn)行改進(jìn)。
現(xiàn)在有以下比較突出的問題：
a.如果hessian服務(wù)端我要做的業(yè)務(wù)很多，怎么辦？
我要定義很多個(gè)接口，然后再寫實(shí)現(xiàn)類，最煩的是還要配置它。
我的設(shè)想是，hessian服務(wù)只提供一個(gè)歸口，再此對(duì)外的接口實(shí)現(xiàn)中反射調(diào)用具體的業(yè)務(wù)類。
b.客戶端在調(diào)用時(shí)，每次調(diào)用遠(yuǎn)程接口都要用以下代碼嗎：
String url = "http://localhost:8080/HessianService/remote/service";
HessianProxyFactory factory = new HessianProxyFactory();
ServiceRemote rmt = (ServiceRemote) factory.create(ServiceRemote.class, url);
顯然是不需要的。
我們可以通過加入緩存的方式對(duì)其進(jìn)行改良，我們也可以通過Spring在客戶端管理它。
一、完善hessian服務(wù)端實(shí)現(xiàn)：
1.首先修改ServiceRemote接口：
package com.al;
import java.util.Map;
@SuppressWarnings("unchecked")
public interface ServiceRemote 
{
public Map callService(String target, Map inputMap) throws Exception;
}
callService為統(tǒng)一入口，在此做如下約定：
1)target字符串為要調(diào)用的service的完整類路徑+要調(diào)用的方法。
2)service的方法均用以下方法簽名：
public Map ***(Map inputMap);
入?yún)镸ap，返回值也為Map，基本可以滿足所有情況了。（至少入?yún)镸ap，很適合調(diào)用iBatis來對(duì)DB進(jìn)行操作。）
2.修改接口實(shí)現(xiàn)類Service，此類不做具體業(yè)務(wù)，而是反射調(diào)用具體業(yè)務(wù)類：
package com.al;
import java.lang.reflect.Method;
import java.util.Map;
import org.apache.commons.beanutils.MethodUtils;
import org.apache.commons.lang.StringUtils;
@SuppressWarnings("unchecked")
public class Service implements ServiceRemote {
public Map callService(String target, Map inputMap) throws Exception {
String className = StringUtils.substringBeforeLast(target, ".");
String methodName = StringUtils.substringAfterLast(target, ".");
Class serviceClass = loadClass(className);
Method method = getMethod(serviceClass, methodName, Map.class);
// 提供訪問效率
method.setAccessible(true);
// 調(diào)用具體業(yè)務(wù)類
return (Map) method.invoke(serviceClass.newInstance(), inputMap);
}
private static <T> Class<T> loadClass(String className) throws ClassNotFoundException {
return (Class<T>) getClassLoader().loadClass(className);
}
private static ClassLoader getClassLoader() {
return Thread.currentThread().getContextClassLoader();
}
private static Method getMethod(Class<?> cls, String name, Class<?> parameterTypes) {
return MethodUtils.getAccessibleMethod(cls, name, parameterTypes);
}
}
3.舉個(gè)例子，服務(wù)端提供業(yè)務(wù)類DisplayUserService.java
package com.al.service;
import java.util.HashMap;
import java.util.Map;
@SuppressWarnings("unchecked")
public class DisplayUserService {
public static final String selectUsers = "com.al.service.DisplayUserService.selectUsers";
public static final String deleteUser = "com.al.service.DisplayUserService.deleteUser";
public Map selectUsers(Map inputMap) {
Map ret = new HashMap();
// 數(shù)據(jù)庫操作取得用戶列表 省略
ret.put("User", "User");
return ret;
}
public Map deleteUser(Map inputMap) {
// 數(shù)據(jù)庫操作取得用戶列表 省略
return null;
}
}
所有其他配置不變，請(qǐng)參考上一篇 Hessian構(gòu)建分布式系統(tǒng)應(yīng)用 。
二、客戶端代碼的修改：
1.加入spring進(jìn)行管理：
application.xml
<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
<bean id="serviceRemote" class="org.springframework.remoting.caucho.HessianProxyFactoryBean">
<property name="serviceUrl" value="http://localhost:8080/HessianService/remote/service" />
<property name="serviceInterface" value="com.al.ServiceRemote" />
</bean>
</beans>
2.客戶端如下調(diào)用即可：
package com.ai.client;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.al.ServiceRemote;
import com.al.service.DisplayUserService;
public class ClientTest {
public static void main(String[] args) throws Exception {
ClassPathXmlApplicationContext cxt = new ClassPathXmlApplicationContext("application.xml");
ServiceRemote rmt = (ServiceRemote)cxt.getBean("serviceRemote");
System.out.println(rmt.callService(DisplayUserService.selectUsers, null));
}
}
另外一種方法是自己實(shí)現(xiàn)緩存。
也就是第一次調(diào)用遠(yuǎn)程代碼時(shí)生成ServiceRemote對(duì)象，將其保存在靜態(tài)的容器(HashMap)中，
每次準(zhǔn)備調(diào)用此遠(yuǎn)程代碼時(shí)，先判斷容器中是否有ServiceRemote對(duì)象，有則直接將其取出并使用即可，要注意的就是在這個(gè)容器上的同步問題。
具體實(shí)現(xiàn)就不做了，很簡單。
在項(xiàng)目中，對(duì)于客戶端代碼來講，還是有許多工作要做的：
1) 如果我們要調(diào)用多個(gè)遠(yuǎn)程服務(wù)怎么辦？
我們要提供一個(gè)統(tǒng)一調(diào)用，將遠(yuǎn)程調(diào)用的動(dòng)作封裝起來，讓使用的人不知道自己調(diào)用了不同的遠(yuǎn)程服務(wù)。
只要調(diào)用某個(gè)方法、傳入?yún)?shù)即可。
2) 如何方便開發(fā)員調(diào)試遠(yuǎn)程的服務(wù)代碼？
在做分布式系統(tǒng)開發(fā)的時(shí)候，如果每修改一下應(yīng)用層的service，就要對(duì)其進(jìn)行發(fā)布，然后再去調(diào)用看是否已OK，那效率會(huì)很低。
3) 如何管理多方調(diào)用的遠(yuǎn)程服務(wù)？
4) 如何提高遠(yuǎn)程調(diào)用的效率？
是否可以通過對(duì) 對(duì)象進(jìn)行緩存、方法是否也可以緩存？甚至是對(duì)調(diào)用結(jié)果進(jìn)行緩存？
5) 等等..
這些在具體的項(xiàng)目中都是不得不考慮的問題。以后再慢慢討論吧。