1.在前面帖子和工程的基础上,这里使用springboot整合dubbo,首先创建springboot项目:
https://start.spring.io/ 进入spring Initializr ,创建服务提供者以及消费者的 springboot项目:
下载后保存到本机,然后解压,导入到eclipse里,并修改包名,把原来的接口的实现类复制过来,然后在pom文件中添加公共接口的依赖:
服务消费者工程同理:将OrderServiceImpl.java拷贝到springboot项目中
2.修改orderService接口(test-interface工程中)及实现类(boot-order-service-consumer工程中)的返回值为List<UserAddress>
在boot-order-service-consumer工程中创建一个controller,并在pom文件引入sprongboot web模块的依赖:
编写测试用的controller:
package com.lch.test.controller; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody; import com.lch.test.service.OrderService; @Controller
public class OrderController { @Autowired
private OrderService orderService; @RequestMapping("/initorder")
@ResponseBody
public Object initOrder(@RequestParam("uid") String userId) {
System.out.println("用户id=" + userId);
return orderService.initOrder(userId); } }
然后引入dubbo依赖:dubbo-spring-boot-starter,这时boot-user-service-provider工程的pom文件内容如下:蓝色部分是额外引入的依赖
<?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>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.1.6.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.lch.test</groupId>
<artifactId>boot-user-service-provider</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>boot-user-service-provider</name>
<description>Demo project for Spring Boot</description> <properties>
<java.version>1.8</java.version>
</properties> <dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
</dependency> <!-- springboot2.0版本以上,使用dubbo-spring-boot-starter 2.0.0及以上版本
默认会把curator-client也导入到工程中
参考https://github.com/apache/dubbo-spring-boot-project -->
<dependency>
31 <groupId>com.alibaba.boot</groupId>
32 <artifactId>dubbo-spring-boot-starter</artifactId>
33 <version>0.2.0</version>
34 </dependency> <dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<!-- 添加公共接口的依赖 -->
42 <dependency>
43 <groupId>com.lch.test</groupId>
44 <artifactId>test-interface</artifactId>
45 <version>0.0.1-SNAPSHOT</version>
46 </dependency>
</dependencies> <build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build> </project>
添加dubbo的配置文件:
1 #应用的名字
2 dubbo.application.name=user-service-provider
3 #dubbo注册中心的地址
4 dubbo.registry.address=127.0.0.1:2181
5 #dubbo注册中心使用的协议
6 dubbo.registry.protocol=zookeeper
7 # dubbo服务提供者与消费者通信使用的协议
8 dubbo.protocol.name=dubbo
9 # dubbo服务提供者与消费者通信的端口
10 dubbo.protocol.port=20880
11
12 # dubbo监控中心使用的协议:从注册中心自动发现
13 dubbo.monitor.protocol=registry
14 # 要暴露的服务 在需要暴露的服务(即接口的实现类)上面,加上dubbo的@Service注解即可!!!从而不用指定每个类来暴露服务
使用dubbo的@Service暴露服务:
在启动函数中开启基于注解的dubbo功能
接下来改造boot-order-service-consumer工程:
(1)配置文件修改:
1 #应用的名字
2 dubbo.application.name=order-service-consumer
3 #dubbo注册中心的地址
4 dubbo.registry.address=zookeeper://127.0.0.1:2181
5 #dubbo注册中心使用的协议
6 #dubbo.registry.protocol=zookeeper
7 # dubbo服务提供者与消费者通信使用的协议
8 dubbo.protocol.name=dubbo
9 # dubbo服务提供者与消费者通信的端口
10 dubbo.protocol.port=20880
11
12 # dubbo监控中心使用的协议:从注册中心自动发现
13 dubbo.monitor.protocol=registry
14 #使用dubbo的@Reference来调用远程服务
(2)使用dubbo的@Reference注解来调用远程服务:OrderServiceImpl类中@autowired注解替换成dubbo的@Reference注解即可!
package com.lch.test.service.impl; import java.util.List; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service; import com.alibaba.dubbo.config.annotation.Reference;
import com.lch.test.bean.UserAddress;
import com.lch.test.service.OrderService;
import com.lch.test.service.UserService; /**
* 1.将服务提供者注册到注册中心 2.让服务消费者去注册中心订阅服务提供者的服务地址
*
* @author
*/
@Service // 这里暂时使用spring的注解
public class OrderServiceImpl implements OrderService { /*
* 这里使用dubbo的@Reference注解来远程引用UserService的服务
*/
// @Autowired
@Reference
UserService userService; public List<UserAddress> initOrder(String userId) {
System.out.println("用户id=" + userId);
// 调用userService 获取用户收货地址
List<UserAddress> addressList = userService.getUserAddressList(userId);
addressList.forEach(address -> {
System.out.println(address);
});
return addressList;
} }
(3)主程序中启用dubbo注解
package com.lch.test; import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication; import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo; @EnableDubbo
@SpringBootApplication
public class BootOrderServiceConsumerApplication { public static void main(String[] args) {
SpringApplication.run(BootOrderServiceConsumerApplication.class, args);
} }
最后,开始测试:
(1)启动zookeeper
(2)启动boot-order-service-consumer ,boot-user-service-provider 的main程序
页面访问http://localhost:8080/initorder?uid=1 ,这时服务的消费者orderService就通过dubbo提供的RPC服务远程调用另外一个进程中的userService服务,返回页面一个地址列表
代码git地址:https://github.com/liuch0228/dubbo-learn.git