SpringBoot + Dubbo + zookeeper整合

• 狂神说
• 1. 创建项目
• • 1.1 创建一个模块，实现服务提供者：provider-server
  • • 1.1.1 添加依赖
    • 1.1.2 在springboot配置文件中配置dubbo相关属性！
    • 1.1.3 编写服务提供者类添加功能
  • 1.2 创建一个模块，实现服务消费者：consumer-server
  • • 1.2.1 导入依赖
    • 1.2.2 配置参数
    • 1.2.3 编写服务消费者类
  • 1.3 测试

https://mp.weixin.qq.com/s?__biz=Mzg2NTAzMTExNg==&mid=2247483947&idx=1&sn=0c8efabbaf9b8ca835d862e6e0a2254f&scene=19#wechat_redirect

创建一个空项目

dubbo-springboot

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

zookeeper

   com.github.sgroschupf
   zkclient
   0.1

【新版的坑】zookeeper及其依赖包，解决日志冲突，还需要剔除日志依赖；

   org.apache.curator
   curator-framework
   2.12.0


   org.apache.curator
   curator-recipes
   2.12.0


   org.apache.zookeeper
   zookeeper
   3.4.14
   
   
       
           org.slf4j
           slf4j-log4j12
       
   

#当前应用名字
dubbo.application.name=provider-server
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181
#扫描指定包下服务
dubbo.scan.base-packages=com.kuang.provider.service

编写接口

package com.kuang.provider.service;

public interface TicketService {
   public String getTicket();
}

编写实现类

import org.apache.dubbo.config.annotation.Service;
import org.springframework.stereotype.Component;

@Service //将服务发布出去
@Component //放在容器中
public class TicketServiceImpl implements TicketService {
   @Override
   public String getTicket() {
       return "《Java》";
  }
}

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




   com.github.sgroschupf
   zkclient
   0.1



   org.apache.curator
   curator-framework
   2.12.0


   org.apache.curator
   curator-recipes
   2.12.0


   org.apache.zookeeper
   zookeeper
   3.4.14
   
   
       
           org.slf4j
           slf4j-log4j12
       
   

#当前应用名字
dubbo.application.name=consumer-server
#注册中心地址
dubbo.registry.address=zookeeper://127.0.0.1:2181

正常步骤是需要将服务提供者的接口打包，然后用pom文件导入，我们这里使用简单的方式，直接将服务的接口拿过来，路径必须保证正确，即和服务提供者相同；

编写service

package com.kuang.consumer.service;

import com.kuang.provider.service.TicketService;
import org.apache.dubbo.config.annotation.Reference;
import org.springframework.stereotype.Service;

@Service //注入到容器中
public class UserService {

   @Reference //远程引用指定的服务，他会按照全类名进行匹配，看谁给注册中心注册了这个全类名
   TicketService ticketService;

   public void bugTicket(){
       String ticket = ticketService.getTicket();
       System.out.println("在注册中心买到"+ticket);
  }

}

开启zookeeper

@RunWith(SpringRunner.class)
@SpringBootTest
public class ConsumerServerApplicationTests {

   @Autowired
   UserService userService;

   @Test
   public void contextLoads() {

       userService.bugTicket();

  }

}