dubbo springboot,踩到的坑,主要是版本问题,springboot的版本为2.2.5release,可以用,否则,报类找不到的错误

如题,废了很大的劲,从2.6.1开始,往下找,直到springboot为2.2.5release,dubbo的消费者,才连上。

 

首先 是建立接口,一般是建立bean的domain,然后在里面提供至少2个接口,分别被消费者consumer和提供者provider使用

 

然后建立提供者,在pom里引用domain,然后

<!-- add by xuyong -->
        <dependency>
            <groupId>cn.taotao</groupId>
            <artifactId>User</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>

        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.5</version>
        </dependency>
        <!-- 使用zk 做注册中心,Dubbo 需要的依赖 -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-dependencies-zookeeper</artifactId>
            <version>2.7.5</version>
            <type>pom</type>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

然后建立application.yml 文件

dubbo:
  #声明注册到zk的名字 应该程序的名称
  application:
    name: taotao-provider
  #声明注册中心的地址和方式
  registry:
    address: zookeeper://www.yiwiki.com:2181
  #使用dubbo协议,将服务暴露在20880端口
  protocol:
    name: dubbo
    port: 20881

并实现上面的一个接口

package cn.taotao.provider.service.impl;

import cn.taotao.domain.User;
import cn.taotao.service.UserService;
import org.apache.dubbo.config.annotation.Service;
import java.util.ArrayList;
import java.util.List;

@Service
public class UserServiceImpl implements UserService {


    public static List<User> users = new ArrayList<>();


    static {
        users.add(new User(1,"gaotang","xu"));
        users.add(new User(2,"qingping","guo"));
    }

    @Override
    public List<User> getAll() {
        return users;
    }

    @Override
    public User getOne(Integer id) {
        return new User(3,"gaxxx","xu");
    }
}

 

然后建立consumer,消费者

pom文件引用,引用超时熔断机制 netflix-hystrix

  <!--引入公共接口项目-->
        <dependency>
            <groupId>cn.taotao</groupId>
            <artifactId>User</artifactId>
            <version>0.0.1-SNAPSHOT</version>
        </dependency>

        <!-- Dubbo Spring Boot Starter -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>2.7.5</version>
        </dependency>
        <!-- 使用zk 做注册中心,Dubbo 需要的依赖 -->
        <dependency>
            <groupId>org.apache.dubbo</groupId>
            <artifactId>dubbo-dependencies-zookeeper</artifactId>
            <version>2.7.5</version>
            <type>pom</type>
            <exclusions>
                <exclusion>
                    <groupId>org.slf4j</groupId>
                    <artifactId>slf4j-log4j12</artifactId>
                </exclusion>
            </exclusions>
        </dependency>

        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-netflix-hystrix</artifactId>
            <version>2.2.1.RELEASE</version>
        </dependency>

yml的引用,这里不需要提供端口号

dubbo:
  #声明注册到zk的名字 应该程序的名称
  application:
    name: taotao-consumer
  registry:
    address: zookeeper://www.yiwiki.com:2181
#  consumer:
#    check: false
#    retries: 2

 

建立consumer的java实现其中的另一个接口,如OrderService 在这个里面远程调用 UserService,这里主要的坑,是好多springboot的版本有问题,我实验了几个,发现2.2.5release版本可用,

他报类无法找到,配置文件有问题,等等。好像是反射没有做好。

package cn.taotao.consumer.service.impl;

import cn.taotao.service.OrderService;
import cn.taotao.service.UserService;
import com.netflix.hystrix.contrib.javanica.annotation.HystrixCommand;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;


@Service
public class OrderServiceImpl implements OrderService {
    @Reference
    private  UserService userService;

    public void setUserService(UserService userService){
        this.userService=userService;
    }


    @Override
    @HystrixCommand(fallbackMethod = "error")
    public void orderinit() {
        System.out.println( this.userService.getOne(1));
    }
}

 

 然后在 dubbo admin里即可看到 consumer和provider了。

 

上一篇:vault安装-centos yum安装


下一篇:猪齿鱼的微服务之路(一):如何迈出关键的第一步