2025年JXTAP2P编程技术例程

[精]JXTA,P2P编程技术例程（4）JXTA,P2P编程技术例程(4)作者:yxiong|曰期:-07-30|字体:大中小广告处理在我們建立了发現监听器之後，它将不停的加入某些新发現的module阐明通告到我們的當地缓冲中。每次processPrimes()措施被调用的時候，客户peer将尝试连接module阐明通告代表的peer，接入到他們的输入通道中，传递一种消息去初始化這個peer的质数发現服务。)這個措施的第一种元素就是决定我們可以委托以工作的peer集合，应當记得一种通告有一种期限限制，因此我們要消除那些不在有效的通告。Publicint[]processPrimes(intlow,inthigh){SetsetCopy=null;synchronized(adverts){SetsetCopy=(Set)adverts.clone();}ArrayListworkingList=newArrayList();ArrayListexpired=newArrayList();longcurrentTime=System.getCurrentTimeMillis();Iteratorit=workingSet.iterator();while(it.hasNext()){ModuleSpecAdvertisementad=(ModuleSpecAdvertisement)it.next();if(ad.getLocalExpirationTime()>currentTime+(2*60*1000)){workingList.addElement(ad);}else{expired.addElement(ad);}}removeExpired(expired);前述的程序段执行了對一种简朴缓冲中被发現的服务的管理，让removeExpired()措施去删除那些過期和即将過期的通告(這裏没有详细阐明removeExpired())。當我們有了一种有效通告的集合之後，我們可以開始對它們進行操作以获得我們需要用来发送消息的管道通告。.注意這個工作的分发是人為的:某些peer也許比其他peer更有能力某些，某些又也許网络连接方面更好些。這些不一样应當在分派工作的時候都被考虑到，实际上，也不會故意把工作分派為過多的片段，由于网络通信時间也許比花在实际计算质数的時间更多。(這個例子的目的是阐明怎么從一种ModuleSpecAdvertisement得到一种管道通告，這样创立一种新的消息，然後怎样通過管道发送一种消息。)Listing16.14展示了這些自然数列是怎样被分為一种一种的子列的，每個子列又能和一种将送往别的peer的消息相對应。消息被插入到一种hash表映射中，映射的键值显示了消息的状态:与否已經发送了,我們与否收到了它的成果,Listing16.14CreatingNewMessagesMapmessageMap=newHashMap();intsize=workingList.size()intmod=high%size;high-=mod;intperPiece=high/size;for(inti=0;i<size;i++){//createanewmessageMessagemsg=pipeSvc.createMessage();msg.setString(ServiceConstants.LOW_INT,low);//lastmessagewillgettocomputeabitmoreif(i==size-1){high=low+perPiece?1+mod;}else{high=low+perPiece-1;}msg.setString(ServiceConstants.HIGH_INT,high);low+=perPiece;//weneithersentthemessage,nordidwegetaresponseStatusMapstatusMap=newStatusMap(false,false);StatusMapstatusMap=newStatusMap(false,false);messageMap.put(statusMap,msg);}StatusMap就是一對布尔值，這裏并没有列出我們的最终一步就是從每個ModuleSpecAdvertisement中提取管道通告，打開每個管道，发送一种消息到那管道，然後将這個消息標识為“已經发送”。应记得一种通告就是一种构造化的文档，类似于XML文档，它能轻易的被转换為一种文本文档然後打印出来，在開发和测试的時候查阅通告的内容是非常有好处的。Listing16.15PrintinganAdvertisementCollectionads=messageMap.values();Iteratorit=ads.iterator();while(it.hasNext()){ModuleSpecAdvertisementad=(ModuleSpecAdvertisement)it.next();//First,printoutModuleSpecadvertisementonstandardoutputStructuredTextDocumentdoc=(StructuredTextDocument)ad.getDocument(newMimeMediaType("text/plain"));try{StringWriterout=newStringWriter();doc.sendToWriter(out);System.out.println(out);out.close();}catch(IOExceptione){}...正如我們先前讨论的，一种StructuredTextDocument类包括了诸多元素，其中一种是一种参数。當我們為我們的服务构造了ModuleSpecAdvertisement的時候，我們将它作為参数進入這個服务的管道通告。這個参数恰好是此外一种StructuredDocument元素，我們可以用操作XML文档同样的措施操纵它。在解析通告的参数元素的過程中，我們首先获得這個通告的ID和类型，通道的ID与URN阐明相统一，在JXTA阐明中有概述，JXTA阐明将管道的特殊鉴定器用128-bit编码，下面是這個URN的一种例子。urn:jxta:uuid-596614E3382CCBF5A242ACE15A8F9D7C04IDFactory类有能力根据每個URN建造一种PipeID對象。這就是我們用pipeID去关联一個pipe通告的机制。Listing16.16WorkingwithAdvertisementParametersStructuredTextDocumentparam=(StructuredTextDocument)ad.getParam();StringpipeID=null;StringpipeType=null;Enumerationen=null;if(param!=null){en=param.getChildren("jxta:PipeAdvertisement");}Enumerationchild=null;if(en!=null){child=((TextElement)en.nextElement()).getChildren();}if(child!=null){while(child.hasMoreElements()){TextElementel=(TextElement)child.nextElement();StringelementName=el.getName();if(elementName.equals("Id")){pipeID=el.getTextValue();}if(elementName.equals("Type")){pipeType=el.getTextValue();}}}if(pipeID!=null||pipeType!=null){PipeAdvertisementpipeAdvert=(PipeAdvertisement)AdvertisementFactory.newAdvertisement(PipeAdvertisement.getAdvertisementType());try{URLpidURL=newURL(pipeID);PipeIDpid=(PipeID)IDFactory.fromURL(pidURL);pipeAdvert.setPipeID(pid);}catch(MalformedURLExceptione){System.out.println("WrongURL:"+e.getMessage());return;}catch(UnknownServiceExceptione){System.out.println("UnknownService:"+e.getMessage());return;}}基于這個PipeAdvertisement，我們目前有能力去构造一种输出管道去连接遠程peer的输入管道了。如Listing16.17，应當记得一种管道是一种單向的沟通渠道，因此我們没有期望從這個管道上获得遠程peer的回执，遠程peer進行一种必要的类似的工作，打開一种管道连接回客户端，然後连同成果一起发回消息。Listing16.17CreatinganOutputPipetry{outputPipe=pipeSvc.createOutputPipe(pipeAdvert,30000);outputPipe.send(msg);System.out.println("Sentmessageonoutputpipe");}catch(IOExceptione){System.out.println("Can'tsendmessagethroughpipe:"+e.getMessage());}}有趣的是，這個管道创立机制是:一种peer也許在发送ModuleSpecAdvertisement和一种客户连接到它之间变化网络身份，虽然如此，這個peer的虚拟身份在JXTA网络上将不會改变，运行時的服务保证被ModuleSpecAdvertisement所通告的管道一直处在连接状态。為了启動应用服务，确定所有的JXTA类都在classpath裏面，然後输入下面這個命令。javaprimecruncher.PrimePeer你也可以运行下面的参数，這些参数容許你饶過JXTA的登入界面。java–Dnet.jxta.tls.principal=USERNAME-Dnet.jxta.tls.password=PASSWORDprimecruncher.PrimePeerBysubs