一、dubbo简介
1.什么是dubbo
Apache Dubbo是一款微服务开发框架，他提供了RPC通信与微服务治理两大关键能力。有着远程发现与通信的能力，可以实现服务注册、负载均衡、流量调度等服务治理诉求。
2.dubbo基本工作原理
- Contaniner:容器
- Provider：服务提供者
- Consumer：服务消费者
- Registry：注册中心
- Monitor：统计服务调用次数和调用时间的监控中心
3.具体介绍参考官方文档
文档|Apache Dubbo
二、准备dubbo-admin（管理控制台）和zookeeper（注册中心）
1.下载注册中心
docker pull zookeeper//拉取zookeeper镜像
docker run -d \
-p 2181:2181 \
-v /mydata/zookeeper/data:/data \
--name zookeeper \
zookeeper:latest
这里我的端口号为2181，我的服务器地址为192.168.31.130
yml配置文件里dubbo配置应该为：dubbo.registry.address=zookeeper://192.168.31.130:2181
-d：后台启动
-p：暴露端口号
-v：数据卷挂载
–name：指定容器名称
2.下载安装dubbo-admin（dubbo的管理控制台）
docker pull dubbo-admin //拉取镜像
//运行镜像
docker run -it -d \
--name dubbo-admin \
-v /mydata/zookeeper/dubbo-admin/data:/data \
-p 9952:8080 \
-e dubbo.registry.address=zookeeper://192.168.31.130:2181 \
-e dubbo.admin.root.password=root -e dubbo.admin.guest.password=root \
chenchuxin/dubbo-admin:latest
三、SpringBoot整合dubbo+zookeeper
分布式微服务主要是将应用的各项功能拆分成不同的模块，(根据不同的功能模块划分成不同的项目)发布在不同的服务器上，然后将需要向外提供的服务api做成分包，模块之间的相互调用通过分包api完成，dubbo的作用在于我们只需要将服务提供者的接口暴露给dubbo托管，服务消费者只要向registry注册中心注册并指定需要调用的服务，即可完成服务间调用，无需关心服务提供者的内部结构是怎样的，用户也感知不到调用了任何外部服务。
创建一个空项目，并创建commons-api、dubbo-provider、dubbo-consumer三个模块
3.1 在commons-api模块创建Account实体类和AccountService接口
@Data
@AllArgsConstructor
@NoArgsConstructor
public class Account implements Serializable {
private int id;
private String username;
private double money;
}
package liao.com.service;
import liao.com.entity.Account;
import org.apache.ibatis.annotations.Param;
import java.util.List;
public interface AccountService {
/**
* @Description:获取所有账户信息
* @Params: []
* @return java.util.List<liao.com.entity.Account>
*/
List<Account> getAllAccounts();
/**
* @Description:根据用户名获取账户余额
* @Params: [username]
* @return double
*/
Account getMoney(String username);
/**
* @Description:增加账户余额
* @Params: [username, money]
* @return int
*/
int updateAddMoney(@Param("username") String username, @Param("money") double money);
/**
* @Description:减少账户余额
* @Params: [username, money]
* @return int
*/
int updateSubMoney(@Param("username") String username, @Param("money") double money);
}
最后记得install打包到本地maven仓库里，provider服务提供者和consumer服务消费者需要用到
3.2创建provider服务提供者
3.2.1添加pom.xml依赖：
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<optional>true</optional>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<!-- 数据库-->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>2.2.2</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.20</version>
</dependency>
<!-- Dubbo Spring Boot Starter -->
<dependency>
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-spring-boot-starter</artifactId>
<version>2.7.8</version>
</dependency>
<dependency><!--zookerper版本一定要匹配！ -->
<groupId>org.apache.dubbo</groupId>
<artifactId>dubbo-registry-zookeeper</artifactId>
<version>2.7.8</version>
</dependency>
<!--这个是commons-api的maven依赖-->
<dependency>
<groupId>liao.com</groupId>
<artifactId>commons-api</artifactId>
<version>0.0.1-SNAPSHOT</version>
</dependency>
3.2.2application.properties文件
spring.datasource.username=root
spring.datasource.password=root
spring.datasource.url=jdbc:mysql://localhost:3306/demo?userSSL=true&useUnicode=true&characterEncoding=UTF-8&serverTimezone=UTC
spring.datasource.driver-class-name=com.mysql.cj.jdbc.Driver
server.port=8887
mybaits.mapper-locations=classpath:dao/*.xml
mybatis.type-aliases-package=liao.com.entity
mybatis.configration-log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
dubbo.application.name=dubbo-provider-service
dubbo.registry.address=zookeeper://192.168.31.130:2181
dubbo.protocol.name=dubbo
dubbo.protocol.port=20887
dubbo.scan.base-packages=liao.com
dubbo.registry.timeout=30000
3.2.3AccountDao.xml文件
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="liao.com.dao.AccountDao">
<select id="getAccountByName" resultType="liao.com.entity.Account" parameterType="String">
select id, username, money from account where username = #{username}
</select>
<update id="updateAddMoney">
update account set money = money + #{money} where username = #{username}
</update>
<update id="updateSubMoney">
update account set money = money - #{money} where username = #{username}
</update>
<select id="getAllAccounts" resultType="liao.com.entity.Account">
select id, username, money from account
</select>
</mapper>
3.2.4创建AccountDao
package liao.com.dao;
import liao.com.entity.Account;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.springframework.stereotype.Repository;
import java.util.List;
/**
* @author: lehu
* @Description:账户类接口
* @Params:
* @return
* @date 2024-04-13 02:38
*/
@Mapper
@Repository
public interface AccountDao {
/**
* @Description:获取所有账户信息
* @Params: []
* @return java.util.List<liao.com.entity.Account>
*/
List<Account> getAllAccounts();
/**
* @Description:根据用户名获取账户余额
* @Params: [username]
* @return double
*/
/*@Select("SELECT id, username,money FROM account WHERE username = #{username}")*/
Account getMoney(String username);
/**
* @Description:增加账户余额
* @Params: [username, money]
* @return int
*/
/*@Select("UPDATE account SET money = money + #{param2} WHERE username = #{param1}")*/
int updateAddMoney(@Param("username") String username, @Param("money") double money);
/**
* @Description:减少账户余额
* @Params: [username, money]
* @return int
*/
int updateSubMoney(@Param("username") String username, @Param("money") double money);
}
3.2.5创建AccountServiceImpl
//@DubboService注解标识该服务是服务提供者provider
@DubboService(version = "1.0.0")
//实现的AccountService接口导入Commons-api模块下的
public class AccountServiceImplPlus implements AccountService {
@Resource
private AccountDao accountDao;
@Override
public List<Account> getAllAccounts() {
return accountDao.getAllAccounts();
}
@Override
public Account getMoney(String username) {
return accountDao.getAccountByName(username);
}
@Override
public int updateAddMoney(String username, double money) {
return accountDao.updateAddMoney(username, money);
}
@Override
public int updateSubMoney(String username, double money) {
return accountDao.updateSubMoney(username, money);
}
}
3.3创建consumer服务消费者
依赖和provider服务提供者一样
application.properties配置文件也类似
创建AccountController
@RestController
@Slf4j
public class AccountController {
//@Reference代表是服务消费者，这里的AccountService接口也是导入的Commons-api模块里的
@Reference(version = "1.0.0")
private AccountService accountService;
@RequestMapping("/getAccounts")
public List<Account> getAccounts() {
List<Account> allAccounts = accountService.getAllAccounts();
log.info("allAccounts:{}", allAccounts);
return allAccounts;
}
@RequestMapping("/getMoenyByUsername")
public void addAccount(String username, String param1, double param2) {
Account account = accountService.getMoney(username);
log.info("account:{}", account);
if (account.getMoney() > 10000) {
accountService.updateAddMoney(param1, param2);
}
}
@RequestMapping("/getAccountByUsername")
public Account getAccountByUsername(@Param("username") String username) {
Account account = accountService.getMoney(username);
log.info("account:{}", account);
return account;
}
@RequestMapping("/addAccount")
public String addAccount(@Param("username") String username, @Param("money") Double money) {
int i = accountService.updateAddMoney(username, money);
if (i > 0) {
return "success";
} else {
return "fail";
}
}
@RequestMapping("/subAccount")
public String subAccount(@Param("username") String username, @Param("money") Double money) {
int i = accountService.updateSubMoney(username, money);
if (i > 0) {
return "success";
} else {
return "fail";
}
}
}
3.3测试
先启动服务提供者，再启动服务消费者
用postman测试一下基于Dubbo+Zookeeper的RPC远程服务调用
查询所有账户信息：
根据用户名来查询Account账户信息：
根据用户名来给用户转账：
再来查询不良帅的余额：
四、在zookeeper客户端命令查看dubbo服务的生产者与消费者
现在我的zookeeper注册中心部署在docker容器里，需要通过命令：docker exec -it 容器id /bin/bash进入容器内部
4.1进入容器内部后切换到bin目录下
docker exec -it 容器id /bin/bash //进入容器内部
cd bin //切换到bin目录
4.2 执行命令./zkCli.sh
./zkCli.sh
4.3 在命令行输入ls /dubbo,即可查到dubbo服务对外提供的接口，如下图：
4.4 查看消费者命令：
ls /dubbbo/liao.com.service.AccountService/consumers
会看到消费者的信息，截图如下：
4.5 查看生产者命令：
ls /dubbo/liao.com.common.CommonService/providers
会看到生产者的信息，截图如下：
OK结束！
