Dubbo是阿里巴巴开发的一个开源的高性能、高可用、可扩展的分布式RPC调用框架,致力于提供高性能和透明化的 RPC 远程调用服务解决方案。作为阿里巴巴 SOA 服务化治理方案的核心框架,目前已进入 Apache 孵化器项目。在单体应用时,不同业务模块部署在同一个JVM 进程内,这时通过本地调用就可以解决不同业务模块之间的相互引用;但在多体应用时,不同业务模块大多部署到不同的机器上,这时一个高效、稳定的RPC框架就显得特别重要了。Apache Dubbo 作为阿里巴巴开源的分布式RPC 框架,在进入Apache 孵化器项目后现已毕业。就目前来说Dubbo是java这块做分布式服务的流行方式。加之dubbo在云原生方面的探索都是我们作为java开发者应该且必须掌握的一门编程技术。就目前来说java的rpc框架包括hession都没有像dubbo这样支持负载均衡的功能。我们知道rpc调用其实相比http这种的各种json转化方便很多,而且不用关注类似鉴权等一些操作,个人觉得或许不是最好的解决方案。诸如此,作者计划学习一下dubbo,而本次学习本着深入了解的思路,尽量发掘dubbo的的设计方式,作为学习的开始,我们还是从demo开始吧。
1.创建父工程,其pom.xml为
代码语言:javascript复制 <properties>
<maven.compiler.source>8</maven.compiler.source>
<maven.compiler.target>8</maven.compiler.target>
<my.version>2.7.6</my.version>
<api.version>1.0</api.version>
<web.version>2.3.3.RELEASE</web.version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
<version>${web.version}</version>
</dependency>
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>${my.version}</version>
</dependency>
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-dependencies-zookeeper</artifactId>
<type>pom</type>
<version>${my.version}</version>
</dependency>
<dependency>
<groupId>com.scaffold.learn</groupId>
<artifactId>my-api</artifactId>
<version>${api.version}</version>
</dependency>
</dependencies>
</dependencyManagement>
2.创建my-api项目。
代码语言:javascript复制public class Entity implements Serializable {
private String name;
private int age;
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public int getAge() {
return age;
}
public void setAge(int age) {
this.age = age;
}
@Override
public String toString() {
return "Entity{"
"name='" name '''
", age=" age
'}';
}
}
创建rpc接口
代码语言:javascript复制public interface ShowApi {
Entity show(String name, int age);
}
创建服务提供者
主要的pom.xml为
代码语言:javascript复制 <dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
<version>2.3.3.RELEASE</version>
</dependency>
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-dependencies-zookeeper</artifactId>
<type>pom</type>
</dependency>
<dependency>
<groupId>com.scaffold.learn</groupId>
<artifactId>my-api</artifactId>
</dependency>
</dependencies>
服务提供者实现接口
代码语言:javascript复制
import com.scaffold.learn.api.ShowApi;
import com.scaffold.learn.api.entity.Entity;
import org.apache.dubbo.config.annotation.Service;
@Service
public class ShowProvider implements ShowApi {
@Override
public Entity show(String name, int age) {
System.out.println("requesttname=" name "tage=" age);
Entity entity=new Entity();
entity.setName("dubbo-" name);
entity.setAge(age 1);
return entity;
}
}
启动函数
代码语言:javascript复制@SpringBootApplication
public class ProviderService {
public static void main(String[] args) {
SpringApplication.run(ProviderService.class,args);
}
}
相关配置文件
代码语言:javascript复制server.port=8333
dubbo.scan.base-packages=com.scaffold.learn.provider
dubbo.application.name=dubbo-provider
dubbo.protocol.name=dubbo
## Random port
dubbo.protocol.port=-1
## Dubbo Registry
dubbo.registry.address=zookeeper://127.0.0.1:2181
3.服务消费者pom.xml文件
代码语言:javascript复制 <dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
<version>2.3.3.RELEASE</version>
</dependency>
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-dependencies-zookeeper</artifactId>
<type>pom</type>
</dependency>
<dependency>
<groupId>com.scaffold.learn</groupId>
<artifactId>my-api</artifactId>
</dependency>
</dependencies>
对外接口:
代码语言:javascript复制@RestController
public class Api {
@Reference
private ShowApi showApi;
@GetMapping(value = "/test")
public String testDubbo(){
Entity entity = showApi.show("tianjingle",1);
System.out.println(entity.toString());
return entity.toString();
}
}
启动函数
代码语言:javascript复制@SpringBootApplication
public class ConsumerService {
public static void main(String[] args) {
SpringApplication.run(ConsumerService.class,args);
}
}
配置文件
代码语言:javascript复制server.port=8334
spring.application.name=consumer
#dubbo.scan.base-packages=com.scaffold.learn.consumer
embedded.zookeeper.port=2181
## Dubbo Registry
dubbo.registry.address= zookeeper://127.0.0.1:${embedded.zookeeper.port}
4.启动zookeeper
5.启动服务提供者和消费者
在浏览器访问服务消费者接口
http://localhost:8334/test
以上demo我们采用apache dubbo来整合springboot,整个过程比较简单,要注意的是我们仅仅在配置文件中配置了dubbo的相关配置,项目就成功启动了。而在spirngboot中类似这种的自动化的配置,其实依靠的spring.factories这个文件,我们大概找一下就在这里,也就是说dubbo-spring-boot这个包自动的将我们需要暴露的rpc接口和rpc接口的依赖暴露或者注入进来,同时dubbo对于自动化配置解析也是这块做的。
我们学习dubbo本质上是为了更好的工作,了解dubbo中的一些特点和预留接口或许能够让解决很多未来潜在的业务难题,本次文章分享到这里。
午安~