创建服务接口模块

接口工程只提供接口，不提供实现，在后面的提供者和消费者中使用

在使用接口的模块中只需要写具体实现类，避免了在每个模块中重复编写接口

在接口中引入依赖包

     org.projectlombok      lombok      true    

创建一个实体类,一定要实现Serializable接口，否则dubbo协议之间无法传输

@Data@AllArgsConstructorpublic class User implements Serializable {  private String name;}

创建接口

public interface UserService {  List getAll();  List getAll2();}

创建服务提供者

引入依赖

         com.yls      common-api      1.0-SNAPSHOT                  org.springframework.boot      spring-boot-starter                  com.alibaba.boot      dubbo-spring-boot-starter      0.2.0    

修改配置文件

#服务名称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

实现服务接口

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

启动服务

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

创建消费者

引入依赖

         org.springframework.boot      spring-boot-starter-web                  com.alibaba.boot      dubbo-spring-boot-starter      0.2.0                  com.yls      common-api      1.0-SNAPSHOT    

修改配置文件

#注册中心dubbo.registry.address=39.97.234.52:2181,39.97.234.52:2182,39.97.234.52:2183dubbo.registry.protocol=zookeeper#dubbo应用名称dubbo.application.name=consumer1

实现消费接口

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

创建controller

@Controllerpublic class OrderController {  @Autowired  private OrderService orderService;  @ResponseBody  @RequestMapping("/init")  public List init() {    return orderService.init();  }}

启动服务消费者

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

dubbo相关补充

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

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