dubbozookeeperspringBootdubbo Ideamaven運(yùn)行環(huán)境配 參考......................................................................................................................... 參考.................................................................................................................地址： #tarxvzfzookeeper-3.4.13.tar.gz#mkdir-p/var/lib/zookeeper#cdzookeeper-手工創(chuàng)建zoo.cfg#cd#vimzoo.cfg//內(nèi)容如下是tickTime的兩倍。dataDir必須指向一個(gè)已存在 務(wù)日志（thelocationtostorethein-memorydatabasesnapshotsand,unlessspecifiedotherwise,thetransactionlogofupdatestothedatabase.） Port Port用 #cd../bin#pwd#ls zkServer.cmdzkServer.shzkTxnLogToolkit.cmdzkTxnLogToolkit.sh#zkServer.shZooKeeperJMXenabledbyUsingconfig:/usr/local/zookeeper/zookeeper-3.4.13/bin/../conf/zoo.cfgStartingzookeeper...STARTEDzkServer.sh#zkCli.sh-server:2181Connectingto:21812017-09-1520:48:06,986[myid:]-INFO[main:Environment@100]-environment:zookeeper.version=3.4.13-2d71af4dbe22557fda74f9a9b4309b15a7487f03,builton06/29/201804:05GMT eto [main-SendThread(localhost:2181)xn$SendThread@1029]-Openingsocketconnectiontoserverlocalhost/:2181.WillnotattempttoauthenticateusingSASL(unknownerror)JLinesupportisZooKeeper-serverhost:portcmdargsstatpath[watch]setpathdatalspath[watch]delquota[-n|-b]pathls2path[watch]setAclpathaclsetquota-n|-bvalpathredocmdnoprintwatcheson|offdeletepath[version]syncpathrmrpathgetpathcreate[-s][-e]pathdataacladdauthschemeauthgetAclpathconnect[zk::2181(CONNECTED)1]ls[zk::2181(CONNECTED)2]create/zk_testmy_dataCreated/zk_test[zk::2181(CONNECTED)3]ls[zookeeper,[zk::2181(CONNECTED)4]get/zk_testcZxid=ctime=FriSep1520:52:32CST2017mZxid=0x2mtime=FriSep1520:52:32CST2017pZxid=0x2cversion=dataVersion=aclVersion=0ephemeralOwner=0x0dataLength=7numChildren=[zk::2181(CONNECTED)5]set/zk_testjunkcZxid=0x2ctime=FriSep1520:52:32CST2017mZxid=0x3mtime=FriSep1520:54:39CSTpZxid=0x2cversion=dataVersion=aclVersion=0ephemeralOwner=0x0dataLength=4numChildren=[zk::2181(CONNECTED)6]get/zk_testcZxid=ctime=FriSep1520:52:32CST2017mZxid=0x3mtime=FriSep1520:54:39CST2017pZxid=0x2cversion=dataVersion=aclVersion=0ephemeralOwner=0x0dataLength=4numChildren=[zk::2181(CONNECTED)7]delete

