Dubbo目录
文章目录
六、Dubbo与SpringBoot整合
6.1、项目结构6.2、项目搭建
6.2.1、导入依赖6.2.2、boot-user-service-provider模块修改6.2.3、boot-order-service-consumer模块修改6.2.3、测试6.2.4、总结
六、Dubbo与SpringBoot整合 6.1、项目结构
和之前的四、dubbo-helloworld基本是一样的，只不过provider、consumer是SpringBoot项目，
api-interface：公共接口层
boot-order-service-consumer：订单模块（调用用户模块）
boot-user-service-provider：用户模块（对用户接口的实现）
boot-order-service-consumer、boot-user-service-provider模块都需要依赖api-interface模块
6.2、项目搭建 6.2.1、导入依赖com.alibaba.boot dubbo-spring-boot-starter 0.2.0
注意starter版本适配：
注意springboot的版本，这里用的是比较老的：2.0.4.RELEASE。新版的，有很多错误
6.2.2、boot-user-service-provider模块修改pom.xml:
4.0.0 org.springframework.boot spring-boot-starter-parent 2.0.4.RELEASE com.wlw.dubbo boot-user-service-provider 0.0.1-SNAPSHOT boot-user-service-provider Demo project for Spring Boot 1.8 com.wlw.dubbo api-interface 1.0-SNAPSHOT com.alibaba.boot dubbo-spring-boot-starter 0.2.0 org.springframework.boot spring-boot-starter-web org.springframework.boot spring-boot-starter-test test org.springframework.boot spring-boot-maven-plugin
application.properties配置文件：
server.port=8082 dubbo.application.name=boot-user-service-provider dubbo.registry.protocol=zookeeper dubbo.registry.address=127.0.0.1:2181 #通信协议 dubbo.protocol.name=dubbo dubbo.protocol.port=20880 #监控中心 dubbo.monitor.protocol=registry dubbo.scan.base-packages=com.wlw.dubbo.service
暴漏服务:
package com.wlw.dubbo.service.impl;
import com.alibaba.dubbo.config.annotation.Service;
import com.wlw.dubbo.bean.UserAddress;
import com.wlw.dubbo.service.UserService;
import org.springframework.stereotype.Component;
import java.util.Arrays;
import java.util.List;
@Service //此注解作用是暴漏服务，之前是在配置文件中配置暴漏哪个服务
@Component
public class UserServiceImpl implements UserService {
@Override
public List getUserAddressList(String userId) {
System.out.println("UserServiceImpl........");
UserAddress address1 = new UserAddress(1, "北京市昌平区宏福科技园综合楼3层", "1", "李老师", "010-56253825", "Y");
UserAddress address2 = new UserAddress(2, "深圳市宝安区西部大厦B座3层", "1", "王老师", "010-56253825", "N");
return Arrays.asList(address1,address2);
}
}
开启Dubbo：
package com.wlw.dubbo;
import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@EnableDubbo//开启基于注解的Dubbo功能
@SpringBootApplication
public class BootUserServiceProviderApplication {
public static void main(String[] args) {
SpringApplication.run(BootUserServiceProviderApplication.class, args);
}
}
6.2.3、boot-order-service-consumer模块修改
application.properties配置文件：
server.port=8084 dubbo.application.name=boot-order-service-consumer dubbo.registry.protocol=zookeeper dubbo.registry.address=127.0.0.1:2181 #监控中心 dubbo.monitor.protocol = registry dubbo.scan.base-packages = com.wlw.dubbo.service
远程引用指定的服务:
package com.wlw.dubbo.service.impl;
import com.alibaba.dubbo.config.annotation.Reference;
import com.wlw.dubbo.bean.UserAddress;
import com.wlw.dubbo.service.OrderService;
import com.wlw.dubbo.service.UserService;
import org.springframework.stereotype.Service;
import java.util.List;
@Service
public class OrderServiceImpl implements OrderService {
//@Autowired
@Reference //远程引用指定的服务，他会按照全类名进行匹配，看谁给注册中心注册了这个全类名
UserService userService;
@Override
public List initOrder(String userId) {
System.out.println("用户id："+userId);
//1、查询用户的收货地址
List addressList = userService.getUserAddressList(userId);
return addressList;
}
}
controller:
package com.wlw.dubbo.controller;
import java.util.List;
import com.wlw.dubbo.bean.UserAddress;
import com.wlw.dubbo.service.OrderService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
@RestController
public class OrderController {
@Autowired
OrderService orderService;
@GetMapping("/initOrder")
public List initOrder(@RequestParam("uid")String userId) {
System.out.println("consumer-调用方法");
return orderService.initOrder(userId);
}
}
启动类：
package com.wlw.dubbo;
import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@EnableDubbo //开启基于注解的Dubbo功能
@SpringBootApplication
public class BootOrderServiceConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(BootOrderServiceConsumerApplication.class, args);
}
}
6.2.3、测试
启动提供者，启动消费者，在浏览器中输入：localhost:8084/initOrder?uid=1 ，就可看到相应的输出，监控平台也有相应的展示。
6.2.4、总结详细代码：wlw/dubboDemo (gitee.com)
过程总结：
开启zookeeper服务（怎么开启：可参考：三、Dubbo环境搭建）
提供者:
导入依赖添加配置暴漏服务：通过注解(com.alibaba.dubbo.config.annotation.Service) 来实现启动类开启Dubbo，注解：@EnableDubbo 消费者：
导入依赖添加配置远程引用指定的服务，注解：com.alibaba.dubbo.config.annotation.Reference;启动类开启Dubbo，注解：@EnableDubbo
