电脑知识|欧美黑人一区二区三区|软件|欧美黑人一级爽快片淫片高清|系统|欧美黑人狂野猛交老妇|数据库|服务器|编程开发|网络运营|知识问答|技术教程文章 - 好吧啦网

您的位置:首頁技術文章
文章詳情頁

SpringBoot系列教程之dubbo和Zookeeper集成方法

瀏覽:7日期:2023-04-27 17:43:31

今日學習新的內容:dubbo

  dubbo是阿里巴巴公司開源的一個高性能優秀的服務框架,一款高性能、輕量級的開源Java RPC框架,它提供了三大核心能力:面向接口的遠程方法調用,智能容錯和負載均衡,以及服務自動注冊和發現。

zookeeper

  zooKeeper是一個分布式的,開放源碼的分布式應用程序協調服務,它是一個為分布式應用提供一致性服務的軟件,提供的功能包括:配置維護、域名服務、分布式同步、組服務等。

SpringBoot整合dubbo和Zookeeper

1、了解Dubbo基本概念

SpringBoot系列教程之dubbo和Zookeeper集成方法服務提供者(Provider):暴露服務的服務提供方,服務提供者在啟動時,向注冊中心注冊自己提供的服務。服務消費者(Consumer):調用遠程服務的服務消費方,服務消費者在啟動時,向注冊中心訂閱自己所需的服務,服務消費者,從提供者地址列表中,基于軟負載均衡算法,選一臺提供者進行調用,如果調用失敗,再選另一臺調用。注冊中心(Registry)(中臺):注冊中心返回服務提供者地址列表給消費者,如果有變更,注冊中心將基于長連接推送變更數據給消費者監控中心(Monitor):服務消費者和提供者,在內存中累計調用次數和調用時間,定時每分鐘發送一次統計數據到監控中心

他們的關系如下:1、服務容器啟動后,運行加載服務提供者provider;2、服務提供者成功啟動,往注冊中心提供自己能提供的服務;3、服務消費者consumer成功啟動,往注冊中心訂閱自己要消費的服務;4、注冊中心Registry返回服務提供者地址列表給消費者,如果有變更,注冊中心將基于長連接推送變更數據給消費者。5、服務消費者,從提供者地址列表中,基于軟負載均衡算法,選一臺提供者進行調用,如果調用失敗,再選另一臺調用。6、服務消費者和提供者,在內存中累計調用次數和調用時間,定時每分鐘發送一次統計數據到監控中心。

2、在docker中安裝zookeeper

安裝:

(自動獲取到最新的zookeeper版本)docker pull zookeeper

啟動:

docker run --name zk01 -p 2181:2181 --restart always -d 6ad6cb039dfa6ad6cb039dfa(鏡像id)

阿里云安全組規則和Linux系統防火墻都記得開放2181端口。

3、新建工程(1)新建工程,工程里新建兩個模塊,provider模塊

SpringBoot系列教程之dubbo和Zookeeper集成方法

(2)consumer模塊

SpringBoot系列教程之dubbo和Zookeeper集成方法

4、給兩個模塊導入相同的pom.xml文件

  zkclient使用起來還是有點坑,注意清除一些包中依賴,也是看狂神視頻學到的,這里在使用2.7.7版本時候用了新的注解出了點問題,還是改回來使用2.7.3,使用新版本還有點點區別,在代碼中我也給出一些警示了。

<dependencies> <!-- dubbo 7.3倒是可以,7.7的就出錯連接不上了--> <dependency> <groupId>org.apache.dubbo</groupId> <artifactId>dubbo-spring-boot-starter</artifactId> <version>2.7.3</version> </dependency> <!-- zookeeper client zkclient--> <!-- https://mvnrepository.com/artifact/com.github.sgroschupf/zkclient --> <dependency> <groupId>com.github.sgroschupf</groupId> <artifactId>zkclient</artifactId> <version>0.1</version> </dependency> <!-- 引入zookeeper 避開連接的坑 --> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-framework</artifactId> <version>2.12.0</version> </dependency> <dependency> <groupId>org.apache.curator</groupId> <artifactId>curator-recipes</artifactId> <version>2.12.0</version> </dependency> <dependency> <groupId>org.apache.zookeeper</groupId> <artifactId>zookeeper</artifactId> <version>3.4.14</version> <!--排除這個slf4j-log4j12--> <exclusions><exclusion> <groupId>org.slf4j</groupId> <artifactId>slf4j-log4j12</artifactId></exclusion> </exclusions> </dependency>

