SpringBoot整合Dubbo

SpringBoot整合Dubbo SpringBoot整合Dubbo

1、启动Linux *** 作系统的zookeeper服务

[root@localhost bin]# ./zkServer.sh start ../conf/zoo.cfg

查看状态
[root@localhost bin]# ./zkServer.sh status ../conf/zoo.cfg
ZooKeeper JMX enabled by default
Using config: ../conf/zoo.cfg
Client port found: 2181. Client address: localhost. Client SSL: false.
Mode: standalone 单机版模式

2、创建工程
3、引入依赖

 
            org.apache.dubbo
            dubbo-spring-boot-starter
            2.7.8
        

        
        
        
            com.101tec
            zkclient
            0.10
        

4、创建子工程
5、编写配置文件
provider中的application.yml

server:
  port: 8080

spring:
  dubbo:
    application:
      name:  dubbo-provider
    registry:
      address: zookeeper://192.168.200.128
      port: 2181
    protocol:
      name: dubbo
      port: 20890
    scan: com.oracle.serviceImpl

Consumer中的application.yml

server:
  port: 8081

spring:
  dubbo:
    application:
      name: dubbo-consumer
    registry:
      address: zookeeper://192.168.200.128
      port: 2181
  scan: com.oracle.controller

Provider中的ServiceImpl:

import com.alibaba.dubbo.config.annotation.Service;

//@Service注解是dubbo的 ，不是spring框架的@Servic注解
//springboot没有xml 配置 如何实例化UserServiceImpl
@Service(version = "1.0.0",timeout = 3000)
public class UserServiceImpl implements UserService {

    @Override
    public User getUser(String uname, String password) {

            User user = new User();
            user.setUid(1);
            user.setUname("admin");
            user.setPassword("123123");

            //假设user是从数据库中查询出来的
            return user;
    }
}

Consumer中的Controller:

@RestController
public class UserController {

    //替换Autowired
    @Reference(version="1.0.0",timeout = 3000)
    private UserService userService;

    @RequestMapping("/getUser")
    public String getUser(){
        User user = userService.getUser("admin", "123");
        System.out.println(user);
        return "success";
    }
}