springboot怎么使用dubbo和zookeeper

小編給大家分享一下springboot怎么使用dubbo和zookeeper，希望大家閱讀完這篇文章之后都有所收獲，下面讓我們一起去探討吧！

創建服務接口模塊

接口工程只提供接口，不提供實現，在后面的提供者和消費者中使用

在使用接口的模塊中只需要寫具體實現類，避免了在每個模塊中重復編寫接口

在接口中引入依賴包

<dependency>      <groupId>org.projectlombok</groupId>      <artifactId>lombok</artifactId>      <optional>true</optional>    </dependency>

創建一個實體類,一定要實現Serializable接口，否則dubbo協議之間無法傳輸

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

創建接口

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

創建服務提供者

引入依賴

<!--引入創建的接口服務-->    <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>

修改配置文件

#服務名稱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<User> getAll() {    User user1 = new User("張三");    User user2 = new User("lisi");    List<User> 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);  }}

創建消費者

引入依賴

<!--消費者是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>

修改配置文件

#注冊中心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<User> init() {    List<User> 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<User> 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;

看完了這篇文章，相信你對“springboot怎么使用dubbo和zookeeper”有了一定的了解，如果想了解更多相關知識，歡迎關注億速云行業資訊頻道，感謝各位的閱讀！