创建服务接口模块

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

1. 在接口中引入依赖包

        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </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>
        </dependency>
        <!--由于服务提供者不是web项目
        ，只需引入spring-boot-starter，不用引入spring-boot-starter-web-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
        </dependency>
        <!--dubbo-->
        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>0.2.0</version>
        </dependency>

2. 修改配置文件 ```java

   服务名称

   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. 实现服务接口
```java
//暴露服务
//这里的@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;
    }
}

1. 启动服务

   //@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>
        </dependency>
        <!--dubbo-->
        <dependency>
            <groupId>com.alibaba.boot</groupId>
            <artifactId>dubbo-spring-boot-starter</artifactId>
            <version>0.2.0</version>
        </dependency>
        <!--引入创建的接口服务-->
        <dependency>
            <groupId>com.yls</groupId>
            <artifactId>common-api</artifactId>
            <version>1.0-SNAPSHOT</version>
        </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;