org.xdi.oxauth.dev.CacheGrantManual クラス

org.xdi.oxauth.dev.CacheGrantManual 連携図

静的公開メンバ関数
static void	main (String[] args) throws IOException
static ThreadFactory	daemonThreadFactory ()

静的非公開メンバ関数
static MemcachedClient	createClients () throws IOException
static int	random ()
static void	sleep (int seconds)
static SessionId	testState ()
static Client	testClient ()
static User	testUser ()
static CacheGrant	testGrant ()

静的非公開変数類
static final int	CLIENT_COUNT = 10
static final Random	RANDOM = new Random()

詳解

著者

yuriyz

バージョン

August 9, 2017

関数詳解

createClients()

static MemcachedClient org.xdi.oxauth.dev.CacheGrantManual.createClients ( ) throws IOException

inlinestaticprivate

                                                                      {
        return new MemcachedClient(new DefaultConnectionFactory(100, 32768),
                Lists.newArrayList(new InetSocketAddress("localhost", 11211)));
    }

daemonThreadFactory()

static ThreadFactory org.xdi.oxauth.dev.CacheGrantManual.daemonThreadFactory ( )

inlinestatic

                                                      {
        return new ThreadFactory() {
            public Thread newThread(Runnable p_r) {
                Thread thread = new Thread(p_r);
                thread.setDaemon(true);
                return thread;
            }
        };
    }

main()

static void org.xdi.oxauth.dev.CacheGrantManual.main ( String []  args ) throws IOException

inlinestatic

                                                              {
        final MemcachedClient client = createClients();
        final ExecutorService executorService = Executors.newFixedThreadPool(1000, daemonThreadFactory());

        int count = 10000;
        final long start = System.currentTimeMillis();

        for (int i = 0; i < count; i++) {
            final int key = i;
            executorService.execute(new Runnable() {
                @Override
                public void run() {
                    // MemcachedClient client = clients.get(random);

                    Object toPut = testGrant();
                    // Object toPut = UUID.randomUUID().toString();

                    OperationFuture<Boolean> set = null;
                    for (int j = 0; j < 3; j++) {
                        set = client.set(Integer.toString(key), 60, toPut);
                    }

                    OperationStatus status = set.getStatus(); // block

                    System.out.println(
                            " key: " + key + ", time: " + (new Date().getTime() - start) + "ms, set: " + status);

                    executorService.execute(new Runnable() {
                        @Override
                        public void run() {

                            int random = random();
                            if (random % 3 == 0) {
                                try {
                                    Thread.sleep(10000);
                                } catch (InterruptedException e) {
                                    e.printStackTrace();
                                }
                            }

                            Object get = client.get(Integer.toString(key));
                            System.out.println("GET key: " + key + " result: " + get);
                        }
                    });
                }
            });
        }

        sleep(40);
        // System.out.println(client.get("myKey"));
        //
        // client.set("myKey", 30, testState());
        //
        // sleep(12);
        // System.out.println(client.get("myKey"));
        //
        // sleep(12);
        // System.out.println(client.get("myKey"));
        client.shutdown();

    }

random()

static int org.xdi.oxauth.dev.CacheGrantManual.random ( )

inlinestaticprivate

                                {
        int min = 0;
        int max = CLIENT_COUNT;
        return RANDOM.nextInt(max - min + 1) + min;
    }

sleep()

static void org.xdi.oxauth.dev.CacheGrantManual.sleep ( int  seconds )

inlinestaticprivate

                                           {
        try {
            Thread.sleep(seconds * 1000);
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
    }

testClient()

static Client org.xdi.oxauth.dev.CacheGrantManual.testClient ( )

inlinestaticprivate

                                       {
        Client client = new Client();
        client.setClientId(UUID.randomUUID().toString());
        return client;
    }

testGrant()

static CacheGrant org.xdi.oxauth.dev.CacheGrantManual.testGrant ( )

inlinestaticprivate

                                          {
        CacheGrant grant = new CacheGrant();
        grant.setAcrValues("basic");
        grant.setAuthenticationTime(new Date());
        grant.setAuthorizationCodeString(UUID.randomUUID().toString());
        grant.setClient(testClient());
        grant.setGrantId(UUID.randomUUID().toString());
        grant.setNonce(UUID.randomUUID().toString());
        grant.setScopes(Sets.newHashSet("openid"));
        grant.setUser(testUser());
        return grant;
    }

testState()

static SessionId org.xdi.oxauth.dev.CacheGrantManual.testState ( )

inlinestaticprivate

                                         {
        HashMap<String, String> map = new HashMap<String, String>();
        map.put("mapKey", "mapValue");

        SessionId state = new SessionId();
        state.setUserDn("userDn");
        state.setId(UUID.randomUUID().toString());
        state.setLastUsedAt(new Date());
        state.setSessionAttributes(map);
        return state;
    }

testUser()

static User org.xdi.oxauth.dev.CacheGrantManual.testUser ( )

inlinestaticprivate

                                   {
        User user = new User();
        user.setUserId(UUID.randomUUID().toString());
        return user;
    }

メンバ詳解

CLIENT_COUNT

final int org.xdi.oxauth.dev.CacheGrantManual.CLIENT_COUNT = 10

staticprivate

RANDOM

final Random org.xdi.oxauth.dev.CacheGrantManual.RANDOM = new Random()

staticprivate

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/OpenId/gluu/src/oxAuth/Server/src/test/java/org/xdi/oxauth/dev/CacheGrantManual.java