5、添加service層售票接口、接口實現類  (1)ITicketService

public interface ITicketService { String saleTicket(String name);}

  (2)TicketServiceImpl

注意使用的包名稱一定要一致,不是spring帶的Service

package top.weidaboy.provider.service.Impl;import org.apache.dubbo.config.annotation.Service;import org.springframework.stereotype.Component;import top.weidaboy.provider.service.ITicketService;//zookeeper:服務注冊與發現@Service //使用后被注入,項目已啟動就自動注冊到注冊中心@Component //放到spring容器中去//新版:import org.apache.dubbo.config.annotation.DubboService;//@DubboService //將服務發布出去public class TicketServiceImpl implements ITicketService { @Override public String saleTicket(String name) { return '確認買票: '+name; }}

6、application.proterties文件配置dubbo詳細信息

server.port=8081#當前應用起名dubbo.application.name=provider-server#找到zookeeper注冊中心地址dubbo.registry.address=zookeeper://你的IP:2181#掃描提供指定包下的服務dubbo.scan.base-packages=top.weidaboy.provider.service

7、啟動服務提供者代碼

  啟動成功后,該程序會往對應的注冊中心地址注冊新的服務,供給需要消費的消費者使用SpringBoot系列教程之dubbo和Zookeeper集成方法

8、編寫服務消費者代碼

  既然有了服務提供者,那么就在consumer模塊中創建消費者來使用服務,分以下三步:

(1)創建消費者服務,以及實現接口

  UserService:

public interface IUserService { //買票 String buyTicket(String name);}

   UserServiceImpl:

@Service//注入到容器中, 這個import org.springframework.stereotype.Service;public class UserServiceImpl implements IUserService { @Reference //遠程引用指定的服務, //該注解會按照全類名來進行匹配,看是哪個給注冊中心注冊了這個全類名 ITicketService ticketService; //相同的接口名 @Override public String buyTicket(String name) { return ticketService.saleTicket(name); }}

(2)在consumer模塊中添加服務提供者的接口代碼

  要求:在consumer模塊提供方的代碼路徑必須與provider模塊的路徑一樣,只需導入接口類ITicketService:

public interface ITicketService { String saleTicket(String name);}

 代碼結構如圖:丑了點嘿嘿,湊合看吧

SpringBoot系列教程之dubbo和Zookeeper集成方法

(3)修改application.proterties文件

  注意:這是在consumer模塊下的文件,因為消費者只是需要消費服務,無須注冊,就可以不用掃描對應的服務包名了

server.port=8082 #需要不同端口#給當前應用起名:dubbo.application.name=consumer-server#注冊中心dubbo.registry.address=zookeeper://你的IP:2181

9、編寫測試類

@SpringBootTestclass WeidaboyApplicationTests { @Autowired IUserService userService; @Test void contextLoads() { System.out.println(userService.buyTicket('唐人街探案三')); }}

10、測試調用不同端口的服務

  運行測試類,要求我們剛剛啟動的服務提供者的程序不要關閉,并且兩個端口不能相互占用,注冊中心地址一樣。

SpringBoot系列教程之dubbo和Zookeeper集成方法

測試成功!

小結

