springboot使用dubbo和zookeeper

软件发布|下载排行|最新软件

当前位置:首页IT学院IT技术

springboot使用dubbo和zookeeper

她的开呀   2019-11-18 我要评论

2019-11-17 yls

创建服务接口模块

接口工程只提供接口,不提供实现,在后面的提供者和消费者中使用
在使用接口的模块中只需要写具体实现类,避免了在每个模块中重复编写接口

  1. 在接口中引入依赖包

            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            <https://img.qb5200.com/download-x/dependency>
  2. 创建一个实体类,一定要实现Serializable接口,否则dubbo协议之间无法传输

    @Data
    @AllArgsConstructor
    public class User implements Serializable {
        private String name;
    }
  3. 创建接口

    
    public interface UserService {
        List<User> getAll();
        List<User> getAll2();
    }

创建服务提供者

  1. 引入依赖

            <!--引入创建的接口服务-->
            <dependency>
                <groupId>com.yls</groupId>
                <artifactId>common-api</artifactId>
                <version>1.0-SNAPSHOT</version>
            <https://img.qb5200.com/download-x/dependency>
            <!--由于服务提供者不是web项目
            ,只需引入spring-boot-starter,不用引入spring-boot-starter-web-->
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter</artifactId>
            <https://img.qb5200.com/download-x/dependency>
    
            <!--dubbo-->
            <dependency>
                <groupId>com.alibaba.boot</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
                <version>0.2.0</version>
            <https://img.qb5200.com/download-x/dependency>
  2. 修改配置文件

    #服务名称
    dubbo.application.name=provider1
    #注册中心地址
    dubbo.registry.address=39.97.234.52:2181,39.97.234.52:2182,39.97.234.52:2183
    #注册中心类型
    dubbo.registry.protocol=zookeeper
    
    #版本号
    dubbo.application.version=3
    # Dubbo Protocol
    #协议名称
    dubbo.protocol.name=dubbo
    #服务暴露端口
    dubbo.protocol.port=20880
  3. 实现服务接口

    //暴露服务
    //这里的@Service是Dubbo提供的,不是spring中的
    //version必填
    @Service(version = "${dubbo.application.version}")
    @Component
    public class UserImpl implements UserService {
        @Override
        public List<User> getAll() {
            User user1 = new User("张三");
            User user2 = new User("lisi");
            List<User> list = Arrays.asList(user1, user2);
            return list;
        }
    }
  4. 启动服务

    //@EnableDubbo等价于在配置文件中配置dubbo.scan.base-packages
    //扫描实现类所在的包,注册Bean
    @EnableDubbo
    @SpringBootApplication
    public class ProviderApplication {
    
        public static void main(String[] args) {
    
            SpringApplication.run(ProviderApplication.class,args);
        }
    }

创建消费者

  1. 引入依赖

    <!--消费者是web项目-->
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            <https://img.qb5200.com/download-x/dependency>
    
            <!--dubbo-->
            <dependency>
                <groupId>com.alibaba.boot</groupId>
                <artifactId>dubbo-spring-boot-starter</artifactId>
                <version>0.2.0</version>
            <https://img.qb5200.com/download-x/dependency>
    
            <!--引入创建的接口服务-->
            <dependency>
                <groupId>com.yls</groupId>
                <artifactId>common-api</artifactId>
                <version>1.0-SNAPSHOT</version>
            <https://img.qb5200.com/download-x/dependency>
  2. 修改配置文件

    #注册中心
    dubbo.registry.address=39.97.234.52:2181,39.97.234.52:2182,39.97.234.52:2183
    dubbo.registry.protocol=zookeeper
    #dubbo应用名称
    dubbo.application.name=consumer1
  3. 实现消费接口

    //服务消费者的Service是spring的
    @Service
    public class OrderImpl implements OrderService {
    
        //使用dubbo提供的@Reference访问远程服务
        //version对应服务提供者的version
        @Reference(version = "3")
        private UserService userService;
    
        @Override
        public List<User> init() {
            List<User> list = userService.getAll();
            list.forEach(item -> System.out.println(item.getName()));
            return list;
        }
    }
  4. 创建controller

    @Controller
    public class OrderController {
    
        @Autowired
        private OrderService orderService;
    
        @ResponseBody
        @RequestMapping("/init")
        public List<User> init() {
            return orderService.init();
        }
    }
    
  5. 启动服务消费者

    @EnableDubbo
    @SpringBootApplication
    public class ConsumerApplication {
        public static void main(String[] args) {
            SpringApplication.run(ConsumerApplication.class, args);
        }
    }

dubbo相关补充

  1. dubbo使用本地缓存方式,如果注册中心全部宕机,dubbo也能正常工作,就算没有注册中心,dubbo也能通过dubbo直连通信

    //使用dubbo提供的@Reference访问远程服务
        //version对应服务提供者的version
        //url:如果没有注册中心,可以通过url配置服务提供者的dubbo协议端口,进行dubbo直连
        @Reference(version = "3",url ="127.0.0.1:20880" )
        private UserService userService;

Copyright 2022 版权所有 软件发布 访问手机版

声明:所有软件和文章来自软件开发商或者作者 如有异议 请与本站联系 联系我们