本文整理汇总了Java中net.spy.memcached.CachedData类的典型用法代码示例。如果您正苦于以下问题：Java CachedData类的具体用法？Java CachedData怎么用？Java CachedData使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
CachedData类属于net.spy.memcached包，在下文中一共展示了CachedData类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: decode
import net.spy.memcached.CachedData; //导入依赖的package包/类
/**
* Perform a decode.
*/
public <T> Future<T> decode(final Transcoder<T> tc,
final CachedData cachedData) {
// assert !pool.isShutdown() : "Pool has already shut down.";
TranscodeService.Task<T> task =
new TranscodeService.Task<T>(new Callable<T>() {
public T call() {
return tc.decode(cachedData);
}
});
// if (tc.asyncDecode(cachedData)) {
// this.pool.execute(task);
// }
return task;
}
开发者ID:Alachisoft，项目名称:TayzGrid，代码行数:21，代码来源:TranscodeService.java
示例2: decode
import net.spy.memcached.CachedData; //导入依赖的package包/类
@Override
public CachedResponse decode(CachedData d) {
try {
byte[] cachedData = d.getData();
int headerSeparatorIndex = Bytes.indexOf(cachedData, HEADER_SEPARATOR);
if (headerSeparatorIndex < 0) {
return null;
}
BufferedReader headerReader = new BufferedReader(new InputStreamReader(
new ByteArrayInputStream(cachedData, 0, headerSeparatorIndex),
Charsets.US_ASCII)
);
int statusCode = readStatusCode(headerReader);
MultivaluedMap<String, String> headers = readHeaders(headerReader);
byte[] responseContent = Arrays.copyOfRange(cachedData, headerSeparatorIndex + HEADER_SEPARATOR.length, cachedData.length);
return new CachedResponse(statusCode, headers, responseContent);
} catch (IOException ex) {
throw new RuntimeException("Corrupted cache entry", ex);
}
}
开发者ID:bazaarvoice，项目名称:dropwizard-caching-bundle，代码行数:25，代码来源:CachedResponseTranscoder.java
示例3: encode
import net.spy.memcached.CachedData; //导入依赖的package包/类
public CachedData encode(Object o) {
ResizeableByteBuffer buffer = (ResizeableByteBuffer)o;
byte[] b;
int flags = 0;
int bufferSize = buffer.size();
int maxPossibleCompressedLength = getMaxCompressedLength(bufferSize);
if (bufferSize > compressionThreshold && maxPossibleCompressedLength < bufferSize) {
try {
b = compress(buffer.getBuf(),0,bufferSize,maxPossibleCompressedLength);
flags |= COMPRESSED;
} catch (Exception e) {
throw new RuntimeException("IO exception compressing data", e);
}
} else {
b = buffer.toByteArray();
}
return new CachedData(flags, b, getMaxSize());
}
开发者ID:tootedom，项目名称:tomcat-memcached-response-filter，代码行数:19，代码来源:SerializingTranscoder.java
示例4: decode
import net.spy.memcached.CachedData; //导入依赖的package包/类
/**
* Perform a decode.
*/
public <T> Future<T> decode(final Transcoder<T> tc,
final CachedData cachedData) {
assert !pool.isShutdown() : "Pool has already shut down.";
TranscodeService.Task<T> task = new TranscodeService.Task<T>(
new Callable<T>() {
public T call() {
return tc.decode(cachedData);
}
});
if (tc.asyncDecode(cachedData)) {
this.pool.execute(task);
}
return task;
}
开发者ID:naver，项目名称:arcus-java-client，代码行数:21，代码来源:TranscodeService.java
示例5: encode
import net.spy.memcached.CachedData; //导入依赖的package包/类
@Override
public CachedData encode(final Object obj) {
final ByteArrayOutputStream byteStream = new ByteArrayOutputStream();
try (Output output = new Output(byteStream)) {
kryo.writeClassAndObject(output, obj);
output.flush();
final byte[] bytes = byteStream.toByteArray();
return new CachedData(0, bytes, bytes.length);
}
}
开发者ID:hsj-xiaokang，项目名称:springboot-shiro-cas-mybatis，代码行数:11，代码来源:KryoTranscoder.java
示例6: decode
import net.spy.memcached.CachedData; //导入依赖的package包/类
@Override
public Object decode(final CachedData d) {
final byte[] bytes = d.getData();
try (Input input = new Input(new ByteArrayInputStream(bytes))) {
final Object obj = kryo.readClassAndObject(input);
return obj;
}
}
开发者ID:hsj-xiaokang，项目名称:springboot-shiro-cas-mybatis，代码行数:9，代码来源:KryoTranscoder.java
示例7: verifyEncodeDecodeTGTImpl
import net.spy.memcached.CachedData; //导入依赖的package包/类
@Test
public void verifyEncodeDecodeTGTImpl() throws Exception {
final Credential userPassCredential = new UsernamePasswordCredential(USERNAME, PASSWORD);
final AuthenticationBuilder bldr = new DefaultAuthenticationBuilder(
new DefaultPrincipalFactory()
.createPrincipal("user", Collections.unmodifiableMap(this.principalAttributes)));
bldr.setAttributes(Collections.unmodifiableMap(this.principalAttributes));
bldr.setAuthenticationDate(new DateTime());
bldr.addCredential(new BasicCredentialMetaData(userPassCredential));
bldr.addFailure("error", AccountNotFoundException.class);
bldr.addSuccess("authn", new DefaultHandlerResult(
new AcceptUsersAuthenticationHandler(),
new BasicCredentialMetaData(userPassCredential)));
final TicketGrantingTicket expectedTGT =
new TicketGrantingTicketImpl(TGT_ID,
org.jasig.cas.services.TestUtils.getService(),
null, bldr.build(),
new NeverExpiresExpirationPolicy());
final ServiceTicket ticket = expectedTGT.grantServiceTicket(ST_ID,
org.jasig.cas.services.TestUtils.getService(),
new NeverExpiresExpirationPolicy(), false, true);
CachedData result = transcoder.encode(expectedTGT);
final TicketGrantingTicket resultTicket = (TicketGrantingTicket) transcoder.decode(result);
assertEquals(expectedTGT, resultTicket);
result = transcoder.encode(ticket);
final ServiceTicket resultStTicket = (ServiceTicket) transcoder.decode(result);
assertEquals(ticket, resultStTicket);
}
开发者ID:hsj-xiaokang，项目名称:springboot-shiro-cas-mybatis，代码行数:33，代码来源:KryoTranscoderTests.java
示例8: encode
import net.spy.memcached.CachedData; //导入依赖的package包/类
@Override
public CachedData encode(final Object obj) {
final ByteArrayOutputStream byteStream = new ByteArrayOutputStream();
try (final Output output = new Output(byteStream)) {
kryo.writeClassAndObject(output, obj);
output.flush();
final byte[] bytes = byteStream.toByteArray();
return new CachedData(0, bytes, bytes.length);
}
}
开发者ID:hsj-xiaokang，项目名称:springboot-shiro-cas-mybatis，代码行数:11，代码来源:KryoTranscoder.java
示例9: decode
import net.spy.memcached.CachedData; //导入依赖的package包/类
@Override
public Object decode(final CachedData d) {
final byte[] bytes = d.getData();
try (final Input input = new Input(new ByteArrayInputStream(bytes))) {
final Object obj = kryo.readClassAndObject(input);
return obj;
}
}
开发者ID:hsj-xiaokang，项目名称:springboot-shiro-cas-mybatis，代码行数:9，代码来源:KryoTranscoder.java
示例10: verifyEncodeDecodeTGTImpl
import net.spy.memcached.CachedData; //导入依赖的package包/类
@Test
public void verifyEncodeDecodeTGTImpl() throws Exception {
final Credential userPassCredential = new UsernamePasswordCredential(USERNAME, PASSWORD);
final AuthenticationBuilder bldr = new DefaultAuthenticationBuilder(
new DefaultPrincipalFactory()
.createPrincipal("user", Collections.unmodifiableMap(this.principalAttributes)));
bldr.setAttributes(Collections.unmodifiableMap(this.principalAttributes));
bldr.setAuthenticationDate(new Date());
bldr.addCredential(new BasicCredentialMetaData(userPassCredential));
bldr.addFailure("error", AccountNotFoundException.class);
bldr.addSuccess("authn", new DefaultHandlerResult(
new AcceptUsersAuthenticationHandler(),
new BasicCredentialMetaData(userPassCredential)));
final TicketGrantingTicket parent =
new TicketGrantingTicketImpl(TGT_ID, TestUtils.getService(), null, bldr.build(),
new NeverExpiresExpirationPolicy());
final TicketGrantingTicket expectedTGT =
new TicketGrantingTicketImpl(TGT_ID, TestUtils.getService(),
null, bldr.build(),
new NeverExpiresExpirationPolicy());
final ServiceTicket ticket = expectedTGT.grantServiceTicket(ST_ID,
TestUtils.getService(),
new NeverExpiresExpirationPolicy(), false);
CachedData result = transcoder.encode(expectedTGT);
final TicketGrantingTicket resultTicket = (TicketGrantingTicket) transcoder.decode(result);
assertEquals(expectedTGT, resultTicket);
result = transcoder.encode(ticket);
final ServiceTicket resultStTicket = (ServiceTicket) transcoder.decode(result);
assertEquals(ticket, resultStTicket);
}
开发者ID:hsj-xiaokang，项目名称:springboot-shiro-cas-mybatis，代码行数:36，代码来源:KryoTranscoderTests.java
示例11: encode
import net.spy.memcached.CachedData; //导入依赖的package包/类
@Override
public CachedData encode(final Object obj) {
final ByteArrayOutputStream byteStream = new ByteArrayOutputStream();
try (Output output = new Output(byteStream)) {
this.kryo.writeClassAndObject(output, obj);
output.flush();
final byte[] bytes = byteStream.toByteArray();
return new CachedData(0, bytes, bytes.length);
}
}
开发者ID:mrluo735，项目名称:cas-5.1.0，代码行数:11，代码来源:KryoTranscoder.java
示例12: decode
import net.spy.memcached.CachedData; //导入依赖的package包/类
@Override
public Object decode(final CachedData d) {
final byte[] bytes = d.getData();
try (Input input = new Input(new ByteArrayInputStream(bytes))) {
final Object obj = this.kryo.readClassAndObject(input);
return obj;
}
}
开发者ID:mrluo735，项目名称:cas-5.1.0，代码行数:9，代码来源:KryoTranscoder.java
示例13: verifyEncodeDecodeTGTImpl
import net.spy.memcached.CachedData; //导入依赖的package包/类
@Test
public void verifyEncodeDecodeTGTImpl() throws Exception {
final Credential userPassCredential = new UsernamePasswordCredential(USERNAME, PASSWORD);
final AuthenticationBuilder bldr = new DefaultAuthenticationBuilder(
new DefaultPrincipalFactory()
.createPrincipal("user", new HashMap<>(this.principalAttributes)));
bldr.setAttributes(new HashMap<>(this.principalAttributes));
bldr.setAuthenticationDate(ZonedDateTime.now());
bldr.addCredential(new BasicCredentialMetaData(userPassCredential));
bldr.addFailure("error", AccountNotFoundException.class);
bldr.addSuccess("authn", new DefaultHandlerResult(
new AcceptUsersAuthenticationHandler(""),
new BasicCredentialMetaData(userPassCredential)));
final TicketGrantingTicket expectedTGT =
new TicketGrantingTicketImpl(TGT_ID,
RegisteredServiceTestUtils.getService(),
null, bldr.build(),
new NeverExpiresExpirationPolicy());
final ServiceTicket ticket = expectedTGT.grantServiceTicket(ST_ID,
RegisteredServiceTestUtils.getService(),
new NeverExpiresExpirationPolicy(), false, true);
CachedData result = transcoder.encode(expectedTGT);
final TicketGrantingTicket resultTicket = (TicketGrantingTicket) transcoder.decode(result);
assertEquals(expectedTGT, resultTicket);
result = transcoder.encode(ticket);
final ServiceTicket resultStTicket = (ServiceTicket) transcoder.decode(result);
assertEquals(ticket, resultStTicket);
}
开发者ID:mrluo735，项目名称:cas-5.1.0，代码行数:33，代码来源:KryoTranscoderTests.java
示例14: encode
import net.spy.memcached.CachedData; //导入依赖的package包/类
@Override
public CachedData encode(final Object obj) {
final ByteArrayOutputStream byteStream = new ByteArrayOutputStream();
final Output output = new Output(byteStream);
kryo.writeClassAndObject(output, obj);
output.flush();
IOUtils.closeQuietly(output);
final byte[] bytes = byteStream.toByteArray();
return new CachedData(0, bytes, bytes.length);
}
开发者ID:luotuo，项目名称:cas4.0.x-server-wechat，代码行数:11，代码来源:KryoTranscoder.java
示例15: decode
import net.spy.memcached.CachedData; //导入依赖的package包/类
@Override
public Object decode(final CachedData d) {
final byte[] bytes = d.getData();
final Input input = new Input(new ByteArrayInputStream(bytes));
final Object obj = kryo.readClassAndObject(input);
IOUtils.closeQuietly(input);
return obj;
}
开发者ID:luotuo，项目名称:cas4.0.x-server-wechat，代码行数:9，代码来源:KryoTranscoder.java
示例16: decode
import net.spy.memcached.CachedData; //导入依赖的package包/类
@Override
public HFileBlock decode(CachedData d) {
try {
ByteBuffer buf = ByteBuffer.wrap(d.getData());
return (HFileBlock) HFileBlock.blockDeserializer.deserialize(buf, true);
} catch (IOException e) {
LOG.warn("Error deserializing data from memcached",e);
}
return null;
}
开发者ID:fengchen8086，项目名称:ditb，代码行数:11，代码来源:MemcachedBlockCache.java
示例17: decode
import net.spy.memcached.CachedData; //导入依赖的package包/类
public Integer decode(CachedData d) {
if (FLAGS == d.getFlags()) {
return tu.decodeInt(d.getData());
} else {
return null;
}
}
开发者ID:Alachisoft，项目名称:TayzGrid，代码行数:8，代码来源:IntegerTranscoder.java
示例18: decode
import net.spy.memcached.CachedData; //导入依赖的package包/类
public Long decode(CachedData d) {
if (FLAGS == d.getFlags()) {
return tu.decodeLong(d.getData());
} else {
getLogger().error(
"Unexpected flags for long: " + d.getFlags() + " wanted " + FLAGS);
return null;
}
}
开发者ID:Alachisoft，项目名称:TayzGrid，代码行数:10，代码来源:LongTranscoder.java
示例19: asyncDecode
import net.spy.memcached.CachedData; //导入依赖的package包/类
@Override
public boolean asyncDecode(CachedData d) {
if ((d.getFlags() & COMPRESSED) != 0 || (d.getFlags() & SERIALIZED) != 0) {
return true;
}
return super.asyncDecode(d);
}
开发者ID:Alachisoft，项目名称:TayzGrid，代码行数:8，代码来源:SerializingTranscoder.java
示例20: deserialize
import net.spy.memcached.CachedData; //导入依赖的package包/类
/**
* Attempt to get the object represented by the given serialized bytes.
*/
private Object deserialize() {
SerializingTranscoder tc = new SerializingTranscoder();
CachedData d = new CachedData(this.getItemFlags(), this.getValue(),
CachedData.MAX_SIZE);
Object rv = null;
rv = tc.decode(d);
return rv;
}
开发者ID:Alachisoft，项目名称:TayzGrid，代码行数:12，代码来源:ResponseMessage.java
注：本文中的net.spy.memcached.CachedData类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
请发表评论