JarCastingokuyama-client-java
Java client library for Okuyama KVS
Feature
- Basic set and get operation
- Compare And Set value updating
- Tagging
- Value compression ability with customizable compression strategy
- Socket pooling with adaptive expansion
- Adaptive value serialization form. Encoding base64 for serializable object.
Usage
For detail, see Javadoc
At first, create OkuyamaClientFactory and specify endpoints and pool size. OkuyamaClientFactory can be held through application life time.
String[] endpoints = {"127.0.0.1:8888", "127.0.0.1:8889"};
int poolSize = 10;
OkuyamaClientFactory factory = new OkuyamaClientFactoryImpl(endpoints, poolSize);
// Enable compression with default compression strategy, compress if size of value is over 32 bytes
factory.setCompressionMode(true);
// Or set your own compression strategy
factory.setCompressionStrategy(new YourCompressionStrategy());
When you use client instance, call factory.createClient(). This instance is supposed to retain short time as in function.
OkuyamaClient client = factory.createClient();
Compatibility
互換モードを指定すると、オリジナルのOkuyamaClientからでも読み出し可能な形式で格納するように下の設定でクライアントを生成する。
- キーを必ずbase64エンコードする
- 文字列を格納する場合にもJavaのシリアライズを行ってからBase64エンコードする
- 圧縮しない（圧縮戦略を設定すると例外を発生させる）
Compression
Implementing CompressionStrategy
public class YourCompressionStrategy implements CompressionStrategy {
private static final int MINIMUM_LENGTH_TO_COMPRESS = 32;
private Compressor compressorDefault;
private Compressor compressorFast;
public YourCompressionStrategy() {
compressorDefault = Compressor.getCompressor(JdkDeflaterCompressor.COMPRESSOR_ID);
compressorFast = Compressor.getCompressor(LZFCompressor.COMPRESSOR_ID);
}
@Override
public Compressor getSuitableCompressor(String key, int valueLength) {
if (valueLength < MINIMUM_LENGTH_TO_COMPRESS) {
return null;
}
if (key.startsWith("session:")) {
return compressorFast;
}
if (key.startsWith("count:")) {
return null;
}
return compressorDefault;
}
}
Integration testing
We need okuyama server for integration testing. For your convinience, I prepare docker images and docker-compose.yml. It is destributed on [mitonize/docker-okuyama] (https://github.com/mitonize/docker-okuyama).
Prerequisites
- docker
- docker-machine
- docker-compose
Procedure
start docker machine
On terminal, run commands below.
$ doker-machine start <your_machine_name>
$ eval $(docker-machine env <your_machine_name>)
start okuyama in docker container
$ git clone https://github.com/mitonize/docker-okuyama.git
$ cd docker-okuyama
$ docker-compose up
run integration tests
On another terminal, do maven integration-test with Okuyama endpoints settings as jvm system properties with named "OKUYAMA_ENDPOINTS".
mvn integration-test -DOKUYAMA_ENDPOINTS=$(docker-machine ip):8888