Cmdmvnv<!--|Thepathtothelocalrepositorymavenwillusetostore||Default:mvn mvninstall-如上說(shuō)明，我們可以直接進(jìn)入到目 下對(duì)應(yīng)工程的 下，獲取我們需要的jar包(附地址 /s/1dm1ftVonqb8gK4DNwn修改jar包perties(路徑dubbo-admin-0.0.1-SNAPSHOT.jar\BOOT-INF\classes\perties)，更改zookeeper地址，例中默認(rèn)如下#java-jardubbo-admin-0.0.1-#firewall-cmd--permanent--zone=public--add-port=7001/tcp#firewall-cmd--reload例中為輸入賬號(hào)\Mavenmirrors配置<!--|Specifiesarepositorymirrorsitetouseinsteadofagivenrepository.Therepositorythat|thismirrorserveshasanIDthatmatchesthemirrorOfelementofthisIDsare|forinheritanceanddirectlookuppurposes,andmustbeuniqueacrossthesetof|<name>HumanReadableNameforthis <name>aliyun <name>aliyun <name>MavenRepository <name>HumanReadableNameforthis <name>HumanReadableNameforthis <name>JBossPublicRepository Maven 的鏡像-- <name>oneof <name>oneofthecentralmirrors Mavenhomedirectory，UserSettingfileLocal-Xms128m-Xmx512m-Duser.language=zh-Dfile.encoding=UTF- 替代方案1：新建系統(tǒng)環(huán)境變量，變量值：-Xms128mXmx512mDuser.language=zhDfile.encoding=UTF-<?xmlversion="1.0"encoding="UTF-<project""dubbo-demo-api:公共服務(wù)apidubbo-demo-provider服務(wù)提供者dubbo-demo-consumer:消費(fèi)者NewModuleModulename,artifactIddubbo-demo-provider，<?<?xmlversion="1.0"encoding="UTF-<project<project""如下，在java源碼 下新建層級(jí)Package，然后右鍵demo包->New->JavaClass,新packagepublicpackagepublicinterface{Stringsay packagevider;packagevider;publicclassDemoServiceImplimplements{publicStringsay o(Stringname){return" o"+name;}}packagepackagepublicclassProvider{Togetipv6addresstowork,beforerunningyourpublicstaticvoidmain(String[]args)throws{ClassPathXmlApplicationContextcontext=newSystem.in.read();//pressanykeyto}} <?xmlversion="1.0"encoding="UTF-<beans <!--提供方應(yīng)用名稱，用于 依賴關(guān)系（provider'sapplicationname,usedfortracingdependencyrelationship--><!--使用multicast廣播 服務(wù)地址（usemulticastregistrycentertoexportservice--><dubbo:registry<!--用dubbo協(xié)議在20880端 露服務(wù)（usedubboprotocoltoexportserviceonport20880--><dubbo:protocolname="dubbo"<beanid="demoService" 需 的服務(wù)接口(declaretheserviceinterfacetobeexported--URIisnotregistered(Settings|Languages&Frameworks|SchemasandFile->SettingsLanguages&FrameworksSchemasandDTDS,點(diǎn)擊右側(cè)+<?xmlversion="1.0"<?xmlversion="1.0"encoding="UTF-<project""###setloglevels######outputtotheconsole######setloglevels######outputtotheconsole###z}]%t%5p%c{2}:dubbo-dubbo-consumer模塊編碼packagepackageimportimportimportpublicclassConsumerpublicstaticvoidmain(String[]args)throws{ClassPathXmlApplicationContextcontext=newClassPathXmlApplicationContext(newString[]{"META-INF/spring/consumer.xml"});//ObtainingaremoteDemoServicedemoService=//Executingremote//o=ythecall }}<?xmlversion="1.0"<?xmlversion="1.0"encoding="UTF-<project"" <?xmlversion="1.0"encoding="UTF-<beansxmlns:xsi="don'tsetitsameasprovider--service--><dubbo:registry remoteservice,thendemoServicecanbeusedinthesamewayasthelocalregularinterface--><dubbo:referenceid="demoService"check="false"http:////o=ythecall whilewhile(true) o=demoService.say }<dubbo:referenceid="demoService"<dubbo:referenceid="demoService"packagepackageimportcom.alibaba.dubbo.rpc.service.GenericService;publicclassConsumerpublicstaticvoidmain(String[]args)throws{ClassPathXmlApplicationContextcontext=newGenericServicedemoService=(GenericService)context.getBean("demoService");Objectresult=demoService.$invoke("say o",newString[]{"java.lang.String"},newObject[]{"world"});}} 不依賴Spring配置文件的泛型調(diào)用packageimportpackageimportimportcom.alibaba.dubbo.config.ReferenceConfig;importcom.alibaba.dubbo.config.RegistryConfig;importimportpublicclassConsumerpublicstaticvoidmain(String[]args)ApplicationConfigapplication=newApplicationConfig(); RegistryConfigregistry=newReferenceConfig<GenericService>reference=reference.setGeneric(true) ReferenceConfigCacheReferenceConfigCachecache=ReferenceConfigCache.getCache();GenericServicegenericService=cache.get(reference);Objectresult= o",new{"java.lang.String"},newObject[]{"world"});}}packageimportjava.util.List;packageimportjava.util.List;publicclassQueryUserInfoReqimplements{privatestaticfinallongserialVersionUID=1L;privateStringname;privateStringprivateList<String>publicString{return}publicvoidsetName(String{=}publicString{return}publicvoidsetAge(String{this.age=}publicpublicList<String>{return}publicvoidsetHobbyList(List<String>{this.hobbyList=}publicString{+",hobbyList="+this.hobbyList+}}packagepublicinterfaceDemoService{StringpackagepublicinterfaceDemoService{String o(StringStringQueryUserInfo(QueryUserInfoReq}packagevider;importpublicpackagevider;importpublicclassDemoServiceImplimplements{publicStringsay o(Stringname){return" o"+name;}publicStringQueryUserInfo(QueryUserInfoRequserInfo){return