為什么要學(xué)習(xí)dubbo 這里不多做說明,有需要可自行百度
說明:基于zookeeper 作為注冊(cè)服務(wù)中心,
1:新建兩個(gè)maven 項(xiàng)目,一個(gè)作為服務(wù)提供者,一個(gè)作為服務(wù)消費(fèi)者,如下
dubbo-client -- 服務(wù)消費(fèi)者
dubbo-provider -- 服務(wù)提供者
2:服務(wù)端接口代碼如下(服務(wù)接口作為服務(wù)提供者的一個(gè)子模塊打包成jar包以供調(diào)用)
public interface SayHello {
public String sayHello(String name);
}
3:接口實(shí)現(xiàn)代碼如下
public class SayHelloImpl implements SayHello {
@Override
public String sayHello(String name) {
return "hello version 1.0.0"+name;
}
public static void main(String[] args) throws Exception{
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("dubbo-server.xml");
context.start();
System.in.read();
}
}
4:版本升級(jí)處理,可通過配置文件指定version,然后在客戶端指定調(diào)用的版本
public class SayHelloImpl2 implements SayHello {
@Override
public String sayHello(String name) {
return "hello version 2.0.0"+name;
}
public static void main(String[] args) throws Exception{
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("dubbo-server.xml");
context.start();
System.in.read();
}
}
5:服務(wù)提供配置xml
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
xmlns="http://www.springframework.org/schema/beans"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
<!-- 提供方應(yīng)用信息,用于計(jì)算依賴關(guān)系,dubbo-provider這個(gè)是項(xiàng)目名 -->
<dubbo:application name="dubbo-provider"/>
<!-- 這里使用的注冊(cè)中心是zookeeper -->
<dubbo:registry address="zookeeper://127.0.0.1:2181" client="zkclient"/>
<!-- 用dubbo協(xié)議在20880端口暴露服務(wù) -->
<dubbo:protocol name="dubbo" port="20880" />
<!-- 將該接口暴露到dubbo中 ,在做服務(wù)升級(jí)的時(shí)候,為了兼容老版本,可通過 version 可以指定調(diào)用的版本-->
<dubbo:service interface="com.share.dubbo.SayHello" ref="sayHelloImpl" version="1.0.0"/>
<dubbo:service interface="com.share.dubbo.SayHello" ref="sayHelloImpl2" version="2.0.0"/>
<bean id="sayHelloImpl" class="com.share.dubbo.SayHelloImpl" />
<bean id="sayHelloImpl2" class="com.share.dubbo.SayHelloImpl2" />
</beans>
6:客戶端調(diào)用(引入服務(wù)接口jar包)
<dependency>
<groupId>com.share.dubbo</groupId>
<artifactId>service-api</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:dubbo="http://dubbo.apache.org/schema/dubbo"
xmlns="http://www.springframework.org/schema/beans"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.3.xsd
http://dubbo.apache.org/schema/dubbo http://dubbo.apache.org/schema/dubbo/dubbo.xsd">
<!-- 提供方應(yīng)用信息,用于計(jì)算依賴關(guān)系,dubbo-provider這個(gè)是項(xiàng)目名 -->
<dubbo:application name="dubbo-client" />
<!-- 這里使用的注冊(cè)中心是zookeeper -->
<dubbo:registry address="zookeeper://127.0.0.1:2181" client="zkclient"/>
<!--通過version 指定調(diào)用的版本-->
<dubbo:reference id="sayHelloImpl" interface="com.share.dubbo.SayHello" version="2.0.0"/>
</beans>
7:客服端調(diào)用服務(wù)
ublic class SayHelloClient {
public static void main(String[] args) {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(
new String[] { "dubbo-client.xml" });
context.start();
SayHello hello = (SayHello)context.getBean("sayHelloImpl");
String name = hello.sayHello("我是來測(cè)試的");
System.out.println(name);
}
}
測(cè)試:
啟動(dòng)zookeeper 后,在啟動(dòng)服務(wù)端,然后會(huì)在zookeeper 中看到新注冊(cè)的服務(wù)中心地址,然后在啟動(dòng)客戶端檢驗(yàn)服務(wù)調(diào)用是否成功
ls /dubbo/com.share.dubbo.SayHello/providers
[dubbo%3A%2F%2F169.254.72.117%3A20880%2Fcom.share.dubbo.SayHello%3Fanyhost%3Dtrue%26application%3Ddubbo-provider%26dubbo%3D2.5.6%26generic%3Dfalse%26interface%3Dcom.share.dubbo.SayHello%26methods%3DsayHello%26pid%3D48779%26revision%3D1.0.0%26side%3Dprovider%26timestamp%3D1533543075021%26version%3D1.0.0, dubbo%3A%2F%2F169.254.72.117%3A20880%2Fcom.share.dubbo.SayHello2%3Fanyhost%3Dtrue%26application%3Ddubbo-provider%26dubbo%3D2.5.6%26generic%3Dfalse%26interface%3Dcom.share.dubbo.SayHello%26methods%3DsayHello%26pid%3D48779%26revision%3D2.0.0%26side%3Dprovider%26timestamp%3D1533543090459%26version%3D2.0.0]
以上完成了 dubbo 簡(jiǎn)單的服務(wù)調(diào)用完成,事例代碼稍后會(huì)上傳github上以供下載