JXTA中通过身份认证来加入“群”(三)

本文是接前面两篇，结束本篇就完成密码对等组创建，发现及加入的过程。

发现一个对等组在以前关于JXTA中的文章中都有说到，没有什么大的差别，在这里主要是注意验证器如何验证用户和密码的过程，不过也相对比较简单。代码的注释中都有详细的说明。直接秀出代码：

1、搜索对等组方法

?//搜索到该“群”
?private PeerGroup discoveryPeerGroup(PeerGroup netpg,
???PeerGroupID satellaPID) {
??//要加入”群“，首先，得搜索到”群“
??//在很多情况下，我们一般使用发现监听及时发现
??//在这里我不这样，因为已经确定对等组广告是在本地缓存中，相对比较简单
??PeerGroup satellaPeerGroup = null;
??DiscoveryService netpgService = null;
??if(null!=netpg){
???netpgService = netpg.getDiscoveryService();
??}else{
???System.out.println("父对等组为空，不能加入目标对等组");
???System.exit(-1);
??}
??boolean isGroupFound = false;
??Enumeration localPGAdv = null;
??PeerGroupAdvertisement spgAdv = null;
??while(!isGroupFound){
???try {
????localPGAdv = netpgService.getLocalAdvertisements(DiscoveryService.GROUP, "GID", satellaPID.toString());
???} catch (IOException e) {
????System.out.println("本地没有发现该对等组广告");
????e.printStackTrace();
???}
???if(null!=localPGAdv){
????while(localPGAdv.hasMoreElements()){
?????PeerGroupAdvertisement pgAdv = null;
?????pgAdv = (PeerGroupAdvertisement)localPGAdv.nextElement();
?????if(pgAdv.getPeerGroupID().equals(satellaPID)){
??????spgAdv = pgAdv;
??????isGroupFound = true;
??????break;
?????}
????}
???}
???try {
????Thread.sleep(5*1000);
???} catch (InterruptedException e) {
????// TODO Auto-generated catch block
????e.printStackTrace();
???}
??}
??try {
???satellaPeerGroup = netpg.newGroup(spgAdv);
??} catch (PeerGroupException e) {
???System.out.println("不能用对等组广告创建目标对等组");
???e.printStackTrace();
???return null;
??}
??return satellaPeerGroup;
?}

2、验证器对身份认证

?/**
? * 要执行该方法而且是符合要求完认证后才能加入到对等组。为了完成验证，验证方法需求从验证器(auth)中提取。
? * 这些方法的名称开始是"setAuth"。其中setAuth1Identity方面支持验证login,而setAuth2_Password支持验证passwd
? * @param auth
? * @param login
? * @param passwd
? */
?private void completeAuth(Authenticator auth, String login, String passwd) {
??Method[] methods = auth.getClass().getMethods();
??Vector authMethods = new Vector();
??//下面for循环只是对auth中的方法过滤和排序
??for(int eachMethod = 0;eachMethod<methods.length;eachMethod++){
???if(methods[eachMethod].getName().startsWith("setAuth")){
????if(Modifier.isPublic(methods[eachMethod].getModifiers())){
?????for(int doInsert = 0;doInsert<=authMethods.size();doInsert++){
??????int insertHere = 1;
??????if(doInsert == authMethods.size()){
???????insertHere = doInsert;
??????}else{
???????if(methods[eachMethod].getName().compareTo(((Method)authMethods.elementAt(doInsert)).getName())<=0){
????????insertHere = doInsert;
???????}
??????}
??????if(-1!=insertHere){
???????authMethods.insertElementAt(methods[eachMethod], insertHere);
???????break;
??????}//end if (-1 != insertHere)
?????}//end for(int doInsert =0
????}//end if (modifier.isPublic
???}//end if (methods[eachMethod]
??}//end for (int eachMethod)
??
??Object[] AuthId = {login};
??Object[] AuthPasswd = {passwd};
??//重点是下面，调用验证器的验证方法对用户和密码进行确认
??for(int eachAuthMethod = 0;eachAuthMethod<authMethods.size();eachAuthMethod++){
???Method doingMethod = (Method)authMethods.elementAt(eachAuthMethod);

???if(doingMethod.getName().equals("setAuth1Identity")){
????//
????try {
?????doingMethod.invoke(auth, AuthId);
????} catch (Exception e) {
?????e.printStackTrace();
????}
???}else
????if(doingMethod.getName().equals("setAuth2_Password")){
?????try {
??????doingMethod.invoke(auth, AuthPasswd);
?????} catch (Exception e) {
??????e.printStackTrace();
?????}
????}
??}
?}

3、确认身份，通过认证则加入，不通过则不能加入

?//加入“群”
?private void joinPeerGroup(PeerGroup spg, String login, String passwd) {
??StructuredDocument creds = null;
??AuthenticationCredential authCred = new AuthenticationCredential(spg,null,creds);
??MembershipService membershipService = spg.getMembershipService();
??Authenticator auth = null;
??try {
???auth = membershipService.apply(authCred);
???completeAuth(auth,login,passwd);
???if(!auth.isReadyForJoin()){
????System.out.println("身份认证失败");
????System.out.println("没有完成认证，不能加入对等组");
???}
???membershipService.join(auth);
??} catch (Exception e) {
???System.out.println("认证失败");
???System.out.println("登录信息不正确，不能加入对等组");
???e.printStackTrace();
???System.exit(-1);
??}

??
?}

?

加上这篇，“JXTA中通过身份认证来加入“群””的全部过程完成。代码也已经全部共享。