摘要：學習筆記的設計目的動態注冊發現服務，軟負載均衡和服務降級。一下是整個工程的內容公共定義一般和共享的接口應該多帶帶一個包進行定義，方便雙方的共享。暴露的服務實現如下入口類的實現如下實現其文件和類似其配置如下，聲明了對服務的引用。
Dubbo學習筆記
Dubbo的設計目的
動態注冊、發現服務，軟負載均衡和服務降級。
描述服務依賴關系，描述整體服務架構。
統計服務負載，按需擴展容量。
簡單實例
該實例參考官方實例，有所修改。
整個項目結構：
dubbo-hello
.
├── dubbo-hello-api
│?? ├── pom.xml
│?? ├── src
│?? │?? ├── main
│?? │?? │?? ├── java
│?? │?? │?? │?? └── com
│?? │?? │?? │?? └── tc
│?? │?? │?? │?? └── dubbo
│?? │?? │?? │?? └── hello
│?? │?? │?? │?? └── HelloService.java
│?? │?? │?? └── resources
│?? │?? └── test
│?? │?? └── java
│?? └── target
│
├── dubbo-hello-consumer
│?? ├── pom.xml
│?? ├── src
│?? │?? ├── main
│?? │?? │?? ├── java
│?? │?? │?? │?? └── com
│?? │?? │?? │?? └── tc
│?? │?? │?? │?? └── dubbo
│?? │?? │?? │?? └── hello
│?? │?? │?? │?? └── consumer
│?? │?? │?? │?? └── Consumer.java
│?? │?? │?? └── resources
│?? │?? │?? ├── META-INF
│?? │?? │?? │?? └── spring
│?? │?? │?? │?? └── dubbo-hello-consumer.xml
│?? │?? │?? ├── dubbo.properties
│?? │?? │?? └── log4j.properties
│?? │?? └── test
│?? │?? └── java
│?? └── target
│??
├── dubbo-hello-provider
│?? ├── pom.xml
│?? ├── src
│?? │?? ├── main
│?? │?? │?? ├── java
│?? │?? │?? │?? └── com
│?? │?? │?? │?? └── tc
│?? │?? │?? │?? └── dubbo
│?? │?? │?? │?? └── hello
│?? │?? │?? │?? └── provider
│?? │?? │?? │?? ├── HelloServiceImpl.java
│?? │?? │?? │?? └── Provider.java
│?? │?? │?? └── resources
│?? │?? │?? ├── META-INF
│?? │?? │?? │?? └── spring
│?? │?? │?? │?? └── dubbo-hello-provider.xml
│?? │?? │?? ├── dubbo.properties
│?? │?? │?? └── log4j.properties
│?? │?? └── test
│?? │?? └── java
│?? └── target
└── pom.xml
整個項目分為三個模塊，dubbo-hello-api、dubbo-hello-provider和dubbo-hello-consumer。一下是整個dubbo-hello工程的pom內容：
4.0.0
com.tc
dubbo-hello
1.0-SNAPSHOT
pom
${project.artifactId}
false
UTF-8
1.8
1.8
dubbo-hello-api
dubbo-hello-provider
dubbo-hello-consumer
公共API定義
一般Provider和Consumer共享的接口應該多帶帶一個包進行定義，方便雙方的共享。這里新建了模塊dubbo-hello-api來定義公共接口。其pom文件為基本配置，無特殊性，簡單定義接口HelloService如下：
package com.tc.dubbo.hello;
/**
* Created by tianchi on 2018/3/14.
*/
public interface HelloService {
String sayHello(String name);
}
Provider實現
服務提供者模塊dubbo-hello-provider的pom文件內容如下：
dubbo-hello
com.tc
1.0-SNAPSHOT
4.0.0
dubbo-hello-provider
jar
${project.artifactId}
The demo provider module of dubbo project
false
com.tc
dubbo-hello-api
${project.parent.version}
com.alibaba
dubbo
2.6.0
org.apache.maven.plugins
maven-assembly-plugin
2.3
false
jar-with-dependencies
com.tc.dubbo.hello.provider.Provider
make-assembly
package
assembly
其中聲明了對com.tc:dubbo-hello-api接口的依賴，還有對com.alibaba:dubbo的依賴。插件plugin聲明了采用加入依賴的打包方式，這樣方便直接運行。
在文件dubbo-hello-provider.xml中聲明了要暴露的服務：
其中說明了注冊方式為multicast，也即利用廣播，無注冊中心的方式。同時聲明了協議和端口號。
暴露的服務HelloServiceImpl實現如下：
package com.tc.dubbo.hello.provider;
import com.alibaba.dubbo.rpc.RpcContext;
import com.tc.dubbo.hello.HelloService;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
* Created by tianchi on 2018/3/14.
*/
public class HelloServiceImpl implements HelloService{
public String sayHello(String name) {
System.out.println("[" + new SimpleDateFormat("HH:mm:ss").format(new Date()) + "] Hello " + name + ", request from consumer: " + RpcContext.getContext().getRemoteAddress());
return "Hello " + name + ", response form provider: " + RpcContext.getContext().getLocalAddress();
}
}
入口類Provider的實現如下：
package com.tc.dubbo.hello.provider;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* Created by tianchi on 2018/3/14.
*/
public class Provider {
public static void main(String[] args) throws Exception {
//Prevent to get IPV6 address,this way only work in debug mode
//But you can pass use -Djava.net.preferIPv4Stack=true,then it work well whether in debug mode or not
System.setProperty("java.net.preferIPv4Stack", "true");
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{"META-INF/spring/dubbo-hello-provider.xml"});
context.start();
System.in.read(); // press any key to exit
}
}
Consumer實現
其pom文件和Provider類似：
dubbo-hello
com.tc
1.0-SNAPSHOT
4.0.0
dubbo-hello-consumer
jar
${project.artifactId}
The demo consumer module of dubbo project
com.tc
dubbo-hello-api
${project.parent.version}
com.alibaba
dubbo
2.6.0
org.apache.maven.plugins
maven-assembly-plugin
2.3
false
jar-with-dependencies
com.tc.dubbo.hello.consumer.Consumer
make-assembly
package
assembly
其dubbo-hello-consumer.xml配置如下，聲明了對服務的引用。
入口類Consumer實現如下：
package com.tc.dubbo.hello.consumer;
import com.tc.dubbo.hello.HelloService;
import org.springframework.context.support.ClassPathXmlApplicationContext;
/**
* Created by tianchi on 2018/3/14.
*/
public class Consumer {
public static void main(String[] args) {
//Prevent to get IPV6 address,this way only work in debug mode
//But you can pass use -Djava.net.preferIPv4Stack=true,then it work well whether in debug mode or not
System.setProperty("java.net.preferIPv4Stack", "true");
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[]{"META-INF/spring/dubbo-hello-consumer.xml"});
context.start();
HelloService helloService = (HelloService) context.getBean("helloService"); // get remote service proxy
while (true) {
try {
Thread.sleep(1000);
String hello = helloService.sayHello("world"); // call remote method
System.out.println(hello); // get result
} catch (Throwable throwable) {
throwable.printStackTrace();
}
}
}
}
文章版權歸作者所有，未經允許請勿轉載,若此文章存在違規行為，您可以聯系管理員刪除。
轉載請注明本文地址：http://specialneedsforspecialkids.com/yun/68864.html
