springboot使用dubbo和zookeeper代碼實例
這篇文章主要介紹了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)文章
SpringBoot?Webflux創(chuàng)建TCP/UDP?server并使用handler解析數(shù)據(jù)
這篇文章主要介紹了SpringBoot?Webflux創(chuàng)建TCP/UDP?server并使用handler解析數(shù)據(jù),具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2022-02-02Java中防止數(shù)據(jù)重復(fù)提交超簡單的6種方法
在平時開發(fā)中,如果網(wǎng)速比較慢的情況下,用戶提交表單后,發(fā)現(xiàn)服務(wù)器半天都沒有響應(yīng),那么用戶可能會以為是自己沒有提交表單,就會再點擊提交按鈕重復(fù)提交表單,這篇文章主要給大家介紹了關(guān)于Java中防止數(shù)據(jù)重復(fù)提交超簡單的6種方法,需要的朋友可以參考下2021-11-11spring?security?自定義Provider?如何實現(xiàn)多種認證
這篇文章主要介紹了spring?security?自定義Provider實現(xiàn)多種認證方式,具有很好的參考價值,希望對大家有所幫助。如有錯誤或未考慮完全的地方,望不吝賜教2021-12-12