一、Dubbo 简介
- Dubbo是一款高性能、轻量级的开源Java RPC框架,它提供了三大核心能力:面向接口的远程方法调用,智能容错和负载均衡,以及服务自动注册和发现。
- Remoting: 网络通信框架,实现了 sync-over-async 和 request-response 消息机制。
- RPC: 一个远程过程调用的抽象,支持负载均衡、容灾和集群功能。
- Registry: 服务目录框架用于服务的注册和服务事件发布和订阅。
二、Zookeeper 简介
- 功能描述:Zookeeper是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现,是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护、域名服务、分布式同步、组服务等。
- 官网下载:https://zookeeper.apache.org/releases.html,选择Zookeeper版本和HTTP下载方式。
zookeeper
下载完成后,进入conf目录下修改配置文件的名称,并进入该文件修改dataDir的属性为D:\Program Files\Java\apache-zookeeper-3.7.0\data。
zookeeper 最后进入bin目录,windows的启用方式是双击zkServer.cmd文件,如能正常打开窗口则证明启动成功! zookeeper
三、SpringBoot整合Dubbo和ZooKeeper框架
- 创建SpringBoot项目作为父工程,利用其多模块特性构建出common、provider、consumer三个子工程,其中common包存放接口和实体,provider作为提供者角色,consumer作为消费者角色,创建步骤如下:1、选中父工程并鼠标右击出现菜单 -> New -> Module;2、构建方式同样选择SpringBoot项目;3、父工程作为子工程的关联,具体实现在子工程,因此无需进行额外配置,项目结构如下: project
- 为避免SpringBoot工程启用时端口冲突,特定给每个项目配置一个唯一的端口。
server.port=8088 -> application.properties
- common工程:创建service包用于存放Java接口,创建domain包,用于存放Java实体类,实体类需要实现序列化,避免远程服务调用时不能被解析,因为只是存放接口,所以也无需进行额外配置。
UserService 接口
public interface UserService {
User getUser();
}
User 实体类
public class User implements Serializable {
private String name = "wjx";
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
}
- provider工程:POM文件引入common工程、Dubbo依赖、ZooKeeper依赖,创建impl包用于存放Java接口实现类,创建Dubbo的配置文件实现远程服务调用。
pom.xml 在dependencies节点里加入以下代码:
<dependency> -> dubbo
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.5.5</version>
<exclusions>
<exclusion>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency> -> zookeeper
<groupId>com.101tec</groupId>
<artifactId>zkclient</artifactId>
<version>0.10</version>
</dependency>
<dependency> -> common模块
<groupId>com.common</groupId>
<artifactId>common</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
dubbo.xml 创建方式:New -> XML Configuration File -> Spring Config
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://code.alibabatech.com/schema/dubbo
http://code.alibabatech.com/schema/dubbo/dubbo.xsd"
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo">
<dubbo:application name="provider"/> -> 提供者
<dubbo:registry address="zookeeper://127.0.0.1:2181"/> -> 注册到服务中心
<dubbo:annotation package="com.provider.impl"/> -> 扫描注解包路径,多个包用逗号分隔
<dubbo:protocol name="dubbo" port="20880"/> -> dubbo端口
<bean id="userService" class="com.provider.impl.UserServiceImpl"/> -> 接口实现
<dubbo:service interface="com.common.service.UserService" ref="userService"/> -> 接口
</beans>
UserServiceImpl 接口实现类
import com.alibaba.dubbo.config.annotation.Service;
@Service(version = "1.0.0")
public class UserServiceImpl implements UserService {
@Override
public User getUser() {
return new User();
}
}
ProviderApplication 启动类
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.ImportResource;
@SpringBootApplication
@ImportResource({"classpath:dubbo.xml"})
public class ProviderApplication {
public static void main(String[] args) {
SpringApplication.run(ProviderApplication.class, args);
}
}
- consumer工程:POM文件引入common工程、Dubbo依赖、ZooKeeper依赖,创建controller包用于存放Java外部调用的API,创建Dubbo的配置文件实现远程服务访问。
pom.xml 在dependencies节点里加入以下代码:
<dependency> -> dubbo
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.5.5</version>
<exclusions>
<exclusion>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency> -> zookeeper
<groupId>com.101tec</groupId>
<artifactId>zkclient</artifactId>
<version>0.10</version>
</dependency>
<dependency> -> common模块
<groupId>com.common</groupId>
<artifactId>common</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
dubbo.xml 创建方式:New -> XML Configuration File -> Spring Config
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans.xsd
http://code.alibabatech.com/schema/dubbo
http://code.alibabatech.com/schema/dubbo/dubbo.xsd"
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo">
<dubbo:application name="consumer"/> -> 消费者
<dubbo:registry address="zookeeper://127.0.0.1:2181"/> -> 注册到服务中心
<dubbo:annotation package="com.consumer.controller"/> -> 扫描注解包路径,多个包用逗号分隔
<dubbo:protocol name="dubbo" port="20880"/> -> dubbo端口
<dubbo:reference id="userService" check="false" interface="com.common.service.UserService"/> -> 远程访问
</beans>
UserController 接口实现类
import com.alibaba.dubbo.config.annotation.Reference;
import javax.annotation.Resource;
@RestController
public class UserController {
@Resource
@Reference(version = "1.0.0")
private UserService userService;
@RequestMapping("user")
public User user() {
return userService.getUser();
}
}
ConsumerApplication 启动类
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.ImportResource;
@SpringBootApplication
@ImportResource({"classpath:dubbo.xml"})
public class ConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(ConsumerApplication.class, args);
}
}
- 搭建过程已全部完成,接下来是启动过程,步骤为:1、启动ZooKeeper;2、启动Provider项目;3、启动Consumer项目;4、访问Controller的接口,得到如下结果则证明运行成功: project
四、Dubbo-Admin 监控台
- 功能描述:提供可视化界面工具,可以直观查看ZooKeeper上有哪些服务,方便管理。
- 克隆项目:IDEA克隆步骤:1、根部导航栏File -> New -> Project From Version Control;2、输入git的仓库地址 https://github.com/apache/incubator-dubbo-ops;3、设置本地磁盘存放位置并点击确定即可从远端拉取项目; project
- 运行项目:IDEA运行步骤:1、启动本地的ZooKeeper服务注册中心;2、修改dubbo-admin-server模块下的端口为8081,避免默认8080端口冲突;3、运行该模块并访问 http://localhost:8081;4、控制台的初始化账号和密码都是root,出现以下界面证明运行成功: project
网友评论