  本次學習內容實現:SpingBoot整合了dubbo和zookeeper實現分布式開發的應用,將提供服務和消費服務進行拆分,讓不同系統去管理,整體是為了更方便,更有目的的開發項目,長路漫漫,繼續前進吧!

到此這篇關于SpringBoot系列教程之dubbo和Zookeeper集成方法的文章就介紹到這了,更多相關SpringBoot dubbo和Zookeeper集成內容請搜索好吧啦網以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持好吧啦網!

標簽: Spring
相關文章:
主站蜘蛛池模板: 膏方加工_丸剂贴牌_膏滋代加工_湖北康瑞生物科技有限公司 | 智能门锁电机_智能门锁离合器_智能门锁电机厂家-温州劲力智能科技有限公司 | 光伏家 - 太阳能光伏发电_分布式光伏发电_太阳能光伏网 | SDG吸附剂,SDG酸气吸附剂,干式酸性气体吸收剂生产厂家,超过20年生产使用经验。 - 富莱尔环保设备公司(原名天津市武清县环保设备厂) | 紧急泄压人孔_防爆阻火器_阻火呼吸阀[河北宏泽石化] | 气胀轴|气涨轴|安全夹头|安全卡盘|伺服纠偏系统厂家-天机传动 | RTO换向阀_VOC高温阀门_加热炉切断阀_双偏心软密封蝶阀_煤气蝶阀_提升阀-湖北霍科德阀门有限公司 | 山东石英砂过滤器,除氟过滤器「价格低」-淄博胜达水处理 | 亚克力制品定制,上海嘉定有机玻璃加工制作生产厂家—官网 | 电脑刺绣_绣花厂家_绣花章仔_织唛厂家-[源欣刺绣]潮牌刺绣打版定制绣花加工厂家 | 千斤顶,液压千斤顶-力良企业,专业的液压千斤顶制造商,shliliang.com | 企小优-企业数字化转型服务商_网络推广_网络推广公司 | 德国UST优斯特氢气检漏仪-德国舒赐乙烷检测仪-北京泽钏 | 耐高温硅酸铝板-硅酸铝棉保温施工|亿欧建设工程 | 冷轧机|两肋冷轧机|扁钢冷轧机|倒立式拉丝机|钢筋拔丝机|收线机-巩义市华瑞重工机械制造有限公司 | 北京燃气公司 用户服务中心| 网优资讯-为循环资源、大宗商品、工业服务提供资讯与行情分析的数据服务平台 | 东莞爱加真空科技有限公司-进口真空镀膜机|真空镀膜设备|Polycold维修厂家 | 智能监控-安防监控-监控系统安装-弱电工程公司_成都万全电子 | 高精度-恒温冷水机-螺杆式冰水机-蒸发冷冷水机-北京蓝海神骏科技有限公司 | 杭州中央空调维修_冷却塔/新风机柜/热水器/锅炉除垢清洗_除垢剂_风机盘管_冷凝器清洗-杭州亿诺能源有限公司 | 天空彩票天下彩,天空彩天空彩票免费资料,天空彩票与你同行开奖,天下彩正版资料大全 | 百度网站优化,关键词排名,SEO优化-搜索引擎营销推广 | 防潮防水通风密闭门源头实力厂家 - 北京酷思帝克门窗 | 中矗模型-深圳中矗模型设计有限公司 | bng防爆挠性连接管-定做金属防爆挠性管-依客思防爆科技 | PSI渗透压仪,TPS酸度计,美国CHAI PCR仪,渗透压仪厂家_价格,微生物快速检测仪-华泰和合(北京)商贸有限公司 | 进口试验机价格-进口生物材料试验机-西安卡夫曼测控技术有限公司 | 齿轮减速电机一体机_蜗轮蜗杆减速马达-德国BOSERL齿轮减速机带电机生产厂家 | ETFE膜结构_PTFE膜结构_空间钢结构_膜结构_张拉膜_浙江萬豪空间结构集团有限公司 | 数控专用机床,专用机床,自动线,组合机床,动力头,自动化加工生产线,江苏海鑫机床有限公司 | 北京网站建设公司_北京网站制作公司_北京网站设计公司-北京爱品特网站建站公司 | 浇钢砖,流钢砖_厂家价低-淄博恒森耐火材料有限公司 | 意大利Frascold/富士豪压缩机_富士豪半封闭压缩机_富士豪活塞压缩机_富士豪螺杆压缩机 | 多功能干燥机,过滤洗涤干燥三合一设备-无锡市张华医药设备有限公司 | 单级/双级旋片式真空泵厂家,2xz旋片真空泵-浙江台州求精真空泵有限公司 | 耐热钢-耐磨钢-山东聚金合金钢铸造有限公司 | 分光色差仪,测色仪,反透射灯箱,爱色丽分光光度仪,美能达色差仪维修_苏州欣美和仪器有限公司 | 橡胶接头_橡胶软接头_套管伸缩器_管道伸缩器厂家-巩义市远大供水材料有限公司 | 光泽度计_测量显微镜_苏州压力仪_苏州扭力板手维修-苏州日升精密仪器有限公司 | 有源电力滤波装置-电力有源滤波器-低压穿排电流互感器|安科瑞 |