RocketMQ 实战：模拟电商网站场景综合案例（二）
===========================================================
一、SpringBoot 整合 Dubbo ：dubbo 概述
1、dubbo 概述
Dubbo ：是阿里巴巴公司开源的一款高性能、轻量级的 Java RPC 框架，它提供了三大核心能力：面向接口的远程方法调用，智能容错和负载均衡，以及服务自动注册和发现。
2、下载 SpringBoot 集成 Dubbo 的依赖包：dubbo-spring-boot-starter
https://github.com/alibaba/dubbo-spring-boot-starter
rocketmq-spring-rocketmq-spring-all-2.0.3.zip
3、将 dubbo-spring-boot-starter 安装到本地仓库。
mvn install -Dmaven.skip.test=true 4、Dubbo 使用流程图
二、SpringBoot 整合 Dubbo ：zookeeper 集群搭建
1、zookeeper 集群搭建：准备工作
1.1 安装 JDK
sudo apt install jdk-81.2 将 Zookeeper 上传到服务器上 /usr/local/zookeeper/
# 建议下载 zookeeper-3.5 以上完全版本/usr/local/zookeeper/zookeeper-3.4.6.tar.gz /usr/local/zookeeper/apache-zookeeper-3.5.6-bin.tar.gz1.3 解压 Zookeeper，并创建 data 目录，将 conf 下的 zoo_sample.cfg 文件改名为 zoo.cfg
# 切换目录：
cd /usr/local/zookeeper/# 解压：
sudo tar -zvxf zookeeper-3.4.6.tar.gz# 创建 data 目录：
mkdir ./zookeeper-3.4.6/data/# 将 conf 下的 zoo_sample.cfg 文件改名为 zoo.cfg
mv ./zookeeper-3.4.6/conf/zoo_sample.cfg ./zookeeper-3.4.6/conf/zoo.cfg 1.4 建立 /usr/local/zookeeper-cluster 文件夹，将解压后的 Zookeeper 复制到三个目录。
# 切换目录：
cd /usr/local/zookeeper/# 创建 zookeeper-cluster 目录：
mkdir /usr/local/zookeeper/zookeeper-cluster/# 将解压后的 Zookeeper 复制到三个目录
cp -rf /usr/local/zookeeper/zookeeper-3.4.6 /usr/local/zookeeper/zookeeper-cluster/zookeeper-1
cp -rf /usr/local/zookeeper/zookeeper-3.4.6 /usr/local/zookeeper/zookeeper-cluster/zookeeper-2
cp -rf /usr/local/zookeeper/zookeeper-3.4.6 /usr/local/zookeeper/zookeeper-cluster/zookeeper-31.5 配置一个 zookeeper 的 dataDir ( zoo.cfg ) , clientPort 分别为：2181, 2182, 2183
# 修改 /usr/local/zookeeper/zookeeper-cluster/zookeeper-1/conf/zoo.cfg
cd /usr/local/zookeeper/zookeeper-cluster/
sudo vim ./zookeeper-1/conf/zoo.cfg clientPort=2181
dataDir=/usr/local/zookeeper/zookeeper-cluster/zookeeper-1/data# 修改 /usr/local/zookeeper/zookeeper-cluster/zookeeper-2/conf/zoo.cfg
cd /usr/local/zookeeper/zookeeper-cluster/
sudo vim ./zookeeper-2/conf/zoo.cfg clientPort=2182
dataDir=/usr/local/zookeeper/zookeeper-cluster/zookeeper-2/data# 修改 /usr/local/zookeeper/zookeeper-cluster/zookeeper-3/conf/zoo.cfg
cd /usr/local/zookeeper/zookeeper-cluster/
sudo vim ./zookeeper-3/conf/zoo.cfg clientPort=2183
dataDir=/usr/local/zookeeper/zookeeper-cluster/zookeeper-3/data2、zookeeper 集群搭建：配置集群
2.1 在每一个 zookeeper 的 data 目录下创建一个 myid 文件，内容分别为 1、2、3。这个文件就是记录每个服务器的 ID。
# 切换目录：
cd /usr/local/zookeeper/zookeeper-cluster/# 创建并编辑 myid 文件：
sudo vim ./zookeeper-1/data/myid
1# 创建并编辑 myid 文件：
sudo vim ./zookeeper-2/data/myid
2# 创建并编辑 myid 文件：
sudo vim ./zookeeper-3/data/myid
32.2 在每一个 zookeeper 的 zoo.cfg 配置客户端访问端口（clientPort）和集群服务器 IP 列表。
# 切换目录：
cd /usr/local/zookeeper/zookeeper-cluster/# 编辑 zoo.cfg 文件：
sudo vim ./zookeeper-1/conf/zoo.cfg # 配置样例：server.服务器 ID = 服务器 IP 地址 ：服务器之间通信的端口 ：服务器之间投票选举的端口
server.1=192.168.25.140:2881:3881
server.2=192.168.25.140:2882:3882
server.3=192.168.25.140:2883:3883# 或者：（填写你自己虚拟机的IP地址）
server.1=172.18.30.110:2881:3881
server.2=172.18.30.110:2882:3882
server.3=172.18.30.110:2883:3883# 编辑 zoo.cfg 文件：
sudo vim ./zookeeper-2/conf/zoo.cfg # 配置样例：server.服务器 ID = 服务器 IP 地址 ：服务器之间通信的端口 ：服务器之间投票选举的端口
server.1=192.168.25.140:2881:3881
server.2=192.168.25.140:2882:3882
server.3=192.168.25.140:2883:3883# 或者：（填写你自己虚拟机的IP地址）
server.1=172.18.30.110:2881:3881
server.2=172.18.30.110:2882:3882
server.3=172.18.30.110:2883:3883# 编辑 zoo.cfg 文件：
sudo vim ./zookeeper-3/conf/zoo.cfg # 配置样例：server.服务器 ID = 服务器 IP 地址 ：服务器之间通信的端口 ：服务器之间投票选举的端口
server.1=192.168.25.140:2881:3881
server.2=192.168.25.140:2882:3882
server.3=192.168.25.140:2883:3883# 或者：（填写你自己虚拟机的IP地址）
server.1=172.18.30.110:2881:3881
server.2=172.18.30.110:2882:3882
server.3=172.18.30.110:2883:38833、zookeeper 集群搭建：启动集群
# 切换目录：
cd /usr/local/zookeeper/zookeeper-cluster/# 启动 zookeeper
./zookeeper-1/bin/zkServer.sh start # 启动 zookeeper
./zookeeper-2/bin/zkServer.sh start # 启动 zookeeper
./zookeeper-3/bin/zkServer.sh start # 查看 zookeeper 启动状态
./zookeeper-1/bin/zkServer.sh status # 查看 zookeeper 启动状态
./zookeeper-2/bin/zkServer.sh status # 查看 zookeeper 启动状态
./zookeeper-3/bin/zkServer.sh status 三、SpringBoot 整合 Dubbo ：dubbo 服务接口开发
1、打开 idea 创建 springboot-dubbo-interface 项目，并在项目 pom.xml 中添加 依赖。
--> idea --> File --> New --> Project --> Maven Project SDK: ( 1.8(java version "1.8.0_131" ) --> Next --> Groupld : ( djh.it )Artifactld : ( springboot-dubbo-interface )Version : 1.0-SNAPSHOT--> Name: ( springboot-dubbo-interface )Location: ( ...\springboot-dubbo-interface\ ) --> Finish2、在 springboot-dubbo-interface 项目中，创建 接口类 IUseService.java
/*** springboot-dubbo-interface\src\main\java\djh\it\shop\service\IUseService.java** 2024-6-4 创建 接口类 IUseService.java*/package djh.it.shop.service;public interface IUseService {public String sayHello(String name);
}3、把 springboot-dubbo-interface 项目 install 安装一下，让它生成 引用 .jar 包。
右键 springboot-dubbo-interface 项目 ---》Run Maven ---》clean Install
---》target 目录会生成 springboot-dubbo-interface-1.0-SNAPSHOT.jar或者：
idea 右边 Maven ---》springboot-dubbo-interface 项目 ---》lifecycle ---》install
---》target 目录会生成 springboot-dubbo-interface-1.0-SNAPSHOT.jar4、打开 idea 创建 springboot-dubbo-provider 项目，并在项目 pom.xml 中添加 接口工程 依赖。
--> idea --> File --> New --> Project --> Maven Project SDK: ( 1.8(java version "1.8.0_131" ) --> Next --> Groupld : ( djh.it )Artifactld : ( springboot-dubbo-provider )Version : 1.0-SNAPSHOT--> Name: ( springboot-dubbo-provider )Location: ( ...\springboot-dubbo-provider\ ) --> Finish
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>djh.it</groupId><artifactId>springboot-dubbo-provider</artifactId><version>1.0-SNAPSHOT</version><dependencies><dependency><groupId>djh.it</groupId><artifactId>springboot-dubbo-interface</artifactId><version>1.0-SNAPSHOT</version></dependency></dependencies></project>
<!-- D:\Java\java-test\idea\springboot-dubbo-provider\pom.xml -->5、打开 idea 创建 springboot-dubbo-consumer 项目，并在项目 pom.xml 中添加 接口工程 依赖。
--> idea --> File --> New --> Project --> Maven Project SDK: ( 1.8(java version "1.8.0_131" ) --> Next --> Groupld : ( djh.it )Artifactld : ( springboot-dubbo-consumer )Version : 1.0-SNAPSHOT--> Name: ( springboot-dubbo-consumer )Location: ( ...\springboot-dubbo-consumer\ ) --> Finish
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>djh.it</groupId><artifactId>springboot-dubbo-consumer</artifactId><version>1.0-SNAPSHOT</version><dependencies><dependency><groupId>djh.it</groupId><artifactId>springboot-dubbo-interface</artifactId><version>1.0-SNAPSHOT</version></dependency></dependencies></project>
<!-- D:\Java\java-test\idea\springboot-dubbo-consumer\pom.xml -->四、SpringBoot 整合 Dubbo ：dubbo 服务提供方
1、打开 springboot-dubbo-provider 项目 pom.xml 完善 依赖。
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>djh.it</groupId><artifactId>springboot-dubbo-provider</artifactId><version>1.0-SNAPSHOT</version><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.0.1.RELEASE</version></parent><dependencies><dependency><groupId>djh.it</groupId><artifactId>springboot-dubbo-interface</artifactId><version>1.0-SNAPSHOT</version></dependency><!-- dubbo --><dependency><groupId>com.alibaba.spring.boot</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.0.0</version></dependency><!-- spring-boot-stater --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId><exclusions><exclusion><artifactId>log4j-to-slf4j</artifactId><groupId>org.apache.logging.log4j</groupId></exclusion></exclusions></dependency><!-- zookeeper --><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.4.10</version><!-- 依赖排除，避免多个日志冲突 --><exclusions><exclusion><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId></exclusion><exclusion><groupId>log4j</groupId><artifactId>log4j</artifactId></exclusion></exclusions></dependency><!-- zkclieng --><dependency><groupId>com.101tec</groupId><artifactId>zkclient</artifactId><version>0.9</version><exclusions><exclusion><artifactId>slf4j-log4j12</artifactId><groupId>org.slf4j</groupId></exclusion></exclusions></dependency></dependencies>
</project>
<!-- D:\Java\java-test\idea\springboot-dubbo-provider\pom.xml -->2、在 springboot-dubbo-provider 项目中，创建 配置文件 application.properties
## D:\Java\java-test\idea\springboot-dubbo-provider\src\main\resources\application.propertiesspring.application.name=dubbo-demo-provider
spring.dubbo.application.id=dubbo-demo-provider
spring.dubbo.application.name=dubbo-demo-provider
# spring.dubbo.registry.address=zookeeper://192.168.25.140:2181;zookeeper://192.168.25.140:2182;zookeeper://192.168.25.140:2183
spring.dubbo.registry.address=zookeeper://172.18.30.110:2181;zookeeper://172.18.30.110:2182;zookeeper://172.18.30.110:2183spring.dubbo.server=true
spring.dubbo.protocol.name=dubbo
spring.dubbo.protocol.port=208803、在 springboot-dubbo-provider 项目中，创建 启动类 ProviderApplication.java
/*** springboot-dubbo-provider\src\main\java\djh\it\shop\springboot\dubbo\ProviderApplication.java** 2024-6-4 创建 启动类 ProviderApplication.java*/package djh.it.shop.springboot.dubbo;import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
@EnableDubboConfiguration
public class ProviderApplication {public static void main(String[] args) {SpringApplication.run(ProviderApplication.class, args);}
}4、在 springboot-dubbo-provider 项目中，创建 接口服务实现类 UserServiceImpl.java 。
/*** springboot-dubbo-provider\src\main\java\djh\it\shop\springboot\dubbo\service\impl\UserServiceImpl.java** 2024-6-4 创建 接口服务实现类 UserServiceImpl.java*/package djh.it.shop.springboot.dubbo.service.impl;import com.alibaba.dubbo.config.annotation.Service;
import djh.it.shop.service.IUseService;
import org.springframework.stereotype.Component;@Component
@Service(interfaceClass = IUseService.class)
public class UserServiceImpl implements IUseService {@Overridepublic String sayHello(String name) {return "hello: " + name;}
}五、SpringBoot 整合 Dubbo ：dubbo-admin 管理平台搭建
1、下载并上传 tomcat 到服务器上。
# 切换目录
cd /usr/local/zookeeper/ # 上传 tomcat : apache-tomcat-7.0.52.tar.gz 2、解压 tomcat
# 切换目录
cd /usr/local/zookeeper/ # 解压 tomcat
tar -zvxf apache-tomcat-7.0.52.tar.gz3、下载并上传 dubbo.war 到服务器上。
# 切换目录
cd /usr/local/zookeeper/apache-tomcat-7.0.52/webapps/# 上传 dubbo.war : dubbo-admin.war4、启动 tomcat
# 切换目录
cd /usr/local/zookeeper/apache-tomcat-7.0.52/bin/# 启动 tomcat
./startup.sh # 查看启动日志
tail -f ../logs/catalina.log 5、访问 dubbo 控制台。默认用户名、密码：root
浏览器地址栏输入：、http://虚拟机IP:8080/项目名
如：http://192.168.25.140:8080/dubbo-admin
六、SpringBoot 整合 Dubbo ：dubbo 服务消费方
1、打开 springboot-dubbo-consumer 项目 pom.xml 完善 依赖。
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion><groupId>djh.it</groupId><artifactId>springboot-dubbo-consumer</artifactId><version>1.0-SNAPSHOT</version><parent><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-parent</artifactId><version>2.0.1.RELEASE</version></parent><dependencies><dependency><groupId>djh.it</groupId><artifactId>springboot-dubbo-interface</artifactId><version>1.0-SNAPSHOT</version></dependency><!-- web --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><!-- dubbo --><dependency><groupId>com.alibaba.spring.boot</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.0.0</version></dependency><!-- spring-boot-stater --><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId><exclusions><exclusion><artifactId>log4j-to-slf4j</artifactId><groupId>org.apache.logging.log4j</groupId></exclusion></exclusions></dependency><!-- zookeeper --><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.4.10</version><!-- 依赖排除，避免多个日志冲突 --><exclusions><exclusion><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId></exclusion><exclusion><groupId>log4j</groupId><artifactId>log4j</artifactId></exclusion></exclusions></dependency><!-- zkclieng --><dependency><groupId>com.101tec</groupId><artifactId>zkclient</artifactId><version>0.9</version><exclusions><exclusion><artifactId>slf4j-log4j12</artifactId><groupId>org.slf4j</groupId></exclusion></exclusions></dependency></dependencies>
</project>
<!-- D:\Java\java-test\idea\springboot-dubbo-consumer\pom.xml -->2、在 springboot-dubbo-consumer 项目中，创建 配置文件 application.properties 。
## springboot-dubbo-consumer\src\main\resources\application.propertiesspring.application.name=dubbo-demo-consumer
spring.dubbo.application.id=dubbo-demo-consumer
spring.dubbo.application.name=dubbo-demo-consumer
spring.dubbo.registry.address=zookeeper://192.168.25.140:2181;zookeeper://192.168.25.140:2182;zookeeper://192.168.25.140:21833、在 springboot-dubbo-consumer 项目中，创建 启动类 ConsumerApplication.java 。
/*** springboot-dubbo-consumer\src\main\java\djh\it\shop\springboot\dubbo\ConsumerApplication.java** 2024-6-4 创建 启动类 ConsumerApplication.java*/package djh.it.shop.springboot.dubbo;import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
@EnableDubboConfiguration
public class ConsumerApplication {public static void main(String[] args) {SpringApplication.run(ConsumerApplication.class, args);}
}4、在 springboot-dubbo-consumer 项目中，创建 调用服务 的 Controller 类 UserController.java
/*** D:\Java\java-test\idea\springboot-dubbo-consumer\src\main\java\djh\it\shop\springboot\dubbo\controller\UserController.java** 2024-6-4 创建 调用服务 的 Controller 类 UserController.java*/package djh.it.shop.springboot.dubbo.controller;import com.alibaba.dubbo.config.annotation.Reference;
import djh.it.shop.service.IUseService;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;@RestController
@RequestMapping("/user")
public class UserController {@Reference //这里不能使用 @Autowired 注解，因为是RPC远程调用，要使用 dubbo 注解 @Referenceprivate IUseService useService;@RequestMapping("/sayHello")public String sayHello(String name){return useService.sayHello(name);}
}5、启动，测试 访问 dubbo 控制台。默认用户名、密码：root
1）dubbo 控制台出现 消费者服务。
2）浏览器地址栏输入：、http://虚拟机IP:8080/类名映射/方法名映射?参数=参数值
如：http://192.168.25.140:8080/user/sayHello?name=zs
http://localhost:8080/user/sayHello?name=张三丰
上一节关联链接请点击：
# RocketMQ 实战：模拟电商网站场景综合案例（一）
