testrouteadv.java

jxta_src_2.41b jxta 2.41b 最新版源码 from www.jxta.org

    }
    
    
    public void testDestDisplay() {
        // create access point advertisment for destination
        System.out.println("Test debug route display");
        AccessPointAdvertisement ap = (AccessPointAdvertisement)
        AdvertisementFactory.newAdvertisement(
        AccessPointAdvertisement.getAdvertisementType());
        ap.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        Vector addresses = new Vector();
        addresses.addElement("TCP:123.123.123.123");
        addresses.addElement("TCP:134.134.134.134");
        ap.setEndpointAddresses(addresses);
        
        // create the route
        RouteAdvertisement route = (RouteAdvertisement)
        AdvertisementFactory.newAdvertisement(
        RouteAdvertisement.getAdvertisementType());
        route.setDest(ap);
        
        AccessPointAdvertisement ap2 = (AccessPointAdvertisement)
        AdvertisementFactory.newAdvertisement(
        AccessPointAdvertisement.getAdvertisementType());
        ap2.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        addresses = new Vector();
        addresses.addElement("TCP:666.666.666.666");
        addresses.addElement("TCP:777.777.777.777");
        ap2.setEndpointAddresses(addresses);
        
        AccessPointAdvertisement ap4 = (AccessPointAdvertisement)
        AdvertisementFactory.newAdvertisement(
        AccessPointAdvertisement.getAdvertisementType());
        ap4.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        addresses = new Vector();
        addresses.addElement("TCP:888.888.888.888");
        addresses.addElement("TCP:999.999.999.999");
        ap4.setEndpointAddresses(addresses);
        
        Vector hops = new Vector();
        hops.addElement(ap2);
        hops.addElement(ap4);
        route.setHops(hops);
        route.setHops(hops);
        System.out.println(route.display());
    }
    
    public void testHops() {
        System.out.println("Test hops");
        AccessPointAdvertisement ap = (AccessPointAdvertisement)
        AdvertisementFactory.newAdvertisement(
        AccessPointAdvertisement.getAdvertisementType());
        PeerID pid = IDFactory.newPeerID(IDFactory.newPeerGroupID());
        ap.setPeerID(pid);
        // create the route
        RouteAdvertisement route = (RouteAdvertisement)
        AdvertisementFactory.newAdvertisement(
        RouteAdvertisement.getAdvertisementType());
        route.setDest(ap);
        assertEquals(pid, route.getDestPeerID());
        AccessPointAdvertisement ap2 = (AccessPointAdvertisement)
        AdvertisementFactory.newAdvertisement(
        AccessPointAdvertisement.getAdvertisementType());
        ap2.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        
        AccessPointAdvertisement ap4 = (AccessPointAdvertisement)
        AdvertisementFactory.newAdvertisement(
        AccessPointAdvertisement.getAdvertisementType());
        ap4.setPeerID(ap.getPeerID());
        Vector hops = new Vector();
        hops.addElement(ap2);
        hops.addElement(ap4);
        route.setHops(hops);
        
        assertEquals(true, route.containsHop(ap.getPeerID()));
        
        
    }
    
    public void testRouteQuery() {
        
        AccessPointAdvertisement ap = (AccessPointAdvertisement)
        AdvertisementFactory.newAdvertisement(
        AccessPointAdvertisement.getAdvertisementType());
        ap.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        Vector addresses = new Vector();
        addresses.addElement("TCP:123.123.123.123");
        addresses.addElement("TCP:134.134.134.134");
        ap.setEndpointAddresses(addresses);
        
        // create the route
        RouteAdvertisement route = (RouteAdvertisement)
        AdvertisementFactory.newAdvertisement(
        RouteAdvertisement.getAdvertisementType());
        route.setDest(ap);
        
        AccessPointAdvertisement ap2 = (AccessPointAdvertisement)
        AdvertisementFactory.newAdvertisement(
        AccessPointAdvertisement.getAdvertisementType());
        ap2.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        addresses = new Vector();
        addresses.addElement("TCP:666.666.666.666");
        addresses.addElement("TCP:777.777.777.777");
        ap2.setEndpointAddresses(addresses);
        
        AccessPointAdvertisement ap4 = (AccessPointAdvertisement)
        AdvertisementFactory.newAdvertisement(
        AccessPointAdvertisement.getAdvertisementType());
        ap4.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        addresses = new Vector();
        addresses.addElement("TCP:888.888.888.888");
        addresses.addElement("TCP:999.999.999.999");
        ap4.setEndpointAddresses(addresses);
        
        Vector hops = new Vector();
        hops.addElement(ap2);
        hops.addElement(ap4);
        route.setHops(hops);
        
        PeerID pid = IDFactory.newPeerID(IDFactory.newPeerGroupID());
        Vector badHops = new Vector();
        RouteQuery query = new RouteQuery(pid, route, badHops);
        
        // write to a file
        try {
            FileOutputStream fp = new FileOutputStream("routequery.msg");
            fp.write(query.toString().getBytes());
            fp.close();
            
            Reader is = new InputStreamReader( new FileInputStream("routequery.msg") );
            RouteQuery query1 = null;
            
            StructuredTextDocument doc = (StructuredTextDocument)
            StructuredDocumentFactory.newStructuredDocument(
            MimeMediaType.XMLUTF8, is );
            
            query1 = new RouteQuery(doc);
            is.close();
            assertEquals(query.getDestPeerID().toString(),
            query1.getDestPeerID().toString());
            //verify advertisement
            ap = query.getSrcRoute().getDest();
            AccessPointAdvertisement ap1 = query1.getSrcRoute().getDest();
            assertEquals(ap.getPeerID(), ap1.getPeerID());
            Enumeration e1 =  ap1.getEndpointAddresses();
            for (Enumeration e =ap.getEndpointAddresses(); e.hasMoreElements();) {
                assertEquals(e.nextElement(), e1.nextElement());
            }
            
            Enumeration r1 = query.getSrcRoute() .getHops();
            for (Enumeration e = query1.getSrcRoute().getHops();
            e.hasMoreElements();) {
                ap = (AccessPointAdvertisement) e.nextElement();
                ap1 = (AccessPointAdvertisement) r1.nextElement();
                assertEquals(ap.getPeerID(), ap1.getPeerID());
                e1 =  ap1.getEndpointAddresses();
                for (Enumeration e2 =ap.getEndpointAddresses();
                e2.hasMoreElements();) {
                    assertEquals(e2.nextElement(), e1.nextElement());
                }
            }
            System.out.println(query1.toString());
        } catch (Exception ex) {
            ex.printStackTrace();
            fail("Error constructing advertisement");
        }
    }
    
    
    public void testRouteResponse() {
        
        AccessPointAdvertisement ap = (AccessPointAdvertisement)
        AdvertisementFactory.newAdvertisement(
        AccessPointAdvertisement.getAdvertisementType());
        ap.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        Vector addresses = new Vector();
        addresses.addElement("TCP:123.123.123.123");
        addresses.addElement("TCP:134.134.134.134");
        ap.setEndpointAddresses(addresses);
        
        // create the route
        RouteAdvertisement route = (RouteAdvertisement)
        AdvertisementFactory.newAdvertisement(
        RouteAdvertisement.getAdvertisementType());
        route.setDest(ap);
        
        AccessPointAdvertisement ap2 = (AccessPointAdvertisement)
        AdvertisementFactory.newAdvertisement(
        AccessPointAdvertisement.getAdvertisementType());
        ap2.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        addresses = new Vector();
        addresses.addElement("TCP:666.666.666.666");
        addresses.addElement("TCP:777.777.777.777");
        ap2.setEndpointAddresses(addresses);
        
        AccessPointAdvertisement ap4 = (AccessPointAdvertisement)
        AdvertisementFactory.newAdvertisement(
        AccessPointAdvertisement.getAdvertisementType());
        ap4.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        addresses = new Vector();
        addresses.addElement("TCP:888.888.888.888");
        addresses.addElement("TCP:999.999.999.999");
        ap4.setEndpointAddresses(addresses);
        
        Vector hops = new Vector();
        hops.addElement(ap2);
        hops.addElement(ap4);
        route.setHops(hops);
        
        AccessPointAdvertisement apDst = (AccessPointAdvertisement)
        AdvertisementFactory.newAdvertisement(
        AccessPointAdvertisement.getAdvertisementType());
        apDst.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        addresses = new Vector();
        addresses.addElement("TCP:234.234.234.234");
        addresses.addElement("TCP:256.256.278.256");
        apDst.setEndpointAddresses(addresses);
        
        // create the route
        RouteAdvertisement routeDst = (RouteAdvertisement)
        AdvertisementFactory.newAdvertisement(
        RouteAdvertisement.getAdvertisementType());
        routeDst.setDest(apDst);
        
        AccessPointAdvertisement ap2Dst = (AccessPointAdvertisement)
        AdvertisementFactory.newAdvertisement(
        AccessPointAdvertisement.getAdvertisementType());
        ap2Dst.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        addresses = new Vector();
        addresses.addElement("TCP:166.166.166.166");
        addresses.addElement("TCP:277.277.277.277");
        ap2Dst.setEndpointAddresses(addresses);
        
        AccessPointAdvertisement ap4Dst = (AccessPointAdvertisement)
        AdvertisementFactory.newAdvertisement(
        AccessPointAdvertisement.getAdvertisementType());
        ap4Dst.setPeerID(IDFactory.newPeerID(IDFactory.newPeerGroupID()));
        addresses = new Vector();
        addresses.addElement("TCP:188.188.818.818");
        addresses.addElement("TCP:929.929.929.929");
        ap4Dst.setEndpointAddresses(addresses);
        
        Vector hopsDst = new Vector();
        hopsDst.addElement(ap2Dst);
        hopsDst.addElement(ap4Dst);
        routeDst.setHops(hopsDst);
        
        RouteResponse response = new RouteResponse( );
        response.setDestRoute( routeDst );
        response.setSrcRoute( route );
        
        // write to a file
        try {
            FileOutputStream fp = new FileOutputStream("routeresponse.msg");
            fp.write(response.toString().getBytes());
            fp.close();
            
            FileInputStream is = new FileInputStream("routeresponse.msg");
            RouteResponse response1 = null;
            
            StructuredTextDocument asDoc = (StructuredTextDocument)
            StructuredDocumentFactory.newStructuredDocument(
            MimeMediaType.XMLUTF8, is );
            is.close();
            
            response1 = new RouteResponse(asDoc);
            
            //verify advertisement
            ap = response.getSrcRoute().getDest();
            AccessPointAdvertisement ap1 = response1.getSrcRoute().getDest();
            assertEquals(ap.getPeerID(), ap1.getPeerID());
            Enumeration e1 =  ap1.getEndpointAddresses();
            for (Enumeration e =ap.getEndpointAddresses(); e.hasMoreElements();) {
                assertEquals(e.nextElement(), e1.nextElement());
            }
            Enumeration r1 = response.getSrcRoute() .getHops();
            for (Enumeration e = response.getSrcRoute().getHops();
            e.hasMoreElements();) {
                ap = (AccessPointAdvertisement) e.nextElement();
                ap1 = (AccessPointAdvertisement) r1.nextElement();
                assertEquals(ap.getPeerID(), ap1.getPeerID());
                e1 =  ap1.getEndpointAddresses();
                for (Enumeration e2 =ap.getEndpointAddresses();
                e2.hasMoreElements();) {
                    assertEquals(e2.nextElement(), e1.nextElement());
                }
            }
            
            ap = response.getDestRoute().getDest();
            ap1 = response1.getDestRoute().getDest();
            assertEquals(ap.getPeerID(), ap1.getPeerID());
            e1 =  ap1.getEndpointAddresses();
            for (Enumeration e =ap.getEndpointAddresses(); e.hasMoreElements();) {
                assertEquals(e.nextElement(), e1.nextElement());
            }
            r1 = response.getDestRoute() .getHops();
            for (Enumeration e = response.getDestRoute().getHops();
            e.hasMoreElements();) {
                ap = (AccessPointAdvertisement) e.nextElement();
                ap1 = (AccessPointAdvertisement) r1.nextElement();
                assertEquals(ap.getPeerID(), ap1.getPeerID());
                e1 =  ap1.getEndpointAddresses();
                for (Enumeration e2 =ap.getEndpointAddresses();
                e2.hasMoreElements();) {
                    assertEquals(e2.nextElement(), e1.nextElement());
                }
            }
            
            
            System.out.println(response1.toString());
        } catch (Exception ex) {
            ex.printStackTrace();
            fail("Error constructing advertisement");
        }
        
    }
    
    
}