com.fr.third.jgroups.blocks

类 MemcachedConnector

java.lang.Object

com.fr.third.jgroups.blocks.MemcachedConnector

所有已实现的接口:

java.lang.Runnable

public class MemcachedConnector
extends java.lang.Object
implements java.lang.Runnable

Class which listens on a server socket for memcached clients, reads the requests, forwards them to an instance of PartitionedHashMap and sends the response. A memcached client should be able to work without changes once the memcached protocol (http://code.sixapart.com/svn/memcached/trunk/server/doc/protocol.txt) has been implemented completely.

作者:

Bela Ban

嵌套类概要

嵌套类

限定符和类型	类和说明
static class	MemcachedConnector.Request

构造器概要

构造器

构造器和说明
MemcachedConnector(java.net.InetAddress bind_addr, int port, PartitionedHashMap<java.lang.String,byte[]> cache)

方法概要

方法

限定符和类型	方法和说明
java.net.InetAddress	getBindAddress()
PartitionedHashMap<java.lang.String,byte[]>	getCache()
int	getPort()
java.util.Map<java.lang.String,java.lang.Object>	getStats()
java.util.concurrent.Executor	getThreadPool()
int	getThreadPoolCoreThreads()
long	getThreadPoolIdleTime()
int	getThreadPoolMaxThreads()
void	run()
void	setBindAddress(java.net.InetAddress bind_addr)
void	setCache(PartitionedHashMap<java.lang.String,byte[]> cache)
void	setPort(int port)
void	setThreadPool(java.util.concurrent.Executor thread_pool)
void	setThreadPoolCoreThreads(int core_threads)
void	setThreadPoolIdleTime(long idle_time)
void	setThreadPoolMaxThreads(int max_threads)
void	start()
void	stop()

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

MemcachedConnector

public MemcachedConnector(java.net.InetAddress bind_addr,
                  int port,
                  PartitionedHashMap<java.lang.String,byte[]> cache)

方法详细资料

getBindAddress

public java.net.InetAddress getBindAddress()

setBindAddress

public void setBindAddress(java.net.InetAddress bind_addr)

getPort

public int getPort()

setPort

public void setPort(int port)

getCache

public PartitionedHashMap<java.lang.String,byte[]> getCache()

setCache

public void setCache(PartitionedHashMap<java.lang.String,byte[]> cache)

getThreadPoolCoreThreads

public int getThreadPoolCoreThreads()

setThreadPoolCoreThreads

public void setThreadPoolCoreThreads(int core_threads)

getThreadPoolMaxThreads

public int getThreadPoolMaxThreads()

setThreadPoolMaxThreads

public void setThreadPoolMaxThreads(int max_threads)

getThreadPoolIdleTime

public long getThreadPoolIdleTime()

setThreadPoolIdleTime

public void setThreadPoolIdleTime(long idle_time)

getThreadPool

public java.util.concurrent.Executor getThreadPool()

setThreadPool

public void setThreadPool(java.util.concurrent.Executor thread_pool)

getStats

public java.util.Map<java.lang.String,java.lang.Object> getStats()

start

public void start()
           throws java.io.IOException,
                  javax.management.MalformedObjectNameException,
                  javax.management.MBeanRegistrationException

抛出:

java.io.IOException

javax.management.MalformedObjectNameException

javax.management.MBeanRegistrationException

stop

public void stop()
          throws java.io.IOException

抛出:

java.io.IOException

run

public void run()

指定者:

run 在接口中 java.lang.Runnable