摘要：学习笔记的设计目的动态注册发现服务，软负载均衡和服务降级。一下是整个工程的内容公共定义一般和共享的接口应该多带带一个包进行定义，方便双方的共享。暴露的服务实现如下入口类的实现如下实现其文件和类似其配置如下，声明了对服务的引用。
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();
}
}
}
}
文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。
转载请注明本文地址：https://www.ucloud.cn/yun/68864.html
