testtspace.java

java pos,你可以直接编译运行,

package space;

import org.jpos.util.Profiler;
import org.jpos.space.*;
import junit.framework.TestCase;

public class TestTSpace extends TestCase implements SpaceListener {
    TSpace sp;
    public static final int COUNT = 100000;
    Object notifiedValue = null;

    public void setUp () {
        sp = new TSpace();
    }
    public void testSimpleOut() {
        sp.out ("Test", "ABC");
        sp.out ("Test", "XYZ");

        assertEquals ("ABC", sp.rdp ("Test"));
        assertEquals ("ABC", sp.inp ("Test"));
        assertEquals ("XYZ", sp.rdp ("Test"));
        assertEquals ("XYZ", sp.inp ("Test"));
        assertNull (sp.rdp ("Test"));
        assertNull (sp.inp ("Test"));
    }
    public void testExpiration () {
        sp.out ("TestExp", "ABC", 50);
        assertEquals ("ABC", sp.rdp ("TestExp"));
        try {
            Thread.sleep (60);
        } catch (InterruptedException e) { }
        assertNull ("ABC", sp.rdp ("TestExp"));
    }
    public void testOutRdpInpRdp() throws Exception {
        Object o = new Boolean (true);
        String k = "key";
        sp.out (k, o);
        assertTrue (o.equals (sp.rdp (k)));
        assertTrue (o.equals (sp.rd  (k)));
        assertTrue (o.equals (sp.rd  (k, 1000)));
        assertTrue (o.equals (sp.inp (k)));
        assertNull (sp.rdp (k));
        assertNull (sp.rd  (k, 100));
    }
    public void testMultiKeyLoad() throws Exception {
        String s = "The quick brown fox jumped over the lazy dog";
        Profiler prof = new Profiler ();
        for (int i=0; i<COUNT; i++) {
            sp.out ("Key" + Integer.toString (i), s, 60000);
        }
        prof.dump (System.out, "MultiKeyLoad out >");
        prof = new Profiler ();
        for (int i=0; i<COUNT; i++) {
            assertTrue (s.equals (sp.in ("Key" + Integer.toString (i))));
        }
        prof.dump (System.out, "MultiKeyLoad in  >");
    }
    public void testSingleKeyLoad() throws Exception {
        String s = "The quick brown fox jumped over the lazy dog";
        String k = "SingleKey";
        Profiler prof = new Profiler ();
        for (int i=0; i<COUNT; i++) {
            sp.out (k, s, 60000);
        }
        prof.dump (System.out, "SingleKeyLoad out >");
        prof = new Profiler ();
        for (int i=0; i<COUNT; i++) {
            assertTrue (s.equals (sp.in (k)));
        }
        prof.dump (System.out, "SingleKeyLoad in  >");

        assertNull (sp.rdp (k));
    }
    public void testGC () throws Exception {
        sp.out ("TestExp", "ABC", 50);
        sp.out ("TestExp", "XYZ", 50);
        assertEquals ("ABC", sp.rdp ("TestExp"));
        try {
            Thread.sleep (60);
        } catch (InterruptedException e) { }

        assertEquals ("TestExp", sp.getKeysAsString());
        sp.gc();
        assertEquals ("", sp.getKeysAsString());
        sp.gc();
    }
    public void testTemplate () throws Exception {
        final String KEY = "TestTemplate";
        sp.out (KEY, "123");
        sp.out (KEY, "456"); 
        sp.out (KEY, "789"); 

        Template tmpl = new ObjectTemplate (KEY, "456");
        assertEquals (sp.rdp (KEY),  "123");
        assertEquals (sp.rdp (tmpl), "456");
        assertEquals (sp.rdp (KEY),  "123");
        assertEquals (sp.inp (tmpl), "456");
        assertNull (sp.rdp (tmpl));
        assertNull (sp.inp (tmpl));
        assertEquals (sp.rdp (KEY),  "123");
        assertEquals (sp.inp (KEY),  "123");
        assertEquals (sp.rdp (KEY),  "789");
        assertEquals (sp.inp (KEY),  "789");
        assertNull (sp.rdp (KEY));
        assertNull (sp.inp (KEY));
    }
    public void testMD5Template () throws Exception {
        final String KEY = "TestMD5Template";
        sp.out (KEY, "123");
        sp.out (KEY, "456"); 
        sp.out (KEY, "789"); 

        Template tmpl = new MD5Template (KEY, "456");
        assertEquals (sp.rdp (KEY),  "123");
        assertEquals (sp.rdp (tmpl), "456");
        assertEquals (sp.rdp (KEY),  "123");
        assertEquals (sp.inp (tmpl), "456");
        assertNull (sp.rdp (tmpl));
        assertNull (sp.inp (tmpl));
        assertEquals (sp.rdp (KEY),  "123");
        assertEquals (sp.inp (KEY),  "123");
        assertEquals (sp.rdp (KEY),  "789");
        assertEquals (sp.inp (KEY),  "789");
        assertNull (sp.rdp (KEY));
        assertNull (sp.inp (KEY));
    }
    public void testNotify() {
        sp.addListener ("Test", this, 500);
        sp.out ("TestNotify", "ABCCBA");
        assertNull (notifiedValue);

        sp.addListener ("TestNotify", this);
        sp.out ("TestNotify", "ABCCBA");
        assertEquals (notifiedValue, "ABCCBA");

        sp.out ("TestNotify", "012345");
        assertEquals (notifiedValue, "012345");

        assertEquals (sp.inp ("TestNotify"), "ABCCBA");
        assertEquals (sp.inp ("TestNotify"), "ABCCBA");
        assertEquals (sp.inp ("TestNotify"), "012345");

        sp.out ("Test", "OLD");
        assertEquals (notifiedValue, "OLD");
        try {
            Thread.sleep (600);
        } catch (InterruptedException e) { }
        sp.out ("Test", "NEW");
        assertEquals (notifiedValue, "OLD");  // still OLD
        assertEquals (sp.inp ("Test"), "OLD");
        assertEquals (sp.inp ("Test"), "NEW");
    }
    public void notify (Object key, Object value) {
        this.notifiedValue = value;
    }
}