實習期間mentor讓看看Tuscany——apache的一個頂級項目。之前一直沒有接觸過,聽mentor說了下用途過后,感覺其像是alibaba的分布式服務框架Dubbo,簡要看了看,似乎和RMI也有相關性??傊彩敲嫦蚍盏姆植际娇蚣?。經過一下午的嘗試,發現Tuscany 2和Tuscany 1還是有比較大的不同(API方面、設計思想沒有深入研究不知道),網上關于Tuscany的資料也不多,所以在此寫文章mark一下。
Tuscany 1的API參考這位博主http://blog.csdn.net/ajun_studio/article/details/7770023
1. 準備
首先是在工程中引入Tuscany 2.0.1的jar包,從一個Apache的China鏡像上不難找到(PS:Tuscany 1在官網上已經不維護了)。
工程需要實現客戶端調用遠程服務器端的服務的功能。該項目中調用遠程完成“加”的功能。
2. 入門
首先添加IAdd接口
package com.ajun.tuscany.server;
public interface IAdd {
double add(double n1,double n2);
}
然后是實現類Addpackage com.ajun.tuscany.server;
public class Add implements IAdd {
@Override
public double add(double n1, double n2) {
// TODO Auto-generated method stub
return n1 + n2;
}
}
加減乘除都屬于“計算”類,此處為了簡便,只實現“加”方法。然后是“計算”的接口。package com.ajun.tuscany.server;
public interface ICalculator {
double add(double n1, double n2);
}
然后是“計算”的實現,注意一定要在setter中加入@Reference,否則會報錯,這里類似于Spring的注入。package com.ajun.tuscany.server;
import org.oasisopen.sca.annotation.Reference;
public class Calculator implements ICalculator {
private IAdd add;
public IAdd getAdd() {
return add;
}
@Reference
public void setAdd(IAdd add) {
this.add = add;
}
@Override
public double add(double n1, double n2) {
// TODO Auto-generated method stub
return this.add.add(n1, n2);
}
}
到此,基本的業務邏輯類就編寫好了,接下來,是Tuscany中重要的配置文件,即XXX.composite,其本質也是一個xml。如果不是面向分布式服務,該xml文件結構類似Spring的application.xml。下面是Calculator.composite,注意配置文件中reference,name標記為add,應該也是同Spring的大寫首字母規則,通過settrt注入。<?xml version="1.0" encoding="UTF-8"?>
<composite xmlns="http://docs.oasis-open.org/ns/opencsa/sca/200912"
xmlns:tuscany="http://tuscany.apache.org/xmlns/sca/1.1"
targetNamespace="http://sample"
xmlns:sample="http://sample"
xmlns:scallop="http://scallop/xmlns/sca/1.1"
name="Calculator" >
<component name="CalculatorServiceComponent">
<implementation.java class="com.ajun.tuscany.server.Calculator" />
<reference name="add" target="AddComponent"/>
</component>
<component name="AddComponent">
<implementation.java class="com.ajun.tuscany.server.Add" />
</component>
</composite>
最后是運行main的類package com.ajun.tuscany.server;
import org.apache.tuscany.sca.node.Node;
import org.apache.tuscany.sca.node.NodeFactory;
public class StartService {
public static void main(String[] args) {
Node node = NodeFactory.newInstance().createNode(
"Calculator.composite");
node.start();
System.out.println("service啟動");
ICalculator c = node.getService(Calculator.class,
"CalculatorServiceComponent");
System.out.println(c.add(2, 2));
}
}
運行輸出如下2014-11-10 17:39:24 org.apache.tuscany.sca.node.impl.NodeFactoryImpl loadContributions
信息: Loading contribution: file:/E:/HuRanjie/EclipseWorkspace/Calculatoer_01/bin/
2014-11-10 17:39:24 org.apache.tuscany.sca.host.rmi.DefaultRMIHost registerService
信息: RMI service registered: rmi://127.0.0.1:8099/CalculatorRMIService
2014-11-10 17:39:24 org.apache.tuscany.sca.core.assembly.impl.DomainRegistryImpl addEndpoint
信息: Add endpoint - binding.rmi - rmi://127.0.0.1:8099/CalculatorRMIService
2014-11-10 17:39:24 org.apache.tuscany.sca.core.assembly.impl.DomainRegistryImpl addEndpoint
信息: Add endpoint - binding.sca - AddComponent/Add
service啟動
4.0
3. 遠程調用rmi
上面并沒有將“計算”類作為一個服務,暴露給遠程調用,只是實現了本地的裝配。下面將其作為服務給遠程調用,后面可以看到,只需要暴露一個包括host、port、serviceName
首先,修改配置文件,修改為如下樣子——在本地(127.0.0.1)的8099端口暴露出名字為CalculatorRMIService的服務
<?xml version="1.0" encoding="UTF-8"?>
<composite xmlns="http://docs.oasis-open.org/ns/opencsa/sca/200912"
xmlns:tuscany="http://tuscany.apache.org/xmlns/sca/1.1"
targetNamespace="http://sample"
xmlns:sample="http://sample"
xmlns:scallop="http://scallop/xmlns/sca/1.1"
name="Calculator" >
<component name="CalculatorServiceComponent">
<implementation.java class="com.ajun.tuscany.server.Calculator" />
<service name="Calculator">
<interface.java interface="com.ajun.tuscany.server.ICalculator"/>
<tuscany:binding.rmi uri="rmi://127.0.0.1:8099/CalculatorRMIService"/>
</service>
<reference name="add" target="AddComponent"/>
</component>
<component name="AddComponent">
<implementation.java class="com.ajun.tuscany.server.Add" />
</component>
</composite>
服務器端的main主要功能是啟動該服務,如下
package com.ajun.tuscany.server;
import org.apache.tuscany.sca.node.Node;
import org.apache.tuscany.sca.node.NodeFactory;
public class StartService {
public static void main(String[] args) {
Node node = NodeFactory.newInstance().createNode(
"Calculator.composite");
node.start();
System.out.println("service啟動");
}
}
客戶端通過rmi調用服務器端的服務,來實現功能,如下
package com.ajun.tuscany.client;
import java.rmi.Naming;
import com.ajun.tuscany.server.ICalculator;
public class CalculatorClient {
public static void main(String[] args) throws Exception {
ICalculator c= (ICalculator) Naming.lookup("http://127.0.0.1:8099/CalculatorRMIService");
System.out.println(c.add(1, 2));
}
}
啟動服務端輸出
2014-11-10 18:00:30 org.apache.tuscany.sca.node.impl.NodeImpl start
信息: Starting node: http://tuscany.apache.org/sca/1.1/nodes/default0 domain: default
2014-11-10 18:00:30 org.apache.tuscany.sca.node.impl.NodeFactoryImpl loadContributions
信息: Loading contribution: file:/E:/HuRanjie/EclipseWorkspace/Calculatoer_01/bin/
2014-11-10 18:00:31 org.apache.tuscany.sca.host.rmi.DefaultRMIHost registerService
信息: RMI service registered: rmi://127.0.0.1:8099/CalculatorRMIService
2014-11-10 18:00:31 org.apache.tuscany.sca.core.assembly.impl.DomainRegistryImpl addEndpoint
信息: Add endpoint - binding.rmi - rmi://127.0.0.1:8099/CalculatorRMIService
2014-11-10 18:00:31 org.apache.tuscany.sca.core.assembly.impl.DomainRegistryImpl addEndpoint
信息: Add endpoint - binding.sca - AddComponent/Add
service啟動
客戶端輸出
3.0