一、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下载方式。下载完成后，进入conf目录下修改配置文件的名称，并进入该文件修改dataDir的属性为D:\Program Files\Java\apache-zookeeper-3.7.0\data。zookeeper
最后进入bin目录，windows的启用方式是双击zkServer.cmd文件，如能正常打开窗口则证明启动成功！zookeeperzookeeper
三、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
