欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

springboot使用dubbo和zookeeper代碼實例

 更新時間:2019年11月19日 09:25:26   作者:她的開呀  
這篇文章主要介紹了springboot使用dubbo和zookeeper代碼實例,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下

這篇文章主要介紹了springboot使用dubbo和zookeeper代碼實例,文中通過示例代碼介紹的非常詳細,對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下

創(chuàng)建服務(wù)接口模塊

接口工程只提供接口,不提供實現(xiàn),在后面的提供者和消費者中使用

在使用接口的模塊中只需要寫具體實現(xiàn)類,避免了在每個模塊中重復(fù)編寫接口

在接口中引入依賴包

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

創(chuàng)建一個實體類,一定要實現(xiàn)Serializable接口,否則dubbo協(xié)議之間無法傳輸

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

創(chuàng)建接口

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

創(chuàng)建服務(wù)提供者

引入依賴

    <!--引入創(chuàng)建的接口服務(wù)-->
    <dependency>
      <groupId>com.yls</groupId>
      <artifactId>common-api</artifactId>
      <version>1.0-SNAPSHOT</version>
    </dependency>
    <!--由于服務(wù)提供者不是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>

修改配置文件

#服務(wù)名稱
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
#協(xié)議名稱
dubbo.protocol.name=dubbo
#服務(wù)暴露端口
dubbo.protocol.port=20880

實現(xiàn)服務(wù)接口

//暴露服務(wù)
//這里的@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;
  }
}

啟動服務(wù)

//@EnableDubbo等價于在配置文件中配置dubbo.scan.base-packages
//掃描實現(xiàn)類所在的包,注冊Bean
@EnableDubbo
@SpringBootApplication
public class ProviderApplication {

  public static void main(String[] args) {

    SpringApplication.run(ProviderApplication.class,args);
  }
}

創(chuàng)建消費者

引入依賴

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

    <!--引入創(chuàng)建的接口服務(wù)-->
    <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:2183
dubbo.registry.protocol=zookeeper
#dubbo應(yīng)用名稱
dubbo.application.name=consumer1

實現(xiàn)消費接口

//服務(wù)消費者的Service是spring的
@Service
public class OrderImpl implements OrderService {

  //使用dubbo提供的@Reference訪問遠程服務(wù)
  //version對應(yīng)服務(wù)提供者的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;
  }
}

創(chuàng)建controller

@Controller
public class OrderController {

  @Autowired
  private OrderService orderService;

  @ResponseBody
  @RequestMapping("/init")
  public List<User> init() {
    return orderService.init();
  }
}

啟動服務(wù)消費者

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

dubbo相關(guān)補充

dubbo使用本地緩存方式,如果注冊中心全部宕機,dubbo也能正常工作,就算沒有注冊中心,dubbo也能通過dubbo直連通信

//使用dubbo提供的@Reference訪問遠程服務(wù)
  //version對應(yīng)服務(wù)提供者的version
  //url:如果沒有注冊中心,可以通過url配置服務(wù)提供者的dubbo協(xié)議端口,進行dubbo直連
  @Reference(version = "3",url ="127.0.0.1:20880" )
  private UserService userService;

以上就是本文的全部內(nèi)容,希望對大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。

相關(guān)文章

  • Java中解密微信加密數(shù)據(jù)工具類

    Java中解密微信加密數(shù)據(jù)工具類

    最近小編一直在開發(fā)微信公眾號、小程序項目,微信返回給我們的數(shù)據(jù)都是加密的,我們需要使用sessionkey配合解密,才能看到我們想要的數(shù)據(jù),基于代碼怎么實現(xiàn)呢,下面小編給大家?guī)砹薐ava中解密微信加密數(shù)據(jù)工具類的完整代碼,一起看看吧
    2021-06-06
  • 深度理解SpringMVC中的HandlerMapping

    深度理解SpringMVC中的HandlerMapping

    這篇文章主要介紹了深度理解SpringMVC中的HandlerMapping,HandlerMapping的作用根據(jù)request找到對應(yīng)的處理器Handler,在HandlerMapping接口中有一個唯一的方法getHanler,需要的朋友可以參考下
    2023-09-09
  • SpringBoot?Webflux創(chuàng)建TCP/UDP?server并使用handler解析數(shù)據(jù)

    SpringBoot?Webflux創(chuàng)建TCP/UDP?server并使用handler解析數(shù)據(jù)

    這篇文章主要介紹了SpringBoot?Webflux創(chuàng)建TCP/UDP?server并使用handler解析數(shù)據(jù),具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2022-02-02
  • java編程實現(xiàn)兩個大數(shù)相加代碼示例

    java編程實現(xiàn)兩個大數(shù)相加代碼示例

    這篇文章主要介紹了java編程實現(xiàn)兩個大數(shù)相加代碼示例,具有一定參考價值,需要的朋友可以了解下。
    2017-12-12
  • Spring事務(wù)的傳播行為解析

    Spring事務(wù)的傳播行為解析

    這篇文章主要介紹了Spring事務(wù)的傳播行為解析,事務(wù)傳播行為(propagation?behavior)指的就是當一個事務(wù)方法被另一個事務(wù)方法調(diào)用時,這個事務(wù)方法應(yīng)該如何運行,需要的朋友可以參考下
    2023-10-10
  • Java中防止數(shù)據(jù)重復(fù)提交超簡單的6種方法

    Java中防止數(shù)據(jù)重復(fù)提交超簡單的6種方法

    在平時開發(fā)中,如果網(wǎng)速比較慢的情況下,用戶提交表單后,發(fā)現(xiàn)服務(wù)器半天都沒有響應(yīng),那么用戶可能會以為是自己沒有提交表單,就會再點擊提交按鈕重復(fù)提交表單,這篇文章主要給大家介紹了關(guān)于Java中防止數(shù)據(jù)重復(fù)提交超簡單的6種方法,需要的朋友可以參考下
    2021-11-11
  • Java設(shè)計模式之策略模式詳細解析

    Java設(shè)計模式之策略模式詳細解析

    這篇文章主要介紹了Java設(shè)計模式之策略模式詳細解析,策略模式中,定義算法族,分別封裝起來,讓他們之間可以相互轉(zhuǎn)化,此模式讓算法的變化獨立于使用算法的客戶,需要的朋友可以參考下
    2023-11-11
  • spring?security?自定義Provider?如何實現(xiàn)多種認證

    spring?security?自定義Provider?如何實現(xiàn)多種認證

    這篇文章主要介紹了spring?security?自定義Provider實現(xiàn)多種認證方式,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教
    2021-12-12
  • Mybatis下的SQL注入漏洞原理及防護方法解析

    Mybatis下的SQL注入漏洞原理及防護方法解析

    SQL 注入是發(fā)生在 Web 程序中數(shù)據(jù)庫層的安全漏洞,是網(wǎng)站存在最多也是最簡單的漏洞,在實際項目中,即使使用了 Mybatis 框架,但仍然有可能因為編碼人員安全意識不足而導(dǎo)致 SQL 注入問題,這篇文章主要介紹了Mybatis下的SQL注入漏洞原理及防護方法?,需要的朋友可以參考下
    2022-11-11
  • 解決@Around對靜態(tài)方法不生效的問題

    解決@Around對靜態(tài)方法不生效的問題

    這篇文章主要介紹了解決@Around對靜態(tài)方法不生效的問題,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2021-02-02

最新評論