- 1、父工程
- 2、公用RPC接口工程
- 3、服务端工程
- 4、消费端工程
- 工程调用验证
基于Zookeeper实现Dubbo与Spring Boot的集成整合。
zk已经在服务器部署并且运行起来了
项目结构：
父工程我们只需要创建一个maven项目。并且保留pom.xml即可。
以下是它的xml文件：
2、公用RPC接口工程4.0.0 com.itheima dubbo-spring 1.0-SNAPSHOT spring-dubbo-interface spring-dubbo-provider spring-dubbo-consumer pom 8 8 2.7.8 2.3.0.RELEASE org.springframework.boot spring-boot-dependencies ${spring-boot.version} pom import org.apache.dubbo dubbo-dependencies-bom ${dubbo-version} pom import org.apache.dubbo dubbo ${dubbo-version} org.springframework spring javax.servlet servlet-api log4j log4j org.apache.dubbo dubbo-spring-boot-starter ${dubbo-version} org.apache.dubbo dubbo org.springframework.boot spring-boot-starter-web ${spring-boot.version} org.apache.curator curator-framework 4.0.1 org.apache.dubbo dubbo-dependencies-zookeeper ${dubbo-version} pom org.slf4j slf4j-log4j12
为便于客户端与服务端的RPC接口引用， 这里对RPC接口做统一封装。
定义了一个订单服务接口， 用于测试验证
该项目只需要创建一个maven工程，并且创建一个接口：
OrderService：
package com.itheima.dubbo.spring.api;
public interface OrderService {
String getOrder(Long orderId);
}
3、服务端工程
首先来看一下工程结构：
我们只需要创建一个springBoot项目，然后修改以下几点：
①POM依赖：
dubbo-spring com.itheima 1.0-SNAPSHOT 4.0.0 spring-dubbo-provider 8 8 org.apache.dubbo dubbo-spring-boot-starter ${dubbo-version} org.apache.dubbo dubbo com.itheima spring-dubbo-interface ${project.version}
②实现RPC服务接口：
OrderServiceImpl:
package com.itheima.dubbo.spring.provider.service;
import com.itheima.dubbo.spring.api.OrderService;
import org.apache.dubbo.config.annotation.DubboService;
import org.apache.dubbo.config.annotation.Method;
import org.springframework.beans.factory.annotation.Value;
import java.util.concurrent.TimeUnit;
//通过DubboService注解， 声明为RPC服务，version可以标识具体的版本号， 消费端需匹配保持一致。
@DubboService(version = "${dubbo.spring.provider.version}")
public class OrderServiceImpl implements OrderService {
@Value("${server.port}")
private String serverPort;
public String getOrder(Long orderId) {
return "Get Order Detail, Id: " + orderId + ", serverPort: " + serverPort;
}
}
③配置文件：
application.properties：
# 服务端口
server.port=18081
# 应用程序名称
spring.application.name=spring-dubbo-provider
# Dubbo服务扫描路径
dubbo.scan.base-packages=com.itheima
# Dubbo 通讯协议
dubbo.protocol.name=dubbo
# Dubbo服务提供的端口， 配置为-1，代表为随机端口
dubbo.protocol.port=-1
#dubbo.protocol.port=28801
## Dubbo 注册器配置信息
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.registry.file = ${user.home}/dubbo-cache/${spring.application.name}/dubbo.cache
dubbo.spring.provider.version = 1.0.0
#配置连接时间
dubbo.registry.timeout=20000
④启动类：
@SpringBootApplication
@ComponentScan(basePackages = {"com.itheima"})
public class DubboSpringProviderApplication {
public static void main(String[] args) {
SpringApplication.run(DubboSpringProviderApplication.class, args);
}
}
4、消费端工程
工程结构：
我们也只需要创建一个spring Boot项目即可。需要修改以下几处：
①pom.xml
dubbo-spring com.itheima 1.0-SNAPSHOT 4.0.0 spring-dubbo-consumer 8 8 org.apache.dubbo dubbo-spring-boot-starter ${dubbo-version} com.itheima spring-dubbo-interface ${project.version}
②消费端调用：
OrderController
package com.itheima.dubbo.spring.consumer.controller;
import com.itheima.dubbo.spring.api.OrderService;
import org.apache.dubbo.config.annotation.DubboReference;
import org.apache.dubbo.config.annotation.Method;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
@Controller
public class OrderController {
private final Logger logger = LoggerFactory.getLogger(getClass());
@DubboReference(version = "${dubbo.spring.provider.version}")
private OrderService orderService;
@RequestMapping("/getOrder")
@ResponseBody
public String getOrder(Long orderId) {
String result = orderService.getOrder(orderId);
return result;
}
}
③配置文件：
application.properties
# 服务端口
server.port=18082
#服务名称
spring.application.name=spring-dubbo-consumer
#服务版本号
dubbo.spring.provider.version = 1.0.0
#消费端注册器配置信息
dubbo.registry.address=zookeeper://127.0.0.1:2181
dubbo.registry.file = ${user.home}/dubbo-cache/${spring.application.name}/dubbo.cache
#配置连接时间
dubbo.registry.timeout=20000
④主启动类：
@SpringBootApplication
@ComponentScan(basePackages = {"com.itheima"})
public class DubboSpringConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(DubboSpringConsumerApplication.class, args);
}
}
工程调用验证
- 启动zk
- 启动服务端， 运行DubboSpringProviderApplication
- 启动消费端， 运行DubboSpringConsumerApplication
- 访问http://127.0.0.1:18082/getOrder?orderId=1001 ，出现以下图片证明调用成